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

add functionsEvents and webhooksEvents

Browse source
This commit is contained in:
shimon 2025-12-28 18:10:44 +02:00
parent 834c18f9fa
commit 6c1f967509
3 changed files with 74 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
app/config/collections/platform.php
View file

@ -276,6 +276,28 @@ return [
'array' => false,
'filters' => ['subQueryWebhooks'],
],
[
'$id' => ID::custom('webhookEvents'),
'type' => Database::VAR_STRING,
'format' => '',
'size' => 16384,
'signed' => true,
'required' => false,
'default' => [],
'array' => true,
'filters' => ['subQueryWebhookEvents'],
],
[
'$id' => ID::custom('functionEvents'),
'type' => Database::VAR_STRING,
'format' => '',
'size' => 16384,
'signed' => true,
'required' => false,
'default' => [],
'array' => true,
'filters' => ['subQueryFunctionEvents'],
],
[
'$id' => ID::custom('keys'),
'type' => Database::VAR_STRING,

38
app/init/database/filters.php
View file

@ -170,6 +170,44 @@ Database::addFilter(
}
);
Database::addFilter(
'subQueryWebhookEvents',
function (mixed $value) {
return;
},
function (mixed $value, Document $document, Database $database) {
$webhooks = $database
->find('webhooks', [
Query::equal('projectInternalId', [$document->getSequence()]),
Query::limit(APP_LIMIT_SUBQUERY),
]);
$events = [];
foreach ($webhooks as $webhook) {
$webhookEvents = $webhook->getAttribute('events', []);
if (!empty($webhookEvents)) {
$events = array_merge($events, $webhookEvents);
}
}
return array_unique($events);
}
);
Database::addFilter(
'subQueryFunctionEvents',
function (mixed $value) {
return;
},
function (mixed $value, Document $document, Database $database) {
// Functions are stored in the project database, not platform database
// This filter will return empty array when called from platform DB
// Function events will need to be computed separately when dbForProject is available
// For now, return empty to avoid errors
return [];
}
);
Database::addFilter(
'subQuerySessions',
function (mixed $value) {

18
src/Appwrite/Platform/Modules/Databases/Http/Databases/Collections/Documents/Action.php
View file

@ -378,11 +378,21 @@ abstract class Action extends DatabasesAction
->from($queueForEvents)
->trigger();
$queueForFunctions
->from($queueForEvents)
->trigger();
$project = $queueForEvents->getProject();
$generatedEvents = Event::generateEvents(
$queueForEvents->getEvent(),
$queueForEvents->getParams()
);
if (!empty($queueForEvents->getProject()?->getAttribute('webhooks', []))) {
$functionEvents = $project?->getAttribute('functionEvents', []);
if (!empty($functionEvents) && !empty(array_intersect($functionEvents, $generatedEvents))) {
$queueForFunctions
->from($queueForEvents)
->trigger();
}
$webhookEvents = $project?->getAttribute('webhookEvents', []);
if (!empty($webhookEvents) && !empty(array_intersect($webhookEvents, $generatedEvents))) {
$queueForWebhooks
->from($queueForEvents)
->trigger();