feat: fixing realtime bugs

app/realtime.php

@@ -323,19 +323,17 @@ function () use ($register, $db, $redis) {
 
  if ($realtime->hasSubscriber($projectId, 'user:' . $userId)) {
  $connection = array_key_first(reset($realtime->subscriptions[$projectId]['user:' . $userId]));
- } else {
- return;
+
+ [$database, $returnDatabase] = getDatabase($register, "_{$projectId}");
+
+ $user = $database->getDocument('users', $userId);
+
+ $roles = Auth::getRoles($user);
+
+ $realtime->subscribe($projectId, $connection, $roles, $realtime->connections[$connection]['channels']);
+
+ call_user_func($returnDatabase);
  }
-
- [$database, $returnDatabase] = getDatabase($register, "_{$projectId}");
-
- $user = $database->getDocument('users', $userId);
-
- $roles = Auth::getRoles($user);
-
- $realtime->subscribe($projectId, $connection, $roles, $realtime->connections[$connection]['channels']);
-
- call_user_func($returnDatabase);
  }
 
  $receivers = $realtime->getSubscribers($event);

src/Appwrite/Messaging/Adapter/Realtime.php

@@ -183,6 +183,7 @@ public function getSubscribers(array $event)
  * Iterate through each channel.
  */
  foreach ($event['data']['channels'] as $channel) {
+
  /**
  * Check if channel has subscriber. Also taking care of the role in the event and the wildcard role.
  */
@@ -282,6 +283,7 @@ public static function fromPayload(string $event, Document $payload, Document $p
  $channels[] = 'memberships';
  $channels[] = 'memberships.' . $payload->getId();
  $roles = ['team:' . $payload->getAttribute('teamId')];
+ var_dump($roles, $channels);
 
  break;
  case strpos($event, 'teams.') === 0: