Compare commits
7
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5752741972
|
||
|
|
2971363d2f
|
||
|
|
0cbf63c78d
|
||
|
|
e487a2c275
|
||
|
|
97dcb360ab
|
||
|
|
7c3b51d6a0
|
||
|
|
c6103ebba4
|
@@ -3,10 +3,10 @@ name: Release Tagging
|
||||
on:
|
||||
push:
|
||||
branches:
|
||||
- main
|
||||
- v0.3.x
|
||||
pull_request:
|
||||
branches:
|
||||
- main
|
||||
- v0.3.x
|
||||
|
||||
jobs:
|
||||
release:
|
||||
|
||||
@@ -3,10 +3,10 @@ name: swoosh Build
|
||||
on:
|
||||
push:
|
||||
branches:
|
||||
- main
|
||||
- v0.3.x
|
||||
pull_request:
|
||||
branches:
|
||||
- main
|
||||
- v0.3.x
|
||||
|
||||
jobs:
|
||||
check:
|
||||
@@ -17,12 +17,11 @@ jobs:
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.95
|
||||
- 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
|
||||
ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
|
||||
ssh-keyscan ${{ secret.MYHOST }} >> ~/.ssh/known_hosts
|
||||
|
||||
eval $(ssh-agent -s)
|
||||
ssh-add -v ~/.ssh/textsender-models_deploy_key
|
||||
@@ -37,12 +36,11 @@ jobs:
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.95
|
||||
- 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
|
||||
ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
|
||||
ssh-keyscan ${{ secret.MYHOST }} >> ~/.ssh/known_hosts
|
||||
|
||||
eval $(ssh-agent -s)
|
||||
ssh-add -v ~/.ssh/textsender-models_deploy_key
|
||||
@@ -57,13 +55,12 @@ jobs:
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.95
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: rustup component add rustfmt
|
||||
- run: |
|
||||
mkdir -p ~/.ssh
|
||||
echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
|
||||
chmod 600 ~/.ssh/textsender-models_deploy_key
|
||||
ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
|
||||
ssh-keyscan ${{ secret.MYHOST }} >> ~/.ssh/known_hosts
|
||||
|
||||
eval $(ssh-agent -s)
|
||||
ssh-add -v ~/.ssh/textsender-models_deploy_key
|
||||
@@ -78,13 +75,12 @@ jobs:
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.95
|
||||
- uses: Swatinem/rust-cache@v2
|
||||
- run: rustup component add clippy
|
||||
- run: |
|
||||
mkdir -p ~/.ssh
|
||||
echo "${{ secrets.MYREPO_TOKEN }}" > ~/.ssh/textsender-models_deploy_key
|
||||
chmod 600 ~/.ssh/textsender-models_deploy_key
|
||||
ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
|
||||
ssh-keyscan ${{ secret.MYHOST }} >> ~/.ssh/known_hosts
|
||||
|
||||
eval $(ssh-agent -s)
|
||||
ssh-add -v ~/.ssh/textsender-models_deploy_key
|
||||
@@ -99,14 +95,14 @@ jobs:
|
||||
- uses: actions-rust-lang/setup-rust-toolchain@v1
|
||||
with:
|
||||
toolchain: 1.95
|
||||
- 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
|
||||
ssh-keyscan ${{ secrets.MY_HOST }} >> ~/.ssh/known_hosts
|
||||
ssh-keyscan ${{ secret.MYHOST }} >> ~/.ssh/known_hosts
|
||||
|
||||
eval $(ssh-agent -s)
|
||||
ssh-add -v ~/.ssh/textsender-models_deploy_key
|
||||
|
||||
cargo build
|
||||
|
||||
|
||||
Generated
+9
-134
@@ -57,17 +57,11 @@ version = "0.22.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "72b3254f16251a8381aa12e40e3c4d2f0199f8c6508fbecb9d91f575e0fbb8c6"
|
||||
|
||||
[[package]]
|
||||
name = "base64-ng"
|
||||
version = "1.0.7"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "8992e20e420add1e6e31c6c548a4ba698ed9339bb0863b37478427179c56f05d"
|
||||
|
||||
[[package]]
|
||||
name = "bitflags"
|
||||
version = "2.13.0"
|
||||
version = "2.12.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "b4388bee8683e3d04af747c73422af53102d2bd24d9eadb6cbc100baef4b43f8"
|
||||
checksum = "84d7ced0ae9557296835c32bf1b1e02b44c746701f898460fb000d7eaa84f00a"
|
||||
|
||||
[[package]]
|
||||
name = "bumpalo"
|
||||
@@ -322,21 +316,6 @@ version = "1.3.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "42703706b716c37f96a77aea830392ad231f44c9e9a67872fa5548707e11b11c"
|
||||
|
||||
[[package]]
|
||||
name = "futures"
|
||||
version = "0.3.32"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "8b147ee9d1f6d097cef9ce628cd2ee62288d963e16fb287bd9286455b241382d"
|
||||
dependencies = [
|
||||
"futures-channel",
|
||||
"futures-core",
|
||||
"futures-executor",
|
||||
"futures-io",
|
||||
"futures-sink",
|
||||
"futures-task",
|
||||
"futures-util",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "futures-channel"
|
||||
version = "0.3.32"
|
||||
@@ -353,17 +332,6 @@ version = "0.3.32"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "7e3450815272ef58cec6d564423f6e755e25379b217b0bc688e295ba24df6b1d"
|
||||
|
||||
[[package]]
|
||||
name = "futures-executor"
|
||||
version = "0.3.32"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "baf29c38818342a3b26b5b923639e7b1f4a61fc5e76102d4b1981c6dc7a7579d"
|
||||
dependencies = [
|
||||
"futures-core",
|
||||
"futures-task",
|
||||
"futures-util",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "futures-io"
|
||||
version = "0.3.32"
|
||||
@@ -399,7 +367,6 @@ version = "0.3.32"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "389ca41296e6190b48053de0321d02a77f32f8a5d2461dd38762c0593805c6d6"
|
||||
dependencies = [
|
||||
"futures-channel",
|
||||
"futures-core",
|
||||
"futures-io",
|
||||
"futures-macro",
|
||||
@@ -851,20 +818,11 @@ version = "0.8.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "92daf443525c4cce67b150400bc2316076100ce0b3686209eb8cf3c31612e6f0"
|
||||
|
||||
[[package]]
|
||||
name = "lock_api"
|
||||
version = "0.4.14"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "224399e74b87b5f3557511d98dff8b14089b3dadafcab6bb93eab67d3aace965"
|
||||
dependencies = [
|
||||
"scopeguard",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "log"
|
||||
version = "0.4.32"
|
||||
version = "0.4.31"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "953f07c43838f8e6f9758cab68bf5bed85465e7587ebe0b823f1bcd81978ad3a"
|
||||
checksum = "113b30b4cd05f7c06868fdb2854f66a7b9fece9a48425351cd532e810d74024f"
|
||||
|
||||
[[package]]
|
||||
name = "lru-slab"
|
||||
@@ -970,29 +928,6 @@ dependencies = [
|
||||
"vcpkg",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "parking_lot"
|
||||
version = "0.12.5"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "93857453250e3077bd71ff98b6a65ea6621a19bb0f559a85248955ac12c45a1a"
|
||||
dependencies = [
|
||||
"lock_api",
|
||||
"parking_lot_core",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "parking_lot_core"
|
||||
version = "0.9.12"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "2621685985a2ebf1c516881c026032ac7deafcda1a2c9b7850dc81e3dfcb64c1"
|
||||
dependencies = [
|
||||
"cfg-if",
|
||||
"libc",
|
||||
"redox_syscall",
|
||||
"smallvec",
|
||||
"windows-link",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "percent-encoding"
|
||||
version = "2.3.2"
|
||||
@@ -1177,15 +1112,6 @@ version = "0.10.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "63b8176103e19a2643978565ca18b50549f6101881c443590420e4dc998a3c69"
|
||||
|
||||
[[package]]
|
||||
name = "redox_syscall"
|
||||
version = "0.5.18"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "ed2bf2547551a7053d6fdfafda3f938979645c44812fbfcda098faae3f1a362d"
|
||||
dependencies = [
|
||||
"bitflags",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "regex"
|
||||
version = "1.12.3"
|
||||
@@ -1246,7 +1172,6 @@ dependencies = [
|
||||
"rustls-platform-verifier",
|
||||
"serde",
|
||||
"serde_json",
|
||||
"serde_urlencoded",
|
||||
"sync_wrapper",
|
||||
"tokio",
|
||||
"tokio-rustls",
|
||||
@@ -1384,12 +1309,6 @@ version = "1.0.22"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "b39cdef0fa800fc44525c84ccb54a029961a8215f9619753635a9c0d2538d46d"
|
||||
|
||||
[[package]]
|
||||
name = "ryu"
|
||||
version = "1.0.23"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "9774ba4a74de5f7b1c1451ed6cd5285a32eddb5cccb8cc655a4e50009e06477f"
|
||||
|
||||
[[package]]
|
||||
name = "same-file"
|
||||
version = "1.0.6"
|
||||
@@ -1408,12 +1327,6 @@ dependencies = [
|
||||
"windows-sys 0.61.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "scopeguard"
|
||||
version = "1.2.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "94143f37725109f92c262ed2cf5e59bce7498c01bcc1502d7b9afe439a4e9f49"
|
||||
|
||||
[[package]]
|
||||
name = "security-framework"
|
||||
version = "3.7.0"
|
||||
@@ -1487,34 +1400,12 @@ dependencies = [
|
||||
"zmij",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "serde_urlencoded"
|
||||
version = "0.7.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "d3491c14715ca2294c4d6a88f15e84739788c1d030eed8c110436aafdaa2f3fd"
|
||||
dependencies = [
|
||||
"form_urlencoded",
|
||||
"itoa",
|
||||
"ryu",
|
||||
"serde",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "shlex"
|
||||
version = "2.0.1"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "f8fadd59c855ef2080decdef8ff161eb6661b86933c9d82e5ba29dc602a55aba"
|
||||
|
||||
[[package]]
|
||||
name = "signal-hook-registry"
|
||||
version = "1.4.8"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "c4db69cba1110affc0e9f7bcd48bbf87b3f4fc7c61fc9155afd4c469eb3d6c1b"
|
||||
dependencies = [
|
||||
"errno",
|
||||
"libc",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "simd-adler32"
|
||||
version = "0.3.9"
|
||||
@@ -1573,11 +1464,9 @@ checksum = "13c2bddecc57b384dee18652358fb23172facb8a2c51ccc10d74c157bdea3292"
|
||||
|
||||
[[package]]
|
||||
name = "swoosh"
|
||||
version = "0.3.2"
|
||||
version = "0.2.1"
|
||||
dependencies = [
|
||||
"base64-ng",
|
||||
"const_format",
|
||||
"futures",
|
||||
"http",
|
||||
"josekit",
|
||||
"rand 0.10.1",
|
||||
@@ -1587,7 +1476,6 @@ dependencies = [
|
||||
"tempfile",
|
||||
"textsender_models",
|
||||
"time",
|
||||
"tokio",
|
||||
"uuid",
|
||||
]
|
||||
|
||||
@@ -1659,11 +1547,12 @@ dependencies = [
|
||||
[[package]]
|
||||
name = "textsender_models"
|
||||
version = "0.3.0"
|
||||
source = "git+ssh://git@git.kundeng.us/phoenix/textsender_models.git?tag=v0.3.0#d504108745b7b97a02eac24e16763cdb5e731f2b"
|
||||
source = "git+ssh://git@git.kundeng.us/phoenix/textsender-models.git?tag=v0.3.0-20-15820d5505-111#15820d550526aea3016821c01f508d8d590292cc"
|
||||
dependencies = [
|
||||
"const_format",
|
||||
"dotenvy",
|
||||
"josekit",
|
||||
"rand 0.10.1",
|
||||
"serde",
|
||||
"serde_json",
|
||||
"time",
|
||||
@@ -1756,25 +1645,11 @@ dependencies = [
|
||||
"bytes",
|
||||
"libc",
|
||||
"mio",
|
||||
"parking_lot",
|
||||
"pin-project-lite",
|
||||
"signal-hook-registry",
|
||||
"socket2",
|
||||
"tokio-macros",
|
||||
"windows-sys 0.61.2",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tokio-macros"
|
||||
version = "2.7.0"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "385a6cb71ab9ab790c5fe8d67f1645e6c450a7ce006a33de03daa956cf70a496"
|
||||
dependencies = [
|
||||
"proc-macro2",
|
||||
"quote",
|
||||
"syn",
|
||||
]
|
||||
|
||||
[[package]]
|
||||
name = "tokio-rustls"
|
||||
version = "0.26.4"
|
||||
@@ -2428,9 +2303,9 @@ checksum = "1ffae5123b2d3fc086436f8834ae3ab053a283cfac8fe0a0b8eaae044768a4c4"
|
||||
|
||||
[[package]]
|
||||
name = "yoke"
|
||||
version = "0.8.3"
|
||||
version = "0.8.2"
|
||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||
checksum = "709fe23a0424b6a435d82152b1bd3fdfb0833487d5fa90d05d42762a9891fef5"
|
||||
checksum = "abe8c5fda708d9ca3df187cae8bfb9ceda00dd96231bed36e445a1a48e66f9ca"
|
||||
dependencies = [
|
||||
"stable_deref_trait",
|
||||
"yoke-derive",
|
||||
|
||||
+3
-6
@@ -1,6 +1,6 @@
|
||||
[package]
|
||||
name = "swoosh"
|
||||
version = "0.3.2"
|
||||
version = "0.2.1"
|
||||
edition = "2024"
|
||||
rust-version = "1.95"
|
||||
description = "Library to send text messages"
|
||||
@@ -8,17 +8,14 @@ description = "Library to send text messages"
|
||||
[dependencies]
|
||||
serde = { version = "1.0.228", features = ["derive"] }
|
||||
serde_json = { version = "1.0.149" }
|
||||
tokio = { version = "1.52.2", features = ["full"] }
|
||||
futures = { version = "0.3.32" }
|
||||
http = { version = "1.4.0" }
|
||||
reqwest = { version = "0.13.3", features = ["form", "json", "blocking", "multipart", "stream"] }
|
||||
reqwest = { version = "0.13.3", features = ["json", "blocking", "multipart", "stream"] }
|
||||
rand = { version = "0.10.1" }
|
||||
time = { version = "0.3.47", features = ["formatting", "macros", "parsing", "serde"] }
|
||||
uuid = { version = "1.23.1", features = ["v4", "serde"] }
|
||||
base64-ng = { version = "1.0.6" }
|
||||
const_format = { version = "0.2.36" }
|
||||
josekit = { version = "0.10.3" }
|
||||
textsender_models = { git = "ssh://git@git.kundeng.us/phoenix/textsender_models.git", tag = "v0.3.0" }
|
||||
textsender_models = { git = "ssh://git@git.kundeng.us/phoenix/textsender-models.git", tag = "v0.3.0-20-15820d5505-111" }
|
||||
|
||||
[dev-dependencies]
|
||||
tempfile = { version = "3.27.0" }
|
||||
|
||||
+107
-49
@@ -1,19 +1,14 @@
|
||||
// use josekit::jwk::alg::ec::EcCurve::P256;
|
||||
|
||||
pub mod types;
|
||||
|
||||
pub async fn response_to_json(response: reqwest::Response) -> serde_json::Value {
|
||||
match response.json().await {
|
||||
Ok(json_body) => json_body,
|
||||
Err(_err) => serde_json::Value::Null,
|
||||
}
|
||||
}
|
||||
|
||||
pub async fn send_mssage(
|
||||
pub fn send_mssage(
|
||||
msg: &textsender_models::message::Message,
|
||||
contact: &textsender_models::contact::Contact,
|
||||
param: crate::twilio::types::Parameters,
|
||||
config: &textsender_models::config::auxiliary::TwilioConfig,
|
||||
) -> Result<reqwest::Response, std::io::Error> {
|
||||
if config.account_sid.is_empty() {
|
||||
) -> Result<crate::twilio::api::types::TwilioAPIMessage, std::io::Error> {
|
||||
if config.account_sid.is_nil() {
|
||||
Err(std::io::Error::other("Account SID is empty"))
|
||||
} else if config.auth_token.is_empty() {
|
||||
Err(std::io::Error::other(" Auth token is empty"))
|
||||
@@ -27,25 +22,24 @@ pub async fn send_mssage(
|
||||
"application/x-www-form-urlencoded".parse().unwrap(),
|
||||
);
|
||||
headers.insert("Accept", "application/json".parse().unwrap());
|
||||
let auth = generate_auth(config).unwrap();
|
||||
headers.insert("Authorization", auth.parse().unwrap());
|
||||
// headers.insert("Authorization", "Basic QUNlZmExZWY1MTYzMTRjOWQxYTY4Y2JkNjU3ZGU0OTI3NzpmNGExZjJiMGI3OWVhMzczNTA3OGMyZDhlZTk2ODRlMQ==".parse()?);
|
||||
|
||||
let mut params = std::collections::HashMap::new();
|
||||
params.insert("To", contact.phone_number.as_str());
|
||||
// params.insert("StatusCallback", "http://OjQozHznkhNTTR.vpnrM1zdXFuiQ");
|
||||
// params.insert("MaxPrice", "1");
|
||||
params.insert("ProvideFeedback", "true");
|
||||
// params.insert("Attempt", "5");
|
||||
// params.insert("ValidityPeriod", "1537");
|
||||
params.insert("ForceDelivery", "false");
|
||||
params.insert("ContentRetention", "retain");
|
||||
params.insert("AddressRetention", "obfuscate");
|
||||
params.insert("SmartEncoded", "true");
|
||||
// params.insert("PersistentAction", "string");
|
||||
// params.insert("PersistentAction", "string");
|
||||
params.insert("ShortenUrls", "true");
|
||||
let date = match param.schedule_at {
|
||||
Some(date_value) => date_value.to_string(),
|
||||
None => String::new(),
|
||||
};
|
||||
if param.schedule && is_scheduleable(&Some(now), ¶m.schedule_at) {
|
||||
params.insert("ScheduleType", "fixed");
|
||||
params.insert("SendAt", date.as_str());
|
||||
}
|
||||
// params.insert("ScheduleType", "fixed");
|
||||
// params.insert("SendAt", "2026-06-03T19:50:00.0Z");
|
||||
params.insert("SendAsMms", "true");
|
||||
params.insert("RiskCheck", "enable");
|
||||
params.insert("From", config.phone_number.as_str());
|
||||
@@ -53,18 +47,26 @@ pub async fn send_mssage(
|
||||
params.insert("Body", msg.content.as_str());
|
||||
|
||||
let url = format!(
|
||||
"https://api.twilio.com/2010-04-01/Accounts/{}/Messages.json",
|
||||
config.account_sid
|
||||
"https://api.twilio.com/2010-04-01/Accounts/ACefa1ef516314c9d1a68cbd657de49277/Messages.json"
|
||||
);
|
||||
|
||||
let request = client.post(url).headers(headers).form(¶ms);
|
||||
let client = reqwest::Client::new();
|
||||
/*
|
||||
let request = client.request(reqwest::Method::POST, url)
|
||||
.headers(headers)
|
||||
.form(¶ms);
|
||||
*/
|
||||
let request = client.post(url).headers(headers);
|
||||
|
||||
match request.send().await {
|
||||
Ok(response) => match response.status() {
|
||||
reqwest::StatusCode::CREATED => Ok(response),
|
||||
status => Err(std::io::Error::other(format!(
|
||||
"Unaccounted status: {status:?}"
|
||||
))),
|
||||
},
|
||||
Ok(response) => {
|
||||
let body = response.text();
|
||||
|
||||
let mut obj = crate::twilio::api::types::TwilioAPIMessage {
|
||||
..Default::default()
|
||||
};
|
||||
Ok(obj)
|
||||
}
|
||||
Err(err) => Err(std::io::Error::other(err.to_string())),
|
||||
}
|
||||
}
|
||||
@@ -73,17 +75,19 @@ pub async fn send_mssage(
|
||||
}
|
||||
}
|
||||
|
||||
fn generate_auth(
|
||||
config: &textsender_models::config::auxiliary::TwilioConfig,
|
||||
) -> Result<String, base64_ng::EncodeError> {
|
||||
let input = format!("{}:{}", config.account_sid, config.auth_token);
|
||||
match base64_ng::encode(input.as_bytes()) {
|
||||
Ok(encoded) => Ok(format!("Basic {encoded}")),
|
||||
Err(err) => Err(err),
|
||||
}
|
||||
}
|
||||
/*
|
||||
#[tokio::main]
|
||||
async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
let client = reqwest::Client::builder()
|
||||
.build()?;
|
||||
|
||||
let mut headers = reqwest::header::HeaderMap::new();
|
||||
headers.insert("Content-Type", "application/x-www-form-urlencoded".parse()?);
|
||||
headers.insert("Accept", "application/json".parse()?);
|
||||
headers.insert("Authorization", "Basic QUNlZmExZWY1MTYzMTRjOWQxYTY4Y2JkNjU3ZGU0OTI3NzpmNGExZjJiMGI3OWVhMzczNTA3OGMyZDhlZTk2ODRlMQ==".parse()?);
|
||||
|
||||
let mut params = std::collections::HashMap::new();
|
||||
params.insert("To", "16303831708");
|
||||
params.insert("StatusCallback", "http://OjQozHznkhNTTR.vpnrM1zdXFuiQ");
|
||||
params.insert("MaxPrice", "1");
|
||||
params.insert("ProvideFeedback", "true");
|
||||
@@ -96,24 +100,78 @@ fn generate_auth(
|
||||
params.insert("PersistentAction", "string");
|
||||
params.insert("PersistentAction", "string");
|
||||
params.insert("ShortenUrls", "true");
|
||||
params.insert("ScheduleType", "fixed");
|
||||
params.insert("SendAt", "2026-06-03T19:50:00.0Z");
|
||||
params.insert("SendAsMms", "true");
|
||||
params.insert("RiskCheck", "enable");
|
||||
params.insert("From", "12243026041");
|
||||
params.insert("MessagingServiceSid", "MG803f3676706b92eb02e18dd820c447f2");
|
||||
params.insert("Body", "This is a test");
|
||||
|
||||
let request = client.request(reqwest::Method::POST, "https://api.twilio.com/2010-04-01/Accounts/ACefa1ef516314c9d1a68cbd657de49277/Messages.json")
|
||||
.headers(headers)
|
||||
.form(¶ms);
|
||||
|
||||
let response = request.send().await?;
|
||||
let body = response.text().await?;
|
||||
|
||||
println!("{}", body);
|
||||
|
||||
Ok(())
|
||||
}
|
||||
*/
|
||||
|
||||
const DEFAULT_SCHEDULING_SECONDS: i64 = 300;
|
||||
/**
|
||||
func (m *MessageSender) Send(msg message.Message, number contact.Contact, sendTime *time.Time) (*types.TwilioResult, map[string]any, error) {
|
||||
if m.Config == nil {
|
||||
return nil, nil, fmt.Errorf("Config has not been initialized")
|
||||
}
|
||||
now := time.Now()
|
||||
client := twilio.NewRestClientWithParams(twilio.ClientParams{
|
||||
Username: m.Config.AccountSID,
|
||||
Password: m.Config.AuthToken,
|
||||
})
|
||||
|
||||
params := &twilioApi.CreateMessageParams{}
|
||||
params.SetTo(number.PhoneNumber)
|
||||
params.SetFrom(m.Config.Number)
|
||||
params.SetMessagingServiceSid(m.Config.ServiceSID)
|
||||
params.SetBody(msg.Content)
|
||||
if sendTime != nil && isSchedulable(&now, sendTime) {
|
||||
params.SetSendAt(*sendTime)
|
||||
params.SetScheduleType(Schedule_Type)
|
||||
}
|
||||
|
||||
if resp, err := client.Api.CreateMessage(params); err != nil {
|
||||
return nil, nil, fmt.Errorf("Error sending message: %v", err)
|
||||
} else {
|
||||
if twilioRespMarshaled, err := json.Marshal(*resp); err != nil {
|
||||
return nil, nil, fmt.Errorf("Error parsing result: %v", err)
|
||||
} else {
|
||||
var rawObject map[string]any
|
||||
if err := json.Unmarshal(twilioRespMarshaled, &rawObject); err != nil {
|
||||
return resp, nil, err
|
||||
} else {
|
||||
return resp, rawObject, nil
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
func isSchedulable(now *time.Time, scheduled *time.Time) bool {
|
||||
early := now.Add(Schedulable_Limit_In_Seconds * time.Second)
|
||||
|
||||
if scheduled.After(early) {
|
||||
return true
|
||||
} else {
|
||||
return false
|
||||
}
|
||||
}
|
||||
*/
|
||||
|
||||
fn is_scheduleable(
|
||||
now: &Option<time::OffsetDateTime>,
|
||||
scheduled: &Option<time::OffsetDateTime>,
|
||||
) -> bool {
|
||||
match scheduled {
|
||||
Some(schedule_at) => {
|
||||
let early = now
|
||||
.unwrap()
|
||||
.checked_add(time::Duration::seconds(DEFAULT_SCHEDULING_SECONDS))
|
||||
.unwrap();
|
||||
*schedule_at > early
|
||||
}
|
||||
None => false,
|
||||
}
|
||||
true
|
||||
}
|
||||
|
||||
+32
-13
@@ -3,28 +3,20 @@ pub struct TwilioAPIMessage {
|
||||
pub account_sid: String,
|
||||
pub api_version: String,
|
||||
pub body: String,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
pub date_created: Option<time::OffsetDateTime>,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
// pub date_created: time::OffsetDateTime,
|
||||
pub date_sent: Option<time::OffsetDateTime>,
|
||||
#[serde(with = "time::serde::rfc3339::option")]
|
||||
pub date_updated: Option<time::OffsetDateTime>,
|
||||
pub direction: String,
|
||||
// Not definite of what type this is
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub error_code: String,
|
||||
pub error_code: Option<String>,
|
||||
// Not definite of what type this is
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub error_message: String,
|
||||
pub error_message: Option<String>,
|
||||
pub from: String,
|
||||
pub messaging_service_sid: String,
|
||||
pub num_media: String,
|
||||
pub num_segments: String,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub price: String,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub price_unit: String,
|
||||
#[serde(skip_serializing_if = "String::is_empty")]
|
||||
pub price: Option<String>,
|
||||
pub price_unit: Option<String>,
|
||||
pub sid: String,
|
||||
pub status: String,
|
||||
pub subresource_uris: SubresourceURI,
|
||||
@@ -36,3 +28,30 @@ pub struct TwilioAPIMessage {
|
||||
pub struct SubresourceURI {
|
||||
pub media: String,
|
||||
}
|
||||
|
||||
/*
|
||||
{
|
||||
"account_sid": "ACefa1ef516314c9d1a68cbd657de49277",
|
||||
"api_version": "2010-04-01",
|
||||
"body": "This is a test",
|
||||
"date_created": "Wed, 03 Jun 2026 19:40:55 +0000",
|
||||
"date_sent": null,
|
||||
"date_updated": "Wed, 03 Jun 2026 19:40:55 +0000",
|
||||
"direction": "outbound-api",
|
||||
"error_code": null,
|
||||
"error_message": null,
|
||||
"from": "+12243026041",
|
||||
"messaging_service_sid": "MG803f3676706b92eb02e18dd820c447f2",
|
||||
"num_media": "0",
|
||||
"num_segments": "0",
|
||||
"price": null,
|
||||
"price_unit": null,
|
||||
"sid": "SMf5c09c776c931bdb00c6e274da2ce34d",
|
||||
"status": "scheduled",
|
||||
"subresource_uris": {
|
||||
"media": "/2010-04-01/Accounts/ACefa1ef516314c9d1a68cbd657de49277/Messages/SMf5c09c776c931bdb00c6e274da2ce34d/Media.json"
|
||||
},
|
||||
"to": "+16303831708",
|
||||
"uri": "/2010-04-01/Accounts/ACefa1ef516314c9d1a68cbd657de49277/Messages/SMf5c09c776c931bdb00c6e274da2ce34d.json"
|
||||
}
|
||||
*/
|
||||
|
||||
@@ -1,4 +1,8 @@
|
||||
/// Parameters - Controls flow of sending message
|
||||
// Things needed to send a message
|
||||
// Contact - Receipient to send to (textsender-models)
|
||||
// Message - The content to sent (textsender-models)
|
||||
// Parameters - Controls flow of sending message
|
||||
// Config - Contains info needed to send message (textsender-models)
|
||||
pub struct Parameters {
|
||||
pub schedule: bool,
|
||||
pub schedule_at: Option<time::OffsetDateTime>,
|
||||
|
||||
Reference in New Issue
Block a user