Merge pull request #2196 from appwrite/fix-SER-91-fix-cross-region-realtime

Author: ItzNotABug

src/routes/(console)/project-[region]-[project]/sites/create-site/deploying/+page.svelte

@@ -18,23 +18,25 @@
     let deployment = $state(data.deployment);
 
     onMount(() => {
-        return sdk.forConsole.client.subscribe(
-            'console',
-            async (response: RealtimeResponseEvent<Models.Deployment>) => {
-                if (
-                    response.events.includes(
-                        `sites.${data.site.$id}.deployments.${data.deployment.$id}.update`
-                    )
-                ) {
-                    deployment = response.payload;
-                    if (response.payload.status === 'ready') {
-                        goto(
-                            `${base}/project-${page.params.region}-${page.params.project}/sites/create-site/finish?site=${data.site.$id}`
-                        );
+        return sdk
+            .forConsoleIn(page.params.region)
+            .client.subscribe(
+                'console',
+                async (response: RealtimeResponseEvent<Models.Deployment>) => {
+                    if (
+                        response.events.includes(
+                            `sites.${data.site.$id}.deployments.${data.deployment.$id}.update`
+                        )
+                    ) {
+                        deployment = response.payload;
+                        if (response.payload.status === 'ready') {
+                            goto(
+                                `${base}/project-${page.params.region}-${page.params.project}/sites/create-site/finish?site=${data.site.$id}`
+                            );
+                        }
                     }
                 }
-            }
-        );
+            );
     });
 </script>
 

src/routes/(console)/project-[region]-[project]/sites/site-[site]/deployments/deployment-[deployment]/+page.svelte

@@ -30,18 +30,20 @@
     let showCancel = $state(false);
 
     onMount(() => {
-        return sdk.forConsole.client.subscribe(
-            'console',
-            async (response: RealtimeResponseEvent<Models.Deployment>) => {
-                if (
-                    response.events.includes(
-                        `sites.${page.params.site}.deployments.${page.params.deployment}.update`
-                    )
-                ) {
-                    await invalidate(Dependencies.DEPLOYMENT);
+        return sdk
+            .forConsoleIn(page.params.region)
+            .client.subscribe(
+                'console',
+                async (response: RealtimeResponseEvent<Models.Deployment>) => {
+                    if (
+                        response.events.includes(
+                            `sites.${page.params.site}.deployments.${page.params.deployment}.update`
+                        )
+                    ) {
+                        await invalidate(Dependencies.DEPLOYMENT);
+                    }
                 }
-            }
-        );
+            );
     });
 </script>