Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
eebd4db4d4
|
@@ -1,46 +0,0 @@
|
||||
name: textsender_models PR
|
||||
|
||||
on:
|
||||
pull_request:
|
||||
branches:
|
||||
- main
|
||||
|
||||
concurrency:
|
||||
group: ${{ github.workflow }}-${{ github.ref }}
|
||||
cancel-in-progress: true
|
||||
|
||||
jobs:
|
||||
check:
|
||||
name: Check
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: cargo check
|
||||
|
||||
fmt:
|
||||
name: Rustfmt
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: rustup component add rustfmt
|
||||
- run: cargo fmt --all -- --check
|
||||
|
||||
clippy:
|
||||
name: Clippy
|
||||
runs-on: ubuntu-24.04
|
||||
steps:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: rustup component add clippy
|
||||
- run: cargo clippy -- -D warnings
|
||||
@@ -3,10 +3,10 @@ name: Release Tagging
|
||||
on:
|
||||
push:
|
||||
branches:
|
||||
- main
|
||||
- v0.3.0-migrate
|
||||
pull_request:
|
||||
branches:
|
||||
- main
|
||||
- v0.3.0-migrate
|
||||
|
||||
jobs:
|
||||
release:
|
||||
@@ -20,7 +20,7 @@ jobs:
|
||||
- name: Install Rust
|
||||
uses: actions-rs/toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
toolchain: 1.95
|
||||
components: cargo
|
||||
|
||||
- name: Extract Version from Cargo.toml
|
||||
|
||||
@@ -3,11 +3,10 @@ name: Rust Build
|
||||
on:
|
||||
push:
|
||||
branches:
|
||||
- main
|
||||
|
||||
concurrency:
|
||||
group: ${{ github.workflow }}-${{ github.ref }}
|
||||
cancel-in-progress: true
|
||||
- v0.3.0-migrate
|
||||
pull_request:
|
||||
branches:
|
||||
- v0.3.0-migrate
|
||||
|
||||
jobs:
|
||||
check:
|
||||
@@ -17,8 +16,7 @@ jobs:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
toolchain: 1.95
|
||||
- run: cargo check
|
||||
|
||||
test:
|
||||
@@ -28,8 +26,7 @@ jobs:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
toolchain: 1.95
|
||||
- run: cargo test
|
||||
|
||||
fmt:
|
||||
@@ -39,8 +36,7 @@ jobs:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
toolchain: 1.95
|
||||
- run: rustup component add rustfmt
|
||||
- run: cargo fmt --all -- --check
|
||||
|
||||
@@ -51,8 +47,7 @@ jobs:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
toolchain: 1.95
|
||||
- run: rustup component add clippy
|
||||
- run: cargo clippy -- -D warnings
|
||||
|
||||
@@ -63,6 +58,5 @@ jobs:
|
||||
- uses: actions/checkout@v5
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.96
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
toolchain: 1.95
|
||||
- run: cargo build
|
||||
|
||||
Generated
+188
-1387
File diff suppressed because it is too large
Load Diff
+10
-18
@@ -1,29 +1,21 @@
|
||||
[package]
|
||||
name = "textsender_models"
|
||||
version = "0.4.11"
|
||||
version = "0.3.0"
|
||||
edition = "2024"
|
||||
rust-version = "1.96"
|
||||
description = "Models used for the textsender project"
|
||||
rust-version = "1.95"
|
||||
description = "models used for the textsender project"
|
||||
# license = "MIT"
|
||||
|
||||
[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.8.6", features = ["postgres", "runtime-tokio-native-tls", "time", "uuid"] }
|
||||
uuid = { version = "1.23.3", features = ["v4", "serde"] }
|
||||
serde_json = { version = "1.0.149" }
|
||||
rand = { version = "0.10.1" }
|
||||
time = { version = "0.3.47", features = ["formatting", "macros", "parsing", "serde"] }
|
||||
uuid = { version = "1.23.1", features = ["v4", "serde"] }
|
||||
dotenvy = { version = "0.15.7" }
|
||||
const_format = { version = "0.2.36" }
|
||||
josekit = { version = "0.10.3" }
|
||||
utoipa = { version = "5.5.0", features = ["uuid", "time"] }
|
||||
|
||||
[features]
|
||||
default = ["full"]
|
||||
full = ["user", "message", "contact", "config", "envy", "token"]
|
||||
user = []
|
||||
message = []
|
||||
contact = []
|
||||
config = []
|
||||
envy = []
|
||||
token = []
|
||||
utoipa = { version = "5.4.0", features = ["uuid", "time"] }
|
||||
|
||||
[dev-dependencies]
|
||||
tempfile = { version = "3.27.0" }
|
||||
|
||||
@@ -1,7 +1,9 @@
|
||||
#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize)]
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize)]
|
||||
pub struct TwilioConfig {
|
||||
#[serde(alias = "auth_id")]
|
||||
pub account_sid: String,
|
||||
pub account_sid: uuid::Uuid,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub service_sid: String,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
@@ -19,25 +21,3 @@ impl TwilioConfig {
|
||||
println!("Number: {:?}", self.phone_number);
|
||||
}
|
||||
}
|
||||
|
||||
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");
|
||||
|
||||
if auth_sid_var.value.is_empty()
|
||||
|| service_sid_var.value.is_empty()
|
||||
|| auth_token_var.value.is_empty()
|
||||
|| phone_number_var.value.is_empty()
|
||||
{
|
||||
Err(std::io::Error::other("Config not set"))
|
||||
} else {
|
||||
Ok(TwilioConfig {
|
||||
service_sid: service_sid_var.value,
|
||||
auth_token: auth_token_var.value,
|
||||
account_sid: auth_sid_var.value,
|
||||
phone_number: phone_number_var.value,
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
+12
-11
@@ -1,19 +1,20 @@
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize)]
|
||||
pub struct Contact {
|
||||
#[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
|
||||
pub id: Option<uuid::Uuid>,
|
||||
pub id: uuid::Uuid,
|
||||
// empty?
|
||||
#[serde(skip_serializing_if = "Option::is_none")]
|
||||
pub firstname: Option<String>,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub firstname: String,
|
||||
// empty?
|
||||
#[serde(skip_serializing_if = "Option::is_none")]
|
||||
pub lastname: Option<String>,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub lastname: String,
|
||||
// empty?
|
||||
#[serde(skip_serializing_if = "Option::is_none")]
|
||||
pub nickname: Option<String>,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub nickname: String,
|
||||
pub phone_number: String,
|
||||
// empty
|
||||
#[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
|
||||
pub user_id: Option<uuid::Uuid>,
|
||||
pub user_id: uuid::Uuid,
|
||||
}
|
||||
|
||||
+14
-14
@@ -1,4 +1,4 @@
|
||||
pub fn get_db_url() -> crate::envy::EnvVar {
|
||||
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 +6,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 +14,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 +22,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 +30,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 +38,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 +46,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 +54,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 +62,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 +77,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 +85,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 +96,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");
|
||||
}
|
||||
}
|
||||
|
||||
+2
-5
@@ -6,10 +6,7 @@ pub mod token;
|
||||
pub mod user;
|
||||
|
||||
pub mod init {
|
||||
pub fn is_uuid_nil(uuid: &Option<uuid::Uuid>) -> bool {
|
||||
match uuid {
|
||||
Some(id) => id.is_nil(),
|
||||
None => true,
|
||||
}
|
||||
pub fn is_uuid_nil(uuid: &uuid::Uuid) -> bool {
|
||||
uuid.is_nil()
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,17 +1,14 @@
|
||||
/// Message status - Instant
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
pub const MESSAGE_EVENT_RESPONSE_STATUS_INSTANT: &str = "INSTANT";
|
||||
/// Message status - Scheduled
|
||||
pub const MESSAGE_EVENT_RESPONSE_STATUS_SCHEDULED: &str = "SCHEDULED";
|
||||
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize)]
|
||||
pub struct MessageEventResponse {
|
||||
pub id: uuid::Uuid,
|
||||
#[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
|
||||
pub scheduled_message_event_id: Option<uuid::Uuid>,
|
||||
/// Stores a json response of the sent message
|
||||
pub response: serde_json::Value,
|
||||
pub scheduled_message_event_id: uuid::Uuid,
|
||||
// Json field
|
||||
pub response: String,
|
||||
pub user_id: uuid::Uuid,
|
||||
pub contact_id: uuid::Uuid,
|
||||
pub message_id: uuid::Uuid,
|
||||
|
||||
+5
-7
@@ -1,13 +1,11 @@
|
||||
pub mod event;
|
||||
pub mod scheduling;
|
||||
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct Message {
|
||||
#[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
|
||||
pub id: Option<uuid::Uuid>,
|
||||
pub id: uuid::Uuid,
|
||||
pub content: String,
|
||||
#[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
|
||||
pub user_id: Option<uuid::Uuid>,
|
||||
pub user_id: uuid::Uuid,
|
||||
}
|
||||
|
||||
@@ -1,26 +1,24 @@
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct ScheduledMessageEvent {
|
||||
pub id: uuid::Uuid,
|
||||
pub contact_id: uuid::Uuid,
|
||||
pub message_id: uuid::Uuid,
|
||||
pub scheduled_message_id: uuid::Uuid,
|
||||
id: uuid::Uuid,
|
||||
contact_id: uuid::Uuid,
|
||||
message_id: uuid::Uuid,
|
||||
scheduled_message_id: uuid::Uuid,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
pub created: Option<time::OffsetDateTime>,
|
||||
created: Option<time::OffsetDateTime>,
|
||||
}
|
||||
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize)]
|
||||
pub struct ScheduledMessage {
|
||||
pub id: uuid::Uuid,
|
||||
id: uuid::Uuid,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
pub scheduled: Option<time::OffsetDateTime>,
|
||||
scheduled: Option<time::OffsetDateTime>,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
pub created: Option<time::OffsetDateTime>,
|
||||
pub status: String,
|
||||
pub user_id: uuid::Uuid,
|
||||
created: Option<time::OffsetDateTime>,
|
||||
status: String,
|
||||
user_id: uuid::Uuid,
|
||||
}
|
||||
|
||||
pub const READY: &str = "READY";
|
||||
|
||||
+20
-94
@@ -1,40 +1,18 @@
|
||||
use serde::Deserialize;
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize)]
|
||||
pub struct Claims {
|
||||
pub user_id: uuid::Uuid,
|
||||
#[serde(skip_serializing_if = "Option::is_none")]
|
||||
pub role: Option<String>,
|
||||
pub role: String,
|
||||
#[serde(alias = "iss")]
|
||||
pub issued: String,
|
||||
#[serde(alias = "exp")]
|
||||
#[serde(deserialize_with = "deserialize_i64_from_f64")]
|
||||
pub expired: i64,
|
||||
#[serde(alias = "iat")]
|
||||
#[serde(deserialize_with = "deserialize_i64_from_f64")]
|
||||
pub issued_at: i64,
|
||||
}
|
||||
|
||||
fn deserialize_i64_from_f64<'de, D>(deserializer: D) -> Result<i64, D::Error>
|
||||
where
|
||||
D: serde::Deserializer<'de>,
|
||||
{
|
||||
let val = f64::deserialize(deserializer)?;
|
||||
// Handle NaN and infinity cases
|
||||
if val.is_nan() || val.is_infinite() {
|
||||
return Err(serde::de::Error::custom("invalid float value"));
|
||||
}
|
||||
// Round to nearest integer and convert
|
||||
let rounded = val.round();
|
||||
// Check if the rounded value can fit in i64
|
||||
if rounded < (i64::MIN as f64) || rounded > (i64::MAX as f64) {
|
||||
Err(serde::de::Error::custom("float out of i64 range"))
|
||||
} else {
|
||||
Ok(rounded as i64)
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize, utoipa::ToSchema)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct LoginResult {
|
||||
pub user_id: uuid::Uuid,
|
||||
pub access_token: String,
|
||||
@@ -43,7 +21,7 @@ pub struct LoginResult {
|
||||
pub issued_at: i64,
|
||||
}
|
||||
|
||||
/// Alias for LoginResult
|
||||
// Alias for LoginResult
|
||||
pub type Login = LoginResult;
|
||||
|
||||
pub fn get_issued() -> time::Result<time::OffsetDateTime> {
|
||||
@@ -54,7 +32,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::from(*provided_time);
|
||||
Ok(converted)
|
||||
}
|
||||
}
|
||||
@@ -64,33 +42,28 @@ pub struct TokenResource {
|
||||
pub message: String,
|
||||
pub issuer: String,
|
||||
pub audiences: Vec<String>,
|
||||
pub user_id: uuid::Uuid,
|
||||
pub id: uuid::Uuid,
|
||||
}
|
||||
|
||||
/// Token type
|
||||
pub const TOKEN_TYPE: &str = "JWT";
|
||||
|
||||
pub struct CreateTokenResult {
|
||||
pub access_token: String,
|
||||
pub issued: i64,
|
||||
pub expires_in: i64,
|
||||
pub token_issued: time::OffsetDateTime,
|
||||
}
|
||||
|
||||
pub fn create_token(
|
||||
key: &String,
|
||||
token_resource: &TokenResource,
|
||||
duration: time::Duration,
|
||||
) -> Result<CreateTokenResult, josekit::JoseError> {
|
||||
) -> Result<(String, i64), josekit::JoseError> {
|
||||
let mut header = josekit::jws::JwsHeader::new();
|
||||
header.set_token_type(TOKEN_TYPE);
|
||||
|
||||
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.clone());
|
||||
if !token_resource.user_id.is_nil() {
|
||||
match payload.set_claim("user_id", Some(serde_json::json!(token_resource.user_id))) {
|
||||
let message = &token_resource.message;
|
||||
let issuer = &token_resource.issuer;
|
||||
let audiences: &Vec<String> = &token_resource.audiences;
|
||||
payload.set_subject(message);
|
||||
payload.set_issuer(issuer);
|
||||
payload.set_audience(audiences.clone());
|
||||
if !token_resource.id.is_nil() {
|
||||
match payload.set_claim("id", Some(serde_json::json!(token_resource.id))) {
|
||||
Ok(_) => {}
|
||||
Err(err) => {
|
||||
return Err(err);
|
||||
@@ -106,58 +79,11 @@ pub fn create_token(
|
||||
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,
|
||||
})
|
||||
Ok((
|
||||
josekit::jwt::encode_with_signer(&payload, &header, &signer).unwrap(),
|
||||
(expire - time::OffsetDateTime::UNIX_EPOCH).whole_seconds(),
|
||||
))
|
||||
}
|
||||
Err(e) => Err(josekit::JoseError::InvalidClaim(e.into())),
|
||||
}
|
||||
}
|
||||
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
const TEST_MESSAGE: &str = "Testing for textsender";
|
||||
const TEST_ISSUER: &str = "textsender-test";
|
||||
const TEST_AUDIENCE: &str = "area-test";
|
||||
const TEST_USER_ID: uuid::Uuid = uuid::uuid!("9ab1c75f-d184-4913-ae99-544b4dcfcb41");
|
||||
const TEST_KEY: &str = "8342nhf7ycrt4983q7ryfc93w478ryfc3w9487ryfc342w98i7cy";
|
||||
|
||||
#[test]
|
||||
fn test_create_token() {
|
||||
let token_resource = super::TokenResource {
|
||||
message: String::from(TEST_MESSAGE),
|
||||
issuer: String::from(TEST_ISSUER),
|
||||
audiences: vec![String::from(TEST_AUDIENCE)],
|
||||
user_id: TEST_USER_ID,
|
||||
};
|
||||
|
||||
let token_duration = time::Duration::minutes(30);
|
||||
let key = String::from(TEST_KEY);
|
||||
|
||||
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 = {
|
||||
d_result.year() == cst.token_issued.year()
|
||||
&& d_result.month() == cst.token_issued.month()
|
||||
&& d_result.day() == cst.token_issued.day()
|
||||
&& d_result.hour() == cst.token_issued.hour()
|
||||
&& d_result.minute() == cst.token_issued.minute()
|
||||
&& d_result.second() == cst.token_issued.second()
|
||||
};
|
||||
assert!(they_match, "Issued times do not match");
|
||||
}
|
||||
Err(err) => {
|
||||
assert!(false, "Error: {err:?}");
|
||||
}
|
||||
},
|
||||
Err(err) => {
|
||||
assert!(false, "Error: {err:?}");
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
+10
-20
@@ -1,6 +1,6 @@
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct User {
|
||||
pub id: uuid::Uuid,
|
||||
pub phone_number: String,
|
||||
@@ -18,9 +18,7 @@ pub struct User {
|
||||
pub salt_id: uuid::Uuid,
|
||||
}
|
||||
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct ServiceUser {
|
||||
pub id: uuid::Uuid,
|
||||
pub username: String,
|
||||
@@ -34,9 +32,7 @@ pub struct ServiceUser {
|
||||
pub salt_id: uuid::Uuid,
|
||||
}
|
||||
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct Organization {
|
||||
pub id: uuid::Uuid,
|
||||
pub name: String,
|
||||
@@ -44,9 +40,7 @@ pub struct Organization {
|
||||
pub created: Option<time::OffsetDateTime>,
|
||||
}
|
||||
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct UserLoginHistory {
|
||||
pub id: uuid::Uuid,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
@@ -54,9 +48,7 @@ pub struct UserLoginHistory {
|
||||
pub user_id: uuid::Uuid,
|
||||
}
|
||||
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct ServiceUserLoginHistory {
|
||||
pub id: uuid::Uuid,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
@@ -64,9 +56,7 @@ pub struct ServiceUserLoginHistory {
|
||||
pub service_user_id: uuid::Uuid,
|
||||
}
|
||||
|
||||
#[derive(
|
||||
Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
|
||||
)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize, utoipa::ToSchema)]
|
||||
pub struct UserProfile {
|
||||
pub user_id: uuid::Uuid,
|
||||
pub phone_number: String,
|
||||
@@ -79,9 +69,9 @@ pub struct UserProfile {
|
||||
pub last_login: Option<time::OffsetDateTime>,
|
||||
}
|
||||
|
||||
#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow)]
|
||||
#[derive(Clone, Debug, Default, Deserialize, Serialize)]
|
||||
pub struct Salt {
|
||||
// #[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
|
||||
#[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