aboutsummaryrefslogtreecommitdiff
path: root/vnext/server/middleware/event.js
diff options
context:
space:
mode:
authorGravatar Vitaly Takmazov2023-06-07 21:57:20 +0300
committerGravatar Vitaly Takmazov2023-06-07 21:57:20 +0300
commit2bc4c4580552ad084c5dd06f22ee1ea333905a14 (patch)
tree0e4f625921249f6e140fad5df44e2581f1c9a07f /vnext/server/middleware/event.js
parent7bbbcf0df392be397ce70e78d218e0d2fcd0815a (diff)
vnext: cleanup lint warnings
Diffstat (limited to 'vnext/server/middleware/event.js')
-rw-r--r--vnext/server/middleware/event.js14
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)
}