regen

Author: ChiragAgg5k

src/client.ts

@@ -300,7 +300,11 @@ class Client {
     /**
      * Holds configuration such as project.
      */
-    config = {
+    config: {
+        endpoint: string;
+        endpointRealtime: string;
+        [key: string]: string | undefined;
+    } = {
         endpoint: 'https://cloud.appwrite.io/v1',
         endpointRealtime: '',
         project: '',
@@ -473,7 +477,9 @@ class Client {
             }
 
             const channels = new URLSearchParams();
-            channels.set('project', this.config.project);
+            if (this.config.project) {
+                channels.set('project', this.config.project);
+            }
             this.realtime.channels.forEach(channel => {
                 channels.append('channels[]', channel);
             });

src/services/realtime.ts

@@ -21,6 +21,18 @@ export type RealtimeResponseEvent<T = any> = {
     payload: T;
 }
 
+export type RealtimeResponseConnected = {
+    channels: string[];
+    user?: object;
+}
+
+export type RealtimeRequest = {
+    type: 'authentication';
+    data: {
+        session: string;
+    };
+}
+
 export enum RealtimeCode {
     NORMAL_CLOSURE = 1000,
     POLICY_VIOLATION = 1008,
@@ -31,6 +43,7 @@ export class Realtime {
     private readonly TYPE_ERROR = 'error';
     private readonly TYPE_EVENT = 'event';
     private readonly TYPE_PONG = 'pong';
+    private readonly TYPE_CONNECTED = 'connected';
     private readonly DEBOUNCE_MS = 1;
     private readonly HEARTBEAT_INTERVAL = 20000; // 20 seconds in milliseconds
 
@@ -332,6 +345,9 @@ export class Realtime {
         }
 
         switch (message.type) {
+            case this.TYPE_CONNECTED:
+                this.handleResponseConnected(message);
+                break;
             case this.TYPE_ERROR:
                 this.handleResponseError(message);
                 break;
@@ -344,6 +360,33 @@ export class Realtime {
         }
     }
 
+    private handleResponseConnected(message: RealtimeResponse): void {
+        if (!message.data) {
+            return;
+        }
+
+        const messageData = message.data as RealtimeResponseConnected;
+
+        let session = this.client.config.session;
+        if (!session) {
+            try {
+                const cookie = JSON.parse(window.localStorage.getItem('cookieFallback') ?? '{}');
+                session = cookie?.[`a_session_${this.client.config.project}`];
+            } catch (error) {
+                console.error('Failed to parse cookie fallback:', error);
+            }
+        }
+
+        if (session && !messageData.user) {
+            this.socket?.send(JSON.stringify(<RealtimeRequest>{
+                type: 'authentication',
+                data: {
+                    session
+                }
+            }));
+        }
+    }
+
     private handleResponseError(message: RealtimeResponse): void {
         const error = new AppwriteException(
             message.data?.message || 'Unknown error'