incognitolm commited on
Commit
4c36487
·
verified ·
1 Parent(s): 8d792e8

Update server/sessionStore.js

Browse files
Files changed (1) hide show
  1. server/sessionStore.js +7 -3
server/sessionStore.js CHANGED
@@ -86,19 +86,23 @@ export const sessionStore = {
86
  return s;
87
  },
88
  async updateUserSession(userId, accessToken, sessionId, patch) {
89
- const user = userCache.get(userId); if (!user) return null;
90
- const s = user.sessions.get(sessionId); if (!s) return null;
91
  Object.assign(s, patch);
92
  await this._persist(userClient(accessToken), userId, s).catch(() => {});
93
  return s;
94
  },
95
  async deleteUserSession(userId, accessToken, id) {
 
96
  userCache.get(userId)?.sessions.delete(id);
 
 
 
97
  await userClient(accessToken).from('web_sessions').delete()
98
  .eq('id', id).eq('user_id', userId).catch(() => {});
99
  },
100
  async deleteAllUserSessions(userId, accessToken) {
101
- const u = userCache.get(userId); if (u) u.sessions.clear();
102
  await userClient(accessToken).from('web_sessions').delete()
103
  .eq('user_id', userId).catch(() => {});
104
  },
 
86
  return s;
87
  },
88
  async updateUserSession(userId, accessToken, sessionId, patch) {
89
+ const user = userCache.get(userId); if (!user) { console.log ("No user for " + userId); return null; }
90
+ const s = user.sessions.get(sessionId); if (!s) { console.log ("No session found for " + sessionId); return null; }
91
  Object.assign(s, patch);
92
  await this._persist(userClient(accessToken), userId, s).catch(() => {});
93
  return s;
94
  },
95
  async deleteUserSession(userId, accessToken, id) {
96
+ try {
97
  userCache.get(userId)?.sessions.delete(id);
98
+ } catch (ex) {
99
+ console.log("Error deleting user session by ID: " + ex);
100
+ }
101
  await userClient(accessToken).from('web_sessions').delete()
102
  .eq('id', id).eq('user_id', userId).catch(() => {});
103
  },
104
  async deleteAllUserSessions(userId, accessToken) {
105
+ const u = userCache.get(userId); if (u) {u.sessions.clear(); } else { console.log ("No user for " + userId); return null; };
106
  await userClient(accessToken).from('web_sessions').delete()
107
  .eq('user_id', userId).catch(() => {});
108
  },