@alipay/faas-biz-server-sdk
Advanced tools
Comparing version 1.1.3-alpha.0 to 1.1.3-alpha.1
@@ -357,18 +357,30 @@ "use strict"; | ||
const res = []; | ||
if (!sockets || !sockets.size) { | ||
return res; | ||
} | ||
if (sockets.size === 1) { | ||
const iterator = sockets.values(); | ||
const socket = iterator.next().value; | ||
res.push({ | ||
connectionId: socket.id, | ||
alive: await socket.isAlive, | ||
}); | ||
return res; | ||
} | ||
const socketsAliveRes = await this.ws.isAlive(sockets.map(socket => socket.id)); | ||
if (socketsAliveRes) { | ||
const { aliveConnIds, deadConnIds } = socketsAliveRes; | ||
aliveConnIds?.forEach(id => { | ||
res.push({ | ||
connectionId: id, | ||
alive: true, | ||
}); | ||
if (!socketsAliveRes) | ||
return res; | ||
const { aliveConnIds, deadConnIds } = socketsAliveRes; | ||
aliveConnIds?.forEach(id => { | ||
res.push({ | ||
connectionId: id, | ||
alive: true, | ||
}); | ||
deadConnIds?.forEach(id => { | ||
res.push({ | ||
connectionId: id, | ||
alive: false, | ||
}); | ||
}); | ||
deadConnIds?.forEach(id => { | ||
res.push({ | ||
connectionId: id, | ||
alive: false, | ||
}); | ||
} | ||
}); | ||
return res; | ||
@@ -375,0 +387,0 @@ }); |
@@ -165,18 +165,30 @@ "use strict"; | ||
const res = []; | ||
if (!sockets || !sockets.size) { | ||
return res; | ||
} | ||
if (sockets.size === 1) { | ||
const iterator = sockets.values(); | ||
const socket = iterator.next().value; | ||
res.push({ | ||
connectionId: socket.id, | ||
alive: await socket.isAlive, | ||
}); | ||
return res; | ||
} | ||
const socketsAliveRes = await this.ws.isAlive(sockets.map(socket => socket.id)); | ||
if (socketsAliveRes) { | ||
const { aliveConnIds, deadConnIds } = socketsAliveRes; | ||
aliveConnIds?.forEach(id => { | ||
res.push({ | ||
connectionId: id, | ||
alive: true, | ||
}); | ||
if (!socketsAliveRes) | ||
return res; | ||
const { aliveConnIds, deadConnIds } = socketsAliveRes; | ||
aliveConnIds?.forEach(id => { | ||
res.push({ | ||
connectionId: id, | ||
alive: true, | ||
}); | ||
deadConnIds?.forEach(id => { | ||
res.push({ | ||
connectionId: id, | ||
alive: false, | ||
}); | ||
}); | ||
deadConnIds?.forEach(id => { | ||
res.push({ | ||
connectionId: id, | ||
alive: false, | ||
}); | ||
} | ||
}); | ||
return res; | ||
@@ -183,0 +195,0 @@ }); |
{ | ||
"name": "@alipay/faas-biz-server-sdk", | ||
"version": "1.1.3-alpha.0", | ||
"version": "1.1.3-alpha.1", | ||
"description": "支付宝云开发业务 SDK(函数端)", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
315057
9647