You've already forked AstralRinth
forked from didirus/AstralRinth
cf190d86d5
* Update Rust version * Update async-compression 0.4.25 -> 0.4.27 * Update async-tungstenite 0.29.1 -> 0.30.0 * Update bytemuck 1.23.0 -> 1.23.1 * Update clap 4.5.40 -> 4.5.43 * Update deadpool-redis 0.21.1 -> 0.22.0 and redis 0.31.0 -> 0.32.4 * Update enumset 1.1.6 -> 1.1.7 * Update hyper-util 0.1.14 -> 0.1.16 * Update indexmap 2.9.0 -> 2.10.0 * Update indicatif 0.17.11 -> 0.18.0 * Update jemalloc_pprof 0.7.0 -> 0.8.1 * Update lettre 0.11.17 -> 0.11.18 * Update meilisearch-sdk 0.28.0 -> 0.29.1 * Update notify 8.0.0 -> 8.2.0 and notify-debouncer-mini 0.6.0 -> 0.7.0 * Update quick-xml 0.37.5 -> 0.38.1 * Fix theseus lint * Update reqwest 0.12.20 -> 0.12.22 * Cargo fmt in theseus * Update rgb 0.8.50 -> 0.8.52 * Update sentry 0.41.0 -> 0.42.0 and sentry-actix 0.41.0 -> 0.42.0 * Update serde_json 1.0.140 -> 1.0.142 * Update serde_with 3.13.0 -> 3.14.0 * Update spdx 0.10.8 -> 0.10.9 * Update sysinfo 0.35.2 -> 0.36.1 * Update tauri suite * Fix build by updating mappings * Update tokio 1.45.1 -> 1.47.1 and tokio-util 0.7.15 -> 0.7.16 * Update tracing-actix-web 0.7.18 -> 0.7.19 * Update zip 4.2.0 -> 4.3.0 * Misc Cargo.lock updates * Update Dockerfiles
75 lines
2.0 KiB
Rust
75 lines
2.0 KiB
Rust
//! Authentication flow interface
|
|
|
|
use crate::State;
|
|
use crate::state::{Credentials, MinecraftLoginFlow};
|
|
|
|
#[tracing::instrument]
|
|
pub async fn begin_login() -> crate::Result<MinecraftLoginFlow> {
|
|
let state = State::get().await?;
|
|
|
|
crate::state::login_begin(&state.pool).await
|
|
}
|
|
|
|
#[tracing::instrument]
|
|
pub async fn finish_login(
|
|
code: &str,
|
|
flow: MinecraftLoginFlow,
|
|
) -> crate::Result<Credentials> {
|
|
let state = State::get().await?;
|
|
|
|
crate::state::login_finish(code, flow, &state.pool).await
|
|
}
|
|
|
|
#[tracing::instrument]
|
|
pub async fn get_default_user() -> crate::Result<Option<uuid::Uuid>> {
|
|
let state = State::get().await?;
|
|
let user = Credentials::get_active(&state.pool).await?;
|
|
Ok(user.map(|user| user.offline_profile.id))
|
|
}
|
|
|
|
#[tracing::instrument]
|
|
pub async fn set_default_user(user: uuid::Uuid) -> crate::Result<()> {
|
|
let state = State::get().await?;
|
|
let users = Credentials::get_all(&state.pool).await?;
|
|
let (_, mut user) = users.remove(&user).ok_or_else(|| {
|
|
crate::ErrorKind::OtherError(format!(
|
|
"Tried to get nonexistent user with ID {user}"
|
|
))
|
|
.as_error()
|
|
})?;
|
|
|
|
user.active = true;
|
|
user.upsert(&state.pool).await?;
|
|
|
|
Ok(())
|
|
}
|
|
|
|
/// Remove a user account from the database
|
|
#[tracing::instrument]
|
|
pub async fn remove_user(uuid: uuid::Uuid) -> crate::Result<()> {
|
|
let state = State::get().await?;
|
|
|
|
let users = Credentials::get_all(&state.pool).await?;
|
|
|
|
if let Some((uuid, user)) = users.remove(&uuid) {
|
|
Credentials::remove(uuid, &state.pool).await?;
|
|
|
|
if user.active
|
|
&& let Some((_, mut user)) = users.into_iter().next()
|
|
{
|
|
user.active = true;
|
|
user.upsert(&state.pool).await?;
|
|
}
|
|
}
|
|
|
|
Ok(())
|
|
}
|
|
|
|
/// Get a copy of the list of all user credentials
|
|
#[tracing::instrument]
|
|
pub async fn users() -> crate::Result<Vec<Credentials>> {
|
|
let state = State::get().await?;
|
|
let users = Credentials::get_all(&state.pool).await?;
|
|
Ok(users.into_iter().map(|x| x.1).collect())
|
|
}
|