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

Revert name merge issue

Browse source
This commit is contained in:
Jake Barnby 2025-04-30 22:47:41 +12:00
parent 6e59859f5c
commit ea42b823d8
No known key found for this signature in database
GPG key ID: C437A8CC85B96E9C
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/Appwrite/Messaging/Adapter/Realtime.php
View file

@ -36,12 +36,12 @@ class Realtime extends MessagingAdapter
*/ */
public array $subscriptions = []; public array $subscriptions = [];
private PubSubPool $redis; private PubSubPool $pubSubPool;
public function __construct() public function __construct()
{ {
global $register; global $register;
$this->redis = new PubSubPool($register->get('pools')->get('pubsub')); $this->pubSubPool = new PubSubPool($register->get('pools')->get('pubsub'));
} }
/** /**
@ -148,7 +148,7 @@ class Realtime extends MessagingAdapter
$permissionsChanged = array_key_exists('permissionsChanged', $options) && $options['permissionsChanged']; $permissionsChanged = array_key_exists('permissionsChanged', $options) && $options['permissionsChanged'];
$userId = array_key_exists('userId', $options) ? $options['userId'] : null; $userId = array_key_exists('userId', $options) ? $options['userId'] : null;
$this->redis->publish('realtime', json_encode([ $this->pubSubPool->publish('realtime', json_encode([
'project' => $projectId, 'project' => $projectId,
'roles' => $roles, 'roles' => $roles,
'permissionsChanged' => $permissionsChanged, 'permissionsChanged' => $permissionsChanged,