1250323Sdteskeif [ ! "$_PACKAGES_INDEX_SUBR" ]; then _PACKAGES_INDEX_SUBR=1
2250323Sdteske#
3250323Sdteske# Copyright (c) 2013 Devin Teske
4252980Sdteske# All rights reserved.
5250323Sdteske#
6250323Sdteske# Redistribution and use in source and binary forms, with or without
7250323Sdteske# modification, are permitted provided that the following conditions
8250323Sdteske# are met:
9250323Sdteske# 1. Redistributions of source code must retain the above copyright
10250323Sdteske#    notice, this list of conditions and the following disclaimer.
11250323Sdteske# 2. Redistributions in binary form must reproduce the above copyright
12250323Sdteske#    notice, this list of conditions and the following disclaimer in the
13250323Sdteske#    documentation and/or other materials provided with the distribution.
14250323Sdteske#
15250323Sdteske# THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
16252987Sdteske# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
17250323Sdteske# IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
18250323Sdteske# ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
19250323Sdteske# FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
20252987Sdteske# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
21250323Sdteske# OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
22250323Sdteske# HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
23250323Sdteske# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
24250323Sdteske# OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
25250323Sdteske# SUCH DAMAGE.
26250323Sdteske#
27250323Sdteske# $FreeBSD$
28250323Sdteske#
29250323Sdteske############################################################ INCLUDES
30250323Sdteske
31250323SdteskeBSDCFG_SHARE="/usr/share/bsdconfig"
32250323Sdteske. $BSDCFG_SHARE/common.subr || exit 1
33250323Sdteskef_dprintf "%s: loading includes..." packages/index.subr
34250323Sdteskef_include $BSDCFG_SHARE/device.subr
35250323Sdteskef_include $BSDCFG_SHARE/media/common.subr
36272230Sdteskef_include $BSDCFG_SHARE/packages/musthavepkg.subr
37250323Sdteskef_include $BSDCFG_SHARE/strings.subr
38250323Sdteske
39250323SdteskeBSDCFG_LIBE="/usr/libexec/bsdconfig"
40250323Sdteskef_include_lang $BSDCFG_LIBE/include/messages.subr
41250323Sdteske
42250323Sdteske############################################################ GLOBALS
43250323Sdteske
44250323SdteskePACKAGE_INDEX=
45250323Sdteske_INDEX_INITTED=
46250323Sdteske
47258420Sdteske#
48258420Sdteske# Default path to pkg(8) repo-packagesite.sqlite database
49258420Sdteske#
50258420SdteskeSQLITE_REPO="/var/db/pkg/repo-packagesite.sqlite"
51258420Sdteske
52258420Sdteske#
53258420Sdteske# Default path to on-disk cache INDEX file
54258420Sdteske#
55258420SdteskePACKAGES_INDEX_CACHEFILE="/var/run/bsdconfig/packages_INDEX.cache"
56258420Sdteske
57250323Sdteske############################################################ FUNCTIONS
58250323Sdteske
59258420Sdteske# f_index_initialize [$var_to_set]
60250323Sdteske#
61258420Sdteske# Read and initialize the global index. Returns success unless media cannot be
62258420Sdteske# initialized for any reason (e.g. user cancels media selection dialog or an
63258420Sdteske# error occurs). The index is sorted before being loaded into $var_to_set.
64250323Sdteske#
65250323Sdteske# NOTE: The index is processed with f_index_read() [below] after being loaded.
66250323Sdteske#
67250323Sdteskef_index_initialize()
68250323Sdteske{
69258420Sdteske	local __funcname=f_index_initialize
70272230Sdteske	local __var_to_set="${1:-PACKAGE_INDEX}"
71250323Sdteske
72250323Sdteske	[ "$_INDEX_INITTED" ] && return $SUCCESS
73250323Sdteske
74250323Sdteske	# Got any media?
75250323Sdteske	f_media_verify || return $FAILURE
76250323Sdteske
77272230Sdteske	# Make sure we have a usable pkg(8) with $PKG_ABI
78272230Sdteske	f_musthavepkg_init
79272230Sdteske
80250323Sdteske	# Does it move when you kick it?
81266290Sdteske	f_device_init device_media || return $FAILURE
82250323Sdteske
83258420Sdteske	f_show_info "$msg_attempting_to_update_repository_catalogue"
84258420Sdteske
85258420Sdteske	#
86258420Sdteske	# Generate $PACKAGESITE variable for pkg(8) based on media type
87258420Sdteske	#
88258420Sdteske	local __type __data __site
89258420Sdteske	device_media get type __type
90258420Sdteske	device_media get private __data
91258420Sdteske	case "$__type" in
92258420Sdteske	$DEVICE_TYPE_DIRECTORY)
93258420Sdteske		__site="file://$__data/packages/$PKG_ABI" ;;
94258420Sdteske	$DEVICE_TYPE_FLOPPY)
95258420Sdteske		__site="file://${__data:-$MOUNTPOINT}/packages/$PKG_ABI" ;;
96258420Sdteske	$DEVICE_TYPE_FTP)
97258420Sdteske		f_getvar $VAR_FTP_PATH __site
98258420Sdteske		__site="$__site/packages/$PKG_ABI" ;;
99258420Sdteske	$DEVICE_TYPE_HTTP)
100258420Sdteske		f_getvar $VAR_HTTP_PATH __site
101258420Sdteske		__site="$__site/$PKG_ABI/latest" ;;
102258420Sdteske	$DEVICE_TYPE_HTTP_PROXY)
103258420Sdteske		f_getvar $VAR_HTTP_PROXY_PATH __site
104258420Sdteske		__site="$__site/packages/$PKG_ABI" ;;
105259533Sgjb	$DEVICE_TYPE_CDROM)
106259533Sgjb		__site="file://$MOUNTPOINT/packages/$PKG_ABI"
107259533Sgjb		export REPOS_DIR="$MOUNTPOINT/packages/repos" ;;
108258420Sdteske	*) # UFS, DISK, CDROM, USB, DOS, NFS, etc.
109258420Sdteske		__site="file://$MOUNTPOINT/packages/$PKG_ABI"
110258420Sdteske	esac
111258420Sdteske
112272230Sdteske	f_dprintf "PACKAGESITE=[%s]" "$__site"
113272230Sdteske	if ! f_eval_catch $__funcname pkg \
114272230Sdteske		'PACKAGESITE="%s" pkg update' "$__site"
115272230Sdteske	then
116258420Sdteske		f_show_err "$msg_unable_to_update_pkg_from_selected_media"
117266290Sdteske		f_device_shutdown device_media
118250323Sdteske		return $FAILURE
119250323Sdteske	fi
120258420Sdteske
121258420Sdteske	#
122258420Sdteske	# Try to get contents from validated on-disk cache
123258420Sdteske	#
124258420Sdteske
125258420Sdteske	#
126258420Sdteske	# Calculate digest used to determine if the on-disk persistant cache
127258420Sdteske	# INDEX (containing this digest on the first line) is valid and can be
128258420Sdteske	# used to quickly populate the environment.
129258420Sdteske	#
130258420Sdteske	local __sqlite_digest
131258420Sdteske	if ! __sqlite_digest=$( md5 < "$SQLITE_REPO" 2> /dev/null ); then
132258420Sdteske		f_show_err "$msg_no_pkg_database_found"
133266290Sdteske		f_device_shutdown device_media
134258420Sdteske		return $FAILURE
135258420Sdteske	fi
136258420Sdteske
137258420Sdteske	#
138258420Sdteske	# Check to see if the persistant cache INDEX file exists
139258420Sdteske	#
140258420Sdteske	if [ -f "$PACKAGES_INDEX_CACHEFILE" ]; then
141258420Sdteske		#
142258420Sdteske		# Attempt to populate the environment with the (soon to be)
143258420Sdteske		# validated on-disk cache. If validation fails, fall-back to
144258420Sdteske		# generating a fresh cache.
145258420Sdteske		#
146258420Sdteske		if eval $__var_to_set='$(
147258420Sdteske			(	# Get digest as the first word on first line
148258420Sdteske				read digest rest_ignored
149258420Sdteske
150258420Sdteske				#
151258420Sdteske				# If the stored digest matches the calculated-
152258420Sdteske				# one populate the environment from the on-disk
153258420Sdteske				# cache and provide success exit status.
154258420Sdteske				#
155258420Sdteske				if [ "$digest" = "$__sqlite_digest" ]; then
156258420Sdteske					cat
157258420Sdteske					exit $SUCCESS
158258420Sdteske				else
159258420Sdteske					# Otherwise, return the current value
160258420Sdteske					eval echo \"\$__var_to_set\"
161258420Sdteske					exit $FAILURE
162258420Sdteske				fi
163258420Sdteske			) < "$PACKAGES_INDEX_CACHEFILE" 2> /dev/null
164258420Sdteske		)'; then
165258420Sdteske			f_show_info \
166258420Sdteske			  "$msg_located_index_now_reading_package_data_from_it"
167258420Sdteske			if ! f_index_read "$__var_to_set"; then
168258420Sdteske				f_show_err \
169258420Sdteske					"$msg_io_or_format_error_on_index_file"
170258420Sdteske				return $FAILURE
171258420Sdteske			fi
172258420Sdteske			_INDEX_INITTED=1
173258420Sdteske			return $SUCCESS
174258420Sdteske		fi
175258420Sdteske		# Otherwise, fall-thru to create a fresh cache from scratch
176258420Sdteske	fi
177258420Sdteske
178258420Sdteske	#
179258420Sdteske	# If we reach this point, we need to generate the data from scratch
180258420Sdteske	#
181258420Sdteske
182258420Sdteske	f_show_info "$msg_generating_index_from_pkg_database"
183272230Sdteske	eval "$__var_to_set"='$( pkg rquery -I | sort )'
184250323Sdteske
185258420Sdteske	#
186258420Sdteske	# Attempt to create the persistant on-disk cache
187258420Sdteske	#
188258420Sdteske
189258420Sdteske	# Create a new temporary file to write to
190260678Sdteske	local __tmpfile
191260678Sdteske	if f_eval_catch -dk __tmpfile $__funcname mktemp \
192260678Sdteske		'mktemp -t "%s"' "$pgm"
193260678Sdteske	then
194258420Sdteske		# Write the temporary file contents
195258420Sdteske		echo "$__sqlite_digest" > "$__tmpfile"
196258420Sdteske		debug= f_getvar "$__var_to_set" >> "$__tmpfile"
197258420Sdteske
198258420Sdteske		# Finally, move the temporary file into place
199258420Sdteske		case "$PACKAGES_INDEX_CACHEFILE" in
200268170Sdteske		*/*) f_eval_catch -d $__funcname mkdir \
201260678Sdteske			'mkdir -p "%s"' "${PACKAGES_INDEX_CACHEFILE%/*}"
202258420Sdteske		esac
203260678Sdteske		f_eval_catch -d $__funcname mv 'mv -f "%s" "%s"' \
204260678Sdteske			"$__tmpfile" "$PACKAGES_INDEX_CACHEFILE"
205258420Sdteske	fi
206258420Sdteske
207250323Sdteske	f_show_info "$msg_located_index_now_reading_package_data_from_it"
208250323Sdteske	if ! f_index_read "$__var_to_set"; then
209258420Sdteske		f_show_err "$msg_io_or_format_error_on_index_file"
210250323Sdteske		return $FAILURE
211250323Sdteske	fi
212250323Sdteske
213250323Sdteske	_INDEX_INITTED=1
214250323Sdteske	return $SUCCESS
215250323Sdteske}
216250323Sdteske
217250323Sdteske# f_index_read [$var_to_get]
218250323Sdteske#
219250323Sdteske# Process the INDEX file (contents contained in $var_to_get) and...
220250323Sdteske#
221250323Sdteske# 1. create a list ($CATEGORY_MENU_LIST) of categories with package counts
222250323Sdteske# 2. For convenience, create $_npkgs holding the total number of all packages
223250323Sdteske# 3. extract associative categories for each package into $_categories_$varpkg
224250323Sdteske# 4. extract runtime dependencies for each package into $_rundeps_$varpkg
225250323Sdteske# 5. extract a [sorted] list of categories into $PACKAGE_CATEGORIES
226250323Sdteske# 6. create $_npkgs_$varcat holding the total number of packages in category
227250323Sdteske#
228250323Sdteske# NOTE: $varpkg is the product of f_str2varname $package varpkg
229250323Sdteske# NOTE: $package is the name as it appears in the INDEX (no archive suffix)
230250323Sdteske# NOTE: We only show categories for which there are at least one package.
231250323Sdteske# NOTE: $varcat is the product of f_str2varname $category varcat
232250323Sdteske#
233250323Sdteskef_index_read()
234250323Sdteske{
235250323Sdteske	local var_to_get="${1:-PACKAGE_INDEX}"
236250323Sdteske
237250323Sdteske	# Export variables required by awk(1) below
238250323Sdteske	export msg_no_description_provided
239250323Sdteske	export msg_all msg_all_desc
240250323Sdteske	export VALID_VARNAME_CHARS
241250538Sdteske	export msg_packages
242250323Sdteske
243250323Sdteske	eval "$( debug= f_getvar "$var_to_get" | awk -F'|' '
244250323Sdteske	function asorti(src, dest)
245250323Sdteske	{
246250323Sdteske		# Copy src indices to dest and calculate array length
247250323Sdteske		nitems = 0; for (i in src) dest[++nitems] = i
248250323Sdteske
249250323Sdteske		# Sort the array of indices (dest) using insertion sort method
250250323Sdteske		for (i = 1; i <= nitems; k = i++)
251250323Sdteske		{
252250323Sdteske			idx = dest[i]
253250323Sdteske			while ((k > 0) && (dest[k] > idx))
254250323Sdteske			{
255250323Sdteske				dest[k+1] = dest[k]
256250323Sdteske				k--
257250323Sdteske			}
258250323Sdteske			dest[k+1] = idx
259250323Sdteske		}
260250323Sdteske
261250323Sdteske		return nitems
262250323Sdteske	}
263250323Sdteske	function print_category(category, npkgs, desc)
264250323Sdteske	{
265250323Sdteske		cat = category
266250323Sdteske		# Accent the category if the first page has been
267250323Sdteske		# cached (also acting as a visitation indicator)
268250323Sdteske		if ( ENVIRON["_index_page_" varcat "_1"] )
269250323Sdteske			cat = cat "*"
270250538Sdteske		printf "'\''%s'\'' '\''%s " packages "'\'' '\''%s'\''\n",
271250323Sdteske		       cat, npkgs, desc
272250323Sdteske	}
273250323Sdteske	BEGIN {
274250323Sdteske		valid_chars = ENVIRON["VALID_VARNAME_CHARS"]
275250323Sdteske		default_desc = ENVIRON["msg_no_description_provided"]
276250538Sdteske		packages = ENVIRON["msg_packages"]
277250410Sdteske		tpkgs = 0
278250323Sdteske		prefix = ""
279250323Sdteske	}
280250323Sdteske	{
281250410Sdteske		tpkgs++
282250323Sdteske		varpkg = $1
283250323Sdteske		gsub("[^" valid_chars "]", "_", varpkg)
284250323Sdteske		print "_categories_" varpkg "=\"" $7 "\""
285250323Sdteske		split($7, pkg_categories, /[[:space:]]+/)
286250323Sdteske		for (pkg_category in pkg_categories)
287250323Sdteske			categories[pkg_categories[pkg_category]]++
288250323Sdteske		print "_rundeps_" varpkg "=\"" $9 "\""
289250323Sdteske	}
290250323Sdteske	END {
291250410Sdteske		print "_npkgs=" tpkgs # For convenience, total package count
292250323Sdteske
293250323Sdteske		n = asorti(categories, categories_sorted)
294250323Sdteske
295250323Sdteske		# Produce package counts for each category
296250323Sdteske		for (i = 1; i <= n; i++)
297250323Sdteske		{
298250323Sdteske			cat = varcat = categories_sorted[i]
299250323Sdteske			npkgs = categories[cat]
300250323Sdteske			gsub("[^" valid_chars "]", "_", varcat)
301250323Sdteske			print "_npkgs_" varcat "=\"" npkgs "\""
302250323Sdteske		}
303250323Sdteske
304250323Sdteske		# Create menu list and generate list of categories at same time
305250323Sdteske		print "CATEGORY_MENU_LIST=\""
306250410Sdteske		print_category(ENVIRON["msg_all"], tpkgs,
307250323Sdteske		               ENVIRON["msg_all_desc"])
308250323Sdteske		category_list = ""
309250323Sdteske		for (i = 1; i <= n; i++)
310250323Sdteske		{
311250323Sdteske			cat = varcat = categories_sorted[i]
312250323Sdteske			npkgs = categories[cat]
313250323Sdteske			cur_prefix = tolower(substr(cat, 1, 1))
314250323Sdteske			if ( prefix != cur_prefix )
315250323Sdteske				prefix = cur_prefix
316250323Sdteske			else
317250323Sdteske				cat = " " cat
318250323Sdteske			gsub("[^" valid_chars "]", "_", varcat)
319250323Sdteske			desc = ENVIRON["_category_" varcat]
320250323Sdteske			if ( ! desc ) desc = default_desc
321250323Sdteske			print_category(cat, npkgs, desc)
322250323Sdteske			category_list = category_list " " cat
323250323Sdteske		}
324250323Sdteske		print "\""
325250323Sdteske
326250323Sdteske		# Produce the list of categories (calculated in above block)
327250323Sdteske		sub(/^ /, "", category_list)
328250323Sdteske		print "PACKAGE_CATEGORIES=\"" category_list "\""
329250323Sdteske
330250323Sdteske	}' )" # End-Quote
331250323Sdteske}
332250323Sdteske
333250323Sdteske# f_index_extract_pages $var_to_get $var_basename $pagesize [$category]
334250323Sdteske#
335252738Sdteske# Extracts the package INDEX ($PACKAGE_INDEX by default if/when $var_to_get is
336252738Sdteske# NULL; but should not be missing) into a series of sequential variables
337250323Sdteske# corresponding to "pages" containing up to $pagesize packages. The package
338250323Sdteske# INDEX data must be contained in the variable $var_to_get. The extracted pages
339250323Sdteske# are stored in variables ${var_basename}_# -- where "#" is a the page number.
340250323Sdteske# If $category is set, only packages for that category are extracted.
341250323Sdteske# Otherwise, if $category is "All", missing, or NULL, all packages are
342250323Sdteske# extracted and no filtering is done.
343250323Sdteske#
344250323Sdteskef_index_extract_pages()
345250323Sdteske{
346252738Sdteske	local var_to_get="${1:-PACKAGE_INDEX}" var_basename="$2" pagesize="$3"
347250323Sdteske	local category="$4" # Optional
348250323Sdteske
349250323Sdteske	eval "$(
350250323Sdteske		debug= f_getvar "$var_to_get" | awk -F'|' \
351250323Sdteske			-v cat="$category" \
352250323Sdteske			-v pagesize="$pagesize" \
353250538Sdteske			-v var_basename="$var_basename" \
354250538Sdteske			-v i18n_all="$msg_all" '
355250323Sdteske		BEGIN { n = page = 0 }
356250323Sdteske		/'\''/{ gsub(/'\''/, "'\''\\'\'\''") }
357250323Sdteske		{
358250538Sdteske			if ( cat !~ "(^$|^" i18n_all "$)" && $7 !~ \
359250323Sdteske			     "(^|[[:space:]])" cat "([[:space:]]|$)" ) next
360250323Sdteske			starting_new_page = (n++ == (pagesize * page))
361250323Sdteske			if ( starting_new_page )
362250323Sdteske				printf "%s%s", ( n > 1 ? "'\''\n" : "" ),
363250323Sdteske				       var_basename "_" ++page "='\''"
364250323Sdteske			printf "%s%s", ( starting_new_page ? "" : "\n" ), $0
365250323Sdteske		}
366250323Sdteske		END { if ( n > 0 ) print "'\''" }'
367250323Sdteske	)"
368250323Sdteske}
369250323Sdteske
370252745Sdteske# f_index_search $var_to_get $name [$var_to_set]
371252745Sdteske#
372252753Sdteske# Search the package INDEX ($PACKAGE_INDEX by default if/when $var_to_get is
373252745Sdteske# NULL; but should not be missing) for $name, returning the first match.
374252745Sdteske# Matches are strict (not regular expressions) and must match the beginning
375252745Sdteske# portion of the package name to be considered a match. If $var_to_set is
376252745Sdteske# missing or NULL, output is sent to standard output. If a match is found,
377252745Sdteske# returns success; otherwise failure.
378252745Sdteske#
379252745Sdteskef_index_search()
380252745Sdteske{
381252745Sdteske	local __var_to_get="${1:-PACKAGE_INDEX}" __pkg_basename="$2"
382252745Sdteske	local __var_to_set="$3"
383252745Sdteske
384252745Sdteske	f_dprintf "f_index_search: Searching package data (in %s) for %s" \
385252745Sdteske	          "$__var_to_get" "$__pkg_basename"
386252745Sdteske
387252745Sdteske	local __pkg=
388252745Sdteske	__pkg=$( debug= f_getvar "$__var_to_get" |
389252745Sdteske			awk -F'|' -v basename="$__pkg_basename" '
390252745Sdteske		BEGIN { n = length(basename) }
391252745Sdteske		substr($1, 0, n) == basename { print $1; exit }
392252745Sdteske	' )
393252745Sdteske	if [ ! "$__pkg" ]; then
394252745Sdteske		f_dprintf "f_index_search: No packages matching %s found" \
395252745Sdteske		          "$__pkg_basename"
396252745Sdteske		return $FAILURE
397252745Sdteske	fi
398252745Sdteske
399252745Sdteske	f_dprintf "f_index_search: Found package %s" "$__pkg"
400252745Sdteske	if [ "$__var_to_set" ]; then
401252745Sdteske		setvar "$__var_to_set" "$__pkg"
402252745Sdteske	else
403252745Sdteske		echo "$__pkg"
404252745Sdteske	fi
405252745Sdteske	return $SUCCESS
406252745Sdteske}
407252745Sdteske
408250323Sdteske############################################################ MAIN
409250323Sdteske
410250323Sdteskef_dprintf "%s: Successfully loaded." packages/index.subr
411250323Sdteske
412250323Sdteskefi # ! $_PACKAGES_INDEX_SUBR
413