toptl-teloxide 0.1.0

Teloxide plugin for TOP.TL — autopost bot stats, gate handlers behind votes, handle vote webhooks.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80

# toptl-teloxide

[![Crates.io](https://img.shields.io/crates/v/toptl-teloxide.svg?color=3775a9)](https://crates.io/crates/toptl-teloxide)
[![docs.rs](https://img.shields.io/docsrs/toptl-teloxide/latest?color=3776ab)](https://docs.rs/toptl-teloxide)
[![Downloads](https://img.shields.io/crates/d/toptl-teloxide.svg?color=blue)](https://crates.io/crates/toptl-teloxide)
[![License](https://img.shields.io/crates/l/toptl-teloxide.svg?color=green)](https://github.com/top-tl/teloxide/blob/main/LICENSE)
[![teloxide](https://img.shields.io/badge/teloxide-0.13-26a5e4)](https://github.com/teloxide/teloxide)
[![TOP.TL](https://img.shields.io/badge/top.tl-developers-2ec4b6)](https://top.tl/developers)

[Teloxide](https://github.com/teloxide/teloxide) plugin for [TOP.TL](https://top.tl) — autopost bot stats, gate handlers behind votes, and handle vote webhooks.

## Install

```toml
[dependencies]
toptl-teloxide = "0.1"
teloxide = "0.13"
tokio = { version = "1", features = ["macros", "rt-multi-thread"] }
```

Built on the [`toptl`](https://crates.io/crates/toptl) SDK.

## Quick start

```rust
use std::time::Duration;
use teloxide::prelude::*;
use toptl::TopTL;
use toptl_teloxide::{record_update, TopTLPlugin};

#[tokio::main]
async fn main() {
    let bot = Bot::from_env();
    let client = TopTL::new("toptl_xxx");
    let plugin = TopTLPlugin::new(client, "mybot");
    plugin.start(Duration::from_secs(30 * 60));

    let plugin_clone = plugin.clone();
    teloxide::repl(bot, move |msg: Message, bot: Bot| {
        let plugin = plugin_clone.clone();
        async move {
            record_update(&plugin, &msg).await;
            bot.send_message(msg.chat.id, "hi").await?;
            Ok::<_, teloxide::RequestError>(())
        }
    })
    .await;
}
```

`plugin.start(...)` spawns a background task that flushes unique user/group/channel counts every interval. `record_update(...)` ingests one incoming message so the counters stay current.

## Vote gating

```rust
async fn premium(msg: Message, bot: Bot, plugin: TopTLPlugin) -> ResponseResult<()> {
    if let Some(user) = &msg.from {
        if !plugin.has_voted(user.id.0 as i64).await {
            bot.send_message(msg.chat.id, "Vote first: https://top.tl/mybot").await?;
            return Ok(());
        }
    }
    bot.send_message(msg.chat.id, "Thanks for voting!").await?;
    Ok(())
}
```

`has_voted` is **fail-open** — network or auth errors count as "not voted" and log, never crash your handler.

## Manual flush

Useful from a shutdown hook:

```rust
plugin.post_now().await?;
```

## License

MIT — see [`LICENSE`](LICENSE).