concord 2.2.9

A terminal user interface client for Discord
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

mod command_dispatch;
mod command_loop;
mod credentials;
mod gateway_commands;
mod history_commands;
mod media_adapters;
mod media_commands;
mod message_commands;
mod notification_commands;
mod read_state_commands;
mod session_commands;
mod shutdown;
mod user_commands;
mod voice_commands;

use tokio::sync::mpsc;

use crate::{DiscordClient, Result, discord::AppEvent, logging, tui, version_check};

use self::{
    command_loop::start_command_loop,
    credentials::resolve_token,
    shutdown::{leave_current_voice_channel_on_shutdown, shutdown_gateway},
};

#[derive(Default)]
pub struct App;

impl App {
    pub fn new() -> Self {
        Self
    }

    pub async fn run(self) -> Result<()> {
        loop {
            let resolved_token = resolve_token().await?;
            let token = resolved_token.token;
            let token_warnings = resolved_token.warnings;
            let client = DiscordClient::new(token)?;
            let effects = client.take_effects();
            let snapshots = client.subscribe_snapshots();
            let (commands_tx, commands_rx) = mpsc::channel(64);
            let gateway_task = client.start_gateway();
            let command_task = start_command_loop(client.clone(), commands_rx);

            // Warm the REST pool before the first user-triggered request pays the
            // TCP, TLS, and HTTP/2 setup cost.
            let prime_client = client.clone();
            tokio::spawn(async move {
                if let Err(error) = prime_client.prime_rest_pool().await {
                    logging::error("app", format!("rest pool warmup failed: {error}"));
                }
            });

            let version_client = client.clone();
            tokio::spawn(async move {
                match version_check::check_latest_version().await {
                    Ok(Some(latest_version)) => {
                        version_client
                            .publish_event(AppEvent::UpdateAvailable { latest_version })
                            .await;
                    }
                    Ok(None) => {}
                    Err(error) => {
                        logging::debug("version", format!("latest version check failed: {error}"))
                    }
                }
            });

            let result = async {
                for warning in token_warnings {
                    logging::error("app", &warning);
                    client
                        .publish_event(AppEvent::GatewayError { message: warning })
                        .await;
                }

                tui::run(effects, snapshots, commands_tx, client.clone()).await
            }
            .await;

            command_task.abort();
            leave_current_voice_channel_on_shutdown(&client);
            shutdown_gateway(&client, gateway_task).await;
            match result? {
                tui::DashboardExit::Quit => return Ok(()),
                tui::DashboardExit::SignOut => {}
            }
        }
    }
}