Merge pull request #10847 from appwrite/feat-csv-export

abnegate · web-flow · commit 0cdabbf95967 · 2025-11-20T06:01:06.000Z
Set downloadUrl on realtime event
diff --git a/src/Appwrite/Platform/Workers/Migrations.php b/src/Appwrite/Platform/Workers/Migrations.php
@@ -411,7 +411,7 @@ function () use ($migration, $transfer, $project, $queueForRealtime) {
                 $source?->success();
 
                 if ($migration->getAttribute('destination') === DestinationCSV::getName()) {
-                    $this->handleCSVExportComplete($project, $migration, $queueForMails);
+                    $this->handleCSVExportComplete($project, $migration, $queueForMails, $queueForRealtime);
                 }
             }
         }
@@ -432,7 +432,8 @@ function () use ($migration, $transfer, $project, $queueForRealtime) {
     protected function handleCSVExportComplete(
         Document $project,
         Document $migration,
-        Mail $queueForMails
+        Mail $queueForMails,
+        Realtime $queueForRealtime,
     ): void {
         $options = $migration->getAttribute('options', []);
         $bucketId = 'default'; // Always use platform default bucket
@@ -530,6 +531,9 @@ protected function handleCSVExportComplete(
         $endpoint = System::getEnv('_APP_DOMAIN', '');
         $protocol = System::getEnv('_APP_OPTIONS_FORCE_HTTPS', 'disabled') === 'enabled' ? 'https' : 'http';
         $downloadUrl = "{$protocol}://{$endpoint}/v1/storage/buckets/{$bucketId}/files/{$fileId}/push?project={$project->getId()}&jwt={$jwt}";
+        $options['downloadUrl'] = $downloadUrl;
+        $migration->setAttribute('options', $options);
+        $this->updateMigrationDocument($migration, $project, $queueForRealtime);
 
         $this->sendCSVEmail(
             success: true,
