124 lines
4.9 KiB
Rust
124 lines
4.9 KiB
Rust
pub mod types;
|
|
|
|
pub async 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() {
|
|
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"))
|
|
} else {
|
|
let now = time::OffsetDateTime::now_utc();
|
|
match reqwest::Client::builder().build() {
|
|
Ok(client) => {
|
|
let mut headers = reqwest::header::HeaderMap::new();
|
|
headers.insert(
|
|
"Content-Type",
|
|
"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());
|
|
|
|
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("SendAsMms", "true");
|
|
params.insert("RiskCheck", "enable");
|
|
params.insert("From", config.phone_number.as_str());
|
|
params.insert("MessagingServiceSid", config.service_sid.as_str());
|
|
params.insert("Body", msg.content.as_str());
|
|
|
|
let url = format!(
|
|
"https://api.twilio.com/2010-04-01/Accounts/{}/Messages.json",
|
|
config.account_sid
|
|
);
|
|
|
|
let request = client.post(url).headers(headers).form(¶ms);
|
|
match request.send().await {
|
|
Ok(response) => match response.status() {
|
|
reqwest::StatusCode::OK => Ok(response),
|
|
status => Err(std::io::Error::other(format!(
|
|
"Unaccounted status: {status:?}"
|
|
))),
|
|
},
|
|
Err(err) => Err(std::io::Error::other(err.to_string())),
|
|
}
|
|
}
|
|
Err(err) => Err(std::io::Error::other(err.to_string())),
|
|
}
|
|
}
|
|
}
|
|
|
|
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),
|
|
}
|
|
}
|
|
/*
|
|
let mut params = std::collections::HashMap::new();
|
|
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");
|
|
params.insert("SendAsMms", "true");
|
|
params.insert("RiskCheck", "enable");
|
|
|
|
let response = request.send().await?;
|
|
let body = response.text().await?;
|
|
println!("{}", body);
|
|
|
|
Ok(())
|
|
}
|
|
*/
|
|
|
|
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(300))
|
|
.unwrap();
|
|
*schedule_at > early
|
|
}
|
|
None => false,
|
|
}
|
|
}
|