kick-api 0.1.9

Rust client for the Kick.com API
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

use kick_api::LiveChatClient;

/// Read live chat messages from a Kick channel.
///
/// Usage:
///   cargo run --example read_chat -- <username>
///
/// Example:
///   cargo run --example read_chat -- xqc
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let args: Vec<String> = std::env::args().collect();
    let username = match args.get(1) {
        Some(name) => name.as_str(),
        None => {
            eprintln!("Usage: cargo run --example read_chat -- <username>");
            eprintln!();
            eprintln!("Example:");
            eprintln!("  cargo run --example read_chat -- xqc");
            std::process::exit(1);
        }
    };

    println!("Connecting to {}'s chat...", username);
    let mut chat = LiveChatClient::connect_by_username(username).await?;
    println!("Connected! Waiting for messages (Ctrl+C to stop)...\n");

    while let Some(msg) = chat.next_message().await? {
        let badges: String = msg
            .sender
            .identity
            .badges
            .iter()
            .map(|b| format!("[{}]", b.text))
            .collect::<Vec<_>>()
            .join("");

        let prefix = if badges.is_empty() {
            msg.sender.username.clone()
        } else {
            format!("{} {}", badges, msg.sender.username)
        };

        println!("{}: {}", prefix, msg.content);
    }

    println!("Connection closed.");
    Ok(())
}