1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
mod command;
mod core;
use futures::StreamExt;
#[macro_use]
extern crate lazy_static;
let mut settings = config::Config::default();
settings.merge(config::File::with_name("rsstg"))?;
let core = core::Core::new(settings).await?;
let mut stream = core.stream();
stream.allowed_updates(&[telegram_bot::AllowedUpdate::Message]);
let mut reply_to: Option<telegram_bot::UserId>;
|
<
<
<
<
|
|
>
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
mod command;
mod core;
use futures::StreamExt;
use anyhow::Result;
#[tokio::main]
async fn main() -> Result<()> {
let settings = config::Config::builder()
.add_source(config::File::with_name("rsstg"))
.build()?;
let core = core::Core::new(settings).await?;
let mut stream = core.stream();
stream.allowed_updates(&[telegram_bot::AllowedUpdate::Message]);
let mut reply_to: Option<telegram_bot::UserId>;
|