bump: textsender_models

Reviewed-on: phoenix/textsender_models#28

.gitea/workflows/pr.yml

@@ -0,0 +1,46 @@
+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

.gitea/workflows/release.yml

@@ -1,4 +1,4 @@
-name: Go Release
+name: Release Tagging
 
 on:
   push:
@@ -9,27 +9,28 @@ on:
       - main
 
 jobs:
-  build-and-release:
+  release:
     runs-on: ubuntu-24.04
     steps:
       - name: Checkout code
         uses: actions/checkout@v5
-
-      - name: Set up Go
-        uses: actions/setup-go@v6
         with:
-          go-version: '1.26.2'
+          fetch-depth: 0 # Important for git describe --tags
 
-      - name: Create version
+      - name: Install Rust
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: 1.96
+          components: cargo
+
+      - name: Extract Version from Cargo.toml
         id: version
         run: |
-          echo "Creating version"
-
-          VERSION="0.2.2"
+          VERSION=$(grep '^version = "' Cargo.toml | sed -E 's/version = "([^"]+)"/\1/')
           PROJECT_COMMIT_HASH=$(git rev-parse HEAD | cut -c 1-10)
           BRANCH_REF="${{ gitea.ref }}"
           BRANCH_NAME=$(echo "$BRANCH_REF" | cut -d '/' -f 3)
-          PROJECT_TAG_RELEASE="v$VERSION-$BRANCH_NAME-$PROJECT_COMMIT_HASH-556"
+          PROJECT_TAG_RELEASE="v$VERSION-$BRANCH_NAME-$PROJECT_COMMIT_HASH-111"
 
           echo "::set-output name=project_tag_release::$PROJECT_TAG_RELEASE"
 

.gitea/workflows/rust.yml

@@ -0,0 +1,68 @@
+name: Rust Build
+
+on:
+  push:
+    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
+
+  test:
+    name: Test Suite
+    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 test
+
+  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
+
+  build:
+    name: build
+    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 build

.gitea/workflows/workflow.yaml

