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

Rollback cross regions connections

Browse source
This commit is contained in:
shimon 2024-11-05 12:21:16 +02:00
parent c2d5e8ec11
commit 2b3e7f67a4
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
app/controllers/api/functions.php
View file

@ -184,8 +184,7 @@ App::post('/v1/functions')
->inject('queueForBuilds') ->inject('queueForBuilds')
->inject('dbForConsole') ->inject('dbForConsole')
->inject('gitHub') ->inject('gitHub')
->inject('realtimeConnection') ->action(function (string $functionId, string $name, string $runtime, array $execute, array $events, string $schedule, int $timeout, bool $enabled, bool $logging, string $entrypoint, string $commands, array $scopes, string $installationId, string $providerRepositoryId, string $providerBranch, bool $providerSilentMode, string $providerRootDirectory, string $templateRepository, string $templateOwner, string $templateRootDirectory, string $templateVersion, string $specification, Request $request, Response $response, Database $dbForProject, Document $project, Document $user, Event $queueForEvents, Build $queueForBuilds, Database $dbForConsole, GitHub $githubgithub) use ($redeployVcs) {
->action(function (string $functionId, string $name, string $runtime, array $execute, array $events, string $schedule, int $timeout, bool $enabled, bool $logging, string $entrypoint, string $commands, array $scopes, string $installationId, string $providerRepositoryId, string $providerBranch, bool $providerSilentMode, string $providerRootDirectory, string $templateRepository, string $templateOwner, string $templateRootDirectory, string $templateVersion, string $specification, Request $request, Response $response, Database $dbForProject, Document $project, Document $user, Event $queueForEvents, Build $queueForBuilds, Database $dbForConsole, GitHub $githubgithub, Callable $realtimeConnection) use ($redeployVcs) {
$functionId = ($functionId == 'unique()') ? ID::unique() : $functionId; $functionId = ($functionId == 'unique()') ? ID::unique() : $functionId;
$allowList = \array_filter(\explode(',', System::getEnv('_APP_FUNCTIONS_RUNTIMES', ''))); $allowList = \array_filter(\explode(',', System::getEnv('_APP_FUNCTIONS_RUNTIMES', '')));
@ -376,7 +375,6 @@ App::post('/v1/functions')
project: $project project: $project
); );
Realtime::send( Realtime::send(
redis: $realtimeConnection($queueForEvents->getSourceRegion()),
projectId: 'console', projectId: 'console',
payload: $rule->getArrayCopy(), payload: $rule->getArrayCopy(),
events: $allEvents, events: $allEvents,
@ -384,7 +382,6 @@ App::post('/v1/functions')
roles: $target['roles'] roles: $target['roles']
); );
Realtime::send( Realtime::send(
redis: $realtimeConnection($queueForEvents->getSourceRegion()),
projectId: $project->getId(), projectId: $project->getId(),
payload: $rule->getArrayCopy(), payload: $rule->getArrayCopy(),
events: $allEvents, events: $allEvents,