From c443a2f9995a60ecd0c2e50475b16be57996cf57 Mon Sep 17 00:00:00 2001
From: Damodar Lohani <dlohani48@gmail.com>
Date: Thu, 27 Mar 2025 05:50:01 +0000
Subject: [PATCH] Fix dual writing

---
 src/Appwrite/Platform/Workers/StatsUsageDump.php | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/Appwrite/Platform/Workers/StatsUsageDump.php b/src/Appwrite/Platform/Workers/StatsUsageDump.php
index 9b7c119821..e6071aa185 100644
--- a/src/Appwrite/Platform/Workers/StatsUsageDump.php
+++ b/src/Appwrite/Platform/Workers/StatsUsageDump.php
@@ -4,6 +4,7 @@ namespace Appwrite\Platform\Workers;
 
 use Appwrite\Extend\Exception;
 use Throwable;
+use Utopia\App;
 use Utopia\CLI\Console;
 use Utopia\Database\Database;
 use Utopia\Database\DateTime;
@@ -178,7 +179,7 @@ class StatsUsageDump extends Action
                             '$internalId' => $project->getInternalId(),
                             'database' => $project->getAttribute('database'),
                         ]);
-                        $this->projects[$project->getInternalId()]['stats'] = $document;
+                        $this->projects[$project->getInternalId()]['stats'][] = $document;
 
                         $this->prepareForLogsDB($project, $document);
                     }
@@ -194,7 +195,7 @@ class StatsUsageDump extends Action
             $shouldProcessBatch = (\time() - $this->lastDispatchTime) >= self::BATCH_AGGREGATION_INTERVAL;
         }
 
-        if ($shouldProcessBatch) {
+        if ($shouldProcessBatch || App::isDevelopment()) {
             try {
                 foreach ($this->projects as $internalId => $projectStats) {
                     /** @var \Utopia\Database\Database $dbForProject */
@@ -206,7 +207,7 @@ class StatsUsageDump extends Action
                     unset($this->projects[$internalId]);
                 }
             } catch (Throwable $e) {
-                Console::error('Error processing audit logs: ' . $e->getMessage());
+                Console::error('Error processing stats: ' . $e->getMessage());
             } finally {
                 $this->lastDispatchTime = time();
             }