fix realtime events for storage

app/controllers/api/storage.php

@@ -358,15 +358,17 @@ App::post('/v1/storage/buckets/:bucketId/files')
     ->inject('user')
     ->inject('audits')
     ->inject('usage')
+    ->inject('events')
     ->inject('mode')
     ->inject('deviceFiles')
     ->inject('deviceLocal')
-    ->action(function ($bucketId, $fileId, $file, $read, $write, $request, $response, $dbForProject, $user, $audits, $usage, $mode, $deviceFiles, $deviceLocal) {
+    ->action(function ($bucketId, $fileId, $file, $read, $write, $request, $response, $dbForProject, $user, $audits, $usage, $events, $mode, $deviceFiles, $deviceLocal) {
         /** @var Utopia\Swoole\Request $request */
         /** @var Appwrite\Utopia\Response $response */
         /** @var Utopia\Database\Database $dbForProject */
         /** @var Utopia\Database\Document $user */
         /** @var Appwrite\Event\Event $audits */
+        /** @var Appwrite\Event\Event $events */
         /** @var Appwrite\Stats\Stats $usage */
         /** @var Utopia\Storage\Device $deviceFiles */
         /** @var Utopia\Storage\Device $deviceLocal */
@@ -673,6 +675,8 @@ App::post('/v1/storage/buckets/:bucketId/files')
             }
         }
 
+        $events->setParam('bucket', $bucket->getArrayCopy());
+
         $metadata = null; // was causing leaks as it was passed by reference
 
         $response->setStatusCode(Response::STATUS_CODE_CREATED);
@@ -1332,12 +1336,14 @@ App::put('/v1/storage/buckets/:bucketId/files/:fileId')
     ->inject('audits')
     ->inject('usage')
     ->inject('mode')
-    ->action(function ($bucketId, $fileId, $read, $write, $response, $dbForProject, $user, $audits, $usage, $mode) {
+    ->inject('events')
+    ->action(function ($bucketId, $fileId, $read, $write, $response, $dbForProject, $user, $audits, $usage, $mode, $events) {
         /** @var Appwrite\Utopia\Response $response */
         /** @var Utopia\Database\Database $dbForProject */
         /** @var Utopia\Database\Document $user */
         /** @var Appwrite\Event\Event $audits */
         /** @var Appwrite\Stats\Stats $usage */
+        /** @var Appwirte\Event\Event $events */
         /** @var string $mode */
 
         $bucket = $dbForProject->getDocument('buckets', $bucketId);
@@ -1399,6 +1405,8 @@ App::put('/v1/storage/buckets/:bucketId/files/:fileId')
             );
         }
 
+        $events->setParam('bucket', $bucket->getArrayCopy());
+
         $audits
             ->setParam('event', 'storage.files.update')
             ->setParam('resource', 'file/' . $file->getId())
@@ -1514,6 +1522,7 @@ App::delete('/v1/storage/buckets/:bucketId/files/:fileId')
 
         $events
             ->setParam('eventData', $response->output($file, Response::MODEL_FILE))
+            ->setParam('bucket', $bucket->getArrayCopy())
         ;
 
         $response->noContent();

app/controllers/shared/api.php

@@ -243,12 +243,14 @@ App::shutdown(function ($utopia, $request, $response, $project, $events, $audits
         if ($project->getId() !== 'console') {
             $payload = new Document($response->getPayload());
             $collection = new Document($events->getParam('collection') ?? []);
+            $bucket = new Document($events->getParam('bucket') ?? []);
 
             $target = Realtime::fromPayload(
                 event: $events->getParam('event'), 
                 payload: $payload, 
                 project: $project, 
-                collection: $collection
+                collection: $collection,
+                bucket: $bucket,
             );
 
             Realtime::send(