OxideTalis/oxidetalis
OxideTalis/oxidetalis
1
Fork 0
Code Issues 10 Pull requests Projects 1 Releases Activity Actions

feat: Add last_logout column to users table #31

Manually merged
awiteb merged 2 commits from awiteb/user-last-login into master 2024-07-24 10:50:24 +02:00 AGit
Conversation 0 Commits 2 Files changed 4 +15 -2
1 changed files with 15 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit c9480d60ea - Show all commits

17
crates/oxidetalis/src/websocket/mod.rs
View file

@ -177,7 +177,7 @@ async fn handle_socket(
} }
}; };
} }
user_disconnected(&conn_id, &user_public_key).await; user_disconnected(&db_conn, &conn_id, &user_public_key, user).await;
}; };
tokio_spawn(fut); tokio_spawn(fut);
} }
@ -225,8 +225,21 @@ async fn handle_events(
} }
/// Handle user disconnected /// Handle user disconnected
async fn user_disconnected(conn_id: &Uuid, public_key: &PublicKey) { async fn user_disconnected(
db_conn: &DatabaseConnection,
conn_id: &Uuid,
public_key: &PublicKey,
user: Option<UserModel>,
) {
ONLINE_USERS.remove_user(conn_id).await; ONLINE_USERS.remove_user(conn_id).await;
if ONLINE_USERS.is_online(public_key).await.is_none() {
if let Some(mut user) = user.map(IntoActiveModel::into_active_model) {
user.last_logout = Set(Utc::now());
if let Err(err) = user.update(db_conn).await {
log::error!("{err}");
}
}
}
log::debug!("User disconnect: ConnId(={conn_id}) PublicKey(={public_key})"); log::debug!("User disconnect: ConnId(={conn_id}) PublicKey(={public_key})");
} }