9c4f09193a 2026-01-09 arcade: use stacked_errors::{
9c4f09193a 2026-01-09 arcade: Result,
9c4f09193a 2026-01-09 arcade: StackableErr,
9c4f09193a 2026-01-09 arcade: };
9c4f09193a 2026-01-09 arcade: use tgbot::{
9c4f09193a 2026-01-09 arcade: api::Client,
9c4f09193a 2026-01-09 arcade: types::{
9c4f09193a 2026-01-09 arcade: Bot,
9c4f09193a 2026-01-09 arcade: ChatPeerId,
9c4f09193a 2026-01-09 arcade: GetBot,
9c4f09193a 2026-01-09 arcade: Message,
9c4f09193a 2026-01-09 arcade: ParseMode,
9c4f09193a 2026-01-09 arcade: SendMessage,
9c4f09193a 2026-01-09 arcade: },
9c4f09193a 2026-01-09 arcade: };
9c4f09193a 2026-01-09 arcade:
9c4f09193a 2026-01-09 arcade: #[derive(Clone)]
9c4f09193a 2026-01-09 arcade: pub struct Tg {
9c4f09193a 2026-01-09 arcade: pub me: Bot,
9c4f09193a 2026-01-09 arcade: pub owner: ChatPeerId,
9c4f09193a 2026-01-09 arcade: pub client: Client,
9c4f09193a 2026-01-09 arcade: }
9c4f09193a 2026-01-09 arcade:
9c4f09193a 2026-01-09 arcade: impl Tg {
9c4f09193a 2026-01-09 arcade: pub async fn new (settings: &config::Config) -> Result<Tg> {
9c4f09193a 2026-01-09 arcade: let api_key = settings.get_string("api_key").stack()?;
9c4f09193a 2026-01-09 arcade:
9c4f09193a 2026-01-09 arcade: let owner = ChatPeerId::from(settings.get_int("owner").stack()?);
9c4f09193a 2026-01-09 arcade: let client = Client::new(&api_key).stack()?
9c4f09193a 2026-01-09 arcade: .with_host(settings.get_string("api_gateway").stack()?)
9c4f09193a 2026-01-09 arcade: .with_max_retries(0);
9c4f09193a 2026-01-09 arcade: let me = client.execute(GetBot).await.stack()?;
9c4f09193a 2026-01-09 arcade: Ok(Tg {
9c4f09193a 2026-01-09 arcade: me,
9c4f09193a 2026-01-09 arcade: owner,
9c4f09193a 2026-01-09 arcade: client,
9c4f09193a 2026-01-09 arcade: })
9c4f09193a 2026-01-09 arcade: }
9c4f09193a 2026-01-09 arcade:
9c4f09193a 2026-01-09 arcade: pub async fn send <S>(&self, msg: S, target: Option<ChatPeerId>, mode: Option<ParseMode>) -> Result<Message>
9c4f09193a 2026-01-09 arcade: where S: Into<String> {
9c4f09193a 2026-01-09 arcade: let msg = msg.into();
9c4f09193a 2026-01-09 arcade:
9c4f09193a 2026-01-09 arcade: let mode = mode.unwrap_or(ParseMode::Html);
9c4f09193a 2026-01-09 arcade: let target = target.unwrap_or(self.owner);
9c4f09193a 2026-01-09 arcade: self.client.execute(
9c4f09193a 2026-01-09 arcade: SendMessage::new(target, msg)
9c4f09193a 2026-01-09 arcade: .with_parse_mode(mode)
9c4f09193a 2026-01-09 arcade: ).await.stack()
9c4f09193a 2026-01-09 arcade: }
9c4f09193a 2026-01-09 arcade:
9c4f09193a 2026-01-09 arcade: pub fn with_owner (&self, owner: i64) -> Tg {
9c4f09193a 2026-01-09 arcade: Tg {
9c4f09193a 2026-01-09 arcade: owner: ChatPeerId::from(owner),
9c4f09193a 2026-01-09 arcade: ..self.clone()
9c4f09193a 2026-01-09 arcade: }
9c4f09193a 2026-01-09 arcade: }
9c4f09193a 2026-01-09 arcade: }