72e637
#!/bin/sh
72e637
#
72e637
# ipset      Start and stop ipset firewall sets
72e637
#
72e637
# config: /etc/sysconfig/ipset-config
72e637
72e637
IPSET_BIN=/usr/sbin/ipset
72e637
IPSET_CONFIG=/etc/sysconfig/ipset-config
72e637
IPSET_DATA_COMPAT=/etc/sysconfig/ipset
72e637
IPSET_DATA_COMPAT_BACKUP=${IPSET_DATA_COMPAT}.save
72e637
IPSET_DATA_DIR=/etc/sysconfig/ipset.d
72e637
IPSET_DATA_DIR_BACKUP=${IPSET_DATA_DIR}.save
72e637
IPSET_DATA_SAVED_FLAG=${IPSET_DATA_DIR}/.saved
72e637
IPSET_LOCK=/run/ipset.lock
72e637
IPSET_RUN=/run/ipset.run
72e637
CLEAN_FILES=""
72e637
72e637
trap "rm -rf \${CLEAN_FILES}" EXIT
72e637
72e637
info() {
72e637
	echo "ipset: ${*}" >&2
72e637
}
72e637
72e637
warn() {
72e637
	echo "<4>ipset: ${*}" >&2
72e637
}
72e637
72e637
err() {
72e637
	echo "<3>ipset: ${*}" >&2
72e637
}
72e637
72e637
[ -x ${IPSET_BIN} ] || { err "Cannot execute ${IPSET_BIN}"; exit 1; }
72e637
72e637
# Source ipset configuration
72e637
# shellcheck source=ipset-config
72e637
[ -f ${IPSET_CONFIG} ] && . ${IPSET_CONFIG}
72e637
72e637
set -f
72e637
72e637
lock() {
72e637
	CLEAN_FILES="${CLEAN_FILES} ${IPSET_LOCK}"
72e637
	until mkdir ${IPSET_LOCK} 2>/dev/null; do :; done
72e637
}
72e637
72e637
save() {
72e637
	fail=0
72e637
72e637
	# Make backups of existing configuration first, if any
72e637
	[ -d ${IPSET_DATA_DIR} ] && mv -Tf ${IPSET_DATA_DIR} ${IPSET_DATA_DIR_BACKUP}
72e637
	[ -f ${IPSET_DATA_COMPAT} ] && mv -Tf ${IPSET_DATA_COMPAT} ${IPSET_DATA_COMPAT_BACKUP}
72e637
72e637
	rm -f ${IPSET_DATA_SAVED_FLAG}
72e637
72e637
	# Save each set in a separate file
72e637
	mkdir -p ${IPSET_DATA_DIR}
72e637
	chmod 0700 ${IPSET_DATA_DIR}
72e637
	IFS="
72e637
"
72e637
	for set in $(${IPSET_BIN} list -n -t); do
72e637
		# Empty name allowed, use ".set" as suffix. 'ipset save' doesn't
72e637
		# quote set names with spaces: if we have a space in the name,
72e637
		# work around this by quoting it ourselves in the output.
72e637
		# shellcheck disable=SC2003 # No POSIX equivalent to expr index
72e637
		if expr index "${set}" " " >/dev/null; then
72e637
			:> "${IPSET_DATA_DIR}/${set}.set"
72e637
			for line in $(${IPSET_BIN} save "${set}"); do
72e637
				create=0
72e637
				echo "${line}" | grep -q "^create " && create=1
72e637
				if [ $create -eq 1 ]; then
72e637
					line=${line#create *}
72e637
				else
72e637
					line=${line#add *}
72e637
				fi
72e637
				line=${line#${set} *}
72e637
				set="$(echo "${set}" | sed 's/"/\\"/g')"
72e637
				if [ $create -eq 1 ]; then
72e637
					echo "create \"${set}\" ${line}" >> "${IPSET_DATA_DIR}/${set}.set"
72e637
				else
72e637
					echo "add \"${set}\" ${line}" >> "${IPSET_DATA_DIR}/${set}.set"
72e637
				fi
72e637
			done
72e637
		else
72e637
			${IPSET_BIN} save "${set}" > "${IPSET_DATA_DIR}/${set}.set" || fail=1
72e637
		fi
72e637
		[ -f "${IPSET_DATA_DIR}/${set}.set" ] && chmod 600 "${IPSET_DATA_DIR}/${set}.set"
72e637
		[ $fail -eq 1 ] && err "Cannot save set ${set}" && unset IFS && return 1
72e637
	done
72e637
	touch ${IPSET_DATA_SAVED_FLAG} || { unset IFS; return 1; }
72e637
	unset IFS
72e637
72e637
	# Done: remove backups
72e637
	rm -rf ${IPSET_DATA_DIR_BACKUP}
72e637
	rm -rf ${IPSET_DATA_COMPAT_BACKUP}
72e637
72e637
	return 0
72e637
}
72e637
72e637
# Generate a grep regexp matching abbreviated command forms. E.g., for create:
72e637
# \(c\|cr\|cre\|crea\|creat\|create\)
72e637
cmd_short_expr() {
72e637
	out=
72e637
	cmd_len=1
72e637
	while [ "${cmd_len}" -le "${#1}" ]; do
72e637
		[ -z "${out}" ] && out='\(' || out="${out}"'\|'
72e637
		# shellcheck disable=SC2003 # No POSIX equivalent to expr substr
72e637
		out="${out}$(expr substr "${1}" 1 "${cmd_len}")"
72e637
		cmd_len=$((cmd_len + 1))
72e637
	done
72e637
	echo "${out}"'\)'
72e637
}
72e637
72e637
ipset_restore() {
72e637
	file="${1}"
72e637
72e637
	retfile="$(mktemp -q /tmp/ipset.XXXXXX)"
72e637
	CLEAN_FILES="${CLEAN_FILES} ${retfile}"
72e637
72e637
	# If restore fails due to invalid lines, remove them and retry
72e637
	while ! restore_err="$( (${IPSET_BIN} -f "${file}" -! restore 2>&1; echo $? >"${retfile}") | head -n1; exit "$(cat "${retfile}")" )"; do
72e637
		warn "${restore_err}"
72e637
		case ${restore_err#*: } in
72e637
		"No command specified"*)
72e637
			line="$(grep -m1 -n "^${restore_err##* }" "${file}")"
72e637
			line="${line%:*}"
72e637
			;;
72e637
		"Missing second mandatory argument to command "*)
72e637
			cmd="${restore_err##* }"
72e637
			cmd_expr="$(cmd_short_expr "${cmd}")"
72e637
			line="$(grep -n '^'"${cmd_expr}" "${file}" | grep -m1 -v '^[0-9]\+\:'"${cmd_expr}"'[[:blank:]]\+[^[:blank:]]\+[[:blank:]]\+[^[:blank:]]\+')"
72e637
			line="${line%:*}"
72e637
			;;
72e637
		"Missing mandatory argument to command "*)
72e637
			cmd="${restore_err##* }"
72e637
			cmd_expr="$(cmd_short_expr "${cmd}")"
72e637
			line="$(grep -n '^'"${cmd_expr}" "${file}" | grep -m1 -v '^[0-9]\+\:'"${cmd_expr}"'[[:blank:]]\+[^[:blank:]]\+')"
72e637
			line="${line%:*}"
72e637
			;;
72e637
		"Command "*"is invalid in restore mode"*)
72e637
			restore_err_cmd="${restore_err#*: }"
72e637
			restore_err_cmd="${restore_err_cmd#*\`}"
72e637
			restore_err_cmd="${restore_err_cmd%%\'*}"
72e637
			cmd="${restore_err_cmd##* }"
72e637
			cmd_expr="$(cmd_short_expr "${cmd}")"
72e637
			line="$(grep -m1 -ne '^'"${cmd_expr}"'[[:blank:]]\+' -e '^'"${restore_err_cmd}"'$' "${file}")"
72e637
			line="${line%:*}"
72e637
			;;
72e637
		"Error in line "*)
72e637
			line="${restore_err%: *}"
72e637
			line="${line##* }"
72e637
			;;
72e637
		*)
