From c53f269c3b70efdb0ae7c2b325a96264de463881 Mon Sep 17 00:00:00 2001
From: Chirag Aggarwal <chiragaggarwal5k@gmail.com>
Date: Tue, 11 Nov 2025 10:14:17 +0530
Subject: [PATCH] use logerror instead

---
 src/Appwrite/Platform/Workers/StatsUsage.php | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

diff --git a/src/Appwrite/Platform/Workers/StatsUsage.php b/src/Appwrite/Platform/Workers/StatsUsage.php
index ec7dc69f6c..f37d2b8dfd 100644
--- a/src/Appwrite/Platform/Workers/StatsUsage.php
+++ b/src/Appwrite/Platform/Workers/StatsUsage.php
@@ -15,6 +15,13 @@ use Utopia\System\System;
 
 class StatsUsage extends Action
 {
+    /**
+     * Log Error Callback
+     *
+     * @var callable
+     */
+    protected mixed $logError;
+
     /**
      * In memory per project metrics calculation
      */
@@ -237,6 +244,7 @@ class StatsUsage extends Action
             ->inject('getProjectDB')
             ->inject('getLogsDB')
             ->inject('register')
+            ->inject('logError')
             ->callback($this->action(...));
 
         $this->lastTriggeredTime = time();
@@ -267,14 +275,16 @@ class StatsUsage extends Action
      * @param callable(): Database $getProjectDB
      * @param callable(): Database $getLogsDB
      * @param Registry $register
+     * @param callable $logError
      * @return void
      * @throws \Utopia\Database\Exception
      * @throws Exception
      */
-    public function action(Message $message, callable $getProjectDB, callable $getLogsDB, Registry $register): void
+    public function action(Message $message, callable $getProjectDB, callable $getLogsDB, Registry $register, callable $logError): void
     {
         $this->getLogsDB = $getLogsDB;
         $this->register = $register;
+        $this->logError = $logError;
         $payload = $message->getPayload() ?? [];
         if (empty($payload)) {
             throw new Exception('Missing payload');
@@ -304,7 +314,10 @@ class StatsUsage extends Action
 
             // Skip invalid metrics
             if (!$this->isValidMetric($metricKey)) {
-                throw new Exception('Invalid metric key: ' . $metricKey);
+                call_user_func($this->logError, new Exception('Invalid metric key: ' . $metricKey), 'appwrite-worker', 'appwrite-queue-'.self::getName(), [
+                    'metricKey' => $metricKey,
+                ]);
+                continue;
             }
 
             $this->keys++;