fix: ws

dm3-org · Oct 25, 2023 · 6e07662 · 6e07662
1 parent 3603bde
commit 6e07662
Show file tree

Hide file tree

Showing 8 changed files with 35 additions and 14 deletions.
diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
@@ -24,7 +24,7 @@ services:
       SIGNING_PUBLIC_KEY: ${SIGNING_PUBLIC_KEY}
       SIGNING_PRIVATE_KEY: ${SIGNING_PRIVATE_KEY}
       ENCRYPTION_PUBLIC_KEY: ${ENCRYPTION_PUBLIC_KEY}
-      ENCRYPTION_PRIVATE_KEY: ${ENCRYPTION_PUBLIC_KEY}
+      ENCRYPTION_PRIVATE_KEY: ${ENCRYPTION_PRIVATE_KEY}
       RPC: ${RPC}
       PORT: 8081
       LOG_LEVEL: 'debug'

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/index.ts b/packages/backend/src/index.ts
@@ -59,6 +59,10 @@ global.logger = winston.createLogger({
     app.locals.io = io;
 
     app.locals.keys = readKeysFromEnv(process.env);
+    logInfo({
+        text: 'keys',
+        keys: app.locals.keys,
+    });
 
     app.locals.deliveryServiceProperties = getDeliveryServiceProperties();
 

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,13 +48,18 @@ 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,
                         });
                         return callback({ error });
                     }
 
+                    global.logger.info({
+                        method: 'WS INCOMING MESSAGE',
+                        keys: app.locals.keys.encryption,
+                    });
+
                     await incomingMessage(
                         data,
                         app.locals.keys.signing,
@@ -75,7 +80,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 +95,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 +114,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 +137,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 +148,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/adapters/messages.ts b/packages/messenger-widget/src/adapters/messages.ts
@@ -90,6 +90,9 @@ export async function submitMessage(
         sendDependencies,
     );
 
+    console.log('### send');
+    console.log(envelop, sendDependencies);
+
     const allOnSuccess = () => {
         if (onSuccess) {
             onSuccess(envelop);

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'],
             });