From 0984fcedd0a2d3fe410c6e7b43b8800406334b22 Mon Sep 17 00:00:00 2001
From: Chirag Aggarwal <chiragaggarwal5k@gmail.com>
Date: Tue, 10 Feb 2026 17:56:56 +0530
Subject: [PATCH] Remove console dependency and logs

---
 composer.json        |  1 -
 composer.lock        | 48 --------------------------------------------
 src/Queue/Server.php | 21 -------------------
 3 files changed, 70 deletions(-)

diff --git a/composer.json b/composer.json
index 2ca084f..b3ece6a 100644
--- a/composer.json
+++ b/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.*",
diff --git a/composer.lock b/composer.lock
index 2ba793f..3df40ba 100644
--- a/composer.lock
+++ b/composer.lock
@@ -2177,54 +2177,6 @@
             },
             "time": "2025-06-29T15:42:06+00:00"
         },
-        {
-            "name": "utopia-php/console",
-            "version": "0.0.1",
-            "source": {
-                "type": "git",
-                "url": "https://github.com/utopia-php/console.git",
-                "reference": "f77104e4a888fa9cb3e08f32955ec09479ab7a92"
-            },
-            "dist": {
-                "type": "zip",
-                "url": "https://api.github.com/repos/utopia-php/console/zipball/f77104e4a888fa9cb3e08f32955ec09479ab7a92",
-                "reference": "f77104e4a888fa9cb3e08f32955ec09479ab7a92",
-                "shasum": ""
-            },
-            "require": {
-                "php": ">=7.4"
-            },
-            "require-dev": {
-                "laravel/pint": "1.2.*",
-                "phpstan/phpstan": "^1.10",
-                "phpunit/phpunit": "^9.3",
-                "squizlabs/php_codesniffer": "^3.6",
-                "swoole/ide-helper": "4.8.8"
-            },
-            "type": "library",
-            "autoload": {
-                "psr-4": {
-                    "Utopia\\": "src/"
-                }
-            },
-            "notification-url": "https://packagist.org/downloads/",
-            "license": [
-                "MIT"
-            ],
-            "description": "Console helpers for logging, prompting, and executing commands",
-            "keywords": [
-                "cli",
-                "console",
-                "php",
-                "terminal",
-                "utopia"
-            ],
-            "support": {
-                "issues": "https://github.com/utopia-php/console/issues",
-                "source": "https://github.com/utopia-php/console/tree/0.0.1"
-            },
-            "time": "2025-10-20T14:41:36+00:00"
-        },
         {
             "name": "utopia-php/di",
             "version": "0.1.0",
diff --git a/src/Queue/Server.php b/src/Queue/Server.php
index 92c2113..4702ad8 100644
--- a/src/Queue/Server.php
+++ b/src/Queue/Server.php
@@ -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.",
-                    );
                 }
             });