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
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
98
99
100
101
102
103
104
105
106
107
108
109
110
111

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 SaCmd {
    /// Income statement (annual|quarterly)
    IncomeStatement {
        ticker: String,
        #[arg(long, default_value = "annual")]
        period: String,
    },
    /// Balance sheet
    BalanceSheet {
        ticker: String,
        #[arg(long, default_value = "annual")]
        period: String,
    },
    /// Cash flow statement
    CashFlow {
        ticker: String,
        #[arg(long, default_value = "annual")]
        period: String,
    },
    /// Live quote
    Quote { ticker: String },
    /// News articles
    News {
        ticker: String,
        #[arg(long, default_value_t = 20)]
        count: u64,
        #[arg(long)]
        since: Option<i64>,
        #[arg(long)]
        until: Option<i64>,
    },
    /// Analysis articles
    Analysis {
        ticker: String,
        #[arg(long, default_value_t = 20)]
        count: u64,
        #[arg(long)]
        since: Option<i64>,
        #[arg(long)]
        until: Option<i64>,
    },
    /// Full article content
    Article { id: String },
}

pub async fn run(
    cmd: SaCmd,
    socket: &str,
    host: &str,
    session: Option<String>,
) -> anyhow::Result<()> {
    let (cmd_name, params) = match cmd {
        SaCmd::IncomeStatement { ticker, period } => (
            "sa.income-statement",
            json!({"ticker": ticker, "period": period}),
        ),
        SaCmd::BalanceSheet { ticker, period } => (
            "sa.balance-sheet",
            json!({"ticker": ticker, "period": period}),
        ),
        SaCmd::CashFlow { ticker, period } => {
            ("sa.cash-flow", json!({"ticker": ticker, "period": period}))
        }
        SaCmd::Quote { ticker } => ("sa.quote", json!({"ticker": ticker})),
        SaCmd::News {
            ticker,
            count,
            since,
            until,
        } => (
            "sa.news",
            json!({"ticker": ticker, "count": count, "since": since, "until": until}),
        ),
        SaCmd::Analysis {
            ticker,
            count,
            since,
            until,
        } => (
            "sa.analysis",
            json!({"ticker": ticker, "count": count, "since": since, "until": until}),
        ),
        SaCmd::Article { id } => ("sa.article", json!({"id": id})),
    };

    if let Some(sid) = session {
        // Explicit session — no acquire/release wrapping.
        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: "sa",
        host,
        cmd: cmd_name,
        params,
    };
    acquire_then_exec(socket, args).await
}