From 28f8e5c5835171c880c33a4dbda708df16c21220 Mon Sep 17 00:00:00 2001
From: Simon Vieille <simon.vieille@trinaps.com>
Date: Wed, 18 Oct 2023 22:33:33 +0200
Subject: [PATCH] replace stop action in messenger

---
 bin/messenger | 46 ++++++----------------------------------------
 1 file changed, 6 insertions(+), 40 deletions(-)

diff --git a/bin/messenger b/bin/messenger
index b678885..8e7a568 100755
--- a/bin/messenger
+++ b/bin/messenger
@@ -34,52 +34,18 @@ on_interrupt() {
 }
 
 start_messenger() {
-	started=0
-	pid=
-
-	if [ -f "$pid_file" ]; then
-		pid="$(cat "$pid_file")"
-	fi
-
-	if [ -n "$pid" ]; then
-		if [ -d "/proc/$pid" ]; then
-			log -t -l warning "Already running"
-			started=1
-		fi
-	fi
-
-	if [ "$started" -eq 0 ]; then
-		nohup php8.1 bin/console messenger:consume 2>/dev/null >/dev/null &
-		echo -n $! > "$pid_file"
-		log -t -l notice "Started"
-	fi
+	nohup php8.1 bin/console messenger:consume 2>/dev/null >/dev/null &
 }
 
 stop_messenger() {
-	pid=
-
-	if [ -f "$pid_file" ]; then
-		pid="$(cat "$pid_file")"
-	fi
-
-	if [ -n "$pid" ]; then
-		if [ ! -d "/proc/$pid" ]; then
-			log -t -l warning "Not started"
-		else
-			kill -9 "$pid"
-			log -t -l notice "Stopped"
-		fi
-
-		rm "$pid_file"
-	else
-		log -t -l warning "Not started"
-	fi
+	php8.1 bin/console messenger:stop-workers
+	log -t -l notice "Stopped"
 }
 
 main() {
 	cd "$(dirname "0")"
 
-	pid_file=var/messenger.pid
+	ACTION=
 
 	while getopts "l:ha:" option; do
 		case "${option}" in
@@ -97,10 +63,10 @@ main() {
 	elif [ "$ACTION" = "restart" ]; then
 		stop_messenger
 		start_messenger
+	else
+		log -l error "Action no defined."
 	fi
 
-	# log [-t] [-l debug|info|notice|warning|error] message
-
 	exit 0
 }