diff options
author | Vitaly Takmazov | 2023-06-07 21:57:20 +0300 |
---|---|---|
committer | Vitaly Takmazov | 2023-06-07 21:57:20 +0300 |
commit | 2bc4c4580552ad084c5dd06f22ee1ea333905a14 (patch) | |
tree | 0e4f625921249f6e140fad5df44e2581f1c9a07f /vnext/server/middleware/event.js | |
parent | 7bbbcf0df392be397ce70e78d218e0d2fcd0815a (diff) |
vnext: cleanup lint warnings
Diffstat (limited to 'vnext/server/middleware/event.js')
-rw-r--r-- | vnext/server/middleware/event.js | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/vnext/server/middleware/event.js b/vnext/server/middleware/event.js index 59f36950..8280f32b 100644 --- a/vnext/server/middleware/event.js +++ b/vnext/server/middleware/event.js @@ -24,12 +24,12 @@ function processMessageEvent(msg) { params.mid = msg.mid } subscribers(new URLSearchParams(JSON.parse(JSON.stringify(params)))).then(users => { - users.forEach(user => { + return users.map(user => { 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) => { + .reduce((result, element) => { allSandboxIds.includes(user.uid) ? result[0].push(element) : result[1].push(element) @@ -44,10 +44,14 @@ function processMessageEvent(msg) { .filter(t => t.type === 'hcm') .map(t => t.token) log(`${user.uname}: ${hmsIds}`) - send(msg, hmsIds).then(() => { - // TODO: handle results - }).catch(log) + return hmsIds }) + }).then(userHmsIds => { + userHmsIds.forEach(hmsIds => { + send(msg, hmsIds) + }) + }).then(() => { + // TODO: handle results }).catch(log) } |