1 files changed, 14 insertions, 0 deletions
diff --git a/src/database/sessions.rs b/src/database/sessions.rs
index 8d4ca73..9adccd4 100644
--- a/src/database/sessions.rs
+++ b/src/database/sessions.rs
@@ -33,6 +33,20 @@ pub fn get_session(token: &str) -> Result<Option<Session>, rusqlite::Error> {
 }
 
 #[instrument()]
+pub fn get_all_sessions() -> Result<Vec<Session>, rusqlite::Error> {
+    tracing::trace!("Retrieving session");
+    let conn = database::connect()?;
+    let mut stmt = conn.prepare("SELECT * FROM sessions")?;
+    let row = stmt.query_map([], |row| {
+        Ok(Session {
+            user_id: row.get(0)?,
+            token: row.get(1)?,
+        })
+    })?;
+    Ok(row.into_iter().flatten().collect())
+}
+
+#[instrument()]
 pub fn set_session(user_id: u64, token: &str) -> Result<(), Box<dyn std::error::Error>> {
     tracing::trace!("Setting new session");
     let conn = database::connect()?;