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

fix: event triggers

Browse source
This commit is contained in:
Christy Jacob 2022-11-16 11:38:01 +05:30
parent e976bd3cb1
commit dbb05c46ba
2 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app/worker.php
View file

@ -69,7 +69,7 @@ Server::setResource('cache', function (Registry $register) {
return new Cache(new Sharding($adapters));
}, ['register']);
Server::setResource('functions', function (Registry $register) {
Server::setResource('queueForFunctions', function (Registry $register) {
$pools = $register->get('pools');
return new Func(
$pools

13
app/workers/functions.php
View file

@ -37,7 +37,7 @@ Server::setResource('execute', function () {
Document $project,
Document $function,
Database $dbForProject,
Func $functions,
Func $queueForFunctions,
string $trigger,
string $executionId = null,
string $event = null,
@ -213,7 +213,7 @@ Server::setResource('execute', function () {
->trigger();
/** Trigger Functions */
$functions
$queueForFunctions
->setData($data ?? '')
->setProject($project)
->setUser($user)
@ -267,10 +267,10 @@ Server::setResource('execute', function () {
$server->job()
->inject('message')
->inject('dbForProject')
->inject('functions')
->inject('queueForFunctions')
->inject('statsd')
->inject('execute')
->action(function (Message $message, Database $dbForProject, Func $functions, Client $statsd, callable $execute) {
->action(function (Message $message, Database $dbForProject, Func $queueForFunctions, Client $statsd, callable $execute) {
$payload = $message->getPayload() ?? [];
if (empty($payload)) {
@ -321,6 +321,7 @@ $server->job()
dbForProject: $dbForProject,
project: $project,
function: $function,
queueForFunctions: $queueForFunctions,
trigger: 'event',
event: $events[0],
eventData: $eventData,
@ -348,7 +349,7 @@ $server->job()
project: $project,
function: $function,
dbForProject: $dbForProject,
functions: $functions,
queueForFunctions: $queueForFunctions,
trigger: 'http',
executionId: $execution->getId(),
event: null,
@ -364,7 +365,7 @@ $server->job()
project: $project,
function: $function,
dbForProject: $dbForProject,
functions: $functions,
queueForFunctions: $queueForFunctions,
trigger: 'http',
executionId: null,
event: null,