fix: ws

dm3-org · Oct 24, 2023 · dd5d3c6 · dd5d3c6
1 parent 3603bde
commit dd5d3c6
Show file tree

Hide file tree

Showing 5 changed files with 22 additions and 13 deletions.
diff --git a/docker/nginx.conf b/docker/nginx.conf
@@ -59,7 +59,7 @@ http {
         }
 
         location /socket.io {
-            proxy_pass http://backend:8081/socket.io/;
+            proxy_pass http://backend:8081/socket.io;
             proxy_http_version 1.1;
             proxy_set_header Upgrade $http_upgrade;
             proxy_set_header Connection "Upgrade";
@@ -69,5 +69,7 @@ http {
             proxy_redirect off;
             proxy_set_header Host $host;
         }
+
+
     }
 }
diff --git a/packages/backend/src/messaging.ts b/packages/backend/src/messaging.ts
@@ -20,7 +20,7 @@ const pendingMessageSchema = {
 export function onConnection(app: express.Application & WithLocals) {
     return (socket: Socket) => {
         socket.on('disconnect', () => {
-            app.locals.logger.info({
+            global.logger.info({
                 method: 'WS DISCONNECT',
                 socketId: socket.id,
             });
@@ -36,7 +36,7 @@ export function onConnection(app: express.Application & WithLocals) {
                 callback,
             ) => {
                 try {
-                    app.locals.logger.info({
+                    global.logger.info({
                         method: 'WS INCOMING MESSAGE',
                     });
 
@@ -48,7 +48,7 @@ export function onConnection(app: express.Application & WithLocals) {
                     if (!isSchemaValid) {
                         const error = 'invalid schema';
 
-                        app.locals.logger.warn({
+                        global.logger.warn({
                             method: 'WS SUBMIT MESSAGE',
                             error,
                         });
@@ -75,7 +75,7 @@ export function onConnection(app: express.Application & WithLocals) {
                     ),
                         callback({ response: 'success' });
                 } catch (error: any) {
-                    app.locals.logger.warn({
+                    global.logger.warn({
                         method: 'WS SUBMIT MESSAGE',
                         error: (error as Error).toString(),
                     });
@@ -90,7 +90,7 @@ export function onConnection(app: express.Application & WithLocals) {
             if (!isSchemaValid) {
                 const error = 'invalid schema';
 
-                app.locals.logger.warn({
+                global.logger.warn({
                     method: 'WS PENDING MESSAGE',
                     error,
                 });
@@ -109,15 +109,15 @@ export function onConnection(app: express.Application & WithLocals) {
                     contactEnsName,
                 );
             } catch (error) {
-                app.locals.logger.warn({
+                global.logger.warn({
                     method: 'WS PENDING MESSAGE',
                     error,
                 });
 
                 return callback({ error });
             }
 
-            app.locals.logger.info({
+            global.logger.info({
                 method: 'WS PENDING MESSAGE',
                 ensName,
                 contactEnsName,
@@ -132,7 +132,7 @@ export function onConnection(app: express.Application & WithLocals) {
                     ))
                 ) {
                     const error = 'Token check failed';
-                    app.locals.logger.warn({
+                    global.logger.warn({
                         method: 'WS PENDING MESSAGE',
                         error,
                     });
@@ -143,7 +143,7 @@ export function onConnection(app: express.Application & WithLocals) {
 
                 callback({ response: 'success' });
             } catch (error) {
-                app.locals.logger.warn({
+                global.logger.warn({
                     method: 'WS PENDING MESSAGE',
                     error: (error as Error).toString(),
                 });

diff --git a/packages/backend/src/utils.ts b/packages/backend/src/utils.ts
@@ -47,7 +47,7 @@ export function socketAuth(app: Express & WithLocals) {
                 socket.handshake.auth.account.ensName,
             );
 
-            app.locals.logger.info({
+            global.logger.info({
                 method: 'WS CONNECT',
                 ensName,
                 socketId: socket.id,

diff --git a/packages/lib/delivery/src/Messages.ts b/packages/lib/delivery/src/Messages.ts
@@ -111,7 +111,12 @@ export async function incomingMessage(
     getIdEnsName: (name: string) => Promise<string>,
     getUsersNotificationChannels: GetNotificationChannels,
 ): Promise<void> {
-    logDebug({ text: 'incomingMessage', token });
+    logDebug({
+        text: 'incomingMessage',
+        token,
+        encryptionKeyPair,
+        envelop: JSON.stringify(envelop),
+    });
     //Checks the size of the incoming message
     if (messageIsToLarge(envelop, sizeLimit)) {
         throw Error('Message is too large');

diff --git a/packages/messenger-widget/src/components/DM3/DM3.tsx b/packages/messenger-widget/src/components/DM3/DM3.tsx
@@ -83,7 +83,9 @@ function DM3(props: Dm3Props) {
                 throw Error('Could not get account profile');
             }
 
-            const socket = socketIOClient(deliveryServiceUrl, {
+
+
+            const socket = socketIOClient(deliveryServiceUrl.replace('/api', ''), {
                 autoConnect: false,
                 transports: ['websocket'],
             });