Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f9c098b92f | ||
|
|
6801b1e635 | ||
|
|
50aa9089f0 | ||
|
|
8dbfd88aae | ||
|
|
71ba4a9c56 | ||
|
|
8fc4bb7626 |
@@ -4,6 +4,9 @@ on:
|
||||
pull_request:
|
||||
branches:
|
||||
- main
|
||||
push:
|
||||
branches:
|
||||
- main
|
||||
|
||||
concurrency:
|
||||
group: ${{ github.workflow }}-${{ github.ref }}
|
||||
@@ -14,10 +17,10 @@ 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
|
||||
@@ -33,10 +36,10 @@ 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: |
|
||||
@@ -53,10 +56,10 @@ jobs:
|
||||
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: |
|
||||
|
||||
Generated
+227
-649
File diff suppressed because it is too large
Load Diff
+8
-8
@@ -1,18 +1,18 @@
|
||||
[package]
|
||||
name = "catapult"
|
||||
version = "0.3.0"
|
||||
rust-version = "1.96"
|
||||
version = "0.3.5"
|
||||
rust-version = "1.97"
|
||||
license = "MIT"
|
||||
description = "Service to carry out text message scheduling"
|
||||
edition = "2024"
|
||||
|
||||
[dependencies]
|
||||
tokio = { version = "1.52.3", features = ["full"] }
|
||||
futures = { version = "0.3.32" }
|
||||
reqwest = { version = "0.13.4", features = ["json", "stream", "multipart"] }
|
||||
serde = { version = "1.0.228", features = ["derive"] }
|
||||
serde_json = { version = "1.0.150" }
|
||||
time = { version = "0.3.49", features = ["formatting", "macros", "parsing", "serde"] }
|
||||
uuid = { version = "1.23.3", features = ["v4", "serde"] }
|
||||
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" }
|
||||
time = { version = "0.3.53", features = ["formatting", "macros", "parsing", "serde"] }
|
||||
uuid = { version = "1.23.5", features = ["v4", "serde"] }
|
||||
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]
|
||||
|
||||
+1
-18
@@ -1,5 +1,4 @@
|
||||
# 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
|
||||
@@ -11,35 +10,23 @@ RUN apt-get update && apt-get install -y --no-install-recommends \
|
||||
openssh-client git \
|
||||
&& rm -rf /var/lib/apt/lists/*
|
||||
|
||||
# << --- ADD HOST KEY HERE --- >>
|
||||
# Replace 'yourgithost.com' with the actual hostname (e.g., github.com)
|
||||
RUN mkdir -p -m 0700 ~/.ssh && \
|
||||
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/catapult*
|
||||
|
||||
# Copy the actual source code
|
||||
COPY src ./src
|
||||
# If you have other directories like `templates` or `static`, copy them too
|
||||
COPY .env ./.env
|
||||
|
||||
# << --- 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)
|
||||
@@ -48,12 +35,8 @@ 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 'catapult' with the actual name of your binary (usually the crate name)
|
||||
COPY --from=builder /usr/src/app/target/release/catapult .
|
||||
|
||||
# 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 .
|
||||
|
||||
# Set the command to run your application
|
||||
|
||||
+22
@@ -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.
|
||||
@@ -0,0 +1,29 @@
|
||||
# catapult
|
||||
A service that manages scheduling text messages.
|
||||
|
||||
|
||||
## Getting started
|
||||
Docker isn't required, but it is the quickest way to get started.
|
||||
|
||||
Copy over the `.env.docker.sample` to `.env`. From that point, make edits to the
|
||||
file to get it working.
|
||||
|
||||
### Messaging configuration
|
||||
The service vendor used to send the messages is `twilio`. After signing up and being
|
||||
provided credentials, update the `TWILIO_*` variables.
|
||||
|
||||
### Client-Server interaction
|
||||
In order for `catapult` to function properly, credentials need to be provided via
|
||||
`SERVICE_USERNAME` and `SERVICE_PASSPHRASE`. The credentials are created from making
|
||||
an API call to register a service user in `textsender_auth`. So, you need to have credentials
|
||||
set in the `.env` file and use those same credentials to create the account in the
|
||||
API call.
|
||||
|
||||
### API sources
|
||||
The `AUTH_URL` and `API_URL` variables need to be set for the base URL for the
|
||||
`textsender_auth` and `textsender_api` respectively.
|
||||
|
||||
|
||||
Since this is meant to run along with `textsender_auth` and `textsender_api`, it isn't
|
||||
meant to be run by itself. So no need to build or run the container in isolation, but
|
||||
that capability is present.
|
||||
+2
-2
@@ -4,8 +4,8 @@ services:
|
||||
songparser:
|
||||
build:
|
||||
context: .
|
||||
ssh: ["default"] # Uses host's SSH agent
|
||||
ssh: ["default"]
|
||||
container_name: catapult
|
||||
env_file:
|
||||
- .env
|
||||
restart: unless-stopped # Optional: Restart policy
|
||||
restart: unless-stopped
|
||||
|
||||
+25
-21
@@ -9,26 +9,24 @@ pub struct App {
|
||||
pub auth_url: String,
|
||||
pub service_username: String,
|
||||
pub service_passphrase: String,
|
||||
pub twilio_config: textsender_models::config::auxiliary::TwilioConfig,
|
||||
pub twilio_config: schedtxt_models::config::auxiliary::TwilioConfig,
|
||||
}
|
||||
|
||||
// TODO: Change this to non-async at some point.
|
||||
// Will require changes in other libraries
|
||||
pub async fn load_app() -> Result<App, std::io::Error> {
|
||||
use textsender_models::envy;
|
||||
let auth_url_env = envy::environment::get_env("AUTH_URL").await;
|
||||
let api_url_env = envy::environment::get_env("API_URL").await;
|
||||
let service_username_env = envy::environment::get_env("SERVICE_USERNAME").await;
|
||||
let service_passphrase_env = envy::environment::get_env("SERVICE_PASSPHRASE").await;
|
||||
pub fn load_app() -> Result<App, std::io::Error> {
|
||||
use schedtxt_models::envy;
|
||||
let auth_url_env = envy::environment::get_env("AUTH_URL");
|
||||
let api_url_env = envy::environment::get_env("API_URL");
|
||||
let service_username_env = envy::environment::get_env("SERVICE_USERNAME");
|
||||
let service_passphrase_env = envy::environment::get_env("SERVICE_PASSPHRASE");
|
||||
|
||||
let envs = vec![
|
||||
api_url_env,
|
||||
auth_url_env,
|
||||
service_username_env,
|
||||
service_passphrase_env,
|
||||
&api_url_env,
|
||||
&auth_url_env,
|
||||
&service_username_env,
|
||||
&service_passphrase_env,
|
||||
];
|
||||
|
||||
let check_envs = |vs: &Vec<envy::EnvVar>| -> (bool, Option<String>) {
|
||||
let check_envs = |vs: &Vec<&envy::EnvVar>| -> (bool, Option<String>) {
|
||||
for env in vs {
|
||||
if env.value.is_empty() {
|
||||
return (false, Some(format!("Key {} is not provided", env.key)));
|
||||
@@ -38,19 +36,25 @@ pub async fn load_app() -> Result<App, std::io::Error> {
|
||||
};
|
||||
|
||||
let (envs_valid, reason) = check_envs(&envs);
|
||||
|
||||
if envs_valid {
|
||||
match textsender_models::config::auxiliary::load_config().await {
|
||||
let auth_url: String = auth_url_env.value;
|
||||
let api_url: String = api_url_env.value;
|
||||
let service_username: String = service_username_env.value;
|
||||
let service_passphrase: String = service_passphrase_env.value;
|
||||
match schedtxt_models::config::auxiliary::load_config() {
|
||||
Ok(twilio_config) => Ok(App {
|
||||
api_url: envs[0].value.clone(),
|
||||
auth_url: envs[1].value.clone(),
|
||||
service_username: envs[2].value.clone(),
|
||||
service_passphrase: envs[3].value.clone(),
|
||||
api_url,
|
||||
auth_url,
|
||||
service_username,
|
||||
service_passphrase,
|
||||
twilio_config,
|
||||
}),
|
||||
Err(err) => Err(err),
|
||||
}
|
||||
} else {
|
||||
Err(std::io::Error::other(reason.unwrap()))
|
||||
match reason {
|
||||
Some(reason) => Err(std::io::Error::other(reason)),
|
||||
None => Err(std::io::Error::other("No reason found")),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
+10
-7
@@ -6,8 +6,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
std::process::exit(-1);
|
||||
}
|
||||
|
||||
let app = match catapult::app::load_app().await {
|
||||
Ok(app) => app,
|
||||
let app = match catapult::app::load_app() {
|
||||
Ok(app) => std::sync::Arc::new(app),
|
||||
Err(err) => {
|
||||
eprintln!("Error: {err:?}");
|
||||
std::process::exit(-1);
|
||||
@@ -16,9 +16,11 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
|
||||
println!("App: {app:?}");
|
||||
|
||||
let auth = catapult::service::auth::Auth { app: app.clone() };
|
||||
let auth = catapult::service::auth::Auth {
|
||||
app: std::sync::Arc::clone(&app),
|
||||
};
|
||||
let token = match auth.get_token().await {
|
||||
Ok(token) => token,
|
||||
Ok(token) => std::sync::Arc::new(token),
|
||||
Err(err) => {
|
||||
eprintln!("Error getting token");
|
||||
eprintln!("Error: {err:?}");
|
||||
@@ -27,8 +29,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
};
|
||||
|
||||
let mut svc = catapult::service::core::Service {
|
||||
app: app.clone(),
|
||||
token,
|
||||
app: std::sync::Arc::clone(&app),
|
||||
token: std::sync::Arc::clone(&token),
|
||||
};
|
||||
|
||||
loop {
|
||||
@@ -36,7 +38,8 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
match auth.get_refresh_token(&svc.token).await {
|
||||
Ok(refresh) => {
|
||||
println!("Refresh token: {refresh:?}");
|
||||
svc.token = refresh;
|
||||
let refreshed = std::sync::Arc::new(refresh);
|
||||
svc.token = refreshed;
|
||||
}
|
||||
Err(err) => {
|
||||
eprintln!("Error: {err:?}");
|
||||
|
||||
+7
-7
@@ -1,9 +1,9 @@
|
||||
pub struct Auth {
|
||||
pub app: crate::app::App,
|
||||
pub app: std::sync::Arc<crate::app::App>,
|
||||
}
|
||||
|
||||
impl Auth {
|
||||
pub async fn get_token(&self) -> Result<textsender_models::token::Login, std::io::Error> {
|
||||
pub async fn get_token(&self) -> Result<schedtxt_models::token::Login, std::io::Error> {
|
||||
let client = reqwest::Client::new();
|
||||
let endpoint = String::from("api/v1/service/login");
|
||||
let api_url = format!("{}/{endpoint}", self.app.auth_url);
|
||||
@@ -37,8 +37,8 @@ impl Auth {
|
||||
|
||||
pub async fn get_refresh_token(
|
||||
&self,
|
||||
login_result: &textsender_models::token::Login,
|
||||
) -> Result<textsender_models::token::Login, std::io::Error> {
|
||||
login_result: &schedtxt_models::token::Login,
|
||||
) -> Result<schedtxt_models::token::Login, std::io::Error> {
|
||||
let client = reqwest::Client::new();
|
||||
let endpoint = String::from("api/v1/token/refresh");
|
||||
let api_url = format!("{}/{endpoint}", self.app.auth_url);
|
||||
@@ -70,7 +70,7 @@ impl Auth {
|
||||
|
||||
async fn parse_token_response(
|
||||
response: &str,
|
||||
) -> Result<textsender_models::token::LoginResult, std::io::Error> {
|
||||
) -> Result<schedtxt_models::token::LoginResult, std::io::Error> {
|
||||
match serde_json::from_str::<serde_json::Value>(response) {
|
||||
Ok(j) => {
|
||||
println!("Good");
|
||||
@@ -85,7 +85,7 @@ async fn parse_token_response(
|
||||
Err(std::io::Error::other("Error response is empty"))
|
||||
} else {
|
||||
let lr = lrs[0].clone();
|
||||
let ll: textsender_models::token::LoginResult =
|
||||
let ll: schedtxt_models::token::LoginResult =
|
||||
match serde_json::from_value(lr) {
|
||||
Ok(lr) => lr,
|
||||
Err(err) => {
|
||||
@@ -102,7 +102,7 @@ async fn parse_token_response(
|
||||
}
|
||||
}
|
||||
|
||||
pub async fn has_token_expired(token: &textsender_models::token::LoginResult) -> bool {
|
||||
pub async fn has_token_expired(token: &schedtxt_models::token::LoginResult) -> bool {
|
||||
let now = time::OffsetDateTime::now_utc();
|
||||
let expire = match time::OffsetDateTime::from_unix_timestamp(token.expires_in) {
|
||||
Ok(res) => res,
|
||||
|
||||
@@ -1,13 +1,13 @@
|
||||
pub struct Contact {
|
||||
pub app: crate::app::App,
|
||||
pub token: textsender_models::token::LoginResult,
|
||||
pub app: std::sync::Arc<crate::app::App>,
|
||||
pub token: std::sync::Arc<schedtxt_models::token::LoginResult>,
|
||||
}
|
||||
|
||||
impl Contact {
|
||||
pub async fn get(
|
||||
&self,
|
||||
contact_id: &uuid::Uuid,
|
||||
) -> Result<Vec<textsender_models::contact::Contact>, std::io::Error> {
|
||||
) -> Result<Vec<schedtxt_models::contact::Contact>, std::io::Error> {
|
||||
let client = reqwest::Client::new();
|
||||
let endpoint = format!("api/v1/contact?id={contact_id}");
|
||||
let api_url = format!("{}/{endpoint}", self.app.api_url);
|
||||
@@ -34,17 +34,17 @@ impl Contact {
|
||||
|
||||
async fn parse_response(
|
||||
response: &str,
|
||||
) -> Result<Vec<textsender_models::contact::Contact>, std::io::Error> {
|
||||
) -> Result<Vec<schedtxt_models::contact::Contact>, std::io::Error> {
|
||||
match serde_json::from_str::<serde_json::Value>(response) {
|
||||
Ok(j) => match j.get("data") {
|
||||
Some(serde_json::Value::Array(lrs)) => {
|
||||
if lrs.is_empty() {
|
||||
Err(std::io::Error::other("Error response is empty"))
|
||||
} else {
|
||||
let mut events: Vec<textsender_models::contact::Contact> = Vec::new();
|
||||
let mut events: Vec<schedtxt_models::contact::Contact> = Vec::new();
|
||||
|
||||
for event in lrs.iter() {
|
||||
let ll: textsender_models::contact::Contact =
|
||||
let ll: schedtxt_models::contact::Contact =
|
||||
match serde_json::from_value(event.clone()) {
|
||||
Ok(lr) => lr,
|
||||
Err(err) => {
|
||||
|
||||
+29
-45
@@ -1,18 +1,17 @@
|
||||
pub struct Service {
|
||||
pub app: crate::app::App,
|
||||
pub token: textsender_models::token::Login,
|
||||
pub app: std::sync::Arc<crate::app::App>,
|
||||
pub token: std::sync::Arc<schedtxt_models::token::Login>,
|
||||
}
|
||||
|
||||
impl Service {
|
||||
pub async fn do_the_work(&mut self) {
|
||||
println!("Do some work");
|
||||
println!("Checking queue");
|
||||
|
||||
use textsender_models::message::scheduling::ScheduledMessage;
|
||||
use schedtxt_models::message::scheduling::ScheduledMessage;
|
||||
|
||||
let queue = super::queue::Queue {
|
||||
app: self.app.clone(),
|
||||
token: self.token.clone(),
|
||||
app: std::sync::Arc::clone(&self.app),
|
||||
token: std::sync::Arc::clone(&self.token),
|
||||
};
|
||||
let queue_item: Option<ScheduledMessage> = match queue.get_queue().await {
|
||||
Ok(item) => Some(item),
|
||||
@@ -38,8 +37,8 @@ impl Service {
|
||||
println!("Can schedule");
|
||||
|
||||
let events_req = super::event::Event {
|
||||
app: self.app.clone(),
|
||||
token: self.token.clone(),
|
||||
app: std::sync::Arc::clone(&self.app),
|
||||
token: std::sync::Arc::clone(&self.token),
|
||||
};
|
||||
|
||||
let scheduled_message_id = queue_item.id;
|
||||
@@ -52,23 +51,31 @@ impl Service {
|
||||
};
|
||||
|
||||
let contacts = super::contact::Contact {
|
||||
app: self.app.clone(),
|
||||
token: self.token.clone(),
|
||||
app: std::sync::Arc::clone(&self.app),
|
||||
token: std::sync::Arc::clone(&self.token),
|
||||
};
|
||||
let messages = super::message::Message {
|
||||
app: self.app.clone(),
|
||||
token: self.token.clone(),
|
||||
app: std::sync::Arc::clone(&self.app),
|
||||
token: std::sync::Arc::clone(&self.token),
|
||||
};
|
||||
let sch_msg = super::scheduler::ScheduledMessage {
|
||||
app: self.app.clone(),
|
||||
token: self.token.clone(),
|
||||
app: std::sync::Arc::clone(&self.app),
|
||||
token: std::sync::Arc::clone(&self.token),
|
||||
};
|
||||
let mer_req = super::mer::MessageEventResponse {
|
||||
app: self.app.clone(),
|
||||
token: self.token.clone(),
|
||||
app: std::sync::Arc::clone(&self.app),
|
||||
token: std::sync::Arc::clone(&self.token),
|
||||
};
|
||||
|
||||
let events = events.unwrap_or_default();
|
||||
let mut sendmsg = swoosh::SendMsg::default();
|
||||
sendmsg.load_config(
|
||||
&self.app.twilio_config.auth_token,
|
||||
&self.app.twilio_config.phone_number,
|
||||
&self.app.twilio_config.service_sid,
|
||||
&self.app.twilio_config.account_sid,
|
||||
);
|
||||
|
||||
for event in &events {
|
||||
println!("Event: {event:?}");
|
||||
let contact = &match contacts.get(&event.contact_id).await {
|
||||
@@ -105,13 +112,15 @@ impl Service {
|
||||
let twilio_config = &self.app.twilio_config;
|
||||
println!("Config: {twilio_config:?}");
|
||||
println!("SM: {scheduled_message:?}");
|
||||
sendmsg.load_message(&message.content);
|
||||
sendmsg.load_recipient(&contact.phone_number);
|
||||
|
||||
match swoosh::twilio::api::send_message(message, contact, ¶m, twilio_config).await {
|
||||
match sendmsg.send_message(¶m).await {
|
||||
Ok(resp) => {
|
||||
println!("Message scheduled");
|
||||
// MER response
|
||||
let result = swoosh::twilio::api::response_to_json(resp).await;
|
||||
let mer = textsender_models::message::event::MessageEventResponse {
|
||||
let mer = schedtxt_models::message::event::MessageEventResponse {
|
||||
contact_id: contact.id.unwrap(),
|
||||
scheduled_message_event_id: Some(event.id),
|
||||
response: result,
|
||||
@@ -138,39 +147,14 @@ impl Service {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
todo!(
|
||||
r#"
|
||||
Need to finish this
|
||||
|
||||
[X] - This function should fetch a token, check if the token is valid, and obtain a refresh token if
|
||||
it has expired.
|
||||
|
||||
Then do the real work.
|
||||
|
||||
1. Check the queue - Done
|
||||
2. If there is an item, get the data - Done
|
||||
3. Evaluate if it is schedulable - Done
|
||||
4. Get the events and iterate each one - Done
|
||||
5. Starting with the message - Done
|
||||
6. Get the contact - Done
|
||||
7. Send the message
|
||||
8. Record the message event response - Added, not used
|
||||
9. Add to scheduler
|
||||
"#
|
||||
);
|
||||
*/
|
||||
}
|
||||
|
||||
fn is_schedulable(
|
||||
&self,
|
||||
queue_item: &textsender_models::message::scheduling::ScheduledMessage,
|
||||
queue_item: &schedtxt_models::message::scheduling::ScheduledMessage,
|
||||
) -> bool {
|
||||
let now = time::OffsetDateTime::now_utc();
|
||||
|
||||
match queue_item.scheduled {
|
||||
Some(date) => date > now,
|
||||
Some(date) => date > time::OffsetDateTime::now_utc(),
|
||||
None => false,
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,13 +1,13 @@
|
||||
pub struct Event {
|
||||
pub app: crate::app::App,
|
||||
pub token: textsender_models::token::LoginResult,
|
||||
pub app: std::sync::Arc<crate::app::App>,
|
||||
pub token: std::sync::Arc<schedtxt_models::token::LoginResult>,
|
||||
}
|
||||
|
||||
impl Event {
|
||||
pub async fn get(
|
||||
&self,
|
||||
scheduled_message_id: &uuid::Uuid,
|
||||
) -> Result<Vec<textsender_models::message::scheduling::ScheduledMessageEvent>, std::io::Error>
|
||||
) -> Result<Vec<schedtxt_models::message::scheduling::ScheduledMessageEvent>, std::io::Error>
|
||||
{
|
||||
let client = reqwest::Client::new();
|
||||
let endpoint =
|
||||
@@ -38,7 +38,7 @@ impl Event {
|
||||
|
||||
async fn parse_response(
|
||||
response: &str,
|
||||
) -> Result<Vec<textsender_models::message::scheduling::ScheduledMessageEvent>, std::io::Error> {
|
||||
) -> Result<Vec<schedtxt_models::message::scheduling::ScheduledMessageEvent>, std::io::Error> {
|
||||
match serde_json::from_str::<serde_json::Value>(response) {
|
||||
Ok(j) => match j.get("data") {
|
||||
Some(serde_json::Value::Array(lrs)) => {
|
||||
@@ -46,11 +46,11 @@ async fn parse_response(
|
||||
Err(std::io::Error::other("Error response is empty"))
|
||||
} else {
|
||||
let mut events: Vec<
|
||||
textsender_models::message::scheduling::ScheduledMessageEvent,
|
||||
schedtxt_models::message::scheduling::ScheduledMessageEvent,
|
||||
> = Vec::new();
|
||||
|
||||
for event in lrs.iter() {
|
||||
let ll: textsender_models::message::scheduling::ScheduledMessageEvent =
|
||||
let ll: schedtxt_models::message::scheduling::ScheduledMessageEvent =
|
||||
match serde_json::from_value(event.clone()) {
|
||||
Ok(lr) => lr,
|
||||
Err(err) => {
|
||||
|
||||
+7
-7
@@ -1,13 +1,13 @@
|
||||
pub struct MessageEventResponse {
|
||||
pub app: crate::app::App,
|
||||
pub token: textsender_models::token::LoginResult,
|
||||
pub app: std::sync::Arc<crate::app::App>,
|
||||
pub token: std::sync::Arc<schedtxt_models::token::LoginResult>,
|
||||
}
|
||||
|
||||
impl MessageEventResponse {
|
||||
pub async fn record_message_event_response(
|
||||
&self,
|
||||
mer: &textsender_models::message::event::MessageEventResponse,
|
||||
) -> Result<textsender_models::message::event::MessageEventResponse, std::io::Error> {
|
||||
mer: &schedtxt_models::message::event::MessageEventResponse,
|
||||
) -> Result<schedtxt_models::message::event::MessageEventResponse, std::io::Error> {
|
||||
let client = reqwest::Client::new();
|
||||
let endpoint = String::from("api/v1/schedule/message/event/response/record");
|
||||
let api_url = format!("{}/{endpoint}", self.app.api_url);
|
||||
@@ -27,7 +27,7 @@ impl MessageEventResponse {
|
||||
"response": mer.response,
|
||||
"user_id": mer.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": mer.contact_id,
|
||||
"message_id": mer.message_id
|
||||
});
|
||||
@@ -79,7 +79,7 @@ impl MessageEventResponse {
|
||||
|
||||
async fn parse_response(
|
||||
response: &str,
|
||||
) -> Result<textsender_models::message::event::MessageEventResponse, std::io::Error> {
|
||||
) -> Result<schedtxt_models::message::event::MessageEventResponse, std::io::Error> {
|
||||
match serde_json::from_str::<serde_json::Value>(response) {
|
||||
Ok(j) => {
|
||||
println!("Good");
|
||||
@@ -94,7 +94,7 @@ async fn parse_response(
|
||||
Err(std::io::Error::other("Error response is empty"))
|
||||
} else {
|
||||
let lr = lrs[0].clone();
|
||||
let ll: textsender_models::message::event::MessageEventResponse =
|
||||
let ll: schedtxt_models::message::event::MessageEventResponse =
|
||||
match serde_json::from_value(lr) {
|
||||
Ok(lr) => lr,
|
||||
Err(err) => {
|
||||
|
||||
@@ -1,13 +1,13 @@
|
||||
pub struct Message {
|
||||
pub app: crate::app::App,
|
||||
pub token: textsender_models::token::LoginResult,
|
||||
pub app: std::sync::Arc<crate::app::App>,
|
||||
pub token: std::sync::Arc<schedtxt_models::token::LoginResult>,
|
||||
}
|
||||
|
||||
impl Message {
|
||||
pub async fn get(
|
||||
&self,
|
||||
message_id: &uuid::Uuid,
|
||||
) -> Result<Vec<textsender_models::message::Message>, std::io::Error> {
|
||||
) -> Result<Vec<schedtxt_models::message::Message>, std::io::Error> {
|
||||
let client = reqwest::Client::new();
|
||||
let endpoint = format!("api/v1/message?id={message_id}");
|
||||
let api_url = format!("{}/{endpoint}", self.app.api_url);
|
||||
@@ -34,17 +34,17 @@ impl Message {
|
||||
|
||||
async fn parse_response(
|
||||
response: &str,
|
||||
) -> Result<Vec<textsender_models::message::Message>, std::io::Error> {
|
||||
) -> Result<Vec<schedtxt_models::message::Message>, std::io::Error> {
|
||||
match serde_json::from_str::<serde_json::Value>(response) {
|
||||
Ok(j) => match j.get("data") {
|
||||
Some(serde_json::Value::Array(lrs)) => {
|
||||
if lrs.is_empty() {
|
||||
Err(std::io::Error::other("Error response is empty"))
|
||||
} else {
|
||||
let mut events: Vec<textsender_models::message::Message> = Vec::new();
|
||||
let mut events: Vec<schedtxt_models::message::Message> = Vec::new();
|
||||
|
||||
for event in lrs.iter() {
|
||||
let ll: textsender_models::message::Message =
|
||||
let ll: schedtxt_models::message::Message =
|
||||
match serde_json::from_value(event.clone()) {
|
||||
Ok(lr) => lr,
|
||||
Err(err) => {
|
||||
|
||||
@@ -1,12 +1,12 @@
|
||||
pub struct Queue {
|
||||
pub app: crate::app::App,
|
||||
pub token: textsender_models::token::LoginResult,
|
||||
pub app: std::sync::Arc<crate::app::App>,
|
||||
pub token: std::sync::Arc<schedtxt_models::token::LoginResult>,
|
||||
}
|
||||
|
||||
impl Queue {
|
||||
pub async fn get_queue(
|
||||
&self,
|
||||
) -> Result<textsender_models::message::scheduling::ScheduledMessage, std::io::Error> {
|
||||
) -> Result<schedtxt_models::message::scheduling::ScheduledMessage, std::io::Error> {
|
||||
let client = reqwest::Client::new();
|
||||
let endpoint = String::from("api/v1/schedule/message/fetch");
|
||||
let api_url = format!("{}/{endpoint}", self.app.api_url);
|
||||
@@ -36,7 +36,7 @@ impl Queue {
|
||||
|
||||
async fn parse_queue_response(
|
||||
response: &str,
|
||||
) -> Result<textsender_models::message::scheduling::ScheduledMessage, std::io::Error> {
|
||||
) -> Result<schedtxt_models::message::scheduling::ScheduledMessage, std::io::Error> {
|
||||
match serde_json::from_str::<serde_json::Value>(response) {
|
||||
Ok(j) => {
|
||||
let message = &j["message"];
|
||||
@@ -50,7 +50,7 @@ async fn parse_queue_response(
|
||||
Err(std::io::Error::other("Error response is empty"))
|
||||
} else {
|
||||
let lr = lrs[0].clone();
|
||||
let ll: textsender_models::message::scheduling::ScheduledMessage =
|
||||
let ll: schedtxt_models::message::scheduling::ScheduledMessage =
|
||||
match serde_json::from_value(lr) {
|
||||
Ok(lr) => lr,
|
||||
Err(err) => {
|
||||
|
||||
@@ -1,13 +1,13 @@
|
||||
pub struct ScheduledMessage {
|
||||
pub app: crate::app::App,
|
||||
pub token: textsender_models::token::LoginResult,
|
||||
pub app: std::sync::Arc<crate::app::App>,
|
||||
pub token: std::sync::Arc<schedtxt_models::token::LoginResult>,
|
||||
}
|
||||
|
||||
impl ScheduledMessage {
|
||||
pub async fn get(
|
||||
&self,
|
||||
scheduled_message_id: &uuid::Uuid,
|
||||
) -> Result<textsender_models::message::scheduling::ScheduledMessage, std::io::Error> {
|
||||
) -> Result<schedtxt_models::message::scheduling::ScheduledMessage, std::io::Error> {
|
||||
let client = reqwest::Client::new();
|
||||
let endpoint = format!("api/v1/schedule/message?id={scheduled_message_id}");
|
||||
let api_url = format!("{}/{endpoint}", self.app.api_url);
|
||||
@@ -34,14 +34,14 @@ impl ScheduledMessage {
|
||||
|
||||
async fn parse_response(
|
||||
response: &str,
|
||||
) -> Result<textsender_models::message::scheduling::ScheduledMessage, std::io::Error> {
|
||||
) -> Result<schedtxt_models::message::scheduling::ScheduledMessage, std::io::Error> {
|
||||
match serde_json::from_str::<serde_json::Value>(response) {
|
||||
Ok(j) => match j.get("data") {
|
||||
Some(serde_json::Value::Array(lrs)) => {
|
||||
if lrs.is_empty() {
|
||||
Err(std::io::Error::other("Error response is empty"))
|
||||
} else {
|
||||
let ll: textsender_models::message::scheduling::ScheduledMessage =
|
||||
let ll: schedtxt_models::message::scheduling::ScheduledMessage =
|
||||
match serde_json::from_value(lrs[0].clone()) {
|
||||
Ok(lr) => lr,
|
||||
Err(err) => {
|
||||
|
||||
Reference in New Issue
Block a user