1 Commits

Author SHA1 Message Date
142efc8e20 Update Rust crate uuid to 1.19.0
All checks were successful
continuous-integration/drone/push Build is passing
2025-12-04 00:12:51 +00:00
25 changed files with 563 additions and 925 deletions

1230
Cargo.lock generated

File diff suppressed because it is too large Load Diff

View File

@@ -9,7 +9,7 @@ edition = "2024"
actix = "0.13.5" actix = "0.13.5"
actix-identity = "0.9.0" actix-identity = "0.9.0"
actix-web = "4.12.1" actix-web = "4.12.1"
actix-session = { version = "0.11.0", features = ["cookie-session", "redis-session"] } actix-session = { version = "0.11.0", features = ["cookie-session"] }
actix-remote-ip = "0.1.0" actix-remote-ip = "0.1.0"
clap = { version = "4.5.53", features = ["derive", "env"] } clap = { version = "4.5.53", features = ["derive", "env"] }
include_dir = "0.7.4" include_dir = "0.7.4"
@@ -23,11 +23,11 @@ uuid = { version = "1.19.0", features = ["v4"] }
mime_guess = "2.0.5" mime_guess = "2.0.5"
askama = "0.14.0" askama = "0.14.0"
urlencoding = "2.1.3" urlencoding = "2.1.3"
rand = "0.10.0-rc.5" rand = "0.9.2"
base64 = "0.22.1" base64 = "0.22.1"
jwt-simple = { version = "0.12.13", default-features = false, features = ["pure-rust"] } jwt-simple = { version = "0.12.13", default-features = false, features = ["pure-rust"] }
digest = "0.11.0-rc.4" digest = "0.10.7"
sha2 = "0.11.0-rc.3" sha2 = "0.10.9"
lazy-regex = "3.4.2" lazy-regex = "3.4.2"
totp_rfc6238 = "0.6.1" totp_rfc6238 = "0.6.1"
base32 = "0.5.1" base32 = "0.5.1"
@@ -39,5 +39,3 @@ bincode = "2.0.1"
chrono = "0.4.42" chrono = "0.4.42"
lazy_static = "1.5.0" lazy_static = "1.5.0"
mailchecker = "6.0.19" mailchecker = "6.0.19"
httpdate = "1.0.3"
build-time = "0.1.3"

View File