72e637
			rm "${retfile}"
72e637
			CLEAN_FILES="${CLEAN_FILES%* ${retfile}}"
72e637
			return 1
72e637
			;;
72e637
		esac
72e637
72e637
		[ -z "${line}" ] && return 1
72e637
72e637
		warn "Skipped invalid entry: $(sed "${line}q;d" "${file}")"
72e637
		sed -i -e "${line}d" "${file}"
72e637
72e637
		[ -s "${file}" ] || return 1
72e637
	done
72e637
72e637
	rm "${retfile}"
72e637
	CLEAN_FILES="${CLEAN_FILES%* ${retfile}}"
72e637
}
72e637
72e637
load() {
72e637
	if [ -f ${IPSET_DATA_SAVED_FLAG} ]; then
72e637
		# If we have a cleanly saved directory with all sets, we can
72e637
		# delete any left-overs and use it
72e637
		rm -rf ${IPSET_DATA_DIR_BACKUP}
72e637
		rm -f ${IPSET_DATA_COMPAT_BACKUP}
72e637
	else
72e637
		# If sets weren't cleanly saved, restore from backups
72e637
		[ -d ${IPSET_DATA_DIR_BACKUP} ] && rm -rf ${IPSET_DATA_DIR} && mv -Tf ${IPSET_DATA_DIR_BACKUP} ${IPSET_DATA_DIR}
72e637
		[ -f ${IPSET_DATA_COMPAT_BACKUP} ] && rm -f ${IPSET_DATA_COMPAT} && mv -Tf ${IPSET_DATA_COMPAT_BACKUP} ${IPSET_DATA_COMPAT}
72e637
	fi
72e637
72e637
	if [ ! -d ${IPSET_DATA_DIR} ] && [ ! -f ${IPSET_DATA_COMPAT} ]; then
72e637
		info "No existing configuration available, none loaded"
72e637
		touch ${IPSET_RUN}
72e637
		return
72e637
	fi
72e637
72e637
	# Merge all sets into temporary file
72e637
	merged="$(mktemp -q /tmp/ipset.XXXXXX)"
72e637
	CLEAN_FILES="${CLEAN_FILES} ${merged}"
72e637
	chmod 600 "${merged}"
72e637
	set +f
72e637
	if [ -d ${IPSET_DATA_DIR} ]; then
72e637
		# Copy create commands from each saved set first, then the rest:
72e637
		# list:set entries depend on other sets, so make sure they all
72e637
		# get created first
72e637
		for f in "${IPSET_DATA_DIR}"/*; do
72e637
			[ "${f}" = "${IPSET_DATA_DIR}/*" ] && break
72e637
			[ -f "${f}" ] || continue
72e637
			grep '^c' "${f}" >> "${merged}"
72e637
		done
72e637
		for f in "${IPSET_DATA_DIR}"/*; do
72e637
			[ "${f}" = "${IPSET_DATA_DIR}/*" ] && break
72e637
			[ -f "${f}" ] || continue
72e637
			grep -v '^c' "${f}" >> "${merged}"
72e637
		done
72e637
	fi
72e637
	set -f
72e637
	[ -f ${IPSET_DATA_COMPAT} ] && cat ${IPSET_DATA_COMPAT} >> "${merged}"
72e637
72e637
	# Drop sets that aren't in saved data, mark conflicts with existing sets
72e637
	conflicts=""
72e637
	IFS="
72e637
"
72e637
	for set in $(${IPSET_BIN} list -n -t); do
72e637
		grep -q "^create ${set} " "${merged}" && conflicts="${conflicts}|${set}" && continue
72e637
72e637
		# We can't destroy the set if it's in use, flush it instead
72e637
		if ! ${IPSET_BIN} destroy "${set}" 2>/dev/null; then
72e637
			${IPSET_BIN} flush "${set}"
72e637
		fi
72e637
	done
72e637
	unset IFS
72e637
	conflicts="${conflicts#|*}"
72e637
72e637
	# Common case: if we have no conflicts, just restore in one shot
72e637
	if [ -z "${conflicts}" ]; then
72e637
		if ! ipset_restore "${merged}"; then
72e637
			err "Failed to restore configured sets"
72e637
			exit 1
72e637
		fi
72e637
		rm "${merged}"
72e637
		CLEAN_FILES="${CLEAN_FILES%* ${merged}}"
72e637
		touch ${IPSET_RUN}
72e637
		return
72e637
	fi
72e637
72e637
	# Find a salt for md5sum that makes names of saved sets unique
72e637
	salt=0
72e637
	while true; do
72e637
		unique=1
72e637
		IFS="
72e637
"
72e637
		for set in $(${IPSET_BIN} list -n -t); do
72e637
			if grep -q "^create $(echo "${salt}${set}" | md5sum | head -c31) " "${merged}"; then
72e637
				unique=0
72e637
				break
72e637
			fi
72e637
		done
72e637
		unset IFS
72e637
		[ ${unique} -eq 1 ] && break
72e637
		salt=$((salt + 1))
72e637
	done
72e637
72e637
	# Add sets, mangling names for conflicting sets
72e637
	mangled="$(mktemp -q /tmp/ipset.XXXXXX)"
72e637
	CLEAN_FILES="${CLEAN_FILES} ${mangled}"
72e637
	chmod 600 "${mangled}"
72e637
72e637
	awk '/^(add|create) ('"${conflicts}"')/ { printf "%s ",$1; system("echo '${salt}'" $2 " | md5sum | head -c31"); $1=""; $2=""; print; next} {print}' "${merged}" > "${mangled}"
72e637
	if ! ipset_restore "${mangled}"; then
72e637
		err "Failed to restore configured sets"
72e637
		exit 1
72e637
	fi
72e637
72e637
	rm "${mangled}"
72e637
	CLEAN_FILES="${CLEAN_FILES%* ${mangled}}"
72e637
72e637
	# Swap and delete old sets
72e637
	IFS='|'
72e637
	for set in ${conflicts}; do
72e637
		mangled="$(echo "${salt}${set}" | md5sum | head -c31)"
72e637
		if ! ${IPSET_BIN} swap "${set}" "${mangled}" 2>/dev/null; then
72e637
			# This fails if set types are different: try to destroy
72e637
			# existing set
72e637
			if ! ${IPSET_BIN} destroy "${set}" 2>/dev/null; then
72e637
				# Conflicting set is in use, we can only warn
72e637
				# and flush the existing set
72e637
				err "Cannot load set \"${set}\", set with same name and conflicting type in use"
72e637
				${IPSET_BIN} flush "${set}"
72e637
				${IPSET_BIN} destroy "${mangled}"
72e637
			else
72e637
				${IPSET_BIN} rename "${mangled}" "${set}"
72e637
			fi
72e637
		else
72e637
			${IPSET_BIN} destroy "${mangled}"
72e637
		fi
72e637
	done
72e637
	unset IFS
72e637
72e637
	rm "${merged}"
72e637
	CLEAN_FILES="${CLEAN_FILES%* ${merged}}"
72e637
	touch ${IPSET_RUN}
72e637
}
72e637
72e637
cleanup() {
72e637
	${IPSET_BIN} flush || err "Failed to flush sets"
72e637
72e637
	# Try to destroy all sets at once. This will fail if some are in use,
72e637
	# destroy all the other ones in that case
72e637
	${IPSET_BIN} destroy 2>/dev/null && return
72e637
	IFS="
72e637
"
72e637
	for set in $(${IPSET_BIN} list -n -t); do
72e637
		if ! ${IPSET_BIN} destroy "${set}"; then
72e637
			err "Failed to destroy set ${set}"
72e637
		fi
72e637
	done
72e637
	unset IFS
72e637
}
72e637
72e637
stop() {
72e637
	[ -f ${IPSET_RUN} ] || { info "Not running"; return 0; }
72e637
	[ "${IPSET_SAVE_ON_STOP}" = "yes" ] && { save || err "Failed to save sets"; }
72e637
72e637
	# Nothing to stop if the ip_set module is not loaded
72e637
	lsmod | grep -q "^ip_set " || { info "Not running"; rm ${IPSET_RUN}; return 0; }
72e637
72e637
	# If the xt_set module is in use, then iptables is using ipset, so
72e637
	# refuse to stop the service
72e637
	if mod="$(lsmod | grep ^xt_set)"; then
72e637
		if [ "$(echo "${mod}" | tr -s ' ' | cut -d' ' -f3)" != "0" ]; then
72e637
			err "Current iptables configuration requires ipset" && return 1
72e637
		fi
72e637
	fi
72e637
72e637
	cleanup
72e637
72e637
	rm ${IPSET_RUN}
72e637
	return 0
72e637
}
72e637
72e637
lock
72e637
case "$1" in
72e637
start)
72e637
	load
72e637
	;;
72e637
stop)
72e637
	stop
72e637
	;;
72e637
reload)
72e637
	cleanup
72e637
	load
72e637
	;;
72e637
save)
72e637
	save
72e637
	;;
72e637
*)
72e637
	info "Usage: $0 {start|stop|reload|save}"
72e637
	exit 1
72e637
esac
72e637
72e637
exit $?