1 files changed, 37 insertions, 37 deletions

diff --git a/vnext/server/middleware/event.js b/vnext/server/middleware/event.js
index 5681eb59..59f36950 100644
--- a/vnext/server/middleware/event.js
+++ b/vnext/server/middleware/event.js
@@ -1,54 +1,54 @@
-import { simpleParser } from 'mailparser';
-import { isPM, isReply, isService } from '../common/MessageUtils';
-import { sendTelegramNotification } from '../durov';
-import { subscribers } from '../http';
-import { sendNotification, buildNotification } from '../sender';
-import debug from 'debug';
-import { send } from '../hms';
-var log = debug('event');
+import { simpleParser } from 'mailparser'
+import { isPM, isReply, isService } from '../common/MessageUtils'
+import { sendTelegramNotification } from '../durov'
+import { subscribers } from '../http'
+import { sendNotification, buildNotification } from '../sender'
+import debug from 'debug'
+import { send } from '../hms'
+var log = debug('event')
 
 /** @type {number[]} */
-const allSandboxIds = [];
+const allSandboxIds = []
 
 /**
  * handle message event
  * @param {import('../../client').Message} msg message
  */
 function processMessageEvent(msg) {
-    let params = {};
-    params.uid = isPM(msg) ? msg.to.uid : msg.user.uid;
+    let params = {}
+    params.uid = isPM(msg) ? msg.to.uid : msg.user.uid
     if (isReply(msg)) {
-        params.mid = msg.mid;
-        params.rid = msg.rid;
+        params.mid = msg.mid
+        params.rid = msg.rid
     } else if (!isPM(msg) && !isService(msg)) {
-        params.mid = msg.mid;
+        params.mid = msg.mid
     }
     subscribers(new URLSearchParams(JSON.parse(JSON.stringify(params)))).then(users => {
         users.forEach(user => {
-            log(`${user.uname}: ${user.unreadCount}`);
+            log(`${user.uname}: ${user.unreadCount}`)
             let [sandboxTokens, productionTokens] = (user.tokens || [])
                 .filter(t => ['mpns', 'apns', 'fcm', 'web'].includes(t.type))
                 .map(t => t.type === 'web' ? JSON.parse(t.token) : t.token)
                 .reduce((result, element, i) => {
                     allSandboxIds.includes(user.uid)
                         ? result[0].push(element)
-                        : result[1].push(element);
-                    return result;
-                }, [[], []]);
-            sendNotification(productionTokens, sandboxTokens, buildNotification(user, msg));
+                        : result[1].push(element)
+                    return result
+                }, [[], []])
+            sendNotification(productionTokens, sandboxTokens, buildNotification(user, msg))
             let durovIds = (user.tokens || [])
                 .filter(t => ['durov'].includes(t.type))
-                .map(t => t.token);
-            sendTelegramNotification(msg, durovIds);
+                .map(t => t.token)
+            sendTelegramNotification(msg, durovIds)
             let hmsIds = (user.tokens || [])
                 .filter(t => t.type === 'hcm')
-                .map(t => t.token);
-            log(`${user.uname}: ${hmsIds}`);
+                .map(t => t.token)
+            log(`${user.uname}: ${hmsIds}`)
             send(msg, hmsIds).then(() => {
                 // TODO: handle results
-            }).catch(log);
-        });
-    }).catch(log);
+            }).catch(log)
+        })
+    }).catch(log)
 }
 
 /**
@@ -58,30 +58,30 @@ function processMessageEvent(msg) {
 export default function handleMessage(req, res) {
     return simpleParser(req.body, {})
         .then(parsed => {
-            const new_version = parsed.headers.get('x-event-version') == '1.0';
-            log(`New event: ${parsed.text}, new version: ${new_version}`);
+            const new_version = parsed.headers.get('x-event-version') == '1.0'
+            log(`New event: ${parsed.text}, new version: ${new_version}`)
             if (new_version) {
                 /** @type {import('../../client').SystemEvent} */
-                const event = JSON.parse(parsed.text || '');
+                const event = JSON.parse(parsed.text || '')
                 if (event.type === 'message' && event.message) {
                     if (event.message.service) {
                         // TODO: remove
-                        let msg = { ...event.message };
+                        let msg = { ...event.message }
                         if (event.from) {
-                            msg.user = event.from;
+                            msg.user = event.from
                         }
-                        processMessageEvent(msg);
+                        processMessageEvent(msg)
                     } else {
-                        processMessageEvent(event.message);
+                        processMessageEvent(event.message)
                     }
 
                 }
             } else {
                 /** @type {import('../../client').Message} */
-                const msg = JSON.parse(parsed.text || '');
-                processMessageEvent(msg);
+                const msg = JSON.parse(parsed.text || '')
+                processMessageEvent(msg)
             }
-            res.end();
+            res.end()
         })
-        .catch(err => { log(err); res.status(400).send('Invalid request'); });
+        .catch(err => { log(err); res.status(400).send('Invalid request') })
 }