Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-24 09:28:40 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

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

Browse source 
Set downloadUrl on realtime event
This commit is contained in:
Jake Barnby 2025-11-20 06:01:06 +00:00 committed by GitHub
commit 0cdabbf959
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/Appwrite/Platform/Workers/Migrations.php
View file

@ -411,7 +411,7 @@ class Migrations extends Action
$source?->success(); $source?->success();
if ($migration->getAttribute('destination') === DestinationCSV::getName()) { if ($migration->getAttribute('destination') === DestinationCSV::getName()) {
$this->handleCSVExportComplete($project, $migration, $queueForMails); $this->handleCSVExportComplete($project, $migration, $queueForMails, $queueForRealtime);
} }
} }
} }
@ -432,7 +432,8 @@ class Migrations extends Action
protected function handleCSVExportComplete( protected function handleCSVExportComplete(
Document $project, Document $project,
Document $migration, Document $migration,
Mail $queueForMails Mail $queueForMails,
Realtime $queueForRealtime,
): void { ): void {
$options = $migration->getAttribute('options', []); $options = $migration->getAttribute('options', []);
$bucketId = 'default'; // Always use platform default bucket $bucketId = 'default'; // Always use platform default bucket
@ -530,6 +531,9 @@ class Migrations extends Action
$endpoint = System::getEnv('_APP_DOMAIN', ''); $endpoint = System::getEnv('_APP_DOMAIN', '');
$protocol = System::getEnv('_APP_OPTIONS_FORCE_HTTPS', 'disabled') === 'enabled' ? 'https' : 'http'; $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}"; $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( $this->sendCSVEmail(
success: true, success: true,