@@ -1,27 +0,0 @@
-name: Go CI
-
-on: [push, pull_request] # Triggers on push or pull request events
-
-jobs:
-  test:
-    name: Test and Lint
-    runs-on: ubuntu-24.04
-    steps:
-      - name: Check out repository code
-        uses: actions/checkout@v5
-
-      - name: Set up Go
-        uses: actions/setup-go@v6
-        with:
-          go-version: '1.26.2'
-      - name: Configure Git for SSH
-        run: |
-          git config --global url."git@${{ secrets.GIT_HOST_ROOT }}:".insteadOf "https://${{ secrets.GIT_HOST_ROOT }}/"
-          go env -w GOPRIVATE=${{ secrets.GIT_HOST_ROOT }}/phoenix/*
-
-      - name: Download dependencies
-        run: |
-          go mod download
-
-      - name: Run tests
-        run: go test -v ./... # Runs all tests in the project

.gitignore

@@ -1 +1 @@
-/vendor/
+target/

Cargo.toml

@@ -0,0 +1,29 @@
+[package]
+name = "textsender_models"
+version = "0.4.3"
+edition = "2024"
+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.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" }
+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 = []
+
+[dev-dependencies]

README.md

@@ -1,10 +0,0 @@
-# textsender-models
-A library containing functions, structs, types, and other code for the textsender
-project
-
-
-### Building project
-```SHELL
-go mod tidy
-go mod vendor
-```

go.mod

@@ -1,15 +0,0 @@
-module git.kundeng.us/phoenix/textsender-models
-
-go 1.26.2
-
-require (
-	github.com/golang-jwt/jwt/v5 v5.3.1
-	github.com/google/uuid v1.6.0
-	github.com/stretchr/testify v1.11.1
-)
-
-require (
-	github.com/davecgh/go-spew v1.1.1 // indirect
-	github.com/pmezard/go-difflib v1.0.0 // indirect
-	gopkg.in/yaml.v3 v3.0.1 // indirect
-)

go.sum

@@ -1,14 +0,0 @@
-github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/golang-jwt/jwt/v5 v5.3.1 h1:kYf81DTWFe7t+1VvL7eS+jKFVWaUnK9cB1qbwn63YCY=
-github.com/golang-jwt/jwt/v5 v5.3.1/go.mod h1:fxCRLWMO43lRc8nhHWY6LGqRcf+1gQWArsqaEUEa5bE=
-github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
-github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
-github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
-gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

src/config/auxiliary/mod.rs

@@ -0,0 +1,21 @@
+#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize)]
+pub struct TwilioConfig {
+    #[serde(alias = "auth_id")]
+    pub account_sid: String,
+    #[serde(skip_serializing_if = "String::is_empty")]
+    pub service_sid: String,
+    #[serde(skip_serializing_if = "String::is_empty")]
+    pub auth_token: String,
+    #[serde(skip_serializing_if = "String::is_empty")]
+    pub phone_number: String,
+}
+
+impl TwilioConfig {
+    pub fn print_config(&self) {
+        println!("Twilio config");
+        println!("Account SID: {:?}", self.account_sid);
+        println!("Service SID: {:?}", self.service_sid);
+        println!("Auth Token: {:?}", self.auth_token);
+        println!("Number: {:?}", self.phone_number);
+    }
+}

src/config/mod.rs

@@ -0,0 +1 @@
+pub mod auxiliary;

src/contact/mod.rs

@@ -0,0 +1,19 @@
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+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,
+    #[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
+    pub user_id: Option<uuid::Uuid>,
+}

src/envy/environment.rs

@@ -0,0 +1,106 @@
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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 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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    crate::envy::init_envvar(key, &value)
+}
+
+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);
+
+    let mut envvar = crate::envy::init_envvar(key, &value);
+    crate::envy::init_delimiter(&mut envvar, ',');
+
+    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);
+
+    crate::envy::init_envvar(environment, &value)
+}

src/envy/keys.rs

@@ -0,0 +1,53 @@
+/// Environment key for Database management
+pub const DB_URL: &str = "DATABASE_URL";
+
+/// Environment key for secret main key
+/// Used for the textsender app
+pub const SECRET_MAIN_KEY: &str = "SECRET_MAIN_KEY";
+
+/// Environment key for service logins
+pub const SERVICE_PASSPHRASE: &str = "SERVICE_PASSPHRASE";
+
+/// Environment key for secret key
+/// Generic use of secret key that could be found in various apps
+pub const SECRET_KEY: &str = "SECRET_KEY";
+
+/// Environment key for root directory for the textsender app
+pub const ROOT_DIRECTORY: &str = "ROOT_DIRECTORY";
+
+/// Environment key for textsender api url
+pub const TEXTSENDER_BASE_API_URL: &str = "TEXTSENDER_BASE_API_URL";
+
+/// Environment key for textsender auth api url
+pub const TEXTSENDER_AUTH_BASE_API_URL: &str = "TEXTSENDER_AUTH_BASE_API_URL";
+
+/// Environment key for App status
+pub const APP_ENV: &str = "APP_ENV";
+/// Environment key for backend port. Used for both auth and core functionality
+pub const BACKEND_PORT: &str = "BACKEND_PORT";
+/// Environment key for frontend url
+pub const FRONTEND_URL: &str = "FRONTEND_URL";
+/// Environment key for application logging
+pub const RUST_LOG: &str = "RUST_LOG";
+/// Environment key for allowed origins for CORS support
+pub const ALLOWED_ORIGINS: &str = "ALLOWED_ORIGINS";
+
+pub mod error {
+    use const_format::concatcp;
+
+    pub const GENERAL_ERROR: &str = "must not be set in enviornment file";
+    pub const DB_URL: &str = concatcp!(super::DB_URL, " ", GENERAL_ERROR);
+    pub const SECRET_MAIN_KEY: &str = concatcp!(super::SECRET_MAIN_KEY, " ", GENERAL_ERROR);
+    pub const SERVICE_LOGIN: &str = concatcp!(super::SERVICE_PASSPHRASE, " ", GENERAL_ERROR);
+    pub const SECRET_KEY: &str = concatcp!(super::SECRET_KEY, " ", GENERAL_ERROR);
+    pub const ROOT_DIRECTORY: &str = concatcp!(super::ROOT_DIRECTORY, " ", GENERAL_ERROR);
+    pub const TEXTSENDER_BASE_API_URL: &str =
+        concatcp!(super::TEXTSENDER_BASE_API_URL, " ", GENERAL_ERROR);
+    pub const TEXTSENDER_AUTH_BASE_API_URL: &str =
+        concatcp!(super::TEXTSENDER_AUTH_BASE_API_URL, " ", GENERAL_ERROR);
+    pub const APP_ENV: &str = concatcp!(super::APP_ENV, " ", GENERAL_ERROR);
+    pub const BACKEND_PORT: &str = concatcp!(super::BACKEND_PORT, " ", GENERAL_ERROR);
+    pub const FRONTEND_URL: &str = concatcp!(super::FRONTEND_URL, " ", GENERAL_ERROR);
+    pub const RUST_LOG: &str = concatcp!(super::RUST_LOG, " ", GENERAL_ERROR);
+    pub const ALLOWED_ORIGINS: &str = concatcp!(super::ALLOWED_ORIGINS, " ", GENERAL_ERROR);
+}

src/envy/mod.rs

@@ -0,0 +1,39 @@
+pub mod environment;
+pub mod keys;
+pub mod utility;
+
+#[derive(Debug, Default, Clone)]
+pub struct EnvVar {
+    pub key: String,
+    pub value: String,
+    pub has_delimiter: bool,
+    pub delimiter: char,
+}
+
+pub fn init_envvar(key: &str, value: &str) -> EnvVar {
+    EnvVar {
+        key: key.to_string(),
+        value: value.to_string(),
+        has_delimiter: false,
+        ..Default::default()
+    }
+}
+
+pub fn init_delimiter(envvar: &mut EnvVar, delimiter: char) {
+    let mut amount_of_delimiters_found: i32 = 0;
+
+    for v in envvar.value.chars() {
+        if v == delimiter {
+            amount_of_delimiters_found += 1;
+        }
+    }
+
+    let has_delimiter = amount_of_delimiters_found >= 1;
+
+    if has_delimiter {
+        envvar.has_delimiter = has_delimiter;
+        envvar.delimiter = delimiter;
+    } else {
+        envvar.has_delimiter = has_delimiter;
+    }
+}

src/envy/utility.rs

@@ -0,0 +1,15 @@
+/// Take the Environment variable and delimitize it. If the value has a delimiter,
+/// extract it into some strings
+pub fn delimitize(var: &crate::envy::EnvVar) -> Result<Vec<String>, std::io::Error> {
+    if var.has_delimiter {
+        Ok(var
+            .value
+            .split(var.delimiter)
+            .map(|c| c.parse::<String>().unwrap())
+            .collect())
+    } else {
+        Err(std::io::Error::other(
+            "Environment variable does not have a delimiter",
+        ))
+    }
+}

src/lib.rs

@@ -0,0 +1,15 @@
+pub mod config;
+pub mod contact;
+pub mod envy;
+pub mod message;
+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,
+        }
+    }
+}

src/message/event/mod.rs

@@ -0,0 +1,18 @@
+pub const MESSAGE_EVENT_RESPONSE_STATUS_INSTANT: &str = "INSTANT";
+pub const MESSAGE_EVENT_RESPONSE_STATUS_SCHEDULED: &str = "SCHEDULED";
+
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct MessageEventResponse {
+    pub id: uuid::Uuid,
+    pub scheduled_message_event_id: uuid::Uuid,
+    /// Stores a json response of the sent message
+    pub response: serde_json::Value,
+    pub user_id: uuid::Uuid,
+    pub contact_id: uuid::Uuid,
+    pub message_id: uuid::Uuid,
+    pub status: String,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub sent: Option<time::OffsetDateTime>,
+}

src/message/mod.rs

@@ -0,0 +1,13 @@
+pub mod event;
+pub mod scheduling;
+
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct Message {
+    #[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
+    pub id: Option<uuid::Uuid>,
+    pub content: String,
+    #[serde(skip_serializing_if = "crate::init::is_uuid_nil")]
+    pub user_id: Option<uuid::Uuid>,
+}

src/message/scheduling/mod.rs

@@ -0,0 +1,29 @@
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, 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,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub created: Option<time::OffsetDateTime>,
+}
+
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct ScheduledMessage {
+    pub id: uuid::Uuid,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub scheduled: Option<time::OffsetDateTime>,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub created: Option<time::OffsetDateTime>,
+    pub status: String,
+    pub user_id: uuid::Uuid,
+}
+
+pub const READY: &str = "READY";
+pub const PENDING: &str = "PENDING";
+pub const PROCESSING: &str = "PROCESSING";
+pub const DONE: &str = "DONE";

src/token/mod.rs

@@ -0,0 +1,112 @@
+use serde::Deserialize;
+
+#[derive(Clone, Debug, Default, serde::Deserialize, serde::Serialize)]
+pub struct Claims {
+    pub user_id: uuid::Uuid,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub role: Option<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)]
+pub struct LoginResult {
+    pub user_id: uuid::Uuid,
+    pub access_token: String,
+    pub token_type: String,
+    pub expires_in: i64,
+    pub issued_at: i64,
+}
+
+/// Alias for LoginResult
+pub type Login = LoginResult;
+
+pub fn get_issued() -> time::Result<time::OffsetDateTime> {
+    Ok(time::OffsetDateTime::now_utc())
+}
+
+mod util {
+    pub fn time_to_std_time(
+        provided_time: &time::OffsetDateTime,
+    ) -> Result<std::time::SystemTime, std::time::SystemTimeError> {
+        let converted = std::time::SystemTime::from(*provided_time);
+        Ok(converted)
+    }
+}
+
+#[derive(Debug, utoipa::ToSchema)]
+pub struct TokenResource {
+    pub message: String,
+    pub issuer: String,
+    pub audiences: Vec<String>,
+    pub user_id: uuid::Uuid,
+}
+
+/// Token type
+pub const TOKEN_TYPE: &str = "JWT";
+
+pub fn create_token(
+    key: &String,
+    token_resource: &TokenResource,
+    duration: time::Duration,
+) -> 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();
+    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.user_id.is_nil() {
+        match payload.set_claim("user_id", Some(serde_json::json!(token_resource.user_id))) {
+            Ok(_) => {}
+            Err(err) => {
+                return Err(err);
+            }
+        }
+    }
+    match get_issued() {
+        Ok(issued) => {
+            let expire = issued + duration;
+            payload.set_issued_at(&util::time_to_std_time(&issued).unwrap());
+            payload.set_expires_at(&util::time_to_std_time(&expire).unwrap());
+
+            let signer = josekit::jws::alg::hmac::HmacJwsAlgorithm::Hs256
+                .signer_from_bytes(key.as_bytes())
+                .unwrap();
+            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())),
+    }
+}

src/user/mod.rs

@@ -0,0 +1,134 @@
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct User {
+    pub id: uuid::Uuid,
+    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>,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub last_login: Option<time::OffsetDateTime>,
+    #[serde(skip)]
+    pub salt_id: uuid::Uuid,
+}
+
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct ServiceUser {
+    pub id: uuid::Uuid,
+    pub username: String,
+    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)]
+    pub salt_id: uuid::Uuid,
+}
+
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct Organization {
+    pub id: uuid::Uuid,
+    pub name: String,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub created: Option<time::OffsetDateTime>,
+}
+
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct UserLoginHistory {
+    pub id: uuid::Uuid,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub login_time: Option<time::OffsetDateTime>,
+    pub user_id: uuid::Uuid,
+}
+
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct ServiceUserLoginHistory {
+    pub id: uuid::Uuid,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub login_time: Option<time::OffsetDateTime>,
+    pub service_user_id: uuid::Uuid,
+}
+
+#[derive(
+    Clone, Debug, Default, serde::Deserialize, serde::Serialize, sqlx::FromRow, utoipa::ToSchema,
+)]
+pub struct UserProfile {
+    pub user_id: uuid::Uuid,
+    pub phone_number: String,
+    pub username: String,
+    pub firstname: String,
+    pub lastname: String,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub created: Option<time::OffsetDateTime>,
+    #[serde(with = "time::serde::rfc3339::option")]
+    pub last_login: Option<time::OffsetDateTime>,
+}
+
+#[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,
+}
+
+impl Salt {
+    pub fn to_json(&self, output_pretty: bool) -> Result<String, serde_json::Error> {
+        if output_pretty {
+            serde_json::to_string_pretty(&self)
+        } else {
+            serde_json::to_string(&self)
+        }
+    }
+}
+
+pub fn init_user_profile(usr: &User) -> UserProfile {
+    UserProfile {
+        user_id: usr.id,
+        phone_number: usr.phone_number.clone(),
+        username: usr.username.clone(),
+        firstname: usr.firstname.clone(),
+        lastname: usr.lastname.clone(),
+        created: usr.created,
+        last_login: usr.last_login,
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    #[test]
+    fn test_init_user_profile() {
+        let usr = super::User {
+            id: uuid::Uuid::new_v4(),
+            phone_number: String::from("+12308438462"),
+            username: String::from("Cowboy99"),
+            password: String::from("238n7cyr2q89d3xhe2"),
+            firstname: String::from("BillyBob"),
+            lastname: String::from("Jones"),
+            created: Some(time::OffsetDateTime::now_utc()),
+            last_login: Some(time::OffsetDateTime::now_utc()),
+            ..Default::default()
+        };
+
+        let profile = super::init_user_profile(&usr);
+        assert_eq!(
+            usr.phone_number, profile.phone_number,
+            "Phone numbers are not equal"
+        );
+    }
+}

tx0/config/auxiliary/twilio_config.go

@@ -1,20 +0,0 @@
-package auxiliary
-
-import (
-	"fmt"
-)
-
-type TwilioConfig struct {
-	AccountSID string `json:"auth_sid"`
-	ServiceSID string `json:"service_sid"`
-	AuthToken  string `json:"auth_token"`
-	Number     string `json:"phone_number"`
-}
-
-func (config *TwilioConfig) PrintConfig() {
-	fmt.Println("Twilio config")
-	fmt.Println("Account SID:", config.AccountSID)
-	fmt.Println("Service SID:", config.ServiceSID)
-	fmt.Println("Auth Token:", config.AuthToken)
-	fmt.Println("Number:", config.Number)
-}

tx0/contact/contact.go

@@ -1,14 +0,0 @@
-package contact
-
-import (
-	"github.com/google/uuid"
-)
-
-type Contact struct {
-	Id          *uuid.UUID `json:"id,omitempty"`
-	Firstname   *string    `json:"first_name,omitempty"`
-	Lastname    *string    `json:"last_name,omitempty"`
-	Nickname    *string    `json:"nickname,omitempty"`
-	PhoneNumber string     `json:"phone_number"`
-	UserId      *uuid.UUID `json:"user_id,omitempty"`
-}

tx0/message/event/response.go

@@ -1,18 +0,0 @@
-package event
-
-import (
-	"time"
-
-	"github.com/google/uuid"
-)
-
-type MessageEventResponse struct {
-	Id                      uuid.UUID      `json:"id,omitempty"`
-	ScheduledMessageEventId uuid.UUID      `json:"scheduled_message_event_id,omitempty"`
-	Response                map[string]any `json:"response"`
-	UserId                  uuid.UUID      `json:"user_id,omitempty"`
-	ContactId               *uuid.UUID     `json:"contact_id,omitempty"`
-	MessageId               *uuid.UUID     `json:"message_id,omitempty"`
-	Status                  string         `json:"status"`
-	Sent                    time.Time      `json:"sent"`
-}

tx0/message/event/status.go

@@ -1,6 +0,0 @@
-package event
-
-const (
-	Message_Event_Response_Status_Instant   = "INSTANT"
-	Message_Event_Response_Status_Scheduled = "SCHEDULED"
-)

tx0/message/message.go

@@ -1,11 +0,0 @@
-package message
-
-import (
-	"github.com/google/uuid"
-)
-
-type Message struct {
-	Id      *uuid.UUID `json:"id,omitempty"`
-	Content string     `json:"content"`
-	UserId  *uuid.UUID `json:"user_id,omitempty"`
-}

tx0/message/scheduling/event.go

@@ -1,15 +0,0 @@
-package scheduling
-
-import (
-	"time"
-
-	"github.com/google/uuid"
-)
-
-type ScheduledMessageEvent struct {
-	Id                 uuid.UUID `json:"id"`
-	ContactId          uuid.UUID `json:"contact_id"`
-	MessageId          uuid.UUID `json:"message_id"`
-	ScheduledMessageId uuid.UUID `json:"scheduled_message_id"`
-	Created            time.Time `json:"created"`
-}

tx0/message/scheduling/message.go

@@ -1,15 +0,0 @@
-package scheduling
-
-import (
-	"time"
-
-	"github.com/google/uuid"
-)
-
-type ScheduledMessage struct {
-	Id        uuid.UUID `json:"id"`
-	Scheduled time.Time `json:"scheduled"`
-	Created   time.Time `json:"created"`
-	Status    string    `json:"status"`
-	UserId    uuid.UUID `json:"user_id"`
-}

tx0/message/scheduling/status.go

@@ -1,8 +0,0 @@
-package scheduling
-
-const (
-	Ready      = "READY"
-	Pending    = "PENDING"
-	Processing = "PROCESSING"
-	Done       = "DONE"
-)

tx0/token/token.go

@@ -1,24 +0,0 @@
-package token
-
-import (
-	"github.com/golang-jwt/jwt/v5"
-	"github.com/google/uuid"
-)
-
-type Claims struct {
-	UserId uuid.UUID `json:"user_id"`
-	Role   string    `json:"role"`
-	jwt.RegisteredClaims
-}
-
-type LoginResult struct {
-	UserId      uuid.UUID `json:"user_id"`
-	AccessToken string    `json:"access_token"`
-	TokenType   string    `json:"token_type"`
-	ExpiresIn   int64     `json:"expires_in"`
-	IssuedAt    int64     `json:"issued_at"`
-}
-
-// Alias for LoginResult
-// Will be deprecated at some point
-type Login = LoginResult

tx0/types/jsonb.go

@@ -1,42 +0,0 @@
-package types
-
-import (
-	"database/sql/driver"
-	"encoding/json"
-	"fmt"
-)
-
-// NOTE: Might end up removing this
-type JSONB json.RawMessage
-
-// Scan implements sql.Scanner
-func (j *JSONB) Scan(value interface{}) error {
-	if value == nil {
-		*j = nil
-		return nil
-	}
-
-	var data []byte
-	switch v := value.(type) {
-	case []byte:
-		// pgx may pass data as []byte in binary format
-		data = v
-	case string:
-		// pgx may pass data as string in text format
-		data = []byte(v)
-	default:
-		return fmt.Errorf("unsupported type: %T", v)
-	}
-
-	*j = JSONB(data)
-	return nil
-}
-
-// Value implements driver.Valuer
-func (j JSONB) Value() (driver.Value, error) {
-	if j == nil {
-		return nil, nil
-	} else {
-		return []byte(j), nil
-	}
-}

tx0/user/login_history.go

@@ -1,18 +0,0 @@
-package user
-
-import (
-	"github.com/google/uuid"
-	"time"
-)
-
-type UserLoginHistory struct {
-	Id        uuid.UUID `json:"id"`
-	LoginTime time.Time `json:"login_time"`
-	UserId    uuid.UUID `json:"user_id"`
-}
-
-type ServiceUserLoginHistory struct {
-	Id            uuid.UUID `json:"id"`
-	LoginTime     time.Time `json:"login_time"`
-	ServiceUserId uuid.UUID `json:"service_user_id"`
-}

tx0/user/service_user.go

@@ -1,16 +0,0 @@
-package user
-
-import (
-	"time"
-
-	"github.com/google/uuid"
-)
-
-type ServiceUser struct {
-	Id uuid.UUID `json:"id"`
-	// TODO: Remove the omitempty tags at a later point
-	Username   string     `json:"username,omitempty"`
-	Passphrase string     `json:"passphrase,omitempty"`
-	Created    time.Time  `json:"created"`
-	LastLogin  *time.Time `json:"last_login,omitempty"`
-}

tx0/user/user.go

@@ -1,20 +0,0 @@
-package user
-
-import (
-	"time"
-
-	"github.com/google/uuid"
-)
-
-type User struct {
-	Id          uuid.UUID  `json:"id"`
-	PhoneNumber string     `json:"phone_number"`
-	Username    string     `json:"username"`
-	Password    string     `json:"password"`
-	// Firstname is a pointer
-	Firstname   *string    `json:"first_name,omitempty"`
-	// Lastname is a pointer
-	Lastname    *string    `json:"last_name,omitempty"`
-	Created     time.Time  `json:"created"`
-	LastLogin   *time.Time `json:"last_login,omitempty"`
-}

tx0/user/user_profile.go

@@ -1,42 +0,0 @@
-package user
-
-import (
-	"fmt"
-	"time"
-
-	"github.com/google/uuid"
-)
-
-// TODO: Replace Usr with all the fields from User, except Password and other sensitive fields
-type UserProfile struct {
-	UserId uuid.UUID `json:"user_id"`
-	PhoneNumber string `json:"phone_number"`
-	Username string `json:"username"`
-	Firstname string `json:"firstname"`
-	Lastname string `json:"lastname"`
-	Created time.Time `json:"created"`
-	LastLogin *time.Time `json:"last_login,omitempty"`
-}
-
-func InitUserProfile(usr *User) (usrProfile *UserProfile, err error) {
-	if usr == nil {
-		return nil, fmt.Errorf("User is empty")
-	} else {
-		 usrProfile = new(UserProfile)
-			usrProfile.UserId = usr.Id
-			usrProfile.PhoneNumber = usr.PhoneNumber
-			usrProfile.Username = usr.Username
-			if usr.Firstname != nil {
-				usrProfile.Firstname = *usr.Firstname
-			}
-			if usr.Lastname != nil {
-				usrProfile.Lastname = *usr.Lastname
-			}
-			usrProfile.Created = usr.Created
-			if usr.LastLogin != nil {
-				usrProfile.LastLogin = usr.LastLogin
-			}
-
-			return usrProfile, nil
-	}
-}

tx0/user/user_profile_test.go

@@ -1,16 +0,0 @@
-package user
-
-import (
-	"testing"
-
-	"github.com/stretchr/testify/assert"
-)
-
-func TestInitUserProfile(t *testing.T) {
-	usr := User{Username: "Bob", PhoneNumber: "+12224572351", Password: "TheNight!"}
-
-	profile, err := InitUserProfile(&usr)
-
-	assert.NoError(t, err, "Error %v", err)
-	assert.NotEmpty(t, profile, "UserProfile is empty")
-}