33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
tg,
my: task::block_on(async {
tg_cloned.send(telegram_bot::GetMe).await
})?,
owner_chat: telegram_bot::UserId::new(owner),
pool: PgPoolOptions::new()
.max_connections(5)
.connect_timeout(std::time::Duration::new(300, 0))
.idle_timeout(std::time::Duration::new(60, 0))
.connect_lazy(&settings.get_string("pg")?)?,
sources: Arc::new(Mutex::new(HashSet::new())),
});
let clone = core.clone();
task::spawn(async move {
loop {
|
|
|
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
tg,
my: task::block_on(async {
tg_cloned.send(telegram_bot::GetMe).await
})?,
owner_chat: telegram_bot::UserId::new(owner),
pool: PgPoolOptions::new()
.max_connections(5)
.acquire_timeout(std::time::Duration::new(300, 0))
.idle_timeout(std::time::Duration::new(60, 0))
.connect_lazy(&settings.get_string("pg")?)?,
sources: Arc::new(Mutex::new(HashSet::new())),
});
let clone = core.clone();
task::spawn(async move {
loop {
|