1
0

Compare commits

..

No commits in common. "d4024d5d5f87f075e7c1bab39d64fe27bead9542" and "8fac571d2054d6348d860b5d7021b5f31ffb3403" have entirely different histories.

12 changed files with 175 additions and 156 deletions

View File

@ -47,6 +47,7 @@ log_always() {
log() {
[ "${IEP_VERBOSE}" = 0 ] || log_always "$@"
}
log_file() { sed -E '/^./s,^, ,' < "$1" >&2 ; }
ln_s() {
if [ "${IEP_VERBOSE}" = 0 ] ; then
@ -75,6 +76,39 @@ have_cmd() { command -v "$1" >/dev/null 2>&1 || return ; }
strip_suffix() { printf '%s' "${1%"$2"}" | tr -s '/' ; }
untemplate_path() {
case "$1" in
## inplace
"${volume_root}"/* | /etc/angie/run/* )
strip_suffix "$1" "$2"
;;
/etc/angie/autoconf.d/* | /etc/angie/conf.d/* | /etc/angie/j2cfg.d/* | /etc/angie/mod.d/* | /etc/angie/modules.d/* | /etc/angie/site.d/* | /etc/angie/snip.d/* )
strip_suffix "$1" "$2"
;;
/etc/angie/static.d/* )
strip_suffix "$1" "$2"
;;
## set appropriate location
/etc/angie/* )
strip_suffix "${volume_root}${1#/etc/angie}" "$2"
;;
/tmp/* )
log_always "untemplate_path() shouldn't work with /tmp/: $1"
strip_suffix "$1" "$2"
;;
## last resort - STRONGLY AVOID
/* )
log_always "untemplate_path() does uncommon/last-resort mapping for: $1"
strip_suffix "${tmp_dir}$1" "$2"
;;
## misbehavior!
* )
log_always "untemplate_path() doesn't work with relative paths: $1"
return 1
;;
esac
}
install_userdir() {
if [ "${IEP_ROOT}" = 1 ] ; then
install -d -o "${NGX_USER}" -g "${NGX_GROUP}" "$@"
@ -174,6 +208,69 @@ expand_dir_j2cfg() {
return ${__ret}
}
remap_path() {
[ -n "$1" ] || return
case "$1" in
## autoconf
/etc/angie/autoconf.dist/* ) echo "${2:-/etc/angie/autoconf.d}${1#/etc/angie/autoconf.dist}" ;;
/etc/angie/autoconf/* ) echo "${2:-/etc/angie/autoconf.d}${1#/etc/angie/autoconf}" ;;
/angie/autoconf/* ) echo "${2:-/etc/angie/autoconf.d}${1#/angie/autoconf}" ;;
## conf
/etc/angie/conf.dist/* ) echo "${2:-/etc/angie/conf.d}${1#/etc/angie/conf.dist}" ;;
/etc/angie/conf/* ) echo "${2:-/etc/angie/conf.d}${1#/etc/angie/conf}" ;;
/angie/conf/* ) echo "${2:-/etc/angie/conf.d}${1#/angie/conf}" ;;
## j2cfg
/etc/angie/j2cfg.dist/* ) echo "${2:-/etc/angie/j2cfg.d}${1#/etc/angie/j2cfg.dist}" ;;
/etc/angie/j2cfg/* ) echo "${2:-/etc/angie/j2cfg.d}${1#/etc/angie/j2cfg}" ;;
/angie/j2cfg/* ) echo "${2:-/etc/angie/j2cfg.d}${1#/angie/j2cfg}" ;;
## mod
/etc/angie/mod.dist/* ) echo "${2:-/etc/angie/mod.d}${1#/etc/angie/mod.dist}" ;;
/etc/angie/mod/* ) echo "${2:-/etc/angie/mod.d}${1#/etc/angie/mod}" ;;
/angie/mod/* ) echo "${2:-/etc/angie/mod.d}${1#/angie/mod}" ;;
## modules
/etc/angie/modules.dist/* ) echo "${2:-/etc/angie/modules.d}${1#/etc/angie/modules.dist}" ;;
/etc/angie/modules/* ) echo "${2:-/etc/angie/modules.d}${1#/etc/angie/modules}" ;;
/angie/modules/* ) echo "${2:-/etc/angie/modules.d}${1#/angie/modules}" ;;
## site
/etc/angie/site.dist/* ) echo "${2:-/etc/angie/site.d}${1#/etc/angie/site.dist}" ;;
/etc/angie/site/* ) echo "${2:-/etc/angie/site.d}${1#/etc/angie/site}" ;;
/angie/site/* ) echo "${2:-/etc/angie/site.d}${1#/angie/site}" ;;
## snip
/etc/angie/snip.dist/* ) echo "${2:-/etc/angie/snip.d}${1#/etc/angie/snip.dist}" ;;
/etc/angie/snip/* ) echo "${2:-/etc/angie/snip.d}${1#/etc/angie/snip}" ;;
/angie/snip/* ) echo "${2:-/etc/angie/snip.d}${1#/angie/snip}" ;;
## static
/etc/angie/static.dist/* ) echo "${2:-/etc/angie/static.d}${1#/etc/angie/static.dist}" ;;
/etc/angie/static/* ) echo "${2:-/etc/angie/static.d}${1#/etc/angie/static}" ;;
/angie/static/* ) echo "${2:-/etc/angie/static.d}${1#/angie/static}" ;;
## log
/etc/angie/log.dist/* ) echo "${2:-/etc/angie/log.d}${1#/etc/angie/log.dist}" ;;
/angie/log/* ) echo "${2:-/etc/angie/log.d}${1#/angie/log}" ;;
## misbehavior!
* )
log_always "remap_path() doesn't know how to handle this path: $1"
return 1
;;
esac
}
combine_remap_path() {
[ -n "$1" ] || return
case "$1" in
"${merged_root}"/* ) echo "${2:-${target_root}}${1#"${merged_root}"}" ;;
## misbehavior!
* )
log_always "combine_remap_path() doesn't know how to handle this path: $1"
return 1
;;
esac
}
is_builtin_module() {
[ -n "${1:-}" ] || return 1
[ -n "${2:-}" ] || return 1
@ -184,30 +281,6 @@ is_builtin_module() {
grep -Fxq -e "$2" "/etc/angie/builtin.$1" || return 1
}
append_list() {
if [ -n "$2" ] ; then
printf '%s' "${1:-}${1:+ }$2"
else
printf '%s' "$1"
fi
}
prepend_list() {
if [ -n "$2" ] ; then
printf '%s' "$2${1:+ }${1:-}"
else
printf '%s' "$1"
fi
}
list_have_item() {
[ -n "$2" ] || return 1
case " $1 " in
*" $2 "* ) return 0 ;;
* ) return 1 ;;
esac
}
normalize_list() {
[ -n "$1" ] || return 0
@ -223,7 +296,3 @@ sort_dedup_list() {
| tr -s '[:space:]' '\n' | sort -uV | paste -sd ' ' \
| sed -zE 's/^\s+//;s/\s+$//'
}
float_div() {
mawk -v "a=$1" -v "b=$2" 'BEGIN{print a/b;exit;}' </dev/null
}

View File

@ -28,46 +28,29 @@ else
NGX_DIRS_LINK="${NGX_DIRS_LINK:-} static"
fi
set -a
NGX_DIRS_MERGE=$(sort_dedup_list "${default_dirs_merge} ${NGX_DIRS_MERGE:-}")
NGX_DIRS_LINK=$(sort_dedup_list "${default_dirs_link} ${NGX_DIRS_LINK:-}")
set +a
unset default_dirs_merge default_dirs_link
unset i dirs
dirs=
for i in ${NGX_DIRS_MERGE:-} ; do
[ -n "$i" ] || continue
case "$i" in
/* | */.* | *./* | *\** | *\?* )
log_always "NGX_DIRS_MERGE: dir '$i' is not legal, skipping"
continue
;;
esac
dirs=$(append_list "${dirs}" "$i")
done
export NGX_DIRS_MERGE="${dirs}"
dirs=
unset i dirs_link
dirs_link=
for i in ${NGX_DIRS_LINK:-} ; do
[ -n "$i" ] || continue
case "$i" in
/* | */.* | *./* | *\** | *\?* )
log_always "NGX_DIRS_LINK: dir '$i' is not legal, skipping"
## naive deduplication
case " ${NGX_DIRS_MERGE} " in
*" $i "* )
log "$i is already specified in NGX_DIRS_MERGE - removing from NGX_DIRS_LINK"
continue
;;
esac
if list_have_item "${NGX_DIRS_MERGE}" "$i" ; then
log "$i is already specified in NGX_DIRS_MERGE - removing from NGX_DIRS_LINK"
continue
fi
dirs=$(append_list "${dirs}" "$i")
dirs_link="${dirs_link}${dirs_link:+ }$i"
done
export NGX_DIRS_LINK="${dirs}"
unset i
unset i dirs
export NGX_DIRS_LINK="${dirs_link}"
unset dirs_link

View File

@ -6,17 +6,17 @@
if [ -z "${NGX_IP_ADDRESSES:-}" ] ; then
NGX_IP_ADDRESSES=$(hostname -I)
fi
NGX_IP_ADDRESSES=$(normalize_list "${NGX_IP_ADDRESSES}")
NGX_IP_ADDRESSES=$(printf '%s' "${NGX_IP_ADDRESSES}" | sed -zE 's/^\s+//;s/\s+$//;s/\s+/ /g')
export NGX_IP_ADDRESSES
unset NGX_IPV4_ADDRESSES NGX_IPV6_ADDRESSES
for i in ${NGX_IP_ADDRESSES} ; do
case "$i" in
*:* )
NGX_IPV6_ADDRESSES=$(append_list "${NGX_IPV6_ADDRESSES}" "$i")
NGX_IPV6_ADDRESSES="${NGX_IPV6_ADDRESSES:-}${NGX_IPV6_ADDRESSES:+ }$i"
;;
* )
NGX_IPV4_ADDRESSES=$(append_list "${NGX_IPV4_ADDRESSES}" "$i")
NGX_IPV4_ADDRESSES="${NGX_IPV4_ADDRESSES:-}${NGX_IPV4_ADDRESSES:+ }$i"
;;
esac
done

View File

@ -18,17 +18,19 @@ for i in ${NGX_CORE_MODULES:-} ; do
if is_builtin_module core "$i" ; then
log "$i is builtin module, moving to NGX_CORE_CONFLOAD"
core_confload=$(append_list "${core_confload}" "$i")
core_confload="${core_confload} $i"
continue
fi
## naive deduplication
if list_have_item "${core_modules}" "$i" ; then
case " ${core_modules} " in
*" $i "* )
log "$i is already specified"
continue
fi
;;
esac
core_modules=$(append_list "${core_modules}" "$i")
core_modules="${core_modules}${core_modules:+ }$i"
done
unset i

View File

@ -182,7 +182,7 @@ fi
if [ ${nofile_limit} -lt ${NGX_WORKER_CONNECTIONS} ] ; then
log_always "WARNING: ${nofile_kind} is less than NGX_WORKER_CONNECTIONS (${nofile_limit} < ${NGX_WORKER_CONNECTIONS})"
else
ratio=$(float_div "${nofile_limit}" "${NGX_WORKER_CONNECTIONS}")
ratio=$(mawk -v "a=${nofile_limit}" -v "b=${NGX_WORKER_CONNECTIONS}" 'BEGIN{print a/b;exit;}' </dev/null)
case "${ratio}" in
1 | 1.* )
log_always "WARNING: \"${nofile_kind}/NGX_WORKER_CONNECTIONS\" ratio is too low (=${ratio})"

View File

@ -1,8 +1,6 @@
#!/bin/sh
if [ "${NGX_HTTP}" = 0 ] ; then
unset NGX_HTTP_NO_PROXY NGX_HTTP_WITH_MODSECURITY
else
if [ "${NGX_HTTP}" = 1 ] ; then
unset http_modules http_confload
http_modules=
http_confload="${NGX_HTTP_CONFLOAD:-}"
@ -10,18 +8,6 @@ else
if [ -n "${NGX_HTTP_MODULES}" ] ; then
## angie-module-lua: depends on angie-module-ndk
## angie-module-set-misc: depends on angie-module-ndk
# unset want_ndk
# want_ndk=0
# if list_have_item "${NGX_HTTP_MODULES}" lua ; then
# want_ndk=1
# elif list_have_item "${NGX_HTTP_MODULES}" set-misc ; then
# want_ndk=1
# fi
# if [ ${want_ndk} = 1 ] ; then
# NGX_HTTP_MODULES=$(prepend_list "${NGX_HTTP_MODULES}" ndk)
# fi
# unset want_ndk
NGX_HTTP_MODULES=$(
printf '%s' "${NGX_HTTP_MODULES}" \
| sed -zE 's/(\s|^)(lua|set-misc)(\s|$)/\1ndk \2\3/g'
@ -42,17 +28,19 @@ else
if is_builtin_module http "$i" ; then
log "$i is builtin module, moving to NGX_HTTP_CONFLOAD"
http_confload=$(append_list "${http_confload}" "$i")
http_confload="${http_confload} $i"
continue
fi
## naive deduplication
if list_have_item "${http_modules}" "$i" ; then
case " ${http_modules} " in
*" $i "* )
log "$i is already specified"
continue
fi
;;
esac
http_modules=$(append_list "${http_modules}" "$i")
http_modules="${http_modules}${http_modules:+ }$i"
done
unset i
@ -67,14 +55,14 @@ else
unset NGX_HTTP_WITH_MODSECURITY
NGX_HTTP_WITH_MODSECURITY=0
while : ; do
if ! list_have_item "${NGX_HTTP_MODULES}" modsecurity ; then
break
fi
case " ${NGX_HTTP_MODULES} " in
*" modsecurity "* ) ;;
* ) break ;;
esac
for d in /angie/modules /etc/angie/modules /etc/angie/modules.dist ; do
[ -d "$d" ] || continue
[ -f "$d/ngx_http_modsecurity_module.so" ] || continue
if ! [ -h "$d/ngx_http_modsecurity_module.so" ] ; then
if [ -f "$d/ngx_http_modsecurity_module.so" ] ; then
NGX_HTTP_WITH_MODSECURITY=1
break
fi

View File

@ -19,17 +19,19 @@ if [ "${NGX_MAIL}" = 1 ] ; then
if is_builtin_module mail "$i" ; then
log "$i is builtin module, moving to NGX_MAIL_CONFLOAD"
mail_confload=$(append_list "${mail_confload}" "$i")
mail_confload="${mail_confload} $i"
continue
fi
## naive deduplication
if list_have_item "${mail_modules}" "$i" ; then
case " ${mail_modules} " in
*" $i "* )
log "$i is already specified"
continue
fi
;;
esac
mail_modules=$(append_list "${mail_modules}" "$i")
mail_modules="${mail_modules}${mail_modules:+ }$i"
done
unset i

View File

@ -19,17 +19,19 @@ if [ "${NGX_STREAM}" = 1 ] ; then
if is_builtin_module stream "$i" ; then
log "$i is builtin module, moving to NGX_STREAM_CONFLOAD"
stream_confload=$(append_list "${stream_confload}" "$i")
stream_confload="${stream_confload} $i"
continue
fi
## naive deduplication
if list_have_item "${stream_modules}" "$i" ; then
case " ${stream_modules} " in
*" $i "* )
log "$i is already specified"
continue
fi
;;
esac
stream_modules=$(append_list "${stream_modules}" "$i")
stream_modules="${stream_modules}${stream_modules:+ }$i"
done
unset i

View File

@ -5,22 +5,6 @@ set -ef
[ -d "${merged_root}" ] || install -d "${merged_root}"
remap_path_int() {
printf '%s' "$2/${1#*/}"
}
remap_path() {
case "$1" in
/etc/angie/* ) remap_path_int "${1#/etc/angie/}" "$2" ;;
/angie/* ) remap_path_int "${1#/angie/}" "$2" ;;
## misbehavior!
* )
log_always "remap_path() doesn't know how to handle this path: '$1'"
return 1
;;
esac
}
for n in ${NGX_DIRS_MERGE} ; do
[ -n "$n" ] || continue

View File

@ -13,7 +13,6 @@ cd "${merged_root}/"
expand_error_delim() {
IEP_DEBUG=0 log_always ' ----------------------------------- '
}
unset expand_error_seen
expand_error() {
[ "${expand_error_seen:-}" != 1 ] || return
expand_error_seen=1

View File

@ -8,7 +8,6 @@ set -f
load_error_delim() {
IEP_DEBUG=0 log_always ' ----------------------------------- '
}
unset load_error_seen
load_error() {
[ "${load_error_seen:-}" != 1 ] || return
load_error_seen=1
@ -48,7 +47,7 @@ for p in ${dirs} ; do
[ -d "$d/$p" ] || install_userdir "$d/$p" || load_error
done
if [ "${NGX_HTTP_WITH_MODSECURITY:-}" = 1 ] ; then
if [ "${NGX_HTTP_WITH_MODSECURITY}" = 1 ] ; then
d="${target_root}/log"
for p in modsecurity modsecurity/concurrent ; do
[ -d "$d/$p" ] || install_userdir "$d/$p" || load_error
@ -62,23 +61,10 @@ d="${target_root}/log"
## NB: if any error occurs above then configuration is merely empty and/or broken
remap_path() {
[ -n "$1" ] || return
case "$1" in
"${merged_root}"/* ) echo "${target_root}${1#"${merged_root}"}" ;;
## misbehavior!
* )
log_always "remap_path() doesn't know how to handle this path: $1"
return 1
;;
esac
}
while read -r old_path ; do
[ -n "${old_path}" ] || continue
new_path=$(remap_path "${old_path}")
new_path=$(combine_remap_path "${old_path}")
[ -n "${new_path}" ]
new_dir="${new_path%/*}"

View File

@ -16,19 +16,19 @@ def is_mapping(x) -> bool:
return isinstance(x, collections.abc.Mapping)
def uniq(a: list | set) -> list:
return sorted(set(a))
def uniq(a: (list, set)) -> list:
return list(dict.fromkeys(a))
def remove_non_str(a: list | set) -> list:
def remove_non_str(a: (list, set)) -> list:
return list(filter(lambda x: isinstance(x, str), a))
def remove_empty_str(a: list | set) -> list:
def remove_empty_str(a: (list, set)) -> list:
return list(filter(None, a))
def uniq_str_list(a: list | set) -> list:
def uniq_str_list(a: (list, set)) -> (list, set):
return remove_empty_str(uniq(a))
@ -47,14 +47,15 @@ def dict_to_env_str_list(x: dict) -> list:
def any_to_str_list(x) -> list:
if x is None:
return []
if isinstance(x, str):
return [x]
if is_sequence(x):
return [str(e) for e in x]
if is_mapping(x):
return dict_to_env_str_list(x)
return [str(x)]
@ -129,16 +130,21 @@ def re_fullmatch_negate(x, pattern, flags=0):
def dict_remap_keys(x: dict, key_map) -> dict:
if key_map is None:
return x
p = set(x.keys())
m = {}
for k in x:
v = key_map(k)
if v == k:
continue
m[k] = v
p.discard(k)
p.discard(v)
return {k: x[k] for k in p} | {v: x[k] for k, v in m.items()}
all_keys = list(x.keys())
kmap = {
k: key_map(k)
for k in all_keys
if k != key_map(k)
}
persist_keys = [
k for k in all_keys
if k not in kmap.keys() and k not in kmap.values()
]
return {
k: x[k] for k in persist_keys
} | {
k: x[v] for k, v in kmap.items()
}
def re_sub(x, pattern, repl, count=0, flags=0):
@ -178,11 +184,9 @@ def any_to_env_dict(x) -> dict:
h = {}
def feed(k, parse=False, v=None):
if v is None:
return
def feed(k, v=None):
k = str(k)
if parse:
if v is None:
k2, m, v2 = k.partition('=')
if m == '=':
k = k2
@ -196,13 +200,13 @@ def any_to_env_dict(x) -> dict:
h[k] = v if v is None else str(v)
if isinstance(x, str):
feed(x, True)
feed(x)
elif is_sequence(x):
for e in x:
feed(e, True)
feed(e)
elif is_mapping(x):
for k in x:
feed(k, False, x[k])
feed(k, x[k])
else:
return {}
@ -221,11 +225,11 @@ def dict_non_empty_keys(x: dict) -> list:
return sorted([k for k in x.keys() if x[k] is not None])
def list_diff(a: list | set, b: list | set) -> list:
def list_diff(a: (list, set), b: (list, set)) -> list:
return list(set(a) - set(b))
def list_intersect(a: list | set, b: list | set) -> list:
def list_intersect(a: (list, set), b: (list, set)) -> list:
return list(set(a) & set(b))