Compare commits
18
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9ea37e56f0
|
||
|
|
6e91320709
|
||
|
|
7736f79649
|
||
|
|
1eb659d865
|
||
|
|
3ea92ae64e
|
||
|
|
0e8e0db284
|
||
|
|
720f3d8f75
|
||
|
|
7e5bc016b1
|
||
|
|
384dd41690
|
||
|
|
f246676203
|
||
|
|
47e6c85fc7
|
||
|
|
82370ad63a
|
||
|
|
e5ab4aa426
|
||
|
|
ad632fca16
|
||
|
|
86febdab0d
|
||
|
|
7534e8652f
|
||
|
|
c4b2c19f77
|
||
|
|
890d03bdf3
|
@@ -14,10 +14,10 @@ jobs:
|
||||
name: Check
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v6
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: cargo check
|
||||
|
||||
@@ -25,10 +25,10 @@ jobs:
|
||||
name: Rustfmt
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v6
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: rustup component add rustfmt
|
||||
- run: cargo fmt --all -- --check
|
||||
@@ -37,10 +37,10 @@ jobs:
|
||||
name: Clippy
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v6
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: rustup component add clippy
|
||||
- run: cargo clippy -- -D warnings
|
||||
|
||||
@@ -13,14 +13,14 @@ jobs:
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- name: Checkout code
|
||||
uses: actions/checkout@v6
|
||||
uses: actions/checkout@v5
|
||||
with:
|
||||
fetch-depth: 0 # Important for git describe --tags
|
||||
|
||||
- name: Install Rust
|
||||
uses: actions-rs/toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
components: cargo
|
||||
|
||||
- name: Extract Version from Cargo.toml
|
||||
|
||||
+10
-10
@@ -14,10 +14,10 @@ jobs:
|
||||
name: Check
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v6
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: cargo check
|
||||
|
||||
@@ -25,10 +25,10 @@ jobs:
|
||||
name: Test Suite
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v6
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: cargo test
|
||||
|
||||
@@ -36,10 +36,10 @@ jobs:
|
||||
name: Rustfmt
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v6
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: rustup component add rustfmt
|
||||
- run: cargo fmt --all -- --check
|
||||
@@ -48,10 +48,10 @@ jobs:
|
||||
name: Clippy
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v6
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: rustup component add clippy
|
||||
- run: cargo clippy -- -D warnings
|
||||
@@ -60,9 +60,9 @@ jobs:
|
||||
name: build
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v6
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96.1
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: cargo build
|
||||
|
||||
Generated
+436
-161
File diff suppressed because it is too large
Load Diff
+3
-3
@@ -1,15 +1,15 @@
|
||||
[package]
|
||||
name = "textsender_models"
|
||||
version = "0.5.1"
|
||||
version = "0.4.10"
|
||||
edition = "2024"
|
||||
rust-version = "1.96.1"
|
||||
rust-version = "1.96"
|
||||
description = "Models used for the textsender project"
|
||||
|
||||
[dependencies]
|
||||
serde = { version = "1.0.228", features = ["derive"] }
|
||||
serde_json = { version = "1.0.150" }
|
||||
time = { version = "0.3.49", features = ["formatting", "macros", "parsing", "serde"] }
|
||||
sqlx = { version = "0.9.0", features = ["runtime-tokio", "tls-native-tls", "postgres", "time", "uuid"] }
|
||||
sqlx = { version = "0.8.6", features = ["postgres", "runtime-tokio-native-tls", "time", "uuid"] }
|
||||
uuid = { version = "1.23.3", features = ["v4", "serde"] }
|
||||
dotenvy = { version = "0.15.7" }
|
||||
const_format = { version = "0.2.36" }
|
||||
|
||||
@@ -20,11 +20,12 @@ impl TwilioConfig {
|
||||
}
|
||||
}
|
||||
|
||||
pub fn load_config() -> Result<TwilioConfig, std::io::Error> {
|
||||
let auth_sid_var = crate::envy::environment::get_env("TWILIO_AUTH_SID");
|
||||
let service_sid_var = crate::envy::environment::get_env("TWILIO_SERVICE_SID");
|
||||
let auth_token_var = crate::envy::environment::get_env("TWILIO_AUTH_TOKEN");
|
||||
let phone_number_var = crate::envy::environment::get_env("TWILIO_PHONE_NUMBER");
|
||||
// TODO: Remove the async at a later point
|
||||
pub async fn load_config() -> Result<TwilioConfig, std::io::Error> {
|
||||
let auth_sid_var = crate::envy::environment::get_env("TWILIO_AUTH_SID").await;
|
||||
let service_sid_var = crate::envy::environment::get_env("TWILIO_SERVICE_SID").await;
|
||||
let auth_token_var = crate::envy::environment::get_env("TWILIO_AUTH_TOKEN").await;
|
||||
let phone_number_var = crate::envy::environment::get_env("TWILIO_PHONE_NUMBER").await;
|
||||
|
||||
if auth_sid_var.value.is_empty()
|
||||
|| service_sid_var.value.is_empty()
|
||||
|
||||
@@ -4,10 +4,13 @@
|
||||
pub struct Contact {
|
||||
#[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
|
||||
pub id: Option<uuid::Uuid>,
|
||||
// empty?
|
||||
#[serde(skip_serializing_if = "Option::is_none")]
|
||||
pub firstname: Option<String>,
|
||||
// empty?
|
||||
#[serde(skip_serializing_if = "Option::is_none")]
|
||||
pub lastname: Option<String>,
|
||||
// empty?
|
||||
#[serde(skip_serializing_if = "Option::is_none")]
|
||||
pub nickname: Option<String>,
|
||||
pub phone_number: String,
|
||||
|
||||
+16
-14
@@ -1,4 +1,6 @@
|
||||
pub fn get_db_url() -> crate::envy::EnvVar {
|
||||
// TODO: Functions does not need to be async
|
||||
|
||||
pub async fn get_db_url() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::DB_URL;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -6,7 +8,7 @@ pub fn get_db_url() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_secret_main_key() -> crate::envy::EnvVar {
|
||||
pub async fn get_secret_main_key() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::SECRET_MAIN_KEY;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -14,7 +16,7 @@ pub fn get_secret_main_key() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_service_passphrase() -> crate::envy::EnvVar {
|
||||
pub async fn get_service_passphrase() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::SERVICE_PASSPHRASE;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -22,7 +24,7 @@ pub fn get_service_passphrase() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_secret_key() -> crate::envy::EnvVar {
|
||||
pub async fn get_secret_key() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::SECRET_KEY;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -30,7 +32,7 @@ pub fn get_secret_key() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_root_directory() -> crate::envy::EnvVar {
|
||||
pub async fn get_root_directory() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::ROOT_DIRECTORY;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -38,7 +40,7 @@ pub fn get_root_directory() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_app_base_api_url() -> crate::envy::EnvVar {
|
||||
pub async fn get_app_base_api_url() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::TEXTSENDER_BASE_API_URL;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -46,7 +48,7 @@ pub fn get_app_base_api_url() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_app_auth_base_api_url() -> crate::envy::EnvVar {
|
||||
pub async fn get_app_auth_base_api_url() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::TEXTSENDER_AUTH_BASE_API_URL;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -54,7 +56,7 @@ pub fn get_app_auth_base_api_url() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_app_env() -> crate::envy::EnvVar {
|
||||
pub async fn get_app_env() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::APP_ENV;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -62,14 +64,14 @@ pub fn get_app_env() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_backend_port() -> crate::envy::EnvVar {
|
||||
pub async fn get_backend_port() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::BACKEND_PORT;
|
||||
let value = std::env::var(key).expect(key);
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_frontend_url() -> crate::envy::EnvVar {
|
||||
pub async fn get_frontend_url() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::FRONTEND_URL;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -77,7 +79,7 @@ pub fn get_frontend_url() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_rust_log() -> crate::envy::EnvVar {
|
||||
pub async fn get_rust_log() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::RUST_LOG;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -85,7 +87,7 @@ pub fn get_rust_log() -> crate::envy::EnvVar {
|
||||
crate::envy::init_envvar(key, &value)
|
||||
}
|
||||
|
||||
pub fn get_allowed_origins() -> crate::envy::EnvVar {
|
||||
pub async fn get_allowed_origins() -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let key = crate::envy::keys::ALLOWED_ORIGINS;
|
||||
let value = std::env::var(key).expect(key);
|
||||
@@ -96,8 +98,8 @@ pub fn get_allowed_origins() -> crate::envy::EnvVar {
|
||||
envvar
|
||||
}
|
||||
|
||||
/// Get environment not specified in the library
|
||||
pub fn get_env(environment: &str) -> crate::envy::EnvVar {
|
||||
/// Get environment not specified in the code
|
||||
pub async fn get_env(environment: &str) -> crate::envy::EnvVar {
|
||||
dotenvy::dotenv().ok();
|
||||
let my_error = format!("{environment} {}", crate::envy::keys::error::GENERAL_ERROR);
|
||||
let value = std::env::var(environment).expect(&my_error);
|
||||
|
||||
+8
-26
@@ -20,17 +20,16 @@ pub fn init_envvar(key: &str, value: &str) -> EnvVar {
|
||||
}
|
||||
|
||||
pub fn init_delimiter(envvar: &mut EnvVar, delimiter: char) {
|
||||
let amount_of_delimiters_found: i32 = {
|
||||
let mut count = 0;
|
||||
for v in envvar.value.chars() {
|
||||
if v == delimiter {
|
||||
count += 1;
|
||||
}
|
||||
}
|
||||
let mut amount_of_delimiters_found: i32 = 0;
|
||||
|
||||
for v in envvar.value.chars() {
|
||||
if v == delimiter {
|
||||
amount_of_delimiters_found += 1;
|
||||
}
|
||||
}
|
||||
|
||||
count
|
||||
};
|
||||
let has_delimiter = amount_of_delimiters_found >= 1;
|
||||
|
||||
if has_delimiter {
|
||||
envvar.has_delimiter = has_delimiter;
|
||||
envvar.delimiter = delimiter;
|
||||
@@ -38,20 +37,3 @@ pub fn init_delimiter(envvar: &mut EnvVar, delimiter: char) {
|
||||
envvar.has_delimiter = has_delimiter;
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
#[test]
|
||||
fn test_init_delimiter() {
|
||||
let delimiter: char = ',';
|
||||
let value = format!("red,green,white,black");
|
||||
let mut env_var = super::EnvVar {
|
||||
key: String::from("COLORS"),
|
||||
value: value.clone(),
|
||||
..Default::default()
|
||||
};
|
||||
|
||||
super::init_delimiter(&mut env_var, delimiter);
|
||||
assert_eq!(value, env_var.value, "Colors do not match");
|
||||
}
|
||||
}
|
||||
|
||||
+3
-41
@@ -2,52 +2,14 @@
|
||||
/// extract it into some strings
|
||||
pub fn delimitize(var: &crate::envy::EnvVar) -> Result<Vec<String>, std::io::Error> {
|
||||
if var.has_delimiter {
|
||||
let values: Vec<String> = match var
|
||||
Ok(var
|
||||
.value
|
||||
.split(var.delimiter)
|
||||
.map(|c| c.parse::<String>())
|
||||
.collect()
|
||||
{
|
||||
Ok(v) => v,
|
||||
Err(err) => {
|
||||
return Err(std::io::Error::other(err));
|
||||
}
|
||||
};
|
||||
|
||||
Ok(values)
|
||||
.map(|c| c.parse::<String>().unwrap())
|
||||
.collect())
|
||||
} else {
|
||||
Err(std::io::Error::other(
|
||||
"Environment variable does not have a delimiter",
|
||||
))
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
use super::*;
|
||||
|
||||
#[test]
|
||||
fn test_delimitize() {
|
||||
let envvar = crate::envy::EnvVar {
|
||||
key: "OCEANS".to_string(),
|
||||
value: "Atlantic|Pacific|Indian|Arctic".to_string(),
|
||||
has_delimiter: true,
|
||||
delimiter: '|',
|
||||
};
|
||||
let all_values = vec![
|
||||
"Atlantic".to_string(),
|
||||
"Pacific".to_string(),
|
||||
"Indian".to_string(),
|
||||
"Arctic".to_string(),
|
||||
];
|
||||
|
||||
match delimitize(&envvar) {
|
||||
Ok(values) => {
|
||||
assert_eq!(values, all_values, "Failure in delimitizing EnvVar values");
|
||||
}
|
||||
Err(err) => {
|
||||
assert!(false, "Error delimitizing: {err:?}");
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
+20
-74
@@ -54,7 +54,7 @@ mod util {
|
||||
pub fn time_to_std_time(
|
||||
provided_time: &time::OffsetDateTime,
|
||||
) -> Result<std::time::SystemTime, std::time::SystemTimeError> {
|
||||
let converted: std::time::SystemTime = (*provided_time).into();
|
||||
let converted: std::time::SystemTime = provided_time.clone().into();
|
||||
Ok(converted)
|
||||
}
|
||||
}
|
||||
@@ -78,57 +78,17 @@ pub struct CreateTokenResult {
|
||||
}
|
||||
|
||||
pub fn create_token(
|
||||
key: &str,
|
||||
token_resource: TokenResource,
|
||||
key: &String,
|
||||
token_resource: &TokenResource,
|
||||
duration: time::Duration,
|
||||
) -> Result<CreateTokenResult, josekit::JoseError> {
|
||||
let mut header = josekit::jws::JwsHeader::new();
|
||||
header.set_token_type(TOKEN_TYPE);
|
||||
|
||||
match init_payload(token_resource, duration) {
|
||||
Ok((payload, issued, expire)) => {
|
||||
let signer = match josekit::jws::alg::hmac::HmacJwsAlgorithm::Hs256
|
||||
.signer_from_bytes(key.as_bytes())
|
||||
{
|
||||
Ok(signer) => signer,
|
||||
Err(err) => {
|
||||
return Err(err);
|
||||
}
|
||||
};
|
||||
let access_token = match josekit::jwt::encode_with_signer(&payload, &header, &signer) {
|
||||
Ok(access_token) => access_token,
|
||||
Err(err) => {
|
||||
return Err(err);
|
||||
}
|
||||
};
|
||||
|
||||
Ok(CreateTokenResult {
|
||||
access_token,
|
||||
issued: issued.unix_timestamp(),
|
||||
expires_in: expire.unix_timestamp(),
|
||||
token_issued: issued,
|
||||
})
|
||||
}
|
||||
Err(e) => Err(josekit::JoseError::InvalidClaim(e.into())),
|
||||
}
|
||||
}
|
||||
|
||||
fn init_payload(
|
||||
token_resource: TokenResource,
|
||||
duration: time::Duration,
|
||||
) -> Result<
|
||||
(
|
||||
josekit::jwt::JwtPayload,
|
||||
time::OffsetDateTime,
|
||||
time::OffsetDateTime,
|
||||
),
|
||||
josekit::JoseError,
|
||||
> {
|
||||
let mut payload = josekit::jwt::JwtPayload::new();
|
||||
payload.set_subject(token_resource.message);
|
||||
payload.set_issuer(token_resource.issuer);
|
||||
payload.set_audience(token_resource.audiences);
|
||||
|
||||
payload.set_subject(&token_resource.message);
|
||||
payload.set_issuer(&token_resource.issuer);
|
||||
payload.set_audience(token_resource.audiences.clone());
|
||||
if !token_resource.user_id.is_nil() {
|
||||
match payload.set_claim("user_id", Some(serde_json::json!(token_resource.user_id))) {
|
||||
Ok(_) => {}
|
||||
@@ -137,38 +97,24 @@ fn init_payload(
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
match init_payload_issued(&mut payload, duration) {
|
||||
Ok((issued, expire)) => Ok((payload, issued, expire)),
|
||||
Err(err) => Err(err),
|
||||
}
|
||||
}
|
||||
|
||||
fn init_payload_issued(
|
||||
payload: &mut josekit::jwt::JwtPayload,
|
||||
duration: time::Duration,
|
||||
) -> Result<(time::OffsetDateTime, time::OffsetDateTime), josekit::JoseError> {
|
||||
match get_issued() {
|
||||
Ok(issued) => {
|
||||
let expire = issued + duration;
|
||||
let issued_at = match util::time_to_std_time(&issued) {
|
||||
Ok(issued_at) => issued_at,
|
||||
Err(err) => {
|
||||
return Err(josekit::JoseError::InvalidClaim(err.into()));
|
||||
}
|
||||
};
|
||||
let expires_at = match util::time_to_std_time(&expire) {
|
||||
Ok(expires_at) => expires_at,
|
||||
Err(err) => {
|
||||
return Err(josekit::JoseError::InvalidClaim(err.into()));
|
||||
}
|
||||
};
|
||||
payload.set_issued_at(&util::time_to_std_time(&issued).unwrap());
|
||||
payload.set_expires_at(&util::time_to_std_time(&expire).unwrap());
|
||||
|
||||
payload.set_issued_at(&issued_at);
|
||||
payload.set_expires_at(&expires_at);
|
||||
Ok((issued, expire))
|
||||
let signer = josekit::jws::alg::hmac::HmacJwsAlgorithm::Hs256
|
||||
.signer_from_bytes(key.as_bytes())
|
||||
.unwrap();
|
||||
|
||||
Ok(CreateTokenResult {
|
||||
access_token: josekit::jwt::encode_with_signer(&payload, &header, &signer).unwrap(),
|
||||
issued: issued.unix_timestamp(),
|
||||
expires_in: expire.unix_timestamp(),
|
||||
token_issued: issued,
|
||||
})
|
||||
}
|
||||
Err(err) => Err(josekit::JoseError::InvalidClaim(err.into())),
|
||||
Err(e) => Err(josekit::JoseError::InvalidClaim(e.into())),
|
||||
}
|
||||
}
|
||||
|
||||
@@ -192,7 +138,7 @@ mod tests {
|
||||
let token_duration = time::Duration::minutes(30);
|
||||
let key = String::from(TEST_KEY);
|
||||
|
||||
match super::create_token(&key, token_resource, token_duration) {
|
||||
match super::create_token(&key, &token_resource, token_duration) {
|
||||
Ok(cst) => match time::OffsetDateTime::from_unix_timestamp(cst.issued) {
|
||||
Ok(d_result) => {
|
||||
let they_match = {
|
||||
|
||||
@@ -6,7 +6,9 @@ pub struct User {
|
||||
pub phone_number: String,
|
||||
pub username: String,
|
||||
pub password: String,
|
||||
// Firstname is a pointer
|
||||
pub firstname: String,
|
||||
// Lastname is a pointer
|
||||
pub lastname: String,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
pub created: Option<time::OffsetDateTime>,
|
||||
@@ -25,6 +27,7 @@ pub struct ServiceUser {
|
||||
pub passphrase: String,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
pub created: Option<time::OffsetDateTime>,
|
||||
// When serializing to json, if empty do not populate
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
pub last_login: Option<time::OffsetDateTime>,
|
||||
#[serde(skip)]
|
||||
@@ -78,6 +81,7 @@ pub struct UserProfile {
|
||||
|
||||
#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow)]
|
||||
pub struct Salt {
|
||||
// #[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
|
||||
pub id: uuid::Uuid,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub salt: String,
|
||||
|
||||
Reference in New Issue
Block a user