Adding license (#34)

Reviewed-on: #34

.env.docker.sample

@@ -1,6 +1,6 @@
 JWT_SECRET=NULqYIzgt28bTiyziCd7IOO7b6LnWDW!
-DB_MAIN_NAME=textsender_db
-DB_MAIN_USER=textsender
+DB_MAIN_NAME=schedtxt_db
+DB_MAIN_USER=schedtxt
 DB_MAIN_PASSWORD=password
 DB_MAIN_HOST=main_db
 DB_MAIN_PORT=5432
@@ -10,4 +10,5 @@ TWILIO_AUTH_SID=9M438C93R943U4329MCU43C34U
 TWILIO_SERVICE_SID=9M4J3X8439U398NUVT3342MC349C348T
 TWILIO_AUTH_TOKEN="MA08HJp9tYtkfs72m8JIIROofRVm74oR0ixEYBHGYpB9"
 TWILIO_PHONE_NUMBER=+10123456789
-ALLOWED_ORIGINS="http://textsender.com"
+ALLOWED_ORIGINS="http://schedtxt.com,http://localhost:5173,http://localhost:9080,http://localhost:9081"
+APP_ENV=production

.env.local.sample

@@ -1,6 +1,6 @@
 JWT_SECRET=NULqYIzgt28bTiyziCd7IOO7b6LnWDW!
-DB_MAIN_NAME=textsender_db
-DB_MAIN_USER=textsender
+DB_MAIN_NAME=schedtxt_db
+DB_MAIN_USER=schedtxt
 DB_MAIN_PASSWORD=password
 DB_MAIN_HOST=localhost
 DB_MAIN_PORT=5432
@@ -10,4 +10,5 @@ TWILIO_AUTH_SID=9M438C93R943U4329MCU43C34U
 TWILIO_SERVICE_SID=9M4J3X8439U398NUVT3342MC349C348T
 TWILIO_AUTH_TOKEN="MA08HJp9tYtkfs72m8JIIROofRVm74oR0ixEYBHGYpB9"
 TWILIO_PHONE_NUMBER=+10123456789
-ALLOWED_ORIGINS="http://textsender.com"
+ALLOWED_ORIGINS="http://schedtxt.com,http://localhost:5173,http://localhost:9080,http://localhost:9081"
+APP_ENV=production

.gitea/workflows/pr.yml

@@ -1,28 +1,32 @@
-name: textsender_api PR
+name: schedtxt_api 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/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       - uses: Swatinem/rust-cache@v2
       - run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
 
           cargo check
 
@@ -30,38 +34,38 @@ jobs:
     name: Rustfmt
     runs-on: ubuntu-24.04
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       - run: rustup component add rustfmt
       - uses: Swatinem/rust-cache@v2
       - run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
           cargo fmt --all -- --check
 
   clippy:
     name: Clippy
     runs-on: ubuntu-24.04
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       - run: rustup component add clippy
       - uses: Swatinem/rust-cache@v2
       - run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
           cargo clippy -- -D warnings

.gitea/workflows/tests.yml

@@ -1,4 +1,4 @@
-name: Rust Build
+name: schedtxt_api Test
 
 on:
   pull_request:
@@ -32,10 +32,10 @@ jobs:
           --health-retries 5
 
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       # --- Add this step for explicit verification ---
       - name: Verify Docker Environment
         run: |
@@ -61,12 +61,12 @@ jobs:
           ENABLE_REGISTRATION: 'TRUE'
         run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
 
           cargo test
 
@@ -74,18 +74,18 @@ jobs:
     name: Rustfmt
     runs-on: ubuntu-24.04
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       - run: rustup component add rustfmt
       - uses: Swatinem/rust-cache@v2
       - run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
           cargo fmt --all -- --check

.gitea/workflows/workflow.yml

@@ -1,4 +1,4 @@
-name: Rust Build
+name: schedtxt_api Build
 
 on:
   push:
@@ -15,19 +15,19 @@ jobs:
     name: Check
     runs-on: ubuntu-24.04
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       - uses: Swatinem/rust-cache@v2
       - run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
 
           cargo check
 
@@ -52,10 +52,10 @@ jobs:
           --health-retries 5
 
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       # --- Add this step for explicit verification ---
       - name: Verify Docker Environment
         run: |
@@ -81,12 +81,12 @@ jobs:
           ENABLE_REGISTRATION: 'TRUE'
         run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
 
           cargo test
 
@@ -94,57 +94,57 @@ jobs:
     name: Rustfmt
     runs-on: ubuntu-24.04
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       - run: rustup component add rustfmt
       - uses: Swatinem/rust-cache@v2
       - run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
           cargo fmt --all -- --check
 
   clippy:
     name: Clippy
     runs-on: ubuntu-24.04
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       - run: rustup component add clippy
       - uses: Swatinem/rust-cache@v2
       - run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
           cargo clippy -- -D warnings
 
   build:
     name: build
     runs-on: ubuntu-24.04
     steps:
-      - uses: actions/checkout@v5
+      - uses: actions/checkout@v6
       - uses: actions-rust-lang/setup-rust-toolchain@v1
         with:
-          toolchain: 1.96
+          toolchain: 1.97
       - uses: Swatinem/rust-cache@v2
       - run: |
           mkdir -p ~/.ssh
-          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
-          chmod 600 ~/.ssh/textsender-models_deploy_key
+          echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/schedtxt-models_deploy_key
+          chmod 600 ~/.ssh/schedtxt-models_deploy_key
           ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
 
           eval $(ssh-agent -s)
-          ssh-add -v ~/.ssh/textsender-models_deploy_key
+          ssh-add -v ~/.ssh/schedtxt-models_deploy_key
           cargo build --release

Cargo.toml

@@ -1,8 +1,10 @@
 [package]
-name = "textsender_api"
-version = "0.2.0"
+name = "schedtxt_api"
+version = "0.2.4"
 edition = "2024"
-rust-version = "1.96"
+license = "MIT"
+description = "Core API for sending text messages"
+rust-version = "1.97"
 
 [dependencies]
 axum = { version = "0.8.9", features = ["multipart"] }
@@ -10,21 +12,18 @@ axum-extra = { version = "0.12.6", features = ["cookie"] }
 serde = { version = "1.0.228", features = ["derive"] }
 serde_json = { version = "1.0.150" }
 tokio = { version = "1.52.3", features = ["full"] }
-tokio-util = { version = "0.7.18", features = ["io"] }
-tower = { version = "0.5.3", features = ["full"] }
-tower-http = { version = "0.6.11", features = ["cors", "timeout"] }
+tower-http = { version = "0.7.0", features = ["cors", "timeout"] }
 tracing-subscriber = "0.3.23"
-futures = { version = "0.3.32" }
-uuid = { version = "1.23.3", features = ["v4", "serde"] }
+uuid = { version = "1.23.5", features = ["v4", "serde"] }
 sqlx = { version = "0.9.0", features = ["runtime-tokio", "tls-native-tls", "postgres", "time", "uuid"] }
-time = { version = "0.3.49", features = ["formatting", "macros", "parsing", "serde"]  }
+time = { version = "0.3.53", features = ["formatting", "macros", "parsing", "serde"]  }
 jsonwebtoken = { version = "10.4.0", features = ["rust_crypto"] }
-josekit = { version = "0.10.3" }
 utoipa = { version = "5.5.0", features = ["axum_extras"] }
 utoipa-swagger-ui = { version = "9.0.2", features = ["axum"] }
-textsender_models = { git = "ssh://git@git.kundeng.us/phoenix/textsender_models.git", tag = "v0.4.10" }
-swoosh = { git = "ssh://git@git.kundeng.us/phoenix/swoosh.git", tag = "v0.4.2.0" }
+schedtxt_models = { git = "ssh://git@git.kundeng.us/phoenix/schedtxt_models.git", tag = "v0.5.3" }
+swoosh = { git = "ssh://git@git.kundeng.us/phoenix/swoosh.git", tag = "v0.5.4" }
 
 [dev-dependencies]
+tower = { version = "0.5.3", features = ["full"] }
+josekit = { version = "0.10.3" }
 url = { version = "2.5.8" }
-tempfile = { version = "3.27.0" }

Dockerfile

@@ -1,50 +1,36 @@
-# Stage 1: Build the application
-FROM rust:1.96 as builder
+FROM rust:1.97 as builder
 
 # Set the working directory inside the container
 WORKDIR /usr/src/app
 
-# Install build dependencies if needed (e.g., git for cloning)
 RUN apt-get update && apt-get install -y --no-install-recommends \
     pkg-config libssl3 \
     ca-certificates \
     openssh-client git \
     && rm -rf /var/lib/apt/lists/*
 
-# Create .ssh/ directory for internal dependencies
 RUN mkdir -p -m 0700 ~/.ssh && \
     echo "Host git.kundeng.us" >> ~/.ssh/config && \
     echo "    User git" >> ~/.ssh/config && \
     chmod 600 ~/.ssh/config
 
-# << --- ADD HOST KEY HERE --- >>
 RUN ssh-keyscan git.kundeng.us >> ~/.ssh/known_hosts
 
-# Copy Cargo manifests
 COPY Cargo.toml Cargo.lock ./
 
-# Build *only* dependencies to leverage Docker cache
-# This dummy build caches dependencies as a separate layer
 RUN --mount=type=ssh mkdir src && \
     echo "fn main() {println!(\"if you see this, the build broke\")}" > src/main.rs && \
     cargo build --release --quiet && \
-    rm -rf src target/release/deps/textsender_api* # Clean up dummy build artifacts (replace textsender_api)
+    rm -rf src target/release/deps/schedtxt_api*
 
 # Copy the actual source code
 COPY src ./src
-# If you have other directories like `templates` or `static`, copy them too
 COPY .env ./.env
 COPY migrations ./migrations
 
-# << --- SSH MOUNT ADDED HERE --- >>
-# Build *only* dependencies to leverage Docker cache
-# This dummy build caches dependencies as a separate layer
-# Mount the SSH agent socket for this command
 RUN --mount=type=ssh \
     cargo build --release --quiet
 
-# Stage 2: Create the final, smaller runtime image
-# Use a minimal base image like debian-slim or even distroless for security/size
 FROM debian:trixie-slim
 
 # Install runtime dependencies if needed (e.g., SSL certificates)
@@ -53,18 +39,12 @@ RUN apt-get update && apt-get install -y ca-certificates libssl-dev libssl3 && r
 # Set the working directory
 WORKDIR /usr/local/bin
 
-# Copy the compiled binary from the builder stage
-# Replace 'textsender_api' with the actual name of your binary (usually the crate name)
-COPY --from=builder /usr/src/app/target/release/textsender_api .
+COPY --from=builder /usr/src/app/target/release/schedtxt_api .
 
-# Copy other necessary files like .env (if used for runtime config) or static assets
-# It's generally better to configure via environment variables in Docker though
 COPY --from=builder /usr/src/app/.env .
 COPY --from=builder /usr/src/app/migrations ./migrations
 
-# Expose the port your Axum app listens on (e.g., 3000 or 8000)
 EXPOSE 9081
 
 # Set the command to run your application
-# Ensure this matches the binary name copied above
-CMD ["./textsender_api"]
+CMD ["./schedtxt_api"]

LICENSE.md

@@ -0,0 +1,22 @@
+Copyright (c) 2026 Kun Deng.
+
+Permission is hereby granted, free of charge, to any person
+obtaining a copy of this software and associated documentation
+files (the "Software"), to deal in the Software without
+restriction, including without limitation the rights to use,
+copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the
+Software is furnished to do so, subject to the following
+conditions:
+
+The above copyright notice and this permission notice shall be
+included in all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
+OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
+HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
+WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
+OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,46 @@
+# schedtxt_api
+Core API to send text messages
+
+
+## Getting started
+Fastest way to get started is with docker. Make sure that is installed before moving forward.
+
+This application requires `schedtxt_auth` and `catapult` repositories to be located in the
+parent directory.
+
+```
+.
+..
+- schedtxt_auth/
+- schedtxt_api/
+- catapult/
+```
+
+Make sure the othe repositories are configured as it is required to operate successfully.
+
+Copy over the `.env.docker.sample` to `.env` to get started.
+
+### Token service
+The `JWT_SECRET` environment variable should be the same variable as `SECRET_MAIN_KEY` in
+`schedtxt_auth`.
+
+### Messaging configuration
+schedtxt uses `twilio` as the service to send the messages. You will need to sign up with
+them and be provided an account SID, service SID, auth token, and phone number. Update the
+corresponding `TWILIO_*` variables.
+
+
+### Database configuration
+Make sure to provide values for the `DB_MAIN_*` variables. For the sake of development, it
+can be left as it is.
+
+
+Build the container
+```
+docker build
+```
+
+Run the container
+```
+docker compose up
+```

docker-compose.yml

@@ -3,12 +3,11 @@ version: '3.8' # Use a recent version
 services:
   # --- Web API ---
   api:
-    build: # Tells docker-compose to build the Dockerfile in the current directory
+    build:
       context: .
-      ssh: ["default"]  # Uses host's SSH agent
-    container_name: textsender_api # Optional: Give the container a specific name
+      ssh: ["default"]
+    container_name: schedtxt_api
     ports:
-      # Map host port 8000 to container port 3000 (adjust as needed)
       - "9081:9081"
     env_file:
       - .env
@@ -16,33 +15,26 @@ services:
       main_db:
         condition: service_healthy
     networks:
-      - textsender_api-network
-    restart: unless-stopped # Optional: Restart policy
+      - schedtxt_api-network
+    restart: unless-stopped
 
   # --- Auth API ---
   auth_api:
     build:
-      # Might want to change the naming convention at some point for the repo names. textsender-models, textsender_auth, textesender-api, etc
-      context: ../textsender_auth # IMPORTANT: Relative path to the local checkout of your web API repo (containing the Dockerfile)
-      ssh: ["default"]  # Uses host's SSH agent
-      dockerfile: Dockerfile # Optional: Specify if your Dockerfile has a non-standard name
+      context: ../schedtxt_auth
+      ssh: ["default"]
+      dockerfile: Dockerfile
     container_name: auth_api
     restart: unless-stopped
     ports:
       - "9080:9080"
-    # environment:
-      # Environment variables your API needs, e.g., database connection
-      # Add other necessary environment variables
     env_file:
-     - ../textsender_auth/.env
+     - ../schedtxt_auth/.env
     depends_on:
       auth_db:
         condition: service_healthy
     networks:
-      - textsender_api-network
-    # Optional: Mount local code for development (live reload)
-    # volumes:
-    #  - ./path/to/your/web-api-repo:/app
+      - schedtxt_api-network
 
   # --- catapult service ---
   catapult:
@@ -60,24 +52,21 @@ services:
      - auth_api
      - auth_db
    networks:
-     - textsender_api-network
+     - schedtxt_api-network
 
 
   # PostgreSQL Database Service
-  # --- textsender_api web api db ---
   main_db:
-    image: postgres:18.4-alpine # Use an official Postgres image (Alpine variant is smaller)
-    container_name: textsender_api_db # Optional: Give the container a specific name
+    image: postgres:18.4-alpine
+    container_name: schedtxt_api_db
     environment:
       # These MUST match the user, password, and database name in the DATABASE_URL above
-      POSTGRES_USER: ${DB_MAIN_USER:-textsender_api}
+      POSTGRES_USER: ${DB_MAIN_USER:-schedtxt_api}
       POSTGRES_PASSWORD: ${DB_MAIN_PASSWORD:-password}
-      POSTGRES_DB: ${DB_MAIN_NAME:-textsender_api_db}
+      POSTGRES_DB: ${DB_MAIN_NAME:-schedtxt_api_db}
     volumes:
-      # Persist database data using a named volume
       - postgres_data:/var/lib/postgresql
     ports:
-      # Optional: Expose port 5432 ONLY if you need to connect directly from your host machine (e.g., for debugging)
       - "5432:5432"
     healthcheck:
         # Checks if Postgres is ready to accept connections
@@ -86,24 +75,23 @@ services:
         timeout: 5s
         retries: 5
         start_period: 10s
-    restart: always # Optional: Restart policy
+    restart: always
     networks:
-      - textsender_api-network
+      - schedtxt_api-network
 
-  # --- textsender_api web auth api db ---
+  # --- schedtxt_api web auth api db ---
   auth_db:
-    image: postgres:18.4-alpine # Use an official Postgres image (Alpine variant is smaller)
-    container_name: textsender_api_auth_db # Optional: Give the container a specific name
+    image: postgres:18.4-alpine
+    container_name: schedtxt_api_auth_db
     environment:
       # These MUST match the user, password, and database name in the DATABASE_URL above
-      POSTGRES_USER: ${DB_AUTH_USER:-textsender_auth}
+      POSTGRES_USER: ${DB_AUTH_USER:-schedtxt_auth}
       POSTGRES_PASSWORD: ${DB_AUTH_PASSWORD:-password}
-      POSTGRES_DB: ${DB_AUTH_NAME:-textsender_auth_db}
+      POSTGRES_DB: ${DB_AUTH_NAME:-schedtxt_auth_db}
     volumes:
       # Persist database data using a named volume
       - postgres_data_auth:/var/lib/postgresql
     ports: 
-      # Optional: Expose port 5432 ONLY if you need to connect directly from your host machine (e.g., for debugging)
       - "5433:5432"
     healthcheck:
         # Checks if Postgres is ready to accept connections
@@ -112,18 +100,16 @@ services:
         timeout: 5s
         retries: 5
         start_period: 10s
-    restart: always # Optional: Restart policy
+    restart: always
     networks:
-      - textsender_api-network
+      - schedtxt_api-network
 
-# Define the named volume for data persistence
 volumes:
   postgres_data:
-    driver: local # Use the default local driver
+    driver: local
   postgres_data_auth:
-    driver: local # Use the default local driver
+    driver: local
 
-# Define the network (optional, but good practice)
 networks:
-  textsender_api-network:
+  schedtxt_api-network:
     driver: bridge

src/auth/mod.rs

@@ -36,13 +36,11 @@ pub async fn auth<B>(
         (StatusCode::UNAUTHORIZED, Json(json_error))
     })?;
 
-    let secret_key = textsender_models::envy::environment::get_secret_main_key()
-        .await
-        .value;
+    let secret_key = schedtxt_models::envy::environment::get_secret_main_key().value;
 
     let mut validation = Validation::new(jsonwebtoken::Algorithm::HS256);
-    validation.set_audience(&["textsender"]); // Must match exactly what's in the token
-    let _claims = decode::<textsender_models::token::Claims>(
+    validation.set_audience(&["schedtxt"]); // Must match exactly what's in the token
+    let _claims = decode::<schedtxt_models::token::Claims>(
         &token,
         &DecodingKey::from_secret(secret_key.as_ref()),
         &validation,

src/caller/contact.rs

@@ -49,7 +49,7 @@ pub mod response {
     #[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
     pub struct AddContactResponse {
         pub message: String,
-        pub data: Vec<textsender_models::contact::Contact>,
+        pub data: Vec<schedtxt_models::contact::Contact>,
     }
 
     pub use AddContactResponse as GetContactResponse;
@@ -69,19 +69,9 @@ pub mod response {
         pub new_lastname: Option<String>,
         pub new_nickname: Option<String>,
     }
-
-    /*
-    #[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
-    pub struct GetContactResponse {
-        pub message: String,
-        pub data: Vec<textsender_models::contact::Contact>,
-    }
-    */
 }
 
 pub mod endpoint {
-    // use axum::{Json, response::IntoResponse};
-
     use crate::repo::contact as contact_repo;
 
     /// Endpoint to create Contact
@@ -126,7 +116,7 @@ pub mod endpoint {
                         sqlx::Error::RowNotFound => {
                             println!("Good to create");
                             // Put code here
-                            let mut contact = textsender_models::contact::Contact {
+                            let mut contact = schedtxt_models::contact::Contact {
                                 firstname: payload.firstname,
                                 lastname: payload.lastname,
                                 phone_number: payload.phone_number,

src/caller/instant.rs

@@ -23,7 +23,7 @@ pub mod response {
     #[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
     pub struct InstantMessageResponse {
         pub message: String,
-        pub data: Vec<textsender_models::message::event::MessageEventResponse>,
+        pub data: Vec<schedtxt_models::message::event::MessageEventResponse>,
     }
 }
 
@@ -57,7 +57,7 @@ pub mod endpoint {
         let mut response = super::response::InstantMessageResponse::default();
 
         if payload.is_valid() {
-            let mut contacts: Vec<textsender_models::contact::Contact> = Vec::new();
+            let mut contacts: Vec<schedtxt_models::contact::Contact> = Vec::new();
 
             for contact_id in &payload.contact_ids {
                 match contact_repo::get(&pool, contact_id).await {
@@ -81,8 +81,7 @@ pub mod endpoint {
                 match message_repo::get(&pool, &payload.message_id).await {
                     Ok(message) => {
                         println!("Valid message");
-                        let t_config =
-                            match textsender_models::config::auxiliary::load_config().await {
+                        let t_config = match schedtxt_models::config::auxiliary::load_config() {
                             Ok(config) => config,
                             Err(err) => {
                                 eprintln!("Error: {err:?}");
@@ -94,26 +93,32 @@ pub mod endpoint {
                             }
                         };
                         let mut results: Vec<
-                            textsender_models::message::event::MessageEventResponse,
+                            schedtxt_models::message::event::MessageEventResponse,
                         > = Vec::new();
                         let pp = swoosh::twilio::types::Parameters {
                             schedule: false,
                             schedule_at: None,
                         };
 
+                        let mut sendmsg = swoosh::SendMsg::default();
+                        sendmsg.load_config(
+                            &t_config.auth_token,
+                            &t_config.phone_number,
+                            &t_config.service_sid,
+                            &t_config.account_sid,
+                        );
+
                         for contact in &contacts {
-                            match swoosh::twilio::api::send_message(
-                                &message, contact, &pp, &t_config,
-                            )
-                            .await
-                            {
+                            sendmsg.load_message(&message.content);
+                            sendmsg.load_recipient(&contact.phone_number);
+                            match sendmsg.send_message(&pp).await {
                                 Ok(result) => {
                                     let val = swoosh::twilio::api::response_to_json(result).await;
-                                    let mer = textsender_models::message::event::MessageEventResponse {
+                                    let mer = schedtxt_models::message::event::MessageEventResponse {
                                         user_id: payload.user_id,
                                         // TODO: Make this more accurate
                                         sent: Some(time::OffsetDateTime::now_utc()),
-                                        status: String::from(textsender_models::message::event::MESSAGE_EVENT_RESPONSE_STATUS_INSTANT),
+                                        status: String::from(schedtxt_models::message::event::MESSAGE_EVENT_RESPONSE_STATUS_INSTANT),
                                         contact_id: contact.id.unwrap(),
                                         message_id: message.id.unwrap(),
                                         response: val,

src/caller/message/event.rs

@@ -40,7 +40,7 @@ pub mod response {
     #[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
     pub struct RecordMessageEventResponse {
         pub message: String,
-        pub data: Vec<textsender_models::message::event::MessageEventResponse>,
+        pub data: Vec<schedtxt_models::message::event::MessageEventResponse>,
     }
 
     pub use RecordMessageEventResponse as GetMERResponse;
@@ -74,7 +74,7 @@ pub mod endpoint {
         let mut response = super::response::RecordMessageEventResponse::default();
 
         if payload.is_valid() {
-            let mut mer = textsender_models::message::event::MessageEventResponse {
+            let mut mer = schedtxt_models::message::event::MessageEventResponse {
                 scheduled_message_event_id: Some(payload.scheduled_message_event_id),
                 user_id: payload.user_id,
                 sent: payload.sent,

src/caller/message/mod.rs

@@ -31,7 +31,7 @@ pub mod response {
     #[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
     pub struct AddMessageResponse {
         pub message: String,
-        pub data: Vec<textsender_models::message::Message>,
+        pub data: Vec<schedtxt_models::message::Message>,
     }
 
     pub use AddMessageResponse as GetMessageResponse;
@@ -65,7 +65,7 @@ pub mod endpoint {
         let mut response = super::response::AddMessageResponse::default();
 
         if payload.is_valid() {
-            let mut msg = textsender_models::message::Message {
+            let mut msg = schedtxt_models::message::Message {
                 content: payload.content,
                 user_id: Some(payload.user_id),
                 ..Default::default()

src/caller/message/scheduling.rs

@@ -52,10 +52,10 @@ pub mod request {
     impl UpdateScheduledMessageStatusRequest {
         pub fn is_valid(&self) -> bool {
             if !self.status.is_empty() || !self.scheduled_message_id.is_nil() {
-                self.status == textsender_models::message::scheduling::PENDING
-                    || self.status == textsender_models::message::scheduling::READY
-                    || self.status == textsender_models::message::scheduling::PROCESSING
-                    || self.status == textsender_models::message::scheduling::DONE
+                self.status == schedtxt_models::message::scheduling::PENDING
+                    || self.status == schedtxt_models::message::scheduling::READY
+                    || self.status == schedtxt_models::message::scheduling::PROCESSING
+                    || self.status == schedtxt_models::message::scheduling::DONE
             } else {
                 false
             }
@@ -70,19 +70,19 @@ pub mod response {
     #[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
     pub struct ScheduleMessageResponse {
         pub message: String,
-        pub data: Vec<textsender_models::message::scheduling::ScheduledMessage>,
+        pub data: Vec<schedtxt_models::message::scheduling::ScheduledMessage>,
     }
 
     #[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
     pub struct GetScheduledMessageResponse {
         pub message: String,
-        pub data: Vec<textsender_models::message::scheduling::ScheduledMessage>,
+        pub data: Vec<schedtxt_models::message::scheduling::ScheduledMessage>,
     }
 
     #[derive(Debug, Default, Deserialize, Serialize, ToSchema)]
     pub struct CreateScheduleMessageEventResponse {
         pub message: String,
-        pub data: Vec<textsender_models::message::scheduling::ScheduledMessageEvent>,
+        pub data: Vec<schedtxt_models::message::scheduling::ScheduledMessageEvent>,
     }
 
     pub use CreateScheduleMessageEventResponse as GetScheduledMessageEventResponse;
@@ -133,13 +133,13 @@ pub mod endpoint {
         let mut response = super::response::ScheduleMessageResponse::default();
 
         if payload.is_valid() {
-            if payload.status != textsender_models::message::scheduling::PENDING {
+            if payload.status != schedtxt_models::message::scheduling::PENDING {
                 response.message = String::from("scheduled message must be pending");
                 (axum::http::StatusCode::BAD_REQUEST, axum::Json(response))
             } else {
                 if can_schedule(&payload.scheduled) {
                     let mut scheduled_message =
-                        textsender_models::message::scheduling::ScheduledMessage {
+                        schedtxt_models::message::scheduling::ScheduledMessage {
                             scheduled: payload.scheduled,
                             status: payload.status,
                             ..Default::default()
@@ -402,7 +402,7 @@ pub mod endpoint {
                 }
             }
 
-            let mut scme = textsender_models::message::scheduling::ScheduledMessageEvent {
+            let mut scme = schedtxt_models::message::scheduling::ScheduledMessageEvent {
                 contact_id: payload.contact_id,
                 message_id: payload.message_id,
                 scheduled_message_id: payload.scheduled_message_id,

src/config/mod.rs

@@ -33,6 +33,7 @@ pub mod init {
             let cors = tower_http::cors::CorsLayer::new()
                 .allow_methods([
                     axum::http::Method::GET,
+                    axum::http::Method::PATCH,
                     axum::http::Method::POST,
                     axum::http::Method::PUT,
                     axum::http::Method::DELETE,
@@ -45,12 +46,12 @@ pub mod init {
                 .max_age(std::time::Duration::from_secs(3600)); // Cache the preflight response for 1 hour:cite[2]
 
             // Dynamically set the allowed origin based on the environment
-            match std::env::var(textsender_models::envy::keys::APP_ENV).as_deref() {
+            match std::env::var(schedtxt_models::envy::keys::APP_ENV).as_deref() {
                 Ok("production") => {
                     // In production, allow only your specific, trusted origins
                     let allowed_origins_env =
-                        textsender_models::envy::environment::get_allowed_origins().await;
-                    match textsender_models::envy::utility::delimitize(&allowed_origins_env) {
+                        schedtxt_models::envy::environment::get_allowed_origins();
+                    match schedtxt_models::envy::utility::delimitize(&allowed_origins_env) {
                         Ok(alwd) => {
                             let allowed_origins: Vec<axum::http::HeaderValue> = alwd
                                 .into_iter()
@@ -92,7 +93,7 @@ pub mod init {
             event_responses::RecordMessageEventResponse
             )),
     tags(
-        (name = "textsender API", description = "Web API to manage texting")
+        (name = "schedtxt API", description = "Web API to manage texting")
     )
     )]
     struct ApiDoc;

src/db/mod.rs

@@ -5,9 +5,7 @@ pub mod connection_settings {
 }
 
 pub async fn create_pool() -> Result<sqlx::PgPool, sqlx::Error> {
-    let database_url = textsender_models::envy::environment::get_db_url()
-        .await
-        .value;
+    let database_url = schedtxt_models::envy::environment::get_db_url().value;
     println!("Database url: {database_url}");
 
     PgPoolOptions::new()

src/main.rs

@@ -3,10 +3,10 @@ async fn main() {
     // initialize tracing
     tracing_subscriber::fmt::init();
 
-    match tokio::net::TcpListener::bind(textsender_api::config::host::get_full()).await {
+    match tokio::net::TcpListener::bind(schedtxt_api::config::host::get_full()).await {
         Ok(listener) => {
             // build our application with routes
-            let app = textsender_api::config::init::app().await;
+            let app = schedtxt_api::config::init::app().await;
             axum::serve(listener, app).await.unwrap();
         }
         Err(err) => {

src/repo/contact.rs

@@ -2,7 +2,7 @@ use sqlx::Row;
 
 pub async fn insert(
     pool: &sqlx::PgPool,
-    contact: &textsender_models::contact::Contact,
+    contact: &schedtxt_models::contact::Contact,
 ) -> Result<uuid::Uuid, sqlx::Error> {
     match sqlx::query(
         r#"
@@ -29,7 +29,7 @@ pub async fn insert(
 pub async fn get(
     pool: &sqlx::PgPool,
     id: &uuid::Uuid,
-) -> Result<textsender_models::contact::Contact, sqlx::Error> {
+) -> Result<schedtxt_models::contact::Contact, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, firstname, lastname, nickname, phone_number, user_id FROM "contacts"
@@ -46,7 +46,7 @@ pub async fn get(
 
             let phone_number: String = row.try_get("phone_number")?;
             let user_id: uuid::Uuid = row.try_get("user_id")?;
-            Ok(textsender_models::contact::Contact {
+            Ok(schedtxt_models::contact::Contact {
                 id: Some(id),
                 firstname: match row.try_get("firstname") {
                     Ok(val) => val,
@@ -81,7 +81,7 @@ pub async fn get_with_user_id_and_phone(
     pool: &sqlx::PgPool,
     user_id: &uuid::Uuid,
     phone_number: &str,
-) -> Result<textsender_models::contact::Contact, sqlx::Error> {
+) -> Result<schedtxt_models::contact::Contact, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, firstname, lastname, nickname, phone_number, user_id FROM "contacts"
@@ -103,7 +103,7 @@ pub async fn get_with_user_id_and_phone(
             let phone_number: String = row.try_get("phone_number")?;
             let user_id: uuid::Uuid = row.try_get("user_id")?;
             println!("Found");
-            Ok(textsender_models::contact::Contact {
+            Ok(schedtxt_models::contact::Contact {
                 id: Some(id),
                 firstname: Some(firstname),
                 lastname: Some(lastname),
@@ -122,7 +122,7 @@ pub async fn get_with_user_id_and_phone(
 pub async fn get_with_user_id(
     pool: &sqlx::PgPool,
     user_id: &uuid::Uuid,
-) -> Result<Vec<textsender_models::contact::Contact>, sqlx::Error> {
+) -> Result<Vec<schedtxt_models::contact::Contact>, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, firstname, lastname, nickname, phone_number, user_id FROM "contacts"
@@ -135,13 +135,13 @@ pub async fn get_with_user_id(
     .await
     {
         Ok(rows) => {
-            let mut contacts: Vec<textsender_models::contact::Contact> = Vec::new();
+            let mut contacts: Vec<schedtxt_models::contact::Contact> = Vec::new();
             for row in rows {
                 let id: uuid::Uuid = row.try_get("id")?;
 
                 let phone_number: String = row.try_get("phone_number")?;
                 let user_id: uuid::Uuid = row.try_get("user_id")?;
-                let contact = textsender_models::contact::Contact {
+                let contact = schedtxt_models::contact::Contact {
                     id: Some(id),
                     firstname: match row.try_get("firstname") {
                         Ok(val) => val,

src/repo/message/event.rs

@@ -2,7 +2,7 @@ use sqlx::Row;
 
 pub async fn insert(
     pool: &sqlx::PgPool,
-    event: &textsender_models::message::event::MessageEventResponse,
+    event: &schedtxt_models::message::event::MessageEventResponse,
 ) -> Result<uuid::Uuid, sqlx::Error> {
     match sqlx::query(
         r#"
@@ -31,7 +31,7 @@ pub async fn insert(
 pub async fn get(
     pool: &sqlx::PgPool,
     id: &uuid::Uuid,
-) -> Result<textsender_models::message::event::MessageEventResponse, sqlx::Error> {
+) -> Result<schedtxt_models::message::event::MessageEventResponse, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, scheduled_message_event_id, response, user_id, sent, contact_id, message_id, status FROM "message_event_responses"
@@ -54,7 +54,7 @@ pub async fn get(
 pub async fn get_with_user_id(
     pool: &sqlx::PgPool,
     user_id: &uuid::Uuid,
-) -> Result<Vec<textsender_models::message::event::MessageEventResponse>, sqlx::Error> {
+) -> Result<Vec<schedtxt_models::message::event::MessageEventResponse>, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, scheduled_message_event_id, response, user_id, sent, contact_id, message_id, status FROM "message_event_responses"
@@ -67,7 +67,7 @@ pub async fn get_with_user_id(
     .await
     {
         Ok(rows) => {
-            let mut events: Vec<textsender_models::message::event::MessageEventResponse> =
+            let mut events: Vec<schedtxt_models::message::event::MessageEventResponse> =
                 Vec::new();
             for row in rows {
                 match parse_row(&row).await {
@@ -88,7 +88,7 @@ pub async fn get_with_user_id(
 
 async fn parse_row(
     row: &sqlx::postgres::PgRow,
-) -> Result<textsender_models::message::event::MessageEventResponse, sqlx::Error> {
+) -> Result<schedtxt_models::message::event::MessageEventResponse, sqlx::Error> {
     println!("Parsing MER");
     let id: uuid::Uuid = row.try_get("id")?;
     let response: serde_json::Value = row.try_get("response")?;
@@ -96,17 +96,19 @@ async fn parse_row(
     let contact_id: uuid::Uuid = row.try_get("contact_id")?;
     let message_id: uuid::Uuid = row.try_get("message_id")?;
     let sent: time::OffsetDateTime = row.try_get("sent")?;
-    let scheduled_message_event_id: uuid::Uuid = row.try_get("scheduled_message_event_id")?;
+    let scheduled_message_event_id: Option<uuid::Uuid> = row
+        .try_get("scheduled_message_event_id")
+        .unwrap_or_default();
     let user_id: uuid::Uuid = row.try_get("user_id")?;
 
-    Ok(textsender_models::message::event::MessageEventResponse {
+    Ok(schedtxt_models::message::event::MessageEventResponse {
         id,
         response,
         contact_id,
         message_id,
         status,
         sent: Some(sent),
-        scheduled_message_event_id: Some(scheduled_message_event_id),
+        scheduled_message_event_id,
         user_id,
     })
 }

src/repo/message/mod.rs

@@ -5,7 +5,7 @@ use sqlx::Row;
 
 pub async fn insert(
     pool: &sqlx::PgPool,
-    message: &textsender_models::message::Message,
+    message: &schedtxt_models::message::Message,
     user_id: &uuid::Uuid,
 ) -> Result<uuid::Uuid, sqlx::Error> {
     match sqlx::query(
@@ -30,7 +30,7 @@ pub async fn insert(
 pub async fn get(
     pool: &sqlx::PgPool,
     id: &uuid::Uuid,
-) -> Result<textsender_models::message::Message, sqlx::Error> {
+) -> Result<schedtxt_models::message::Message, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, content, user_id FROM "messages"
@@ -47,7 +47,7 @@ pub async fn get(
 
             let content: String = row.try_get("content")?;
             let user_id: uuid::Uuid = row.try_get("user_id")?;
-            Ok(textsender_models::message::Message {
+            Ok(schedtxt_models::message::Message {
                 id: Some(id),
                 content,
                 user_id: Some(user_id),
@@ -60,7 +60,7 @@ pub async fn get(
 pub async fn get_with_user_id(
     pool: &sqlx::PgPool,
     user_id: &uuid::Uuid,
-) -> Result<Vec<textsender_models::message::Message>, sqlx::Error> {
+) -> Result<Vec<schedtxt_models::message::Message>, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, content, user_id FROM "messages"
@@ -73,13 +73,13 @@ pub async fn get_with_user_id(
     .await
     {
         Ok(rows) => {
-            let mut messages: Vec<textsender_models::message::Message> = Vec::new();
+            let mut messages: Vec<schedtxt_models::message::Message> = Vec::new();
             for row in rows {
                 let id: uuid::Uuid = row.try_get("id")?;
                 let content: String = row.try_get("content")?;
                 let user_id: uuid::Uuid = row.try_get("user_id")?;
 
-                let message = textsender_models::message::Message {
+                let message = schedtxt_models::message::Message {
                     id: Some(id),
                     content,
                     user_id: Some(user_id),

src/repo/message/scheduling.rs

@@ -2,7 +2,7 @@ use sqlx::Row;
 
 pub async fn insert(
     pool: &sqlx::PgPool,
-    scheduled_message: &textsender_models::message::scheduling::ScheduledMessage,
+    scheduled_message: &schedtxt_models::message::scheduling::ScheduledMessage,
     user_id: &uuid::Uuid,
 ) -> Result<(uuid::Uuid, time::OffsetDateTime), sqlx::Error> {
     match sqlx::query(
@@ -29,7 +29,7 @@ pub async fn insert(
 pub async fn get(
     pool: &sqlx::PgPool,
     id: &uuid::Uuid,
-) -> Result<textsender_models::message::scheduling::ScheduledMessage, sqlx::Error> {
+) -> Result<schedtxt_models::message::scheduling::ScheduledMessage, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, scheduled, created, status, user_id FROM "scheduled_messages"
@@ -52,7 +52,7 @@ pub async fn get(
 pub async fn get_with_user_id(
     pool: &sqlx::PgPool,
     user_id: &uuid::Uuid,
-) -> Result<Vec<textsender_models::message::scheduling::ScheduledMessage>, sqlx::Error> {
+) -> Result<Vec<schedtxt_models::message::scheduling::ScheduledMessage>, sqlx::Error> {
     match sqlx::query(
         r#"
         SELECT id, scheduled, created, status, user_id FROM "scheduled_messages"
@@ -65,7 +65,7 @@ pub async fn get_with_user_id(
     .await
     {
         Ok(rows) => {
-            let mut messages: Vec<textsender_models::message::scheduling::ScheduledMessage> =
+            let mut messages: Vec<schedtxt_models::message::scheduling::ScheduledMessage> =
                 Vec::new();
             for row in rows {
                 match parse_row(&row).await {
@@ -86,7 +86,7 @@ pub async fn get_with_user_id(
 
 pub async fn fetch(
     pool: &sqlx::PgPool,
-) -> Result<textsender_models::message::scheduling::ScheduledMessage, sqlx::Error> {
+) -> Result<schedtxt_models::message::scheduling::ScheduledMessage, sqlx::Error> {
     match sqlx::query(
         r#"
         UPDATE "scheduled_messages"
@@ -101,8 +101,8 @@ pub async fn fetch(
 		RETURNING id, scheduled, created, status, user_id
         "#,
     )
-    .bind(textsender_models::message::scheduling::PROCESSING)
-    .bind(textsender_models::message::scheduling::READY)
+    .bind(schedtxt_models::message::scheduling::PROCESSING)
+    .bind(schedtxt_models::message::scheduling::READY)
     .fetch_one(pool)
     .await
     {
@@ -136,14 +136,14 @@ pub async fn update_status(
 
 async fn parse_row(
     row: &sqlx::postgres::PgRow,
-) -> Result<textsender_models::message::scheduling::ScheduledMessage, sqlx::Error> {
+) -> Result<schedtxt_models::message::scheduling::ScheduledMessage, sqlx::Error> {
     let id: uuid::Uuid = row.try_get("id")?;
     let scheduled: time::OffsetDateTime = row.try_get("scheduled")?;
     let status: String = row.try_get("status")?;
     let created: time::OffsetDateTime = row.try_get("created")?;
     let user_id: uuid::Uuid = row.try_get("user_id")?;
 
-    Ok(textsender_models::message::scheduling::ScheduledMessage {
+    Ok(schedtxt_models::message::scheduling::ScheduledMessage {
         id,
         scheduled: Some(scheduled),
         created: Some(created),
@@ -157,7 +157,7 @@ pub mod sched_msg_event {
 
     pub async fn insert(
         pool: &sqlx::PgPool,
-        scheduled_message_event: &textsender_models::message::scheduling::ScheduledMessageEvent,
+        scheduled_message_event: &schedtxt_models::message::scheduling::ScheduledMessageEvent,
     ) -> Result<(uuid::Uuid, time::OffsetDateTime), sqlx::Error> {
         match sqlx::query(
             r#"
@@ -183,7 +183,7 @@ pub mod sched_msg_event {
     pub async fn get(
         pool: &sqlx::PgPool,
         id: &uuid::Uuid,
-    ) -> Result<textsender_models::message::scheduling::ScheduledMessageEvent, sqlx::Error> {
+    ) -> Result<schedtxt_models::message::scheduling::ScheduledMessageEvent, sqlx::Error> {
         match sqlx::query(
             r#"
             SELECT id, contact_id, message_id, scheduled_message_id, created FROM "scheduled_message_events"
@@ -206,8 +206,7 @@ pub mod sched_msg_event {
     pub async fn get_with_scheduled_message_id(
         pool: &sqlx::PgPool,
         scheduled_message_id: &uuid::Uuid,
-    ) -> Result<Vec<textsender_models::message::scheduling::ScheduledMessageEvent>, sqlx::Error>
-    {
+    ) -> Result<Vec<schedtxt_models::message::scheduling::ScheduledMessageEvent>, sqlx::Error> {
         match sqlx::query(
             r#"
             SELECT id, contact_id, message_id, scheduled_message_id, created FROM "scheduled_message_events"
@@ -220,7 +219,7 @@ pub mod sched_msg_event {
         .await
         {
             Ok(rows) => {
-                let mut scheduled_message_events: Vec<textsender_models::message::scheduling::ScheduledMessageEvent> =
+                let mut scheduled_message_events: Vec<schedtxt_models::message::scheduling::ScheduledMessageEvent> =
                     Vec::new();
                 for row in rows {
                     match parse_row(&row).await {
@@ -241,7 +240,7 @@ pub mod sched_msg_event {
 
     pub async fn delete(
         pool: &sqlx::PgPool,
-        scheduled_message_event: &textsender_models::message::scheduling::ScheduledMessageEvent,
+        scheduled_message_event: &schedtxt_models::message::scheduling::ScheduledMessageEvent,
     ) -> Result<(), sqlx::Error> {
         match sqlx::query(
             r#"
@@ -260,7 +259,7 @@ pub mod sched_msg_event {
 
     async fn parse_row(
         row: &sqlx::postgres::PgRow,
-    ) -> Result<textsender_models::message::scheduling::ScheduledMessageEvent, sqlx::Error> {
+    ) -> Result<schedtxt_models::message::scheduling::ScheduledMessageEvent, sqlx::Error> {
         let id: uuid::Uuid = row.try_get("id")?;
         let contact_id: uuid::Uuid = row.try_get("contact_id")?;
         let message_id: uuid::Uuid = row.try_get("message_id")?;
@@ -268,7 +267,7 @@ pub mod sched_msg_event {
         let created: time::OffsetDateTime = row.try_get("created")?;
 
         Ok(
-            textsender_models::message::scheduling::ScheduledMessageEvent {
+            schedtxt_models::message::scheduling::ScheduledMessageEvent {
                 id,
                 contact_id,
                 message_id,

tests/test.rs

@@ -1,4 +1,4 @@
-use textsender_api::db;
+use schedtxt_api::db;
 
 mod db_mgr {
     use std::str::FromStr;
@@ -6,9 +6,7 @@ mod db_mgr {
     pub const LIMIT: usize = 6;
 
     pub async fn get_pool() -> Result<sqlx::PgPool, sqlx::Error> {
-        let tm_db_url = textsender_models::envy::environment::get_db_url()
-            .await
-            .value;
+        let tm_db_url = schedtxt_models::envy::environment::get_db_url().value;
         let tm_options = sqlx::postgres::PgConnectOptions::from_str(&tm_db_url).unwrap();
         sqlx::PgPool::connect_with(tm_options).await
     }
@@ -20,9 +18,7 @@ mod db_mgr {
     }
 
     pub async fn connect_to_db(db_name: &str) -> Result<sqlx::PgPool, sqlx::Error> {
-        let db_url = textsender_models::envy::environment::get_db_url()
-            .await
-            .value;
+        let db_url = schedtxt_models::envy::environment::get_db_url().value;
         let options = sqlx::postgres::PgConnectOptions::from_str(&db_url)?.database(db_name);
         sqlx::PgPool::connect_with(options).await
     }
@@ -81,9 +77,7 @@ mod db_mgr {
     }
 
     pub async fn get_database_name() -> Result<String, Box<dyn std::error::Error>> {
-        let database_url = textsender_models::envy::environment::get_db_url()
-            .await
-            .value;
+        let database_url = schedtxt_models::envy::environment::get_db_url().value;
         let parsed_url = url::Url::parse(&database_url)?;
 
         if parsed_url.scheme() == "postgres" || parsed_url.scheme() == "postgresql" {
@@ -107,7 +101,7 @@ mod db_mgr {
 
 mod init {
     pub async fn app(pool: sqlx::PgPool) -> axum::Router {
-        textsender_api::config::init::routes()
+        schedtxt_api::config::init::routes()
             .await
             .layer(axum::Extension(pool))
             .layer(axum::extract::DefaultBodyLimit::max(1024 * 1024 * 1024))
@@ -142,8 +136,8 @@ mod util {
 pub fn token_fields() -> (String, String, String) {
     (
         String::from("What a twist!"),
-        String::from("textsender_test"),
-        String::from("textsender"),
+        String::from("schedtxt_test"),
+        String::from("schedtxt"),
     )
 }
 
@@ -191,20 +185,18 @@ pub fn test_mer_response() -> serde_json::Value {
 }
 
 pub async fn test_token() -> Result<String, josekit::JoseError> {
-    let key: String = textsender_models::envy::environment::get_secret_main_key()
-        .await
-        .value;
+    let key: String = schedtxt_models::envy::environment::get_secret_main_key().value;
     let (message, issuer, audience) = token_fields();
 
-    let token_resource = textsender_models::token::TokenResource {
+    let token_resource = schedtxt_models::token::TokenResource {
         message: message,
         issuer: issuer,
         audiences: vec![audience],
         user_id: TEST_USER_ID,
     };
 
-    match textsender_models::token::create_token(&key, &token_resource, time::Duration::hours(1)) {
-        Ok((access_token, _some_time)) => Ok(access_token),
+    match schedtxt_models::token::create_token(&key, token_resource, time::Duration::hours(1)) {
+        Ok(access_token) => Ok(access_token.access_token),
         Err(err) => Err(err),
     }
 }
@@ -247,7 +239,7 @@ mod request {
 
         match run_post(
             Some(&payload),
-            textsender_api::caller::endpoints::ADD_CONTACT,
+            schedtxt_api::caller::endpoints::ADD_CONTACT,
             axum::http::Method::POST,
             true,
         )
@@ -265,11 +257,7 @@ mod request {
         app: &axum::Router,
         id: &uuid::Uuid,
     ) -> Result<axum::response::Response, axum::http::Error> {
-        let uri = format!(
-            "{}?id={}",
-            textsender_api::caller::endpoints::GET_CONTACT,
-            id
-        );
+        let uri = format!("{}?id={}", schedtxt_api::caller::endpoints::GET_CONTACT, id);
 
         match run_post(None, &uri, axum::http::Method::GET, false).await {
             Ok(req) => match app.clone().oneshot(req).await {
@@ -297,7 +285,7 @@ mod request {
 
         match run_post(
             Some(&payload),
-            textsender_api::caller::endpoints::UPDATE_CONTACT_NAME,
+            schedtxt_api::caller::endpoints::UPDATE_CONTACT_NAME,
             axum::http::Method::PATCH,
             true,
         )
@@ -324,7 +312,7 @@ mod request {
 
             match super::run_post(
                 Some(&payload),
-                textsender_api::caller::endpoints::ADD_MESSAGE,
+                schedtxt_api::caller::endpoints::ADD_MESSAGE,
                 axum::http::Method::POST,
                 true,
             )
@@ -342,11 +330,7 @@ mod request {
             app: &axum::Router,
             id: &uuid::Uuid,
         ) -> Result<axum::response::Response, axum::http::Error> {
-            let uri = format!(
-                "{}?id={}",
-                textsender_api::caller::endpoints::GET_MESSAGE,
-                id
-            );
+            let uri = format!("{}?id={}", schedtxt_api::caller::endpoints::GET_MESSAGE, id);
 
             match super::run_post(None, &uri, axum::http::Method::GET, false).await {
                 Ok(req) => match app.clone().oneshot(req).await {
@@ -380,14 +364,14 @@ mod request {
                     "response": super::super::super::test_mer_response(),
                     "user_id": user_id,
                     "sent": sent,
-                    "status": textsender_models::message::event::MESSAGE_EVENT_RESPONSE_STATUS_SCHEDULED,
+                    "status": schedtxt_models::message::event::MESSAGE_EVENT_RESPONSE_STATUS_SCHEDULED,
                     "contact_id": contact_id,
                     "message_id": message_id
                 });
 
                 match super::super::run_post(
                     Some(&payload),
-                    textsender_api::caller::endpoints::RECORD_MESSAGE_EVENT_RESPONSE,
+                    schedtxt_api::caller::endpoints::RECORD_MESSAGE_EVENT_RESPONSE,
                     axum::http::Method::POST,
                     true,
                 )
@@ -407,7 +391,7 @@ mod request {
             ) -> Result<axum::response::Response, axum::http::Error> {
                 let uri = format!(
                     "{}?id={}",
-                    textsender_api::caller::endpoints::GET_MESSAGE_EVENT_RESPONSE,
+                    schedtxt_api::caller::endpoints::GET_MESSAGE_EVENT_RESPONSE,
                     id
                 );
 
@@ -438,13 +422,13 @@ mod request {
 
                 let payload = serde_json::json!({
                     "scheduled": scheduled,
-                    "status": textsender_models::message::scheduling::PENDING,
+                    "status": schedtxt_models::message::scheduling::PENDING,
                     "user_id": super::super::super::TEST_USER_ID,
                 });
 
                 match super::super::run_post(
                     Some(&payload),
-                    textsender_api::caller::endpoints::SCHEDULE_MESSAGE,
+                    schedtxt_api::caller::endpoints::SCHEDULE_MESSAGE,
                     axum::http::Method::POST,
                     true,
                 )
@@ -464,7 +448,7 @@ mod request {
             ) -> Result<axum::response::Response, axum::http::Error> {
                 let uri = format!(
                     "{}?id={}",
-                    textsender_api::caller::endpoints::GET_SCHEDULE_MESSAGE,
+                    schedtxt_api::caller::endpoints::GET_SCHEDULE_MESSAGE,
                     id
                 );
 
@@ -482,7 +466,7 @@ mod request {
             ) -> Result<axum::response::Response, axum::http::Error> {
                 match super::super::run_post(
                     None,
-                    textsender_api::caller::endpoints::FETCH_SCHEDULED_MESSAGE,
+                    schedtxt_api::caller::endpoints::FETCH_SCHEDULED_MESSAGE,
                     axum::http::Method::GET,
                     false,
                 )
@@ -501,7 +485,7 @@ mod request {
                 id: &uuid::Uuid,
                 updated_status: &str,
             ) -> Result<axum::response::Response, axum::http::Error> {
-                let uri = textsender_api::caller::endpoints::UPDATE_SCHEDULED_MESSAGE_STATUS;
+                let uri = schedtxt_api::caller::endpoints::UPDATE_SCHEDULED_MESSAGE_STATUS;
                 let payload = serde_json::json!({
                     "scheduled_message_id": id,
                     "status": updated_status
@@ -534,7 +518,7 @@ mod request {
 
                 match super::super::run_post(
                     Some(&payload),
-                    textsender_api::caller::endpoints::CREATE_SCHEDULED_MESSAGE_EVENT,
+                    schedtxt_api::caller::endpoints::CREATE_SCHEDULED_MESSAGE_EVENT,
                     axum::http::Method::POST,
                     true,
                 )
@@ -554,7 +538,7 @@ mod request {
             ) -> Result<axum::response::Response, axum::http::Error> {
                 let uri = format!(
                     "{}?scheduled_message_id={}",
-                    textsender_api::caller::endpoints::GET_SCHEDULED_MESSAGE_EVENT,
+                    schedtxt_api::caller::endpoints::GET_SCHEDULED_MESSAGE_EVENT,
                     scheduled_message_id
                 );
 
@@ -572,7 +556,7 @@ mod request {
                 scheduled_message_event_id: &uuid::Uuid,
             ) -> Result<axum::response::Response, axum::http::Error> {
                 let uri = super::super::super::util::format_url_with_value(
-                    textsender_api::caller::endpoints::DELETE_SCHEDULED_MESSAGE_EVENT,
+                    schedtxt_api::caller::endpoints::DELETE_SCHEDULED_MESSAGE_EVENT,
                     scheduled_message_event_id,
                 )
                 .await;
@@ -632,7 +616,7 @@ async fn test_create_contact() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -654,7 +638,7 @@ async fn test_get_contact() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -664,7 +648,7 @@ async fn test_get_contact() {
             match request::get_contact(&app, &id).await {
                 Ok(response) => {
                     let resp = util::get_resp_data::<
-                        textsender_api::caller::contact::response::GetContactResponse,
+                        schedtxt_api::caller::contact::response::GetContactResponse,
                     >(response)
                     .await;
                     assert_eq!(
@@ -691,13 +675,13 @@ async fn test_update_contact_names() {
     let (tm_pool, db_name, pool) = db_mgr::get_database_ready().await;
     let app = init::app(pool).await;
 
-    let mut opt_contact: Option<textsender_models::contact::Contact> = None;
+    let mut opt_contact: Option<schedtxt_models::contact::Contact> = None;
 
     // Send request
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -707,7 +691,7 @@ async fn test_update_contact_names() {
             match request::get_contact(&app, &id).await {
                 Ok(response) => {
                     let resp = util::get_resp_data::<
-                        textsender_api::caller::contact::response::GetContactResponse,
+                        schedtxt_api::caller::contact::response::GetContactResponse,
                     >(response)
                     .await;
                     assert_eq!(
@@ -745,7 +729,7 @@ async fn test_update_contact_names() {
             {
                 Ok(response) => {
                     let resp = util::get_resp_data::<
-                        textsender_api::caller::contact::response::UpdateContactNamesResponse,
+                        schedtxt_api::caller::contact::response::UpdateContactNamesResponse,
                     >(response)
                     .await;
                     assert_eq!(false, resp.data.is_empty(), "Error updating Contact names");
@@ -772,7 +756,7 @@ async fn test_create_message() {
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -794,13 +778,13 @@ async fn test_create_message() {
 async fn test_get_message() {
     let (tm_pool, db_name, pool) = db_mgr::get_database_ready().await;
     let app = init::app(pool).await;
-    let mut message_result: Option<textsender_models::message::Message> = None;
+    let mut message_result: Option<schedtxt_models::message::Message> = None;
 
     // Send request
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -823,7 +807,7 @@ async fn test_get_message() {
     match request::message::get_message(&app, &message_id).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::GetMessageResponse,
+                schedtxt_api::caller::message::response::GetMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -844,7 +828,7 @@ async fn test_schedule_message() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -867,7 +851,7 @@ async fn test_get_scheduled_message() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -883,7 +867,7 @@ async fn test_get_scheduled_message() {
         match request::message::scheduling::get_scheduled_messages(&app, &parsed_id).await {
             Ok(response) => {
                 let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::GetScheduledMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::GetScheduledMessageResponse,
             >(response)
             .await;
                 assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -911,7 +895,7 @@ async fn test_create_scheduled_message_event() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -925,7 +909,7 @@ async fn test_create_scheduled_message_event() {
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -940,7 +924,7 @@ async fn test_create_scheduled_message_event() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -961,7 +945,7 @@ async fn test_create_scheduled_message_event() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -986,7 +970,7 @@ async fn test_get_scheduled_message_event() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1000,7 +984,7 @@ async fn test_get_scheduled_message_event() {
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1015,7 +999,7 @@ async fn test_get_scheduled_message_event() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1036,7 +1020,7 @@ async fn test_get_scheduled_message_event() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1051,7 +1035,7 @@ async fn test_get_scheduled_message_event() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::GetScheduledMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::GetScheduledMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1076,7 +1060,7 @@ async fn test_delete_scheduled_message_event() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1090,7 +1074,7 @@ async fn test_delete_scheduled_message_event() {
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1105,7 +1089,7 @@ async fn test_delete_scheduled_message_event() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1126,7 +1110,7 @@ async fn test_delete_scheduled_message_event() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1141,7 +1125,7 @@ async fn test_delete_scheduled_message_event() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::GetScheduledMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::GetScheduledMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1154,7 +1138,7 @@ async fn test_delete_scheduled_message_event() {
             {
                 Ok(response) => {
                     let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::DeleteScheduledMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::DeleteScheduledMessageEventResponse,
             >(response)
             .await;
                     assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1184,7 +1168,7 @@ async fn test_update_scheduled_message_status() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1198,7 +1182,7 @@ async fn test_update_scheduled_message_status() {
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1213,7 +1197,7 @@ async fn test_update_scheduled_message_status() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1234,7 +1218,7 @@ async fn test_update_scheduled_message_status() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1247,13 +1231,13 @@ async fn test_update_scheduled_message_status() {
     match request::message::scheduling::update_scheduled_message_status(
         &app,
         &scheduled_message_id,
-        textsender_models::message::scheduling::READY,
+        schedtxt_models::message::scheduling::READY,
     )
     .await
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,
+                schedtxt_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1278,7 +1262,7 @@ async fn test_fetch_scheduled_message() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1292,7 +1276,7 @@ async fn test_fetch_scheduled_message() {
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1307,7 +1291,7 @@ async fn test_fetch_scheduled_message() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1328,7 +1312,7 @@ async fn test_fetch_scheduled_message() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1341,13 +1325,13 @@ async fn test_fetch_scheduled_message() {
     match request::message::scheduling::update_scheduled_message_status(
         &app,
         &scheduled_message_id,
-        textsender_models::message::scheduling::READY,
+        schedtxt_models::message::scheduling::READY,
     )
     .await
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,
+                schedtxt_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1360,7 +1344,7 @@ async fn test_fetch_scheduled_message() {
     match request::message::scheduling::fetch_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::FetchScheduledMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::FetchScheduledMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1386,7 +1370,7 @@ async fn test_record_message_event_response() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1400,7 +1384,7 @@ async fn test_record_message_event_response() {
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1415,7 +1399,7 @@ async fn test_record_message_event_response() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1436,7 +1420,7 @@ async fn test_record_message_event_response() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1451,13 +1435,13 @@ async fn test_record_message_event_response() {
     match request::message::scheduling::update_scheduled_message_status(
         &app,
         &scheduled_message_id,
-        textsender_models::message::scheduling::READY,
+        schedtxt_models::message::scheduling::READY,
     )
     .await
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,
+                schedtxt_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1470,7 +1454,7 @@ async fn test_record_message_event_response() {
     match request::message::scheduling::fetch_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::FetchScheduledMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::FetchScheduledMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1497,7 +1481,7 @@ async fn test_record_message_event_response() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::event::response::RecordMessageEventResponse,
+                schedtxt_api::caller::message::event::response::RecordMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1523,7 +1507,7 @@ async fn test_get_message_event_response() {
     match request::create_contact(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::contact::response::AddContactResponse,
+                schedtxt_api::caller::contact::response::AddContactResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1537,7 +1521,7 @@ async fn test_get_message_event_response() {
     match request::message::create_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::response::AddMessageResponse,
+                schedtxt_api::caller::message::response::AddMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1552,7 +1536,7 @@ async fn test_get_message_event_response() {
     match request::message::scheduling::create_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::ScheduleMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::ScheduleMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1573,7 +1557,7 @@ async fn test_get_message_event_response() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
+                schedtxt_api::caller::message::scheduling::response::CreateScheduleMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1588,13 +1572,13 @@ async fn test_get_message_event_response() {
     match request::message::scheduling::update_scheduled_message_status(
         &app,
         &scheduled_message_id,
-        textsender_models::message::scheduling::READY,
+        schedtxt_models::message::scheduling::READY,
     )
     .await
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,
+                schedtxt_api::caller::message::scheduling::response::UpdateScheduledMessageStatusResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1607,7 +1591,7 @@ async fn test_get_message_event_response() {
     match request::message::scheduling::fetch_scheduled_message(&app).await {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::scheduling::response::FetchScheduledMessageResponse,
+                schedtxt_api::caller::message::scheduling::response::FetchScheduledMessageResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1634,7 +1618,7 @@ async fn test_get_message_event_response() {
     {
         Ok(response) => {
             let resp = util::get_resp_data::<
-                textsender_api::caller::message::event::response::RecordMessageEventResponse,
+                schedtxt_api::caller::message::event::response::RecordMessageEventResponse,
             >(response)
             .await;
             assert_eq!(false, resp.data.is_empty(), "Should not be empty");
@@ -1642,7 +1626,7 @@ async fn test_get_message_event_response() {
             match request::message::event::get_message_event_response(&app, &mer.id).await {
                 Ok(response) => {
                     let resp = util::get_resp_data::<
-                        textsender_api::caller::message::event::response::GetMERResponse,
+                        schedtxt_api::caller::message::event::response::GetMERResponse,
                     >(response)
                     .await;
                     assert_eq!(false, resp.data.is_empty(), "Should not be empty");