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

chore: refactor adapter

Browse source
This commit is contained in:
Chirag Aggarwal 2025-02-26 16:24:05 +00:00
parent 55e7633bd1
commit 0ddcb9b14c
1 changed files with 15 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
src/Appwrite/Event/Realtime.php
View file

@ -82,33 +82,21 @@ class Realtime extends Event
bucket: $bucket,
);
if (!empty($this->getTargets())) {
foreach ($this->getTargets() as $targetProjectId) {
RealtimeAdapter::send(
projectId: $targetProjectId,
payload: $this->getRealtimePayload(),
events: $allEvents,
channels: $target['channels'],
roles: $target['roles'],
options: [
'permissionsChanged' => $target['permissionsChanged'],
'userId' => $this->getParam('userId')
]
);
}
} else {
RealtimeAdapter::send(
projectId: $target['projectId'] ?? $this->getProject()->getId(),
payload: $this->getRealtimePayload(),
events: $allEvents,
channels: $target['channels'],
roles: $target['roles'],
options: [
'permissionsChanged' => $target['permissionsChanged'],
'userId' => $this->getParam('userId')
]
);
}
$projectIds = !empty($this->getTargets())
? $this->getTargets()
: [$target['projectId'] ?? $this->getProject()->getId()];
RealtimeAdapter::send(
projectId: $projectIds,
payload: $this->getRealtimePayload(),
events: $allEvents,
channels: $target['channels'],
roles: $target['roles'],
options: [
'permissionsChanged' => $target['permissionsChanged'],
'userId' => $this->getParam('userId')
]
);
return true;
}