From 4e7236a3663d2d61bd2380fdc2c8e2b7025b68c2 Mon Sep 17 00:00:00 2001 From: Jake Barnby Date: Wed, 6 May 2026 14:00:45 +1200 Subject: [PATCH] feat(notifications): register queueForNotifications resource in worker and request containers Co-Authored-By: Claude Opus 4.7 (1M context) --- app/init/resources/request.php | 4 ++++ app/init/worker/message.php | 5 +++++ 2 files changed, 9 insertions(+) diff --git a/app/init/resources/request.php b/app/init/resources/request.php index 70d691370d..1ee6d79d4a 100644 --- a/app/init/resources/request.php +++ b/app/init/resources/request.php @@ -12,6 +12,7 @@ use Appwrite\Event\Event; use Appwrite\Event\Func; use Appwrite\Event\Mail; use Appwrite\Event\Messaging; +use Appwrite\Event\Notification; use Appwrite\Event\Realtime; use Appwrite\Event\Webhook; use Appwrite\Extend\Exception; @@ -123,6 +124,9 @@ return function (Container $container): void { $container->set('queueForMails', function (Publisher $publisher) { return new Mail($publisher); }, ['publisher']); + $container->set('queueForNotifications', function (Publisher $publisher) { + return new Notification($publisher); + }, ['publisher']); $container->set('queueForBuilds', function (Publisher $publisher) { return new Build($publisher); }, ['publisher']); diff --git a/app/init/worker/message.php b/app/init/worker/message.php index 17796fadcd..c61ed64f06 100644 --- a/app/init/worker/message.php +++ b/app/init/worker/message.php @@ -7,6 +7,7 @@ use Appwrite\Event\Event; use Appwrite\Event\Func; use Appwrite\Event\Mail; use Appwrite\Event\Messaging; +use Appwrite\Event\Notification; use Appwrite\Event\Realtime; use Appwrite\Event\Webhook; use Appwrite\Usage\Context; @@ -342,6 +343,10 @@ return function (Container $container): void { return new Mail($publisher); }, ['publisher']); + $container->set('queueForNotifications', function (Publisher $publisher) { + return new Notification($publisher); + }, ['publisher']); + $container->set('queueForBuilds', function (Publisher $publisher) { return new Build($publisher); }, ['publisher']);