From 79426088df628240e004afa21c62c944ea7196fb Mon Sep 17 00:00:00 2001
From: Bradley Schofield <bradley@appwrite.io>
Date: Wed, 12 Jul 2023 12:12:26 +0100
Subject: [PATCH] Try to fix realtime

---
 app/workers/migrations.php                  | 26 ++++++++++++++-------
 src/Appwrite/Messaging/Adapter/Realtime.php |  6 +++++
 2 files changed, 23 insertions(+), 9 deletions(-)

diff --git a/app/workers/migrations.php b/app/workers/migrations.php
index 971085bcce..a48ef3f5d5 100644
--- a/app/workers/migrations.php
+++ b/app/workers/migrations.php
@@ -116,16 +116,16 @@ class MigrationsV1 extends Worker
 
     protected function updateMigrationDocument(Document $migration, Document $project): Document
     {
-        // Trigger Webhook
-        $migrationModel = new Migration();
+        // // Trigger Webhook
+        // $migrationModel = new Migration();
 
-        $migrationUpdate = new Event(Event::MIGRATIONS_QUEUE_NAME, Event::MIGRATIONS_CLASS_NAME);
-        $migrationUpdate
-            ->setProject($project)
-            ->setEvent('migrations.[migrationId].update')
-            ->setParam('migrationId', $migration->getId())
-            ->setPayload($migration->getArrayCopy(array_keys($migrationModel->getRules())))
-            ->trigger();
+        // $migrationUpdate = new Event(Event::MIGRATIONS_QUEUE_NAME, Event::MIGRATIONS_CLASS_NAME);
+        // $migrationUpdate
+        //     ->setProject($project)
+        //     ->setEvent('migrations.[migrationId].update')
+        //     ->setParam('migrationId', $migration->getId())
+        //     ->setPayload($migration->getArrayCopy(array_keys($migrationModel->getRules())))
+        //     ->trigger();
 
         /** Trigger Realtime */
         $allEvents = Event::generateEvents('migrations.[migrationId].update', [
@@ -146,6 +146,14 @@ class MigrationsV1 extends Worker
             roles: $target['roles'],
         );
 
+        Realtime::send(
+            projectId: $project->getId(),
+            payload: $migration->getArrayCopy(),
+            events: $allEvents,
+            channels: $target['channels'],
+            roles: $target['roles'],
+        );
+
         return $this->dbForProject->updateDocument('migrations', $migration->getId(), $migration);
     }
 
diff --git a/src/Appwrite/Messaging/Adapter/Realtime.php b/src/Appwrite/Messaging/Adapter/Realtime.php
index 33fe484c13..f884f3ecd2 100644
--- a/src/Appwrite/Messaging/Adapter/Realtime.php
+++ b/src/Appwrite/Messaging/Adapter/Realtime.php
@@ -326,6 +326,12 @@ class Realtime extends Adapter
                 }
 
                 break;
+
+            case 'migrations':
+                $channels[] = 'console';
+                $projectId = 'console';
+                $roles = [Role::team($project->getAttribute('teamId'))->toString()];
+                break;
         }
 
         return [