Merge branch '1.9.x' into CLO-4204-slow-query-hook

src/Appwrite/Platform/Modules/Functions/Workers/Screenshots.php

@@ -20,6 +20,8 @@ use Utopia\Platform\Action;
 use Utopia\Queue\Message;
 use Utopia\Storage\Device;
 use Utopia\System\System;
+use Utopia\Telemetry\Adapter as Telemetry;
+use Utopia\Telemetry\Counter;
 
 use function Swoole\Coroutine\batch;
 
@@ -44,6 +46,7 @@ class Screenshots extends Action
             ->inject('dbForProject')
             ->inject('project')
             ->inject('deviceForFiles')
+            ->inject('telemetry')
             ->callback($this->action(...));
     }
 
@@ -53,7 +56,8 @@ class Screenshots extends Action
         Database $dbForPlatform,
         Database $dbForProject,
         Document $project,
-        Device $deviceForFiles
+        Device $deviceForFiles,
+        Telemetry $telemetry
     ): void {
         Console::log('Screenshot action started');
 
@@ -64,6 +68,7 @@ class Screenshots extends Action
         }
 
         $screenshotMessage = Screenshot::fromArray($payload);
+        $counter = $telemetry->createCounter('worker.screenshots.capture');
 
         Console::log('Site screenshot started');
 
@@ -268,8 +273,24 @@ class Screenshots extends Action
             $date = \date('H:i:s');
             $this->appendToLogs($dbForProject, $deployment->getId(), $queueForRealtime, "[$date] [appwrite] Screenshot capturing failed. Deployment will continue. \n");
 
+            $this->recordTelemetry($counter, 'failure');
+
             throw $th;
         }
+
+        $this->recordTelemetry($counter, 'success');
+    }
+
+    protected function recordTelemetry(Counter $counter, string $result): void
+    {
+        try {
+            $counter->add(1, [
+                'resourceType' => RESOURCE_TYPE_SITES,
+                'result' => $result,
+            ]);
+        } catch (\Throwable) {
+            // Telemetry should never affect screenshot processing.
+        }
     }
 
     protected function appendToLogs(Database $dbForProject, string $deploymentId, Realtime $queueForRealtime, string $logs)