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
84
85
86
87
88
89
90
91
92
93
94
95
96
97

#[cfg(feature = "dispatch")]
use std::env;
#[cfg(feature = "dispatch")]
use std::sync::{
    Arc,
    atomic::{AtomicBool, Ordering},
};
#[cfg(feature = "dispatch")]
use teamtalk::dispatch::{ClientConfig, ConnectParamsOwned, DispatchFlow, Dispatcher};
#[cfg(feature = "dispatch")]
use teamtalk::types::ChannelId;
#[cfg(feature = "dispatch")]
use teamtalk::{Client, Event, LoginParams, ReconnectConfig};

#[cfg(feature = "dispatch")]
fn env_or(name: &str, default: &str) -> String {
    env::var(name).unwrap_or_else(|_| default.to_string())
}

#[cfg(feature = "dispatch")]
fn env_or_i32(name: &str, default: i32) -> i32 {
    env::var(name)
        .ok()
        .and_then(|value| value.parse::<i32>().ok())
        .unwrap_or(default)
}

#[cfg(feature = "dispatch")]
fn main() -> teamtalk::Result<()> {
    let host = env_or("TT_HOST", "127.0.0.1");
    let tcp = env_or_i32("TT_TCP", 10333);
    let udp = env_or_i32("TT_UDP", 10333);
    let nickname = env_or("TT_NICK", "DispatchBot");
    let username = env_or("TT_USER", "guest");
    let password = env_or("TT_PASS", "guest");
    let client_name = env_or("TT_CLIENT", "TeamTalkRust");
    let channel_password = env_or("TT_CHAN_PASS", "");
    let root_channel = ChannelId(1);
    let should_join = Arc::new(AtomicBool::new(true));

    let client = Client::new()?;
    client.set_login_params(LoginParams::new(
        &nickname,
        &username,
        &password,
        &client_name,
    ));
    client.set_last_channel(root_channel, Some(&channel_password));
    client.connect_remember(&host, tcp, udp, false)?;

    let config = ClientConfig::new().reconnect_with_events(
        ConnectParamsOwned::new(&host, tcp, udp, false),
        ReconnectConfig::default(),
        vec![Event::MySelfKicked],
    );

    let should_join_on_login = should_join.clone();
    let mut dispatcher = Dispatcher::with_config(client, config)
        .on_connect_success(move |ctx| {
            if let Some(client) = ctx.client() {
                client.login_with_params().ok();
            }
            DispatchFlow::Continue
        })
        .on_event(Event::MySelfKicked, {
            let should_join = should_join.clone();
            move |_| {
                should_join.store(true, Ordering::Relaxed);
                DispatchFlow::Continue
            }
        })
        .on_event(Event::ConnectionLost, {
            let should_join = should_join.clone();
            move |_| {
                should_join.store(true, Ordering::Relaxed);
                DispatchFlow::Continue
            }
        })
        .on_event(Event::MySelfLoggedIn, move |ctx| {
            if let Some(client) = ctx.client()
                && should_join_on_login.swap(false, Ordering::Relaxed)
            {
                client.join_channel(root_channel, &channel_password);
            }
            DispatchFlow::Continue
        });

    dispatcher.run();
    Ok(())
}

#[cfg(not(feature = "dispatch"))]
fn main() {
    eprintln!(
        "Enable the dispatch feature: cargo run --example dispatch_reconnect --features dispatch"
    );
}