tail-fin-daemon 0.7.8

Long-running browser-session daemon for tail-fin (tfd binary). Keeps Chrome tabs warm across invocations via a Unix-socket protocol; registers Site implementations through a runtime Arc<dyn Site> registry.
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

use crate::spawn::ensure_daemon_safe;
use clap::Subcommand;
use night_fury_daemon_core::cli::make_req;
use night_fury_daemon_core::client;
use serde_json::json;

use super::{acquire_then_exec, ExecArgs};

#[derive(Subcommand)]
pub enum TwitterCmd {
    /// Home timeline
    Timeline {
        #[arg(long, default_value = "following")]
        r#type: String,
        #[arg(long, default_value_t = 20)]
        count: u64,
    },
    /// Search tweets
    Search {
        query: String,
        #[arg(long, default_value_t = 20)]
        count: u64,
    },
}

pub async fn run(
    cmd: TwitterCmd,
    socket: &str,
    host: &str,
    session: Option<String>,
) -> anyhow::Result<()> {
    let (cmd_name, params) = match cmd {
        TwitterCmd::Timeline { r#type, count } => {
            ("twitter.timeline", json!({"type": r#type, "count": count}))
        }
        TwitterCmd::Search { query, count } => {
            ("twitter.search", json!({"query": query, "count": count}))
        }
    };

    if let Some(sid) = session {
        ensure_daemon_safe(socket).await?;
        let req = make_req(cmd_name, Some(&sid), params);
        let resp = client::send(socket, &req).await?;
        super::print_and_check(&resp);
        return Ok(());
    }

    let args = ExecArgs {
        site: "twitter",
        host,
        cmd: cmd_name,
        params,
    };
    acquire_then_exec(socket, args).await
}