Merge pull request #69 from utopia-php/remove-console-logs

Author: ChiragAgg5k

composer.json

@@ -26,7 +26,6 @@
     "require": {
         "php": ">=8.3",
         "php-amqplib/php-amqplib": "^3.7",
-        "utopia-php/console": "0.0.*",
         "utopia-php/servers": "0.2.*",
         "utopia-php/fetch": "0.5.*",
         "utopia-php/pools": "1.*",

composer.lock

@@ -4,7 +4,6 @@
 
 use Exception;
 use Throwable;
-use Utopia\Console;
 use Utopia\Servers\Hook;
 use Utopia\Telemetry\Adapter as Telemetry;
 use Utopia\Telemetry\Adapter\None as NoTelemetry;
@@ -267,7 +266,6 @@ public function start(): self
     {
         try {
             $this->adapter->workerStart(function (string $workerId) {
-                Console::success("[Worker] Worker {$workerId} started.");
                 self::setResource('workerId', fn () => $workerId);
 
                 foreach ($this->workerStartHooks as $hook) {
@@ -278,9 +276,6 @@ public function start(): self
                     $this->adapter->queue,
                     function (Message $message) {
                         $receivedAtTimestamp = microtime(true);
-                        Console::info(
-                            "[Job] Received Job ({$message->getPid()}).",
-                        );
                         try {
                             $waitDuration =
                                 microtime(true) - $message->getTimestamp();
@@ -353,18 +348,8 @@ function (Message $message) {
                                 }
                             }
                         }
-                        Console::success(
-                            "[Job] ({$message->getPid()}) successfully run.",
-                        );
                     },
                     function (?Message $message, Throwable $th) {
-                        Console::error(
-                            "[Job] ({$message?->getPid()}) failed to run.",
-                        );
-                        Console::error(
-                            "[Job] ({$message?->getPid()}) {$th->getMessage()}",
-                        );
-
                         self::setResource('error', fn () => $th);
 
                         foreach ($this->errorHooks as $hook) {
@@ -383,17 +368,11 @@ function (?Message $message, Throwable $th) {
                         try {
                             $hook->getAction()(...$this->getArguments($hook));
                         } catch (Throwable $e) {
-                            Console::error(
-                                "[Worker] Worker {$workerId} workerStop hook failed: {$e->getMessage()}",
-                            );
                         }
                     }
                 } finally {
                     // Always close consumer connection, even if hooks throw
                     $this->adapter->consumer->close();
-                    Console::success(
-                        "[Worker] Worker {$workerId} stopped.",
-                    );
                 }
             });