@@ -11,7 +11,7 @@
* Copyright 2011-2024 The Bootstrap Authors * Copyright 2011-2024 The Bootstrap Authors
* Licensed under MIT (https://github.com/twbs/bootstrap/blob/main/LICENSE) * Licensed under MIT (https://github.com/twbs/bootstrap/blob/main/LICENSE)
*/ */
@import url("/assets/robotfont/font.css"); @import url("https://fonts.googleapis.com/css2?family=Roboto:wght@400;700&display=swap");
:root, :root,
[data-bs-theme=light] { [data-bs-theme=light] {
--bs-blue: #2a9fd6; --bs-blue: #2a9fd6;

View File

@@ -1,15 +1,4 @@
services: services:
redis:
image: redis
network_mode: host
volumes:
- ./redis/redis.conf:/redis.conf:ro
command: [ "redis-server", "/redis.conf" ]
healthcheck:
test: [ "CMD", "redis-cli", "ping" ]
interval: 10s
timeout: 30s
retries: 3
upstream: upstream:
image: dexidp/dex image: dexidp/dex
user: "1000" user: "1000"
@@ -44,14 +33,9 @@ services:
image: rust image: rust
user: "1000" user: "1000"
network_mode: host network_mode: host
depends_on:
redis:
condition: service_healthy
environment: environment:
- STORAGE_PATH=/storage - STORAGE_PATH=/storage
- DISABLE_LOCAL_LOGIN=true - DISABLE_LOCAL_LOGIN=true
- USE_REDIS=true
- REDIS_PASSWORD=secretsecret
#- RUST_LOG=debug #- RUST_LOG=debug
volumes: volumes:
- ../:/app - ../:/app

View File

@@ -1,3 +0,0 @@
maxmemory 256mb
maxmemory-policy allkeys-lru
requirepass secretsecret

View File

@@ -5,7 +5,7 @@ use std::net::IpAddr;
use actix::{Actor, AsyncContext, Context, Handler, Message}; use actix::{Actor, AsyncContext, Context, Handler, Message};
use crate::constants::{FAIL_LOGIN_ATTEMPT_CLEANUP_INTERVAL, KEEP_FAILED_LOGIN_ATTEMPTS_FOR}; use crate::constants::{FAIL_LOGIN_ATTEMPT_CLEANUP_INTERVAL, KEEP_FAILED_LOGIN_ATTEMPTS_FOR};
use crate::utils::time_utils::time; use crate::utils::time::time;
#[derive(Message)] #[derive(Message)]
#[rtype(result = "()")] #[rtype(result = "()")]
@@ -87,7 +87,7 @@ mod test {
use std::net::{IpAddr, Ipv4Addr}; use std::net::{IpAddr, Ipv4Addr};
use crate::actors::bruteforce_actor::BruteForceActor; use crate::actors::bruteforce_actor::BruteForceActor;
use crate::utils::time_utils::time; use crate::utils::time::time;
const IP_1: IpAddr = IpAddr::V4(Ipv4Addr::new(192, 168, 1, 1)); const IP_1: IpAddr = IpAddr::V4(Ipv4Addr::new(192, 168, 1, 1));
const IP_2: IpAddr = IpAddr::V4(Ipv4Addr::new(192, 168, 1, 2)); const IP_2: IpAddr = IpAddr::V4(Ipv4Addr::new(192, 168, 1, 2));

View File

@@ -10,7 +10,7 @@ use crate::data::jwt_signer::JWTSigner;
use crate::data::user::UserID; use crate::data::user::UserID;
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::string_utils::rand_str; use crate::utils::string_utils::rand_str;
use crate::utils::time_utils::time; use crate::utils::time::time;
#[derive(Clone, Debug, serde::Serialize, serde::Deserialize, Eq, PartialEq)] #[derive(Clone, Debug, serde::Serialize, serde::Deserialize, Eq, PartialEq)]
pub struct SessionID(pub String); pub struct SessionID(pub String);

View File

@@ -15,7 +15,7 @@ use std::net::IpAddr;
use crate::data::login_redirect::LoginRedirect; use crate::data::login_redirect::LoginRedirect;
use crate::data::provider::ProviderID; use crate::data::provider::ProviderID;
use crate::utils::string_utils::rand_str; use crate::utils::string_utils::rand_str;
use crate::utils::time_utils::time; use crate::utils::time::time;
#[derive(Debug, Clone, serde::Serialize)] #[derive(Debug, Clone, serde::Serialize)]
pub struct ProviderLoginState { pub struct ProviderLoginState {

View File

@@ -1,11 +1,7 @@
use crate::utils::crypt_utils::sha256;
use crate::utils::time_utils;
use actix_web::http::header;
use actix_web::{HttpRequest, HttpResponse, web};
use include_dir::{Dir, include_dir};
use std::ops::Add;
use std::path::Path; use std::path::Path;
use std::time::Duration;
use actix_web::{HttpResponse, web};
use include_dir::{Dir, include_dir};
/// Assets directory /// Assets directory
static ASSETS_DIR: Dir = include_dir!("$CARGO_MANIFEST_DIR/assets"); static ASSETS_DIR: Dir = include_dir!("$CARGO_MANIFEST_DIR/assets");
@@ -16,39 +12,14 @@ pub async fn robots_txt() -> HttpResponse {
.body(include_str!("../../assets/robots.txt")) .body(include_str!("../../assets/robots.txt"))
} }
pub async fn assets_route(req: HttpRequest, path: web::Path<String>) -> HttpResponse { pub async fn assets_route(path: web::Path<String>) -> HttpResponse {
let path: &Path = path.as_ref().as_ref(); let path: &Path = path.as_ref().as_ref();
match ASSETS_DIR.get_file(path) { match ASSETS_DIR.get_file(path) {
None => HttpResponse::NotFound().body("404 Not found"), None => HttpResponse::NotFound().body("404 Not found"),
Some(file) => { Some(file) => {
let res = mime_guess::from_path(path).first_or_octet_stream(); let res = mime_guess::from_path(path).first_or_octet_stream();
let digest = format!("{:x?}", sha256(file.contents()));
// Check if the browser already knows the file by date
if let Some(c) = req.headers().get(header::IF_MODIFIED_SINCE) {
let date_str = c.to_str().unwrap_or("");
if let Ok(date) = httpdate::parse_http_date(date_str)
&& date.add(Duration::from_secs(1))
>= time_utils::unix_to_system_time(time_utils::build_time())
{
return HttpResponse::NotModified().finish();
}
}
// Check if the browser already knows the etag
if let Some(c) = req.headers().get(header::IF_NONE_MATCH)
&& c.to_str().unwrap_or("") == digest
{
return HttpResponse::NotModified().finish();
}
HttpResponse::Ok() HttpResponse::Ok()
.content_type(res.to_string()) .content_type(res.to_string())
.insert_header(("etag", digest))
.insert_header((
"last-modified",
time_utils::unix_to_http_date(time_utils::build_time()),
))
.body(file.contents()) .body(file.contents())
} }
} }

View File

@@ -26,7 +26,7 @@ use crate::data::login_redirect::{LoginRedirect, get_2fa_url};
use crate::data::session_identity::SessionIdentity; use crate::data::session_identity::SessionIdentity;
use crate::data::user::User; use crate::data::user::User;
use crate::utils::string_utils::rand_str; use crate::utils::string_utils::rand_str;
use crate::utils::time_utils::time; use crate::utils::time::time;
pub async fn get_configuration(req: HttpRequest) -> impl Responder { pub async fn get_configuration(req: HttpRequest) -> impl Responder {
let is_secure_request = req let is_secure_request = req

View File

@@ -14,7 +14,7 @@ use crate::data::current_user::CurrentUser;
use crate::data::totp_key::TotpKey; use crate::data::totp_key::TotpKey;
use crate::data::user::User; use crate::data::user::User;
use crate::data::webauthn_manager::WebAuthManagerReq; use crate::data::webauthn_manager::WebAuthManagerReq;
use crate::utils::time_utils::fmt_time; use crate::utils::time::fmt_time;
#[derive(Template)] #[derive(Template)]
#[template(path = "settings/two_factors_page.html")] #[template(path = "settings/two_factors_page.html")]

View File

@@ -17,7 +17,7 @@ use crate::data::provider::{Provider, ProviderID};
use crate::data::session_identity::SessionIdentity; use crate::data::session_identity::SessionIdentity;
use crate::data::user::{FactorID, GrantedClients, TwoFactor, TwoFactorType, User, UserID}; use crate::data::user::{FactorID, GrantedClients, TwoFactor, TwoFactorType, User, UserID};
use crate::utils::time_utils::time; use crate::utils::time::time;
#[derive(serde::Serialize)] #[derive(serde::Serialize)]
pub struct LoggableUser { pub struct LoggableUser {

View File

@@ -67,30 +67,6 @@ pub struct AppConfig {
/// to authenticate /// to authenticate
#[arg(long, env)] #[arg(long, env)]
pub disable_local_login: bool, pub disable_local_login: bool,
/// Use Redis to store cookie sessions
#[arg(long, env)]
pub use_redis: bool,
/// Redis connection hostname
#[clap(long, env, default_value = "localhost")]
redis_hostname: String,
/// Redis connection port
#[clap(long, env, default_value_t = 6379)]
redis_port: u16,
/// Redis database number
#[clap(long, env, default_value_t = 0)]
redis_db_number: i64,
/// Redis username
#[clap(long, env)]
redis_username: Option<String>,
/// Redis password
#[clap(long, env, default_value = "secretredis")]
redis_password: String,
} }
lazy_static::lazy_static! { lazy_static::lazy_static! {
@@ -161,21 +137,6 @@ impl AppConfig {
let domain = self.domain_name(); let domain = self.domain_name();
domain.split_once(':').map(|i| i.0).unwrap_or(domain) domain.split_once(':').map(|i| i.0).unwrap_or(domain)
} }
/// Get Redis connection configuration
pub fn redis_connection_string(&self) -> Option<String> {
match self.use_redis {
true => Some(format!(
"redis://{}:{}@{}:{}/{}",
self.redis_username.as_deref().unwrap_or(""),
self.redis_password,
self.redis_hostname,
self.redis_port,
self.redis_db_number
)),
false => None,
}
}
} }
#[cfg(test)] #[cfg(test)]

View File

@@ -13,7 +13,7 @@ use crate::actors::users_actor::UsersActor;
use crate::constants::SECOND_FACTOR_EXPIRATION_FOR_CRITICAL_OPERATIONS; use crate::constants::SECOND_FACTOR_EXPIRATION_FOR_CRITICAL_OPERATIONS;
use crate::data::session_identity::SessionIdentity; use crate::data::session_identity::SessionIdentity;
use crate::data::user::User; use crate::data::user::User;
use crate::utils::time_utils::time; use crate::utils::time::time;
pub struct CurrentUser { pub struct CurrentUser {
user: User, user: User,

View File

@@ -9,7 +9,7 @@ use crate::data::app_config::AppConfig;
use crate::data::provider::Provider; use crate::data::provider::Provider;
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::time_utils::time; use crate::utils::time::time;
/// Provider configuration /// Provider configuration
#[derive(Debug, Clone)] #[derive(Debug, Clone)]

View File

@@ -3,7 +3,7 @@ use actix_web::{HttpMessage, HttpRequest};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use crate::data::user::{User, UserID}; use crate::data::user::{User, UserID};
use crate::utils::time_utils::time; use crate::utils::time::time;
#[derive(Debug, Serialize, Deserialize, Eq, PartialEq, Default)] #[derive(Debug, Serialize, Deserialize, Eq, PartialEq, Default)]
pub enum SessionStatus { pub enum SessionStatus {

View File

@@ -5,7 +5,7 @@ use totp_rfc6238::{HashAlgorithm, TotpGenerator};
use crate::data::app_config::AppConfig; use crate::data::app_config::AppConfig;
use crate::data::user::User; use crate::data::user::User;
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::time_utils::time; use crate::utils::time::time;
const BASE32_ALPHABET: Alphabet = Alphabet::Rfc4648 { padding: true }; const BASE32_ALPHABET: Alphabet = Alphabet::Rfc4648 { padding: true };
const NUM_DIGITS: usize = 6; const NUM_DIGITS: usize = 6;

View File

@@ -9,7 +9,7 @@ use crate::data::login_redirect::LoginRedirect;
use crate::data::provider::{Provider, ProviderID}; use crate::data::provider::{Provider, ProviderID};
use crate::data::totp_key::TotpKey; use crate::data::totp_key::TotpKey;
use crate::data::webauthn_manager::WebauthnPubKey; use crate::data::webauthn_manager::WebauthnPubKey;
use crate::utils::time_utils::{fmt_time, time}; use crate::utils::time::{fmt_time, time};
#[derive(Clone, Debug, Eq, PartialEq, serde::Serialize, serde::Deserialize, Encode, Decode)] #[derive(Clone, Debug, Eq, PartialEq, serde::Serialize, serde::Deserialize, Encode, Decode)]
pub struct UserID(pub String); pub struct UserID(pub String);

View File

@@ -4,7 +4,7 @@ use crate::actors::users_actor::{AuthorizedAuthenticationSources, UsersSyncBacke
use crate::data::entity_manager::EntityManager; use crate::data::entity_manager::EntityManager;
use crate::data::user::{FactorID, GeneralSettings, GrantedClients, TwoFactor, User, UserID}; use crate::data::user::{FactorID, GeneralSettings, GrantedClients, TwoFactor, User, UserID};
use crate::utils::err::{Res, new_error}; use crate::utils::err::{Res, new_error};
use crate::utils::time_utils::time; use crate::utils::time::time;
impl EntityManager<User> { impl EntityManager<User> {
/// Update user information /// Update user information

View File

@@ -16,7 +16,7 @@ use crate::constants::{
use crate::data::app_config::AppConfig; use crate::data::app_config::AppConfig;
use crate::data::user::{User, UserID}; use crate::data::user::{User, UserID};
use crate::utils::err::Res; use crate::utils::err::Res;
use crate::utils::time_utils::time; use crate::utils::time::time;
#[derive(Clone, Debug, serde::Serialize, serde::Deserialize)] #[derive(Clone, Debug, serde::Serialize, serde::Deserialize)]
pub struct WebauthnPubKey { pub struct WebauthnPubKey {

View File

@@ -1,12 +1,12 @@
use core::time::Duration; use core::time::Duration;
use std::sync::Arc; use std::sync::Arc;
use actix::{Actor, Addr}; use actix::Actor;
use actix_identity::IdentityMiddleware; use actix_identity::IdentityMiddleware;
use actix_identity::config::LogoutBehavior; use actix_identity::config::LogoutBehavior;
use actix_remote_ip::RemoteIPConfig; use actix_remote_ip::RemoteIPConfig;
use actix_session::SessionMiddleware; use actix_session::SessionMiddleware;
use actix_session::storage::{CookieSessionStore, RedisSessionStore}; use actix_session::storage::CookieSessionStore;
use actix_web::cookie::{Key, SameSite}; use actix_web::cookie::{Key, SameSite};
use actix_web::middleware::Logger; use actix_web::middleware::Logger;
use actix_web::{App, HttpResponse, HttpServer, get, middleware, web}; use actix_web::{App, HttpResponse, HttpServer, get, middleware, web};
@@ -14,7 +14,6 @@ use actix_web::{App, HttpResponse, HttpServer, get, middleware, web};
use basic_oidc::actors::bruteforce_actor::BruteForceActor; use basic_oidc::actors::bruteforce_actor::BruteForceActor;
use basic_oidc::actors::openid_sessions_actor::OpenIDSessionsActor; use basic_oidc::actors::openid_sessions_actor::OpenIDSessionsActor;
use basic_oidc::actors::providers_states_actor::ProvidersStatesActor; use basic_oidc::actors::providers_states_actor::ProvidersStatesActor;
use basic_oidc::actors::users_actor;
use basic_oidc::actors::users_actor::{UsersActor, UsersSyncBackend}; use basic_oidc::actors::users_actor::{UsersActor, UsersSyncBackend};
use basic_oidc::constants::*; use basic_oidc::constants::*;
use basic_oidc::controllers::assets_controller::assets_route; use basic_oidc::controllers::assets_controller::assets_route;
@@ -27,20 +26,9 @@ use basic_oidc::data::provider::ProvidersManager;
use basic_oidc::data::user::User; use basic_oidc::data::user::User;
use basic_oidc::data::webauthn_manager::WebAuthManager; use basic_oidc::data::webauthn_manager::WebAuthManager;
use basic_oidc::middlewares::auth_middleware::AuthMiddleware; use basic_oidc::middlewares::auth_middleware::AuthMiddleware;
use basic_oidc::middlewares::multi_session_store::MultiSessionStore;
#[get("/health")] #[get("/health")]
async fn health(users: web::Data<Addr<UsersActor>>) -> &'static str { async fn health() -> &'static str {
// Check users list is working
let users = users
.send(users_actor::GetAllUsers)
.await
.expect("Could not retrieve users list!");
if users.is_empty() {
log::error!("Got empty list of users!");
panic!("Got empty list of users!");
}
"Running" "Running"
} }
@@ -81,18 +69,6 @@ async fn main() -> std::io::Result<()> {
.expect("Failed to change default admin password!"); .expect("Failed to change default admin password!");
} }
let redis_store = match AppConfig::get().redis_connection_string() {
Some(s) => {
log::info!("Connect to Redis session store...");
Some(
RedisSessionStore::new(s)
.await
.expect("Failed to connect to Redis!"),
)
}
None => None,
};
let users_actor = UsersActor::new(users).start(); let users_actor = UsersActor::new(users).start();
let bruteforce_actor = BruteForceActor::default().start(); let bruteforce_actor = BruteForceActor::default().start();
let providers_states_actor = ProvidersStatesActor::default().start(); let providers_states_actor = ProvidersStatesActor::default().start();
@@ -115,10 +91,7 @@ async fn main() -> std::io::Result<()> {
HttpServer::new(move || { HttpServer::new(move || {
let session_mw = SessionMiddleware::builder( let session_mw = SessionMiddleware::builder(
match redis_store.clone() { CookieSessionStore::default(),
None => MultiSessionStore::Cookie(CookieSessionStore::default()),
Some(s) => MultiSessionStore::Redis(s),
},
Key::from(config.token_key.as_bytes()), Key::from(config.token_key.as_bytes()),
) )
.cookie_name(SESSION_COOKIE_NAME.to_string()) .cookie_name(SESSION_COOKIE_NAME.to_string())

View File

@@ -1,2 +1 @@
pub mod auth_middleware; pub mod auth_middleware;
pub mod multi_session_store;

View File

@@ -1,63 +0,0 @@
use actix_session::storage::{
CookieSessionStore, LoadError, RedisSessionStore, SaveError, SessionKey, SessionStore,
UpdateError,
};
use actix_web::cookie::time::Duration;
use jwt_simple::Error;
use std::collections::HashMap;
type SessionState = HashMap<String, String>;
/// Session store multiplexer.
///
/// Allows to easily support different store without having a lot of duplicate code
pub enum MultiSessionStore {
Cookie(CookieSessionStore),
Redis(RedisSessionStore),
}
impl SessionStore for MultiSessionStore {
async fn load(&self, session_key: &SessionKey) -> Result<Option<SessionState>, LoadError> {
match self {
MultiSessionStore::Cookie(c) => c.load(session_key).await,
MultiSessionStore::Redis(r) => r.load(session_key).await,
}
}
async fn save(
&self,
session_state: SessionState,
ttl: &Duration,
) -> Result<SessionKey, SaveError> {
match self {
MultiSessionStore::Cookie(c) => c.save(session_state, ttl).await,
MultiSessionStore::Redis(r) => r.save(session_state, ttl).await,
}
}
async fn update(
&self,
session_key: SessionKey,
session_state: SessionState,
ttl: &Duration,
) -> Result<SessionKey, UpdateError> {
match self {
MultiSessionStore::Cookie(c) => c.update(session_key, session_state, ttl).await,
MultiSessionStore::Redis(r) => r.update(session_key, session_state, ttl).await,
}
}
async fn update_ttl(&self, session_key: &SessionKey, ttl: &Duration) -> Result<(), Error> {
match self {
MultiSessionStore::Cookie(c) => c.update_ttl(session_key, ttl).await,
MultiSessionStore::Redis(r) => r.update_ttl(session_key, ttl).await,
}
}
async fn delete(&self, session_key: &SessionKey) -> Result<(), Error> {
match self {
MultiSessionStore::Cookie(c) => c.delete(session_key).await,
MultiSessionStore::Redis(r) => r.delete(session_key).await,
}
}
}

View File

@@ -1,4 +1,4 @@
pub mod crypt_utils; pub mod crypt_utils;
pub mod err; pub mod err;
pub mod string_utils; pub mod string_utils;
pub mod time_utils; pub mod time;

View File

@@ -1,5 +1,5 @@
use chrono::DateTime; use chrono::DateTime;
use std::time::{Duration, SystemTime, UNIX_EPOCH}; use std::time::{SystemTime, UNIX_EPOCH};
/// Get the current time since epoch /// Get the current time since epoch
pub fn time() -> u64 { pub fn time() -> u64 {
@@ -19,27 +19,9 @@ pub fn fmt_time(timestamp: u64) -> String {
datetime.format("%Y-%m-%d %H:%M:%S").to_string() datetime.format("%Y-%m-%d %H:%M:%S").to_string()
} }
/// Convert UNIX time to system time
pub fn unix_to_system_time(time: u64) -> SystemTime {
UNIX_EPOCH + Duration::from_secs(time)
}
/// Format UNIX time to HTTP date
pub fn unix_to_http_date(time: u64) -> String {
httpdate::fmt_http_date(unix_to_system_time(time))
}
/// Get build time in UNIX format
pub fn build_time() -> u64 {
let build_time = build_time::build_time_local!();
let date =
chrono::DateTime::parse_from_rfc3339(build_time).expect("Failed to parse compile date");
date.timestamp() as u64
}
#[cfg(test)] #[cfg(test)]
mod test { mod test {
use crate::utils::time_utils::{fmt_time, time}; use crate::utils::time::{fmt_time, time};
#[test] #[test]
fn test_time() { fn test_time() {