Bug fix: Deleting a session with messages (#411)

antoinejaussoin · Jul 9, 2022 · b2e4788 · b2e4788
1 parent 6c1165a
commit b2e4788
Showing 1 changed file with 29 additions and 17 deletions.
diff --git a/backend/src/db/actions/sessions.ts b/backend/src/db/actions/sessions.ts
@@ -226,23 +226,35 @@ export async function deleteSessions(
       );
       return false;
     }
-    await sessionRepository.query(
-      `delete from visitors where sessions_id = $1;`,
-      [sessionId]
-    );
-    await sessionRepository.query(`delete from posts where session_id = $1;`, [
-      sessionId,
-    ]);
-    await sessionRepository.query(
-      `delete from columns where session_id = $1;`,
-      [sessionId]
-    );
-    await sessionRepository.query(`delete from groups where session_id = $1;`, [
-      sessionId,
-    ]);
-    await sessionRepository.query(`delete from sessions where id = $1;`, [
-      sessionId,
-    ]);
+
+    try {
+      await sessionRepository.query(
+        `delete from messages where session_id = $1;`,
+        [sessionId]
+      );
+      await sessionRepository.query(
+        `delete from visitors where sessions_id = $1;`,
+        [sessionId]
+      );
+      await sessionRepository.query(
+        `delete from posts where session_id = $1;`,
+        [sessionId]
+      );
+      await sessionRepository.query(
+        `delete from columns where session_id = $1;`,
+        [sessionId]
+      );
+      await sessionRepository.query(
+        `delete from groups where session_id = $1;`,
+        [sessionId]
+      );
+      await sessionRepository.query(`delete from sessions where id = $1;`, [
+        sessionId,
+      ]);
+    } catch (err) {
+      console.error('Could not delete session', sessionId, err);
+      return false;
+    }
 
     return true;
   });