discord-cli-rs 0.1.0

Local-first read-only Discord archival CLI — search, sync, tail, and download via a user token
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

//! `discord top` — most active senders.

use anyhow::Result;

use crate::commands::resolve;
use crate::commands::Ctx;
use crate::db::Db;
use crate::output;

pub fn run(ctx: &Ctx, channel: Option<&str>, hours: Option<i64>, limit: i64) -> Result<()> {
    let db = Db::open(&ctx.db_path)?;
    let channel_id = resolve::resolve_channel(&db, channel)?;

    let rows = db.top_senders(channel_id.as_deref(), hours, limit)?;

    if ctx.json {
        let data: Vec<serde_json::Value> = rows
            .iter()
            .map(|(name, count, first, last)| {
                serde_json::json!({
                    "sender": name,
                    "count": count,
                    "first_message": first,
                    "last_message": last,
                })
            })
            .collect();
        output::print_json(&data);
        return Ok(());
    }

    if rows.is_empty() {
        output::dim("No messages found.");
        return Ok(());
    }

    let table_rows: Vec<Vec<String>> = rows
        .iter()
        .enumerate()
        .map(|(i, (name, count, first, last))| {
            vec![
                format!("{}", i + 1),
                name.clone(),
                count.to_string(),
                first.chars().take(10).collect(),
                last.chars().take(10).collect(),
            ]
        })
        .collect();
    output::print_table(&["#", "sender", "messages", "first seen", "last seen"], &table_rows);
    Ok(())
}