fix: dingens lol haher

mobile-app/api/realtime/index.ts

@@ -1,6 +1,6 @@
 import { TextEncoder } from 'text-encoding';
 
 import { Logger, ScopedLogger } from '@/utils/logging';
 
 /**
  * stompjs is an abstraction layer on top of websocket that uses the global TextEncoder class.
@@ -72,21 +72,6 @@
         });
 
         this.ws.addEventListener('message', (e) => this.onMessage(e));
-
-        this.ws.addEventListener('open', () => {
-            this.logger.info('connection opened');
-            this._subscribeToGroups();
-        });
-
-        this.ws.addEventListener('close', () => {
-            this.logger.info('connection closed');
-        });
-
-        this.ws.addEventListener('error', (e) => {
-            this.logger.error('error:', e);
-        });
-
-        this.ws.addEventListener('message', (e) => this.onMessage(e));
     }
 
     /**

mobile-app/api/realtime/useRealtimeConnection.ts

@@ -5,7 +5,12 @@
 import { useLogging } from '@/utils/useLogging';
 import { useGroupStore } from '@/zustand/group/stateGroupStore';
 
-import { RealtimeClient } from '.';
+import {
+    RealtimeAffectedEntity,
+    RealtimeClient,
+    RealtimeEvent,
+    RealtimeEventHandler,
+} from '.';
 import { env } from '../env';
 import { ignoreSeason, QK } from '../utils/reactQuery';
 
@@ -22,27 +27,7 @@
         writeLog(...data);
     }
 
-    useEffect(() => {
-        if (client.current) {
-            client.current.logger.addEventListener('*', writeLogs);
-
-            return () =>
-                client.current.logger.removeEventListener('*', writeLogs);
-        }
-    }, [client.current]);
-
-    useEffect(() => {
-        client.current.subscribeToGroups(groupIds);
-    }, [groupIds]);
-
-    function refetchGroup(groupId: string) {
-        qc.invalidateQueries({
-            queryKey: [QK.group, groupId],
-            exact: true,
-        });
-    }
-
-    client.current.on.event((e) => {
+    const hoher: RealtimeEventHandler = (e) => {
         switch (e.eventType) {
             case 'GROUPS':
                 client.current.logger.info('refetching groups');
@@ -125,7 +110,29 @@
                 });
                 break;
         }
-    });
+    };
+
+    useEffect(() => {
+        if (client.current) {
+            client.current.logger.addEventListener('*', writeLogs);
+
+            client.current.on.event(hoher);
+
+            return () =>
+                client.current.logger.removeEventListener('*', writeLogs);
+        }
+    }, [client.current]);
+
+    useEffect(() => {
+        client.current.subscribeToGroups(groupIds);
+    }, [groupIds]);
+
+    function refetchGroup(groupId: string) {
+        qc.invalidateQueries({
+            queryKey: [QK.group, groupId],
+            exact: true,
+        });
+    }
 
     return client.current;
 }