130 lines
2.2 KiB
Bash
Executable file
130 lines
2.2 KiB
Bash
Executable file
#!/bin/sh
|
|
|
|
set -eu
|
|
|
|
usage() {
|
|
printf "Usage: %s [-l DEBUG_LEVEL] [-h] start|stop|restart\n" "$0"
|
|
}
|
|
|
|
help() {
|
|
cat << EOH
|
|
SYNOPSIS
|
|
$0 [-l DEBUG_LEVEL] [-h] -a start|stop|restart
|
|
|
|
DESCRIPTION
|
|
|
|
$0 manages symfony messenger
|
|
|
|
OPTIONS
|
|
|
|
-h Show this help
|
|
|
|
-l debug|info|notice|warning|error
|
|
Debug level
|
|
|
|
-a start|stop|restart|status
|
|
EOH
|
|
}
|
|
|
|
on_interrupt() {
|
|
log -l notice ""
|
|
log -l notice "Process aborted!"
|
|
|
|
exit 130
|
|
}
|
|
|
|
start_messenger() {
|
|
nohup php8.1 bin/console messenger:consume 2>/dev/null >/dev/null &
|
|
log -t -l notice "Started"
|
|
}
|
|
|
|
stop_messenger() {
|
|
php8.1 bin/console messenger:stop-workers
|
|
log -t -l notice "Stopped"
|
|
}
|
|
|
|
get_pid() {
|
|
pgrep -f messenger:consume
|
|
}
|
|
|
|
main() {
|
|
cd "$(dirname "0")"
|
|
|
|
ACTION=
|
|
|
|
while getopts "l:ha:" option; do
|
|
case "${option}" in
|
|
h) help; exit 0;;
|
|
l) LOG_VERBOSE="$OPTARG";;
|
|
a) ACTION="$OPTARG";;
|
|
?) log -l error "$(usage)"; exit 1;;
|
|
esac
|
|
done
|
|
|
|
if [ "$ACTION" = "start" ]; then
|
|
start_messenger
|
|
elif [ "$ACTION" = "stop" ]; then
|
|
stop_messenger
|
|
elif [ "$ACTION" = "restart" ]; then
|
|
stop_messenger
|
|
start_messenger
|
|
elif [ "$ACTION" = "status" ]; then
|
|
get_pid
|
|
else
|
|
log -l error "Action is required."
|
|
fi
|
|
|
|
exit 0
|
|
}
|
|
|
|
log() {
|
|
LOG_VERBOSE="${LOG_VERBOSE:-info}"
|
|
LEVEL=info
|
|
TIME=
|
|
|
|
while getopts "tl:" option; do
|
|
case "${option}" in
|
|
l) LEVEL="$OPTARG"; shift $((OPTIND-1));;
|
|
t) TIME="$(printf "[%s] " "$(date +'%Y-%m-%dT%H:%M:%S.%s')")"; shift $((OPTIND-1));;
|
|
*) exit 1;;
|
|
esac
|
|
done
|
|
|
|
if [ -t 2 ] && [ -z "${NO_COLOR-}" ]; then
|
|
case "${LEVEL}" in
|
|
debug) COLOR="$(tput setaf 3)";;
|
|
notice) COLOR="$(tput setaf 4)";;
|
|
warning) COLOR="$(tput setaf 5)";;
|
|
error) COLOR="$(tput setaf 1)";;
|
|
*) COLOR="$(tput sgr0)";;
|
|
esac
|
|
fi
|
|
|
|
case "${LEVEL}" in
|
|
debug) LEVEL=100;;
|
|
notice) LEVEL=250;;
|
|
warning) LEVEL=300;;
|
|
error) LEVEL=400;;
|
|
*) LEVEL=200;;
|
|
esac
|
|
|
|
case "${LOG_VERBOSE}" in
|
|
debug) LOG_VERBOSE_VALUE=100;;
|
|
notice) LOG_VERBOSE_VALUE=250;;
|
|
warning) LOG_VERBOSE_VALUE=300;;
|
|
error) LOG_VERBOSE_VALUE=400;;
|
|
*) LOG_VERBOSE_VALUE=200;;
|
|
esac
|
|
|
|
if [ $LEVEL -ge $LOG_VERBOSE_VALUE ]; then
|
|
printf "%s\n" "$*" | while IFS='' read -r LINE; do
|
|
printf "%s%s%s\n" "${COLOR:-}" "${TIME:-}" "$LINE" >&2
|
|
done
|
|
fi
|
|
}
|
|
|
|
trap on_interrupt INT
|
|
|
|
main "$@"
|
|
|