use reqwest::header::CONTENT_TYPE;
use std::fmt::Debug;
use telegram_types::bot::methods::{ChatTarget, GetUpdates, Method, SendDocument, TelegramResult};
use telegram_types::bot::types::{FileToSend, InputFile, Message, Update};
async fn make_request<T: Method + Debug>(data: &T) -> TelegramResult<T::Item> {
let token = std::env::var("BOT_TOKEN").unwrap();
let client = reqwest::Client::new();
let res = client
.post(T::url(&*token))
.header(CONTENT_TYPE, "application/json")
.body(serde_json::to_string(data).unwrap())
.send()
.await
.unwrap();
let res = res.text().await.unwrap();
serde_json::from_str(&res).unwrap()
}
async fn upload(chat_id: ChatTarget<'_>) -> TelegramResult<Message> {
let file_field = "document";
let action = SendDocument::new(chat_id, FileToSend::InputFile(InputFile::new(file_field)));
let token = std::env::var("BOT_TOKEN").unwrap();
let client = reqwest::Client::new();
let url = format!(
"{}?{}",
SendDocument::url(&*token),
serde_urlencoded::to_string(action).unwrap()
);
let part = reqwest::multipart::Part::text("hello, world")
.file_name("hello.txt")
.mime_str("text/plain")
.unwrap();
let form = reqwest::multipart::Form::new().part(file_field, part);
let res = client
.post(url)
.header(CONTENT_TYPE, "multipart/form-data")
.multipart(form)
.send()
.await
.unwrap();
serde_json::from_slice(&*res.bytes().await.unwrap()).unwrap()
}
#[tokio::main]
async fn main() {
use telegram_types::bot::types::UpdateContent as Content;
let mut get_update = GetUpdates::new();
loop {
let updates: Vec<Update> = make_request(&get_update).await.result.unwrap();
for update in updates {
let content = update.content.unwrap_or_default();
match content {
Content::Message(message) => {
if let Some(text) = message.text.as_ref() {
let chat_id = ChatTarget::Id(message.chat.id);
if text.contains("file") {
let sent = upload(chat_id).await;
dbg!(sent);
}
}
}
_ => {}
}
get_update.offset(update.update_id + 1);
}
}
}