MirrorSave
/
budibase
mirror of https://github.com/Budibase/budibase.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

catch block in invalidate sessions

This commit is contained in:
Martin McKeaveney 2022-05-24 22:57:32 +01:00
parent bf0ca9784b
commit 50c6ad9630
1 changed files with 24 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
packages/backend-core/src/security/sessions.js
View File

@ -15,29 +15,33 @@ function makeSessionID(userId, sessionId) {
} }
async function invalidateSessions(userId, sessionIds = null) { async function invalidateSessions(userId, sessionIds = null) {
let sessions = [] try {
let sessions = []
// If no sessionIds, get all the sessions for the user // If no sessionIds, get all the sessions for the user
if (!sessionIds) { if (!sessionIds) {
sessions = await getSessionsForUser(userId) sessions = await getSessionsForUser(userId)
sessions.forEach( sessions.forEach(
session => session =>
(session.key = makeSessionID(session.userId, session.sessionId)) (session.key = makeSessionID(session.userId, session.sessionId))
) )
} else { } else {
// use the passed array of sessionIds // use the passed array of sessionIds
sessions = Array.isArray(sessionIds) ? sessionIds : [sessionIds] sessions = Array.isArray(sessionIds) ? sessionIds : [sessionIds]
sessions = sessions.map(sessionId => ({ sessions = sessions.map(sessionId => ({
key: makeSessionID(userId, sessionId), key: makeSessionID(userId, sessionId),
})) }))
} }
const client = await redis.getSessionClient() const client = await redis.getSessionClient()
const promises = [] const promises = []
for (let session of sessions) { for (let session of sessions) {
promises.push(client.delete(session.key)) promises.push(client.delete(session.key))
}
await Promise.all(promises)
} catch (err) {
console.error(`Error invalidating sessions: ${err}`)
} }
await Promise.all(promises)
} }
exports.createASession = async (userId, session) => { exports.createASession = async (userId, session) => {