teamtalk 6.0.0

TeamTalk SDK for Rust
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
81
82
83

use super::{Bot, BotBuilder, BotConfig, MemoryStateStore, Router, Scheduler, StateStore};
use crate::client::Client;
use crate::events::Result;

/// High-level bot entrypoint that wires router/scheduler/state into a runtime.
///
/// This struct helps build one bot definition and run it with a sync or async
/// runtime without repeating the same wiring code.
pub struct BotApp {
    router: Router,
    scheduler: Scheduler,
    state: Box<dyn StateStore>,
    config: BotConfig,
}

impl Default for BotApp {
    fn default() -> Self {
        Self {
            router: Router::new(),
            scheduler: Scheduler::new(),
            state: Box::new(MemoryStateStore::new()),
            config: BotConfig::default(),
        }
    }
}

impl BotApp {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn with_router(mut self, router: Router) -> Self {
        self.router = router;
        self
    }

    pub fn with_scheduler(mut self, scheduler: Scheduler) -> Self {
        self.scheduler = scheduler;
        self
    }

    pub fn with_state_store(mut self, store: impl StateStore + 'static) -> Self {
        self.state = Box::new(store);
        self
    }

    pub fn with_config(mut self, config: BotConfig) -> Self {
        self.config = config;
        self
    }

    /// Builds a sync bot runtime.
    pub fn into_bot(self, client: Client) -> Bot {
        BotBuilder::new(client)
            .with_router(self.router)
            .with_scheduler(self.scheduler)
            .with_boxed_state_store(self.state)
            .with_config(self.config)
            .build()
    }

    /// Builds and runs a sync bot runtime.
    pub fn run_sync(self, client: Client) -> Result<()> {
        let mut bot = self.into_bot(client);
        bot.run()
    }

    #[cfg(feature = "async")]
    pub fn into_async_bot(self, client: crate::async_api::AsyncClient) -> super::AsyncBot {
        super::AsyncBotBuilder::new(client)
            .with_router(self.router)
            .with_scheduler(self.scheduler)
            .with_boxed_state_store(self.state)
            .with_config(super::AsyncBotConfig)
            .build()
    }

    #[cfg(feature = "async")]
    pub async fn run_async(self, client: crate::async_api::AsyncClient) -> Result<()> {
        let mut bot = self.into_async_bot(client);
        bot.run().await
    }
}