Hex Artifact Content
Logged in as anonymous

Artifact f1db2464ab4ad847a83423d4917d421e1af4e2423e99f028bf339f78b7002915:


0000: 75 73 65 20 73 74 61 63 6b 65 64 5f 65 72 72 6f  use stacked_erro
0010: 72 73 3a 3a 7b 0a 09 52 65 73 75 6c 74 2c 0a 09  rs::{..Result,..
0020: 53 74 61 63 6b 61 62 6c 65 45 72 72 2c 0a 7d 3b  StackableErr,.};
0030: 0a 75 73 65 20 74 67 62 6f 74 3a 3a 7b 0a 09 61  .use tgbot::{..a
0040: 70 69 3a 3a 43 6c 69 65 6e 74 2c 0a 09 74 79 70  pi::Client,..typ
0050: 65 73 3a 3a 7b 0a 09 09 42 6f 74 2c 0a 09 09 43  es::{...Bot,...C
0060: 68 61 74 50 65 65 72 49 64 2c 0a 09 09 47 65 74  hatPeerId,...Get
0070: 42 6f 74 2c 0a 09 09 4d 65 73 73 61 67 65 2c 0a  Bot,...Message,.
0080: 09 09 50 61 72 73 65 4d 6f 64 65 2c 0a 09 09 53  ..ParseMode,...S
0090: 65 6e 64 4d 65 73 73 61 67 65 2c 0a 09 7d 2c 0a  endMessage,..},.
00a0: 7d 3b 0a 0a 23 5b 64 65 72 69 76 65 28 43 6c 6f  };..#[derive(Clo
00b0: 6e 65 29 5d 0a 70 75 62 20 73 74 72 75 63 74 20  ne)].pub struct 
00c0: 54 67 20 7b 0a 09 70 75 62 20 6d 65 3a 20 42 6f  Tg {..pub me: Bo
00d0: 74 2c 0a 09 70 75 62 20 6f 77 6e 65 72 3a 20 43  t,..pub owner: C
00e0: 68 61 74 50 65 65 72 49 64 2c 0a 09 70 75 62 20  hatPeerId,..pub 
00f0: 63 6c 69 65 6e 74 3a 20 43 6c 69 65 6e 74 2c 0a  client: Client,.
0100: 7d 0a 0a 69 6d 70 6c 20 54 67 20 7b 0a 09 70 75  }..impl Tg {..pu
0110: 62 20 61 73 79 6e 63 20 66 6e 20 6e 65 77 20 28  b async fn new (
0120: 73 65 74 74 69 6e 67 73 3a 20 26 63 6f 6e 66 69  settings: &confi
0130: 67 3a 3a 43 6f 6e 66 69 67 29 20 2d 3e 20 52 65  g::Config) -> Re
0140: 73 75 6c 74 3c 54 67 3e 20 7b 0a 09 09 6c 65 74  sult<Tg> {...let
0150: 20 61 70 69 5f 6b 65 79 20 3d 20 73 65 74 74 69   api_key = setti
0160: 6e 67 73 2e 67 65 74 5f 73 74 72 69 6e 67 28 22  ngs.get_string("
0170: 61 70 69 5f 6b 65 79 22 29 2e 73 74 61 63 6b 28  api_key").stack(
0180: 29 3f 3b 0a 0a 09 09 6c 65 74 20 6f 77 6e 65 72  )?;....let owner
0190: 20 3d 20 43 68 61 74 50 65 65 72 49 64 3a 3a 66   = ChatPeerId::f
01a0: 72 6f 6d 28 73 65 74 74 69 6e 67 73 2e 67 65 74  rom(settings.get
01b0: 5f 69 6e 74 28 22 6f 77 6e 65 72 22 29 2e 73 74  _int("owner").st
01c0: 61 63 6b 28 29 3f 29 3b 0a 09 09 6c 65 74 20 63  ack()?);...let c
01d0: 6c 69 65 6e 74 20 3d 20 43 6c 69 65 6e 74 3a 3a  lient = Client::
01e0: 6e 65 77 28 26 61 70 69 5f 6b 65 79 29 2e 73 74  new(&api_key).st
01f0: 61 63 6b 28 29 3f 0a 09 09 09 2e 77 69 74 68 5f  ack()?.....with_
0200: 68 6f 73 74 28 73 65 74 74 69 6e 67 73 2e 67 65  host(settings.ge
0210: 74 5f 73 74 72 69 6e 67 28 22 61 70 69 5f 67 61  t_string("api_ga
0220: 74 65 77 61 79 22 29 2e 73 74 61 63 6b 28 29 3f  teway").stack()?
0230: 29 0a 09 09 09 2e 77 69 74 68 5f 6d 61 78 5f 72  ).....with_max_r
0240: 65 74 72 69 65 73 28 30 29 3b 0a 09 09 6c 65 74  etries(0);...let
0250: 20 6d 65 20 3d 20 63 6c 69 65 6e 74 2e 65 78 65   me = client.exe
0260: 63 75 74 65 28 47 65 74 42 6f 74 29 2e 61 77 61  cute(GetBot).awa
0270: 69 74 2e 73 74 61 63 6b 28 29 3f 3b 0a 09 09 4f  it.stack()?;...O
0280: 6b 28 54 67 20 7b 0a 09 09 09 6d 65 2c 0a 09 09  k(Tg {....me,...
0290: 09 6f 77 6e 65 72 2c 0a 09 09 09 63 6c 69 65 6e  .owner,....clien
02a0: 74 2c 0a 09 09 7d 29 0a 09 7d 0a 0a 09 70 75 62  t,...})..}...pub
02b0: 20 61 73 79 6e 63 20 66 6e 20 73 65 6e 64 20 3c   async fn send <
02c0: 53 3e 28 26 73 65 6c 66 2c 20 6d 73 67 3a 20 53  S>(&self, msg: S
02d0: 2c 20 74 61 72 67 65 74 3a 20 4f 70 74 69 6f 6e  , target: Option
02e0: 3c 43 68 61 74 50 65 65 72 49 64 3e 2c 20 6d 6f  <ChatPeerId>, mo
02f0: 64 65 3a 20 4f 70 74 69 6f 6e 3c 50 61 72 73 65  de: Option<Parse
0300: 4d 6f 64 65 3e 29 20 2d 3e 20 52 65 73 75 6c 74  Mode>) -> Result
0310: 3c 4d 65 73 73 61 67 65 3e 0a 09 77 68 65 72 65  <Message>..where
0320: 20 53 3a 20 49 6e 74 6f 3c 53 74 72 69 6e 67 3e   S: Into<String>
0330: 20 7b 0a 09 09 6c 65 74 20 6d 73 67 20 3d 20 6d   {...let msg = m
0340: 73 67 2e 69 6e 74 6f 28 29 3b 0a 0a 09 09 6c 65  sg.into();....le
0350: 74 20 6d 6f 64 65 20 3d 20 6d 6f 64 65 2e 75 6e  t mode = mode.un
0360: 77 72 61 70 5f 6f 72 28 50 61 72 73 65 4d 6f 64  wrap_or(ParseMod
0370: 65 3a 3a 48 74 6d 6c 29 3b 0a 09 09 6c 65 74 20  e::Html);...let 
0380: 74 61 72 67 65 74 20 3d 20 74 61 72 67 65 74 2e  target = target.
0390: 75 6e 77 72 61 70 5f 6f 72 28 73 65 6c 66 2e 6f  unwrap_or(self.o
03a0: 77 6e 65 72 29 3b 0a 09 09 73 65 6c 66 2e 63 6c  wner);...self.cl
03b0: 69 65 6e 74 2e 65 78 65 63 75 74 65 28 0a 09 09  ient.execute(...
03c0: 09 53 65 6e 64 4d 65 73 73 61 67 65 3a 3a 6e 65  .SendMessage::ne
03d0: 77 28 74 61 72 67 65 74 2c 20 6d 73 67 29 0a 09  w(target, msg)..
03e0: 09 09 09 2e 77 69 74 68 5f 70 61 72 73 65 5f 6d  ....with_parse_m
03f0: 6f 64 65 28 6d 6f 64 65 29 0a 09 09 29 2e 61 77  ode(mode)...).aw
0400: 61 69 74 2e 73 74 61 63 6b 28 29 0a 09 7d 0a 0a  ait.stack()..}..
0410: 09 70 75 62 20 66 6e 20 77 69 74 68 5f 6f 77 6e  .pub fn with_own
0420: 65 72 20 28 26 73 65 6c 66 2c 20 6f 77 6e 65 72  er (&self, owner
0430: 3a 20 69 36 34 29 20 2d 3e 20 54 67 20 7b 0a 09  : i64) -> Tg {..
0440: 09 54 67 20 7b 0a 09 09 09 6f 77 6e 65 72 3a 20  .Tg {....owner: 
0450: 43 68 61 74 50 65 65 72 49 64 3a 3a 66 72 6f 6d  ChatPeerId::from
0460: 28 6f 77 6e 65 72 29 2c 0a 09 09 09 2e 2e 73 65  (owner),......se
0470: 6c 66 2e 63 6c 6f 6e 65 28 29 0a 09 09 7d 0a 09  lf.clone()...}..
0480: 7d 0a 7d 0a                                      }.}.