From 6b447232b9f5ba5212289e126f50415ec99fe873 Mon Sep 17 00:00:00 2001 From: Damodar Lohani Date: Thu, 21 Oct 2021 15:25:58 +0545 Subject: [PATCH] fix for buckets --- src/Appwrite/Messaging/Adapter/Realtime.php | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/src/Appwrite/Messaging/Adapter/Realtime.php b/src/Appwrite/Messaging/Adapter/Realtime.php index 4269fa04d..ee42b9eff 100644 --- a/src/Appwrite/Messaging/Adapter/Realtime.php +++ b/src/Appwrite/Messaging/Adapter/Realtime.php @@ -273,12 +273,6 @@ class Realtime extends Adapter $channels[] = 'teams.' . $payload->getId(); $roles = ['team:' . $payload->getId()]; - break; - case strpos($event, 'database.collections.') === 0: - $channels[] = 'collections'; - $channels[] = 'collections.' . $payload->getId(); - $roles = $payload->getRead(); - break; case strpos($event, 'database.documents.') === 0: $channels[] = 'documents'; @@ -287,8 +281,9 @@ class Realtime extends Adapter $roles = $payload->getRead(); break; - case strpos($event, 'storage.') === 0: + case strpos($event, 'storage.files') === 0: $channels[] = 'files'; + $channels[] = 'buckets.' . $payload->getAttribute('bucketId') . '.files'; $channels[] = 'files.' . $payload->getId(); $roles = $payload->getRead();