eli_cli/
args.rs

1#[derive(Parser, Debug)]
2#[command(name = "market-search", version, about = "Market Search: MCP server for finance data + a terminal coding agent")]
3struct Cli {
4    #[command(subcommand)]
5    cmd: Option<Command>,
6
7    /// Provider: openrouter | openai | anthropic | ollama | mock
8    #[arg(long, global = true)]
9    provider: Option<String>,
10
11    /// Model name (provider-specific)
12    #[arg(long, global = true)]
13    model: Option<String>,
14}
15
16#[derive(Subcommand, Debug)]
17enum Command {
18    /// Interactive setup - configure provider, model, and API key
19    Setup,
20
21    /// Create a default config file (if missing)
22    Init,
23
24    /// Print or set config values
25    Config {
26        /// Set a config value: provider, model, mem_steps, key, sec_user_agent, compact, compact_trigger, compact_keep, summary_model, parallel_commands, parallel_subagents, scrollback_max_lines
27        #[arg(long)]
28        set: Option<String>,
29
30        /// Value to set
31        #[arg(long)]
32        value: Option<String>,
33    },
34
35    /// Emit JSON schema for a CLI subcommand (hidden)
36    #[command(hide = true)]
37    ToolInfo {
38        /// Subcommand path (e.g., finance timeseries)
39        #[arg(value_name = "PATH", num_args = 0..)]
40        path: Vec<String>,
41    },
42
43    /// Financial data tools (for raw time-series exploration)
44    Finance {
45        #[command(subcommand)]
46        cmd: FinanceCommand,
47    },
48
49    /// Web tools (crawl, search, read)
50    Web {
51        #[command(subcommand)]
52        cmd: WebCommand,
53    },
54
55    /// Start MCP (Model Context Protocol) server — exposes market-search tools as native Claude Code tools via JSON-RPC stdio.
56    Mcp(McpArgs),
57
58    /// Log research picks for a report to track performance over time.
59    Picks {
60        #[command(subcommand)]
61        cmd: PicksCommand,
62    },
63}
64
65#[derive(Subcommand, Debug)]
66enum PicksCommand {
67    /// Record ticker/market picks at current prices for a given report.
68    Log(PicksLogArgs),
69}
70
71#[derive(clap::Args, Debug)]
72struct PicksLogArgs {
73    /// Path to the HTML report file (supports ~/).
74    #[arg(long)]
75    report: String,
76
77    /// Equity ticker(s) to track at current price (comma-separated or repeatable).
78    #[arg(long, value_delimiter = ',')]
79    ticker: Vec<String>,
80
81    /// Prediction market slug(s) to track at current probability (comma-separated or repeatable).
82    #[arg(long, value_delimiter = ',')]
83    market: Vec<String>,
84}
85
86#[derive(clap::Args, Debug)]
87struct McpArgs {
88    #[command(subcommand)]
89    cmd: Option<McpSubcommand>,
90
91    /// Run as HTTP server instead of stdio (MCP Streamable HTTP transport).
92    #[arg(long, default_value_t = false)]
93    http: bool,
94
95    /// Port for HTTP mode.
96    #[arg(long, default_value = "8484")]
97    port: u16,
98}
99
100#[derive(Subcommand, Debug)]
101enum McpSubcommand {
102    /// Get a public HTTPS /mcp URL (boots local HTTP MCP + spawns a tunnel).
103    Share(ShareArgs),
104}
105
106#[derive(clap::Args, Debug)]
107struct ShareArgs {
108    /// Tunnel provider: cloudflare | ngrok | tunnelmole | self-host
109    #[arg(long, default_value = "cloudflare")]
110    provider: String,
111
112    /// Local port the MCP HTTP server is bound to.
113    #[arg(long, default_value = "8484")]
114    port: u16,
115
116    /// For ngrok: reserved subdomain (e.g. mysub.ngrok-free.dev or just mysub).
117    #[arg(long)]
118    domain: Option<String>,
119
120    /// For ngrok: authtoken if not already configured globally.
121    #[arg(long)]
122    authtoken: Option<String>,
123}
124
125#[derive(Subcommand, Debug)]
126enum FinanceCommand {
127    /// Fetch OHLCV time-series for one or more tickers.
128    Timeseries(FinanceTimeseriesArgs),
129    /// Largest day movers by percent move, market cap, dollar volume, or estimated value change.
130    Movers(FinanceMoversArgs),
131    /// Current snapshot of income/balance/cashflow + 32 trailing ratios + company profile (sector, industry, employees). Single ticker returns object; multi-ticker returns array.
132    Fundamentals(FinanceFundamentalsArgs),
133    /// Search for ticker symbols or macro series IDs.
134    Search(FinanceSearchArgs),
135    /// Fetch recent SEC filings (8-K, 10-K, 10-Q) for a ticker.
136    Filings(FinanceFilingsArgs),
137    /// Alias for filings.
138    Sec(FinanceFilingsArgs),
139    /// Fetch earnings and macro release schedules (no-auth public endpoints).
140    Schedule(FinanceScheduleArgs),
141    /// Aggregate implied Fed policy trajectory from local prediction-market cache.
142    RatePath(FinanceRatePathArgs),
143    /// Prediction market discovery + pricing (Kalshi default; falls back to Polymarket).
144    Odds(FinanceOddsArgs),
145    /// Listed options chains with IV/skew summaries (Yahoo Finance).
146    Options(FinanceOptionsArgs),
147    /// Deprecated alias for `finance odds sync` (canonical). Same flags, same backend; kept for cron compatibility.
148    Sync(FinanceSyncArgs),
149    /// Local paper trading sandbox using live Kalshi/Polymarket prices.
150    Paper(FinancePaperArgs),
151    /// Interactive Brokers via local TWS / IB Gateway.
152    Ibkr(FinanceIbkrArgs),
153    /// Recent US Treasury auction results (bid-to-cover, tails, bidder breakdown).
154    Auctions(FinanceAuctionsArgs),
155    /// CFTC Commitment of Traders positioning (spec vs commercial, weekly).
156    Cot(FinanceCotArgs),
157    /// Futures term structure (forward curve) for commodities.
158    Curve(FinanceCurveArgs),
159    /// NY Fed Markets: overnight rates (SOFR/EFFR), reverse repo, SOMA holdings, dealer positions.
160    Nyfed(FinanceNyfedArgs),
161    /// CBOE volatility indices / term structure: VIX, VVIX, OVX, GVZ, SKEW.
162    #[command(name = "volatility", visible_alias = "volsurface")]
163    Volsurface(FinanceVolsurfaceArgs),
164    /// OFR Financial Stress Index: composite + credit/equity/funding/vol decomposition.
165    Stress(FinanceStressArgs),
166    /// Treasury fiscal data: national debt, daily statement, average interest rates.
167    Fiscal(FinanceFiscalArgs),
168    /// ECB Statistical Data Warehouse: EUR/USD, Euro STR, M3, EURIBOR, yield curve, balance sheet.
169    Ecb(FinanceEcbArgs),
170    /// EIA: US petroleum inventories (crude, gasoline, distillate), natural gas storage.
171    Eia(FinanceEiaArgs),
172    /// BIS: global central bank policy rates, total assets, credit-to-GDP gaps, property prices.
173    Bis(FinanceBisArgs),
174    /// BOJ: Bank of Japan monetary base, balance sheet, TANKAN, call rate, money stock.
175    Boj(FinanceBojArgs),
176    /// BOE: Bank of England Bank Rate, SONIA, gilt yields, M4, GBP FX rates.
177    Boe(FinanceBoeArgs),
178}
179
180#[derive(Subcommand, Debug)]
181enum WebCommand {
182    /// Crawl a website and extract content from all discovered pages.
183    Crawl(WebCrawlArgs),
184    /// Ingestion-focused web search for URL candidates + diagnostics.
185    Search(WebSearchArgs),
186    /// Read and extract content from one or many URLs.
187    Read(WebReadArgs),
188    /// Extract key facts from content (URL, file, or text).
189    Extract(WebExtractArgs),
190}
191
192#[derive(Subcommand, Debug)]
193enum AgentCommand {
194    /// Generate a market intelligence report (JSON + HTML) using Eli tools and optional model synthesis.
195    Report(AgentReportArgs),
196    /// Run a single Eli worker from a natural-language task.
197    Run(AgentRunArgs),
198    /// Run many Eli workers in parallel from a task template and vars file.
199    Fanout(AgentFanoutArgs),
200    /// Chunk a large input and orchestrate map/reduce/critic swarm synthesis.
201    Swarm(AgentSwarmArgs),
202    /// Critique a lead thesis/report using worker fanout.
203    Critique(AgentModeArgs),
204    /// Find additional evidence for/against a thesis via worker fanout.
205    Evidence(AgentModeArgs),
206    /// Run competitive workers to find the best answer.
207    Compete(AgentModeArgs),
208    /// Run worker debate and synthesize consensus.
209    Debate(AgentModeArgs),
210}
211
212#[derive(Subcommand, Debug)]
213enum SentinelCommand {
214    /// Start the sentinel daemon in the background.
215    Start(SentinelStartArgs),
216    /// Stop the sentinel daemon.
217    Stop(SentinelStopArgs),
218    /// Print sentinel daemon status.
219    Status(SentinelStatusArgs),
220    /// Register a new sentinel trigger subscription.
221    Subscribe(SentinelSubscribeArgs),
222    /// Remove a sentinel subscription by id or name.
223    Unsubscribe(SentinelUnsubscribeArgs),
224    /// List configured sentinel subscriptions.
225    List(SentinelListArgs),
226    /// Emit a synthetic alert packet for wiring tests.
227    Test(SentinelTestArgs),
228    /// Replay recent packets from queue file.
229    Replay(SentinelReplayArgs),
230    /// Internal daemon process entrypoint.
231    #[command(hide = true)]
232    DaemonRun(SentinelDaemonRunArgs),
233}
234
235#[derive(Debug, Serialize)]
236struct RustFileSummary {
237    items_total: usize,
238    functions: usize,
239    function_names: Vec<String>,
240    /// Full signatures: "pub async fn name(param: Type) -> ReturnType"
241    /// Lets an AI caller understand the API contract without reading source.
242    function_signatures: Vec<String>,
243    structs: usize,
244    struct_names: Vec<String>,
245    /// Per-struct field list: {struct_name: ["field: Type", ...]}
246    struct_fields: std::collections::BTreeMap<String, Vec<String>>,
247    enums: usize,
248    enum_names: Vec<String>,
249    impls: usize,
250    impl_targets: Vec<String>,
251    /// Methods per impl block: {"LlmAdapter for AnthropicAdapter": ["pub async fn chat(...)  -> ..."]}
252    impl_methods: std::collections::BTreeMap<String, Vec<String>>,
253    traits: usize,
254    trait_names: Vec<String>,
255    modules: usize,
256    module_names: Vec<String>,
257    uses: usize,
258    use_paths: Vec<String>,
259    consts: usize,
260    const_names: Vec<String>,
261    statics: usize,
262    type_aliases: usize,
263    type_alias_names: Vec<String>,
264    macros: usize,
265    others: usize,
266}
267
268#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
269enum CrawlViewMode {
270    Summary,
271    Raw,
272    Path,
273}
274
275#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
276enum CrawlSaveMode {
277    Auto,
278    Off,
279}
280
281#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
282enum WebSearchModeArg {
283    Auto,
284    News,
285    Finance,
286    Research,
287    Tech,
288    Encyclopedia,
289}
290
291#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
292enum WebSearchRecencyArg {
293    Day,
294    Week,
295    Month,
296    Year,
297}
298
299#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
300enum FinancePaperCommandArg {
301    Trade,
302    Positions,
303    Trades,
304    Mark,
305    Reset,
306}
307
308#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
309enum FinancePaperModeArg {
310    Simulated,
311    #[value(alias = "live_like")]
312    LiveLike,
313    #[value(alias = "kalshi_demo")]
314    KalshiDemo,
315    #[value(alias = "polymarket_demo")]
316    PolymarketDemo,
317}
318
319#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
320enum FinancePaperSideArg {
321    Yes,
322    No,
323}
324
325#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
326enum FinancePaperOrderActionArg {
327    Buy,
328    Sell,
329}
330
331#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
332enum FinanceIbkrCommandArg {
333    Snapshot,
334    Timeseries,
335    AccountSummary,
336    Positions,
337    Portfolio,
338    OpenOrders,
339    PlaceOrder,
340    CancelOrder,
341}
342
343#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
344enum SentinelSeverityArg {
345    Low,
346    Medium,
347    High,
348    Critical,
349}
350
351#[derive(Copy, Clone, Debug, ValueEnum, Eq, PartialEq)]
352enum SentinelSpawnTargetArg {
353    Default,
354    Codex,
355    Claude,
356    Gemini,
357    Both,
358}
359
360#[derive(clap::Args, Debug)]
361struct SentinelPathArgs {
362    /// Sentinel root directory.
363    #[arg(long = "sentinel-dir")]
364    sentinel_dir: Option<PathBuf>,
365
366    /// Queue JSONL file override.
367    #[arg(long = "queue-file")]
368    queue_file: Option<PathBuf>,
369
370    /// Intelligence packets JSONL file override.
371    #[arg(long = "packets-file")]
372    packets_file: Option<PathBuf>,
373}
374
375#[derive(clap::Args, Debug)]
376struct SentinelStartArgs {
377    #[command(flatten)]
378    paths: SentinelPathArgs,
379
380    /// Daemon evaluation interval in seconds.
381    #[arg(long = "interval-secs", default_value_t = 15)]
382    interval_secs: u64,
383}
384
385#[derive(clap::Args, Debug)]
386struct SentinelStopArgs {
387    #[command(flatten)]
388    paths: SentinelPathArgs,
389}
390
391#[derive(clap::Args, Debug)]
392struct SentinelStatusArgs {
393    #[command(flatten)]
394    paths: SentinelPathArgs,
395}
396
397#[derive(clap::Args, Debug)]
398struct SentinelSubscribeArgs {
399    #[command(flatten)]
400    paths: SentinelPathArgs,
401
402    /// Human-readable subscription name (internal slug).
403    #[arg(long)]
404    name: String,
405
406    /// Human-readable prediction statement shown in the UI.
407    /// Example: "Gold will reach 5200 before Friday close"
408    #[arg(long)]
409    title: Option<String>,
410
411    /// Title of the report that authored this prediction.
412    #[arg(long = "source-report")]
413    source_report_title: Option<String>,
414
415    /// Date of the source report (ISO format, e.g. 2026-03-06).
416    #[arg(long = "source-date")]
417    source_report_date: Option<String>,
418
419    /// Filename of the source report (relative to reports_dir) for opening in the UI.
420    #[arg(long = "source-file")]
421    source_report_file: Option<String>,
422
423    /// Key evidence snippet or quote from the source report justifying this prediction.
424    #[arg(long = "source-evidence")]
425    source_evidence: Option<String>,
426
427    /// Trigger expression, e.g. \"pyth_wti > 80 && poly_hormuz_yes > 0.50\".
428    /// Optional when --fire-at is set (defaults to "true" for pure checkpoint daemons).
429    #[arg(long)]
430    expr: Option<String>,
431
432    /// Optional variable mapping (repeatable): var=provider:query
433    #[arg(long = "var")]
434    vars: Vec<String>,
435
436    /// Why this alert matters (stored in packet/playbook).
437    #[arg(long = "why")]
438    why: Option<String>,
439
440    /// Prompt template for the follow-up playbook.
441    #[arg(long = "prompt-template")]
442    prompt_template: Option<String>,
443
444    /// Alert severity.
445    #[arg(long, value_enum, default_value = "medium")]
446    severity: SentinelSeverityArg,
447
448    /// Cooldown between repeated triggers (seconds).
449    #[arg(long = "cooldown-secs", default_value_t = 300)]
450    cooldown_secs: u64,
451
452    /// Start enabled (default true).
453    #[arg(long, default_value_t = true)]
454    enabled: bool,
455
456    /// Spawn headless AI agent (claude/codex) when this subscription triggers.
457    #[arg(long = "spawn-agent", default_value_t = false)]
458    spawn_agent: bool,
459
460    /// Which headless writer(s) should fire when this subscription triggers.
461    #[arg(long = "spawn-target", value_enum, default_value = "default")]
462    spawn_target: SentinelSpawnTargetArg,
463
464    /// Legacy spawn cooldown field retained for compatibility with existing subscriptions.
465    /// Spawn routing now uses rolling per-hour budgets instead.
466    #[arg(long = "spawn-cooldown-secs", default_value_t = 14400, hide = true)]
467    spawn_cooldown_secs: u64,
468
469    /// Human-readable prediction thesis this daemon encodes.
470    /// When set, fires on HIT (condition met) OR MISS (deadline elapsed without condition met).
471    #[arg(long = "prediction")]
472    prediction: Option<String>,
473
474    /// Which variable name in --expr to track as the prediction target (e.g., "pyth_wti").
475    #[arg(long = "target-var")]
476    target_var: Option<String>,
477
478    /// Predicted numeric target for target-var (e.g., 90.0).
479    #[arg(long = "target-value")]
480    target_value: Option<f64>,
481
482    /// Prediction deadline in RFC3339 format (e.g., 2026-04-01T00:00:00Z).
483    /// Fires MISS if condition not met by this time.
484    #[arg(long = "deadline")]
485    deadline: Option<String>,
486
487    /// Scheduled fire time in RFC3339 format (e.g., 2026-03-12T16:03:00Z).
488    /// Daemon fires ONCE at this exact time. Expr is evaluated at that moment for HIT/MISS.
489    /// Omit --expr for a pure checkpoint (always fires, no condition).
490    #[arg(long = "fire-at")]
491    fire_at: Option<String>,
492}
493
494#[derive(clap::Args, Debug)]
495struct SentinelUnsubscribeArgs {
496    #[command(flatten)]
497    paths: SentinelPathArgs,
498
499    /// Subscription id or exact name.
500    #[arg(long = "id")]
501    id_or_name: String,
502}
503
504#[derive(clap::Args, Debug)]
505struct SentinelListArgs {
506    #[command(flatten)]
507    paths: SentinelPathArgs,
508}
509
510#[derive(clap::Args, Debug)]
511struct SentinelTestArgs {
512    #[command(flatten)]
513    paths: SentinelPathArgs,
514
515    /// Synthetic test scenario.
516    #[arg(long, default_value = "generic")]
517    scenario: String,
518}
519
520#[derive(clap::Args, Debug)]
521struct SentinelReplayArgs {
522    #[command(flatten)]
523    paths: SentinelPathArgs,
524
525    /// Number of recent queue lines to replay.
526    #[arg(long = "max-lines", default_value_t = 50)]
527    max_lines: usize,
528}
529
530#[derive(clap::Args, Debug)]
531struct SentinelDaemonRunArgs {
532    #[command(flatten)]
533    paths: SentinelPathArgs,
534
535    /// Daemon evaluation interval in seconds.
536    #[arg(long = "interval-secs", default_value_t = 15)]
537    interval_secs: u64,
538}
539
540#[derive(clap::Args, Debug)]
541struct AgentReportArgs {
542    /// Report objective/prompt. Defaults to Eli three-pillar research framework.
543    #[arg(long)]
544    prompt: Option<String>,
545
546    /// Comma-separated market tickers for snapshot/timeseries.
547    #[arg(
548        long,
549        value_delimiter = ',',
550        default_value = "SPY,QQQ,IWM,DIA,^VIX,BTC-USD,ETH-USD,SOL-USD,DX-Y.NYB,GC=F,CL=F"
551    )]
552    tickers: Vec<String>,
553
554    /// Historical lookback span for timeseries (e.g. 14d, 30d, 3mo).
555    #[arg(long, default_value = "14d")]
556    lookback: String,
557
558    /// Timeseries granularity (e.g. 15min, 1h, 1d).
559    #[arg(long, default_value = "1h")]
560    granularity: String,
561
562    /// Lock clock-sensitive tools to N minutes before report start.
563    #[arg(long = "lock-minutes", conflicts_with = "as_of")]
564    lock_minutes: Option<u64>,
565
566    /// Explicit report anchor time (RFC3339 or YYYY-MM-DD).
567    #[arg(long = "as-of", conflicts_with = "lock_minutes")]
568    as_of: Option<String>,
569
570    /// Comma-separated odds search queries.
571    #[arg(
572        long,
573        value_delimiter = ',',
574        default_value = "recession,fed,inflation,iran,oil,china,taiwan"
575    )]
576    odds_queries: Vec<String>,
577
578    /// Number of top markets per odds query.
579    #[arg(long, default_value_t = 8)]
580    top: usize,
581
582    /// Comma-separated web queries for narrative context.
583    #[arg(
584        long,
585        value_delimiter = ',',
586        default_value = "stock market today,treasury yields today,fed policy outlook,oil geopolitical risk"
587    )]
588    web_queries: Vec<String>,
589
590    /// Max runtime budget per command invocation (milliseconds).
591    #[arg(long = "max-ms", default_value_t = 45000)]
592    max_ms: u64,
593
594    /// Comma-separated fallback models for synthesis worker.
595    #[arg(long = "fallback-models", value_delimiter = ',')]
596    fallback_models: Vec<String>,
597
598    /// Optional explicit HTML output path.
599    #[arg(long = "html-out")]
600    html_out: Option<PathBuf>,
601
602    /// Output JSON path for the report envelope.
603    #[arg(long)]
604    out: Option<PathBuf>,
605}
606
607#[derive(clap::Args, Debug)]
608struct AgentRunArgs {
609    /// Natural-language task for the worker.
610    #[arg(long)]
611    task: String,
612
613    /// Output file path (JSON).
614    #[arg(long)]
615    out: Option<PathBuf>,
616
617    /// Comma-separated fallback models (used on worker failure).
618    #[arg(long = "fallback-models", value_delimiter = ',')]
619    fallback_models: Vec<String>,
620
621    /// Max runtime budget per worker (milliseconds).
622    #[arg(long = "max-ms", default_value_t = 45000)]
623    max_ms: u64,
624
625    /// Max total attempts per worker across primary + fallbacks.
626    #[arg(long = "max-attempts", default_value_t = 4)]
627    max_attempts: usize,
628
629    /// Require the final report to cite these path prefixes (comma-separated).
630    #[arg(long = "must-cite", value_delimiter = ',')]
631    must_cite: Vec<String>,
632}
633
634#[derive(clap::Args, Debug)]
635struct AgentFanoutArgs {
636    /// Task template. Use placeholders like {{ticker}} or {{stance}}.
637    #[arg(long = "task-template")]
638    task_template: String,
639
640    /// JSON file containing an array of objects for template vars.
641    #[arg(long)]
642    vars: PathBuf,
643
644    /// Optional shared artifact manifest path all workers should read first.
645    #[arg(long = "shared-manifest")]
646    shared_manifest: Option<PathBuf>,
647
648    /// Max workers to run at once.
649    #[arg(long, default_value = "4")]
650    max_parallel: usize,
651
652    /// Output file path (JSON).
653    #[arg(long)]
654    out: Option<PathBuf>,
655
656    /// Comma-separated fallback models (used on worker failure).
657    #[arg(long = "fallback-models", value_delimiter = ',')]
658    fallback_models: Vec<String>,
659
660    /// Max runtime budget per worker (milliseconds).
661    #[arg(long = "max-ms", default_value_t = 45000)]
662    max_ms: u64,
663
664    /// Max total attempts per worker across primary + fallbacks.
665    #[arg(long = "max-attempts", default_value_t = 4)]
666    max_attempts: usize,
667
668    /// Require each successful worker report to cite these path prefixes (comma-separated).
669    #[arg(long = "must-cite", value_delimiter = ',')]
670    must_cite: Vec<String>,
671}
672
673#[derive(clap::Args, Debug)]
674struct AgentSwarmArgs {
675    /// High-level goal for the swarm.
676    #[arg(long)]
677    task: String,
678
679    /// Input file to process (txt/md/json/csv/ndjson/pdf).
680    #[arg(long)]
681    input: PathBuf,
682
683    /// Optional explicit number of chunk workers (X swarms).
684    #[arg(long)]
685    chunks: Option<usize>,
686
687    /// Approximate characters per chunk when --chunks is not provided.
688    #[arg(long = "chunk-chars", default_value_t = 20_000)]
689    chunk_chars: usize,
690
691    /// Character overlap between chunks to reduce boundary loss.
692    #[arg(long = "overlap-chars", default_value_t = 500)]
693    overlap_chars: usize,
694
695    /// Hard cap on produced chunks.
696    #[arg(long = "max-chunks", default_value_t = 64)]
697    max_chunks: usize,
698
699    /// Max workers to run at once for map stage.
700    #[arg(long, default_value = "4")]
701    max_parallel: usize,
702
703    /// Output file path (JSON).
704    #[arg(long)]
705    out: Option<PathBuf>,
706
707    /// Comma-separated fallback models (used on worker failure).
708    #[arg(long = "fallback-models", value_delimiter = ',')]
709    fallback_models: Vec<String>,
710
711    /// Max runtime budget per worker (milliseconds).
712    #[arg(long = "max-ms", default_value_t = 120_000)]
713    max_ms: u64,
714
715    /// Max total attempts per worker across primary + fallbacks.
716    #[arg(long = "max-attempts", default_value_t = 4)]
717    max_attempts: usize,
718
719    /// Require successful stage reports to cite these path prefixes (comma-separated).
720    #[arg(long = "must-cite", value_delimiter = ',')]
721    must_cite: Vec<String>,
722}
723
724#[derive(clap::Args, Debug)]
725struct AgentModeArgs {
726    /// User objective for this report mode.
727    #[arg(long)]
728    prompt: String,
729
730    /// Optional lead report or thesis file path.
731    #[arg(long)]
732    lead: Option<PathBuf>,
733
734    /// JSON file containing an array of worker objects (name/model/role/etc).
735    #[arg(long)]
736    vars: PathBuf,
737
738    /// Optional shared artifact manifest path all workers should read first.
739    #[arg(long = "shared-manifest")]
740    shared_manifest: Option<PathBuf>,
741
742    /// Allow workers to reference peer output in compete/debate modes.
743    #[arg(long, default_value_t = false)]
744    allow_cheat: bool,
745
746    /// Max workers to run at once.
747    #[arg(long, default_value = "4")]
748    max_parallel: usize,
749
750    /// Output file path (JSON).
751    #[arg(long)]
752    out: Option<PathBuf>,
753
754    /// Comma-separated fallback models (used on worker failure).
755    #[arg(long = "fallback-models", value_delimiter = ',')]
756    fallback_models: Vec<String>,
757
758    /// Max runtime budget per worker (milliseconds).
759    #[arg(long = "max-ms", default_value_t = 120_000)]
760    max_ms: u64,
761
762    /// Max total attempts per worker across primary + fallbacks.
763    #[arg(long = "max-attempts", default_value_t = 2)]
764    max_attempts: usize,
765
766    /// Require each successful worker report to cite these path prefixes (comma-separated).
767    #[arg(long = "must-cite", value_delimiter = ',')]
768    must_cite: Vec<String>,
769}
770
771#[derive(clap::Args, Debug)]
772struct CodeArgs {
773    /// Path to Rust source file or directory to analyze.
774    path: PathBuf,
775
776    /// Also generate code (e.g., getter methods for structs).
777    #[arg(long, default_value_t = false)]
778    generate: bool,
779
780    /// Minimum line count filter (directory mode only).
781    #[arg(long, default_value_t = 0)]
782    min_loc: usize,
783
784    /// Maximum number of files to analyze after sorting by path (directory mode only).
785    #[arg(long)]
786    max_files: Option<usize>,
787
788    /// Parallel worker count for Rust parsing (directory mode only).
789    #[arg(long)]
790    workers: Option<usize>,
791
792    /// Number of rows to include for each hotspot ranking (directory mode only).
793    #[arg(long, default_value_t = 20)]
794    top: usize,
795
796    /// Include per-file metrics in response (directory mode only).
797    #[arg(long, default_value_t = false)]
798    include_files: bool,
799
800    /// Search for symbol usages across all .rs files in path (comma-separated).
801    /// Uses multi-pattern matching. Returns every line containing any of the symbols
802    /// with file path and line number. Works on files and directories.
803    #[arg(long, value_delimiter = ',')]
804    find: Vec<String>,
805
806    /// Emit the complete public API surface for a directory: every pub fn (with full
807    /// signature), pub struct (with field types), pub enum (with variants), pub trait
808    /// (with method signatures), grouped by file. Ideal for understanding a module's
809    /// contract before writing new code.
810    #[arg(long, default_value_t = false)]
811    pub_api: bool,
812
813    /// Optional output file for JSON response.
814    #[arg(long)]
815    out: Option<PathBuf>,
816}
817
818#[derive(clap::Args, Debug)]
819struct WebCrawlArgs {
820    /// URL to start crawling from.
821    #[arg(long)]
822    url: String,
823
824    /// Maximum number of pages to crawl (default: 50).
825    #[arg(long, default_value = "50")]
826    max_pages: usize,
827
828    /// Respect robots.txt (default: true).
829    #[arg(long, default_value = "true")]
830    respect_robots: bool,
831
832    /// Include subdomains in crawl (default: false).
833    #[arg(long, default_value = "false")]
834    subdomains: bool,
835
836    /// Crawl via sitemap discovery mode.
837    #[arg(long, default_value = "false")]
838    sitemap: bool,
839
840    /// Smart crawl mode: HTTP first, render JS only when needed.
841    #[arg(long, default_value = "false", conflicts_with = "sitemap")]
842    smart: bool,
843
844    /// Terminal output view.
845    #[arg(long, value_enum, default_value_t = CrawlViewMode::Summary)]
846    view: CrawlViewMode,
847
848    /// Save policy when --out is not provided.
849    #[arg(long, value_enum, default_value_t = CrawlSaveMode::Auto)]
850    save: CrawlSaveMode,
851
852    /// Output file path (JSON).
853    #[arg(long)]
854    out: Option<PathBuf>,
855}
856
857#[derive(clap::Args, Debug)]
858struct WebSearchArgs {
859    /// Search query.
860    #[arg(long)]
861    query: String,
862
863    /// Search mode tuned for different ingestion workflows.
864    #[arg(long, value_enum, default_value_t = WebSearchModeArg::Auto)]
865    mode: WebSearchModeArg,
866
867    /// Include only these domains (comma-separated).
868    #[arg(long, value_delimiter = ',')]
869    domains: Vec<String>,
870
871    /// Exclude these domains (comma-separated).
872    #[arg(long = "exclude-domains", value_delimiter = ',')]
873    exclude_domains: Vec<String>,
874
875    /// Recency hint (day, week, month, year).
876    #[arg(long, value_enum)]
877    recency: Option<WebSearchRecencyArg>,
878
879    /// Earliest publication date (YYYY-MM-DD).
880    #[arg(long)]
881    since: Option<String>,
882
883    /// Latest publication date (YYYY-MM-DD).
884    #[arg(long)]
885    until: Option<String>,
886
887    /// Maximum items to return.
888    #[arg(long, default_value_t = 15)]
889    top: usize,
890
891    /// Number of top results to probe with web read diagnostics.
892    #[arg(long = "probe-top", default_value_t = 4)]
893    probe_top: usize,
894
895    /// Maximum parallel network operations.
896    #[arg(long = "max-parallel", default_value_t = 6)]
897    max_parallel: usize,
898
899    /// Optional run-tracking key for delta comparisons.
900    #[arg(long = "track-key")]
901    track_key: Option<String>,
902
903    /// Emit full verbose payload (snippets + detailed score components).
904    #[arg(long, default_value_t = false)]
905    full: bool,
906
907    /// Output file path (JSON).
908    #[arg(long)]
909    out: Option<PathBuf>,
910}
911
912#[derive(clap::Args, Debug)]
913struct WebReadArgs {
914    /// URL(s) to read content from (repeatable or comma-separated).
915    #[arg(long = "url", value_delimiter = ',')]
916    url: Vec<String>,
917
918    /// Optional file containing URLs (one per line, '#' comments allowed).
919    #[arg(long = "urls-file")]
920    urls_file: Option<PathBuf>,
921
922    /// Maximum parallel URL fetches.
923    #[arg(long = "max-parallel", default_value_t = 6)]
924    max_parallel: usize,
925
926    /// Max chars to keep per article text in default compact mode.
927    #[arg(long = "max-chars", default_value_t = 2400)]
928    max_chars: usize,
929
930    /// Emit full verbose payload (full text + attempt details).
931    #[arg(long, default_value_t = false)]
932    full: bool,
933
934    /// Output file path (JSON).
935    #[arg(long)]
936    out: Option<PathBuf>,
937}
938
939#[derive(clap::Args, Debug)]
940struct WebExtractArgs {
941    /// URL to fetch and extract from.
942    #[arg(long)]
943    url: Option<String>,
944
945    /// File path to extract from.
946    #[arg(long)]
947    file: Option<PathBuf>,
948
949    /// Inline text to extract from (use heredoc for large content).
950    #[arg(long)]
951    text: Option<String>,
952
953    /// Number of bullet points to extract (default: 10).
954    #[arg(long, default_value = "10")]
955    bullets: usize,
956
957    /// Focus extraction on specific topic.
958    #[arg(long)]
959    focus: Option<String>,
960
961    /// Output file path (JSON).
962    #[arg(long)]
963    out: Option<PathBuf>,
964}
965
966#[derive(clap::Args, Debug)]
967pub struct FinanceScheduleArgs {
968    /// Schedule kind: earnings | macro | all.
969    #[arg(long, default_value = "all")]
970    pub kind: String,
971    /// Single date (YYYY-MM-DD). If set, overrides --from/--to.
972    #[arg(long)]
973    pub date: Option<String>,
974    /// Start date (YYYY-MM-DD).
975    #[arg(long = "from")]
976    pub from: Option<String>,
977    /// End date (YYYY-MM-DD).
978    #[arg(long = "to")]
979    pub to: Option<String>,
980    /// Optional ticker filter for earnings rows (repeatable or comma-separated).
981    #[arg(long, visible_alias = "tickers", value_delimiter = ',')]
982    pub ticker: Vec<String>,
983    /// Macro-only: keep only major US releases (CPI, PCE, GDP, jobs, FOMC, claims).
984    #[arg(long, default_value_t = false)]
985    pub major: bool,
986    /// Minimum market cap for earnings (e.g. 10B, 500M, 1T).
987    #[arg(long = "min-cap")]
988    pub min_cap: Option<String>,
989    /// Filter earnings by report time: pre-market | after-hours.
990    #[arg(long)]
991    pub time: Option<String>,
992    /// Macro filtering profile: broad | market | major.
993    #[arg(long = "macro-profile", default_value = "market")]
994    pub macro_profile: String,
995    /// Output format (json only).
996    #[arg(long, default_value = "json")]
997    pub format: String,
998    /// Write full JSON output to a file instead of stdout.
999    #[arg(long)]
1000    pub out: Option<PathBuf>,
1001}
1002
1003#[derive(clap::Args, Debug)]
1004pub struct FinanceRatePathArgs {
1005    /// Optional cache directory for prediction-market CSVs.
1006    #[arg(long)]
1007    pub cache_dir: Option<PathBuf>,
1008    /// DEPRECATED: accepted for backwards compatibility but ignored. The live
1009    /// API path always dominates; the CSV cache is only used when the live
1010    /// fetch fails. The auto/meeting/fallback distinction was a no-op.
1011    #[arg(long, default_value = "auto", hide = true)]
1012    pub source_mode: String,
1013    /// Output format (json only).
1014    #[arg(long, default_value = "json")]
1015    pub format: String,
1016    /// Output file path.
1017    #[arg(long)]
1018    pub out: Option<PathBuf>,
1019}
1020
1021#[derive(clap::Args, Debug)]
1022pub struct FinanceAuctionsArgs {
1023    /// Filter by security type: bill, note, bond, tips, frn, or all.
1024    #[arg(long, default_value = "all")]
1025    pub security_type: String,
1026    /// Number of recent auctions to return.
1027    #[arg(long, default_value_t = 50)]
1028    pub limit: usize,
1029    /// Output format (json only).
1030    #[arg(long, default_value = "json")]
1031    pub format: String,
1032    /// Output file path.
1033    #[arg(long)]
1034    pub out: Option<PathBuf>,
1035}
1036
1037#[derive(clap::Args, Debug)]
1038pub struct FinanceCotArgs {
1039    /// Search query to filter by contract name (e.g. "gold", "crude oil", "10y note").
1040    #[arg(long)]
1041    pub query: Option<String>,
1042    /// Number of weeks of data to fetch. Default 12.
1043    #[arg(long, default_value_t = 12)]
1044    pub weeks: usize,
1045    /// Report type: auto (detect from query), disaggregated (commodities), or financial (rates/FX/equity).
1046    #[arg(long, default_value = "auto")]
1047    pub report: String,
1048    /// Max number of distinct contracts to return (default 15).
1049    #[arg(long)]
1050    pub limit: Option<usize>,
1051    /// Output format (json only).
1052    #[arg(long, default_value = "json")]
1053    pub format: String,
1054    /// Output file path.
1055    #[arg(long)]
1056    pub out: Option<PathBuf>,
1057}
1058
1059#[derive(clap::Args, Debug)]
1060pub struct FinanceCurveArgs {
1061    /// Commodity to chart (e.g. oil, gold, natgas, silver, copper). Use --list to see all.
1062    #[arg(long)]
1063    pub commodity: Option<String>,
1064    /// Number of forward months to include (default 12, max 24).
1065    #[arg(long, default_value_t = 12)]
1066    pub months: usize,
1067    /// List supported commodities.
1068    #[arg(long, default_value_t = false)]
1069    pub list: bool,
1070    /// Output file path.
1071    #[arg(long)]
1072    pub out: Option<PathBuf>,
1073}
1074
1075#[derive(clap::Args, Debug)]
1076pub struct FinanceNyfedArgs {
1077    /// Endpoint: rates | rrp | soma | dealers
1078    #[arg(long, default_value = "rates")]
1079    pub kind: String,
1080    #[arg(long, default_value = "json")]
1081    pub format: String,
1082    #[arg(long)]
1083    pub out: Option<PathBuf>,
1084}
1085
1086#[derive(clap::Args, Debug)]
1087pub struct FinanceVolsurfaceArgs {
1088    /// Comma-separated CBOE index symbols (default: all 9). Options: VIX,VIX9D,VIX3M,VIX6M,VIX1Y,VVIX,OVX,GVZ,SKEW
1089    #[arg(long)]
1090    pub symbols: Option<String>,
1091    /// Number of historical trading days (default: latest only)
1092    #[arg(long)]
1093    pub history: Option<usize>,
1094    #[arg(long, default_value = "json")]
1095    pub format: String,
1096    #[arg(long)]
1097    pub out: Option<PathBuf>,
1098}
1099
1100#[derive(clap::Args, Debug)]
1101pub struct FinanceStressArgs {
1102    /// Days of history (default: 30)
1103    #[arg(long, default_value_t = 30)]
1104    pub range: usize,
1105    #[arg(long, default_value = "json")]
1106    pub format: String,
1107    #[arg(long)]
1108    pub out: Option<PathBuf>,
1109}
1110
1111#[derive(clap::Args, Debug)]
1112pub struct FinanceFiscalArgs {
1113    /// Endpoint: debt | statement | interest
1114    #[arg(long, default_value = "debt")]
1115    pub kind: String,
1116    #[arg(long, default_value = "json")]
1117    pub format: String,
1118    #[arg(long)]
1119    pub out: Option<PathBuf>,
1120}
1121
1122#[derive(clap::Args, Debug)]
1123pub struct FinanceEcbArgs {
1124    /// Preset: eurusd | fx_majors | estr | m3 | euribor | yield_curve | balance_sheet
1125    #[arg(long)]
1126    pub preset: Option<String>,
1127    /// SDMX dataset (e.g. EXR, BSI, FM, EST, YC). Use with --key.
1128    #[arg(long)]
1129    pub dataset: Option<String>,
1130    /// SDMX dimension key (e.g. D.USD.EUR.SP00.A). Use with --dataset.
1131    #[arg(long)]
1132    pub key: Option<String>,
1133    /// Start period (YYYY-MM-DD or YYYY-MM or YYYY).
1134    #[arg(long, default_value = "2025-01-01")]
1135    pub start: String,
1136    /// End period.
1137    #[arg(long)]
1138    pub end: Option<String>,
1139    #[arg(long, default_value = "json")]
1140    pub format: String,
1141    #[arg(long)]
1142    pub out: Option<PathBuf>,
1143}
1144
1145#[derive(clap::Args, Debug)]
1146pub struct FinanceEiaArgs {
1147    /// Preset: crude | gasoline | distillate | all | nat_gas
1148    #[arg(long)]
1149    pub preset: Option<String>,
1150    /// Custom API route (e.g. petroleum/stoc/wstk/data/).
1151    #[arg(long)]
1152    pub route: Option<String>,
1153    /// Start date (YYYY-MM-DD).
1154    #[arg(long)]
1155    pub start: Option<String>,
1156    /// Max observations to return (default 52 = ~1 year weekly).
1157    #[arg(long, default_value = "52")]
1158    pub length: usize,
1159    #[arg(long, default_value = "json")]
1160    pub format: String,
1161    #[arg(long)]
1162    pub out: Option<PathBuf>,
1163}
1164
1165#[derive(clap::Args, Debug)]
1166pub struct FinanceBisArgs {
1167    /// Preset: policy_rates | assets | credit_gap | property | eer
1168    #[arg(long)]
1169    pub preset: Option<String>,
1170    /// SDMX dataset (e.g. WS_CBPOL). Use with --key.
1171    #[arg(long)]
1172    pub dataset: Option<String>,
1173    /// SDMX key (e.g. M.US+XM+JP+GB). Use with --dataset.
1174    #[arg(long)]
1175    pub key: Option<String>,
1176    /// Country codes (comma-separated, e.g. US,XM,JP,GB).
1177    #[arg(long)]
1178    pub countries: Option<String>,
1179    /// Start period (YYYY-MM).
1180    #[arg(long, default_value = "2020-01")]
1181    pub start: String,
1182    #[arg(long, default_value = "json")]
1183    pub format: String,
1184    #[arg(long)]
1185    pub out: Option<PathBuf>,
1186}
1187
1188#[derive(clap::Args, Debug)]
1189pub struct FinanceBojArgs {
1190    /// Preset: policy_rate | call_rate | monetary_base | balance_sheet | money_stock | tankan | fx
1191    #[arg(long)]
1192    pub preset: Option<String>,
1193    /// BOJ database name (e.g. IR01, FM01, BS01, CO). Use with --codes.
1194    #[arg(long)]
1195    pub db: Option<String>,
1196    /// BOJ series codes (comma-separated).
1197    #[arg(long)]
1198    pub codes: Option<String>,
1199    /// Start date (YYYYMM format for BOJ).
1200    #[arg(long, default_value = "202401")]
1201    pub start: String,
1202    #[arg(long, default_value = "json")]
1203    pub format: String,
1204    #[arg(long)]
1205    pub out: Option<PathBuf>,
1206}
1207
1208#[derive(clap::Args, Debug)]
1209pub struct FinanceBoeArgs {
1210    /// Preset: bank_rate | sonia | gilts | m4 | fx | all
1211    #[arg(long)]
1212    pub preset: Option<String>,
1213    /// Series codes (comma-separated, e.g. IUDBEDR,IUDSOIA).
1214    #[arg(long)]
1215    pub codes: Option<String>,
1216    /// Start date (DD/Mon/YYYY format, e.g. 01/Jan/2025).
1217    #[arg(long, default_value = "01/Jan/2025")]
1218    pub start: String,
1219    /// End date (DD/Mon/YYYY or "now").
1220    #[arg(long, default_value = "now")]
1221    pub end: String,
1222    #[arg(long, default_value = "json")]
1223    pub format: String,
1224    #[arg(long)]
1225    pub out: Option<PathBuf>,
1226}
1227
1228#[derive(clap::Args, Debug)]
1229struct FinanceFundamentalsArgs {
1230    /// Tickers to fetch (repeatable or comma-separated).
1231    #[arg(long, visible_alias = "ticker", value_delimiter = ',')]
1232    tickers: Vec<String>,
1233
1234    /// Output format (currently: json).
1235    #[arg(long, default_value = "json")]
1236    format: String,
1237
1238    /// Write full JSON output to a file instead of stdout.
1239    #[arg(long)]
1240    out: Option<PathBuf>,
1241}
1242
1243#[derive(clap::Args, Debug)]
1244struct FinanceMoversArgs {
1245    /// Candidate universe: day_movers | day_gainers | day_losers | tickers.
1246    #[arg(long, default_value = "day_movers")]
1247    universe: String,
1248
1249    /// Explicit tickers for universe=tickers, or to override screener discovery.
1250    #[arg(long, visible_alias = "ticker", value_delimiter = ',')]
1251    tickers: Vec<String>,
1252
1253    /// Direction filter: gainers | losers | both.
1254    #[arg(long, default_value = "both")]
1255    direction: String,
1256
1257    /// Sort by: percent | abs_percent | market_cap | value_change | dollar_volume | volume.
1258    #[arg(long, default_value = "value_change")]
1259    sort_by: String,
1260
1261    /// Data provider for price/change: auto | yahoo | ibkr. Auto uses IBKR when configured, Yahoo otherwise.
1262    #[arg(long, default_value = "auto")]
1263    provider: String,
1264
1265    /// Minimum market cap filter, e.g. 500M, 2B, 1.5T.
1266    #[arg(long)]
1267    min_market_cap: Option<String>,
1268
1269    /// Maximum market cap filter, e.g. 2B for small/mid-cap screens.
1270    #[arg(long)]
1271    max_market_cap: Option<String>,
1272
1273    /// Minimum absolute percent move.
1274    #[arg(long, default_value_t = 0.0)]
1275    min_change_pct: f64,
1276
1277    /// Minimum last price.
1278    #[arg(long, default_value_t = 5.0)]
1279    min_price: f64,
1280
1281    /// Minimum reported day volume.
1282    #[arg(long)]
1283    min_volume: Option<u64>,
1284
1285    /// Number of movers to return.
1286    #[arg(long, default_value_t = 25)]
1287    limit: usize,
1288
1289    /// Candidate count per Yahoo screener leg before local filtering/sorting.
1290    #[arg(long, default_value_t = 100)]
1291    scan_limit: usize,
1292
1293    /// Optional IBKR account code. Used when --provider ibkr or auto detects IBKR setup.
1294    #[arg(long)]
1295    ibkr_account: Option<String>,
1296
1297    /// Optional IBKR host override.
1298    #[arg(long)]
1299    ibkr_host: Option<String>,
1300
1301    /// Optional IBKR port override.
1302    #[arg(long)]
1303    ibkr_port: Option<u16>,
1304
1305    /// Optional IBKR client id override.
1306    #[arg(long)]
1307    ibkr_client_id: Option<i32>,
1308
1309    /// Optional IBKR market data type: 1 live, 2 frozen, 3 delayed, 4 delayed-frozen.
1310    #[arg(long)]
1311    ibkr_market_data_type: Option<i32>,
1312
1313    /// Optional IBKR timeout in seconds.
1314    #[arg(long)]
1315    ibkr_timeout_secs: Option<u64>,
1316
1317    /// Output format (currently: json).
1318    #[arg(long, default_value = "json")]
1319    format: String,
1320
1321    /// Write full JSON output to a file instead of stdout.
1322    #[arg(long)]
1323    out: Option<PathBuf>,
1324}
1325
1326#[derive(clap::Args, Debug)]
1327struct FinanceSearchArgs {
1328    /// Search query (e.g. "Apple" or "Inflation").
1329    #[arg(long, required = false)]
1330    query: Option<String>,
1331
1332    /// Search query (positional alternative to --query).
1333    #[arg(index = 1, required = false)]
1334    query_positional: Option<String>,
1335
1336    /// Data provider (yahoo | ibkr).
1337    #[arg(long, default_value = "yahoo")]
1338    provider: String,
1339
1340    /// Optional IBKR account code (e.g. U1234567). Used when --provider ibkr.
1341    #[arg(long)]
1342    ibkr_account: Option<String>,
1343
1344    /// Optional IBKR host override.
1345    #[arg(long)]
1346    ibkr_host: Option<String>,
1347
1348    /// Optional IBKR port override.
1349    #[arg(long)]
1350    ibkr_port: Option<u16>,
1351
1352    /// Optional IBKR client id override.
1353    #[arg(long)]
1354    ibkr_client_id: Option<i32>,
1355
1356    /// Optional IBKR market data type: 1 live, 2 frozen, 3 delayed, 4 delayed-frozen.
1357    #[arg(long)]
1358    ibkr_market_data_type: Option<i32>,
1359
1360    /// Output format (currently: json).
1361    #[arg(long, default_value = "json")]
1362    format: String,
1363
1364    /// Optional policy file override.
1365    #[arg(long = "policy-file")]
1366    policy_file: Option<PathBuf>,
1367
1368    /// Policy mode: observe | assist | enforce.
1369    #[arg(long = "policy-mode", default_value = "observe")]
1370    policy_mode: String,
1371
1372    /// Write full JSON output to a file instead of stdout.
1373    #[arg(long)]
1374    out: Option<PathBuf>,
1375}
1376
1377#[derive(clap::Args, Debug)]
1378struct FinanceOddsArgs {
1379    #[command(subcommand)]
1380    action: Option<FinanceOddsAction>,
1381
1382    /// Data source: kalshi (default), polymarket, or auto (kalshi then polymarket).
1383    #[arg(long)]
1384    provider: Option<String>,
1385    /// Kalshi series ticker.
1386    #[arg(long)]
1387    series: Option<String>,
1388
1389    /// Event ticker.
1390    #[arg(long)]
1391    event: Option<String>,
1392
1393    /// Market ticker.
1394    #[arg(long)]
1395    market: Option<String>,
1396
1397    /// Filter by status (e.g. open).
1398    #[arg(long)]
1399    status: Option<String>,
1400
1401    /// Page size limit.
1402    #[arg(long)]
1403    limit: Option<usize>,
1404
1405    /// Pagination cursor.
1406    #[arg(long)]
1407    cursor: Option<String>,
1408
1409    /// Max pages to fetch (Kalshi list endpoints).
1410    #[arg(long)]
1411    max_pages: Option<usize>,
1412
1413    /// List series (Kalshi only).
1414    #[arg(long)]
1415    list_series: bool,
1416
1417    /// List events.
1418    #[arg(long)]
1419    list_events: bool,
1420
1421    /// List markets.
1422    #[arg(long)]
1423    list_markets: bool,
1424
1425    /// List tags (Polymarket only).
1426    #[arg(long)]
1427    list_tags: bool,
1428
1429    /// Category filter (Kalshi list endpoints, and local CSV search when --search is used).
1430    #[arg(long)]
1431    category: Option<String>,
1432
1433    /// Case-insensitive literal substring match (titles/tickers/slugs).
1434    #[arg(long, alias = "query")]
1435    search: Option<String>,
1436
1437    /// Optional country filter for local CSV search (v1: US only).
1438    #[arg(long)]
1439    country: Option<String>,
1440
1441    /// Minimum market volume in USD (local CSV search).
1442    #[arg(long = "min-volume")]
1443    min_volume: Option<f64>,
1444
1445    /// Return top N markets after ranking (local CSV search).
1446    #[arg(long)]
1447    top: Option<usize>,
1448
1449    /// Ranking for local CSV search output.
1450    /// Options: relevance, volume, delta_prob, delta_yes_price, delta_volume.
1451    #[arg(long = "sort-by", default_value = "relevance")]
1452    sort_by: String,
1453    /// Query profile: auto | macro | broad.
1454    #[arg(long, default_value = "auto")]
1455    profile: String,
1456
1457    /// Optional policy file override.
1458    #[arg(long = "policy-file")]
1459    policy_file: Option<PathBuf>,
1460
1461    /// Policy mode: observe | assist | enforce.
1462    #[arg(long = "policy-mode", default_value = "observe")]
1463    policy_mode: String,
1464
1465    /// Only include markets that changed since the last sync (requires sync delta index).
1466    #[arg(long, default_value_t = false)]
1467    deltas_only: bool,
1468
1469    /// Minimum absolute probability move (percentage points) since last sync.
1470    /// Requires sync delta index.
1471    #[arg(long = "min-delta-pp")]
1472    min_delta_pp: Option<f64>,
1473
1474    /// Include compact ranking explanations in local CSV search output.
1475    #[arg(long, default_value_t = false)]
1476    explain: bool,
1477
1478    /// Upgrade CSV search results to live API prices (fresh bid/ask/volume).
1479    #[arg(long, default_value_t = false)]
1480    live: bool,
1481
1482    /// Include mention/speech-prediction markets (filtered by default).
1483    #[arg(long, default_value_t = false)]
1484    include_mentions: bool,
1485
1486    /// Include orderbook depth (heavier call; Polymarket orderbook supported).
1487    #[arg(long)]
1488    orderbook: bool,
1489
1490    /// Orderbook depth (levels).
1491    #[arg(long)]
1492    depth: Option<usize>,
1493
1494    /// Output format (currently: json).
1495    #[arg(long, default_value = "json")]
1496    format: String,
1497
1498    /// Write full JSON output to a file instead of stdout.
1499    #[arg(long)]
1500    out: Option<PathBuf>,
1501}
1502
1503#[derive(Subcommand, Debug)]
1504enum FinanceOddsAction {
1505    /// Sync prediction markets (Kalshi + Polymarket) to a local CSV cache.
1506    Sync(FinanceSyncArgs),
1507
1508    /// Print local cache paths for odds CSVs.
1509    Where(FinanceOddsWhereArgs),
1510}
1511
1512#[derive(clap::Args, Debug)]
1513struct FinanceOddsWhereArgs {
1514    /// Override cache directory (defaults to the same cache used by `eli finance sync`).
1515    #[arg(long)]
1516    cache_dir: Option<PathBuf>,
1517}
1518
1519#[derive(clap::Args, Debug)]
1520struct FinanceOptionsArgs {
1521    /// Underlying ticker (e.g. INTC).
1522    #[arg(long, visible_alias = "tickers")]
1523    ticker: String,
1524
1525    /// Expiration date (YYYY-MM-DD). If omitted, summary mode uses the first usable future expiry.
1526    #[arg(long)]
1527    expiry: Option<String>,
1528
1529    /// Target days to expiry. If set and --expiry is omitted, picks the closest listed expiry.
1530    #[arg(long = "target-dte")]
1531    target_dte: Option<i64>,
1532
1533    /// Filter: calls | puts | both (default: both).
1534    #[arg(long = "type", value_name = "calls|puts|both")]
1535    option_type: Option<String>,
1536
1537    /// Only return strikes within this percentage of the underlying (e.g. 10 = +/-10%).
1538    #[arg(long = "near-money")]
1539    near_money: Option<f64>,
1540
1541    /// Return summary metrics only (no full chain).
1542    #[arg(long)]
1543    summary: bool,
1544
1545    /// List available expirations only.
1546    #[arg(long)]
1547    expirations: bool,
1548
1549    /// Fetch ALL expirations and compute cross-expiry analytics.
1550    /// Dumps full chain to --out file, prints term structure summary to stdout.
1551    #[arg(long)]
1552    all: bool,
1553
1554    /// Data provider (yahoo | ibkr).
1555    #[arg(long, default_value = "yahoo")]
1556    provider: String,
1557
1558    /// Optional IBKR account code (e.g. U1234567). Used when --provider ibkr.
1559    #[arg(long)]
1560    ibkr_account: Option<String>,
1561
1562    /// Optional IBKR host override.
1563    #[arg(long)]
1564    ibkr_host: Option<String>,
1565
1566    /// Optional IBKR port override.
1567    #[arg(long)]
1568    ibkr_port: Option<u16>,
1569
1570    /// Optional IBKR client id override.
1571    #[arg(long)]
1572    ibkr_client_id: Option<i32>,
1573
1574    /// Optional IBKR market data type: 1 live, 2 frozen, 3 delayed, 4 delayed-frozen.
1575    #[arg(long)]
1576    ibkr_market_data_type: Option<i32>,
1577
1578    /// Output format (currently: json).
1579    #[arg(long, default_value = "json")]
1580    format: String,
1581
1582    /// Write full JSON output to a file instead of stdout.
1583    #[arg(long)]
1584    out: Option<PathBuf>,
1585}
1586
1587#[derive(clap::Args, Debug)]
1588struct FinanceSyncArgs {
1589    /// Sources to sync: kalshi, polymarket (comma-separated). Default: both.
1590    #[arg(long, value_delimiter = ',')]
1591    sources: Vec<String>,
1592
1593    /// Debug only: frontier-sample page cap per source. Hides coverage and is not a normal sync control.
1594    #[arg(long)]
1595    max_pages: Option<usize>,
1596
1597    /// Fail if pagination/coverage checks indicate incomplete source exhaustion.
1598    #[arg(long)]
1599    strict: bool,
1600
1601    /// Include sports markets/events in sync output (default: false).
1602    #[arg(long)]
1603    include_sports: bool,
1604
1605    /// Include Kalshi historical markets (archived/settled tier). Default: false.
1606    #[arg(long, hide = true)]
1607    include_historical: bool,
1608
1609    /// Fast refresh from Kalshi websocket ticker stream using cached baseline (no full re-pagination).
1610    #[arg(long)]
1611    stream_refresh: bool,
1612
1613    /// Breadth heartbeat in hours for stream refresh mode. If cached baseline is older, force strict REST anchor sync (default: 6).
1614    #[arg(long, hide = true)]
1615    refresh_heartbeat_hours: Option<u64>,
1616
1617    /// WebSocket listen window in seconds for stream refresh mode (default: 300).
1618    #[arg(long, hide = true)]
1619    stream_refresh_timeout_secs: Option<u64>,
1620
1621    /// Cache directory for CSV files (defaults to platform cache dir).
1622    #[arg(long)]
1623    cache_dir: Option<PathBuf>,
1624
1625    /// Output format (currently: json).
1626    #[arg(long, default_value = "json", hide = true)]
1627    format: String,
1628
1629    /// Emit full verbose payload on stdout (default is compact/token-efficient).
1630    #[arg(long, hide = true)]
1631    full: bool,
1632
1633    /// Optional policy file override.
1634    #[arg(long = "policy-file", hide = true)]
1635    policy_file: Option<PathBuf>,
1636
1637    /// Policy mode: observe | assist | enforce.
1638    #[arg(long = "policy-mode", default_value = "observe", hide = true)]
1639    policy_mode: String,
1640
1641    /// Write full JSON output to a file instead of stdout.
1642    #[arg(long)]
1643    out: Option<PathBuf>,
1644}
1645
1646#[derive(clap::Args, Debug)]
1647struct FinancePaperArgs {
1648    /// Command: trade | positions | trades | mark | reset
1649    #[arg(long, value_enum, default_value = "trade")]
1650    command: FinancePaperCommandArg,
1651
1652    /// Execution mode (v1: simulated local fills)
1653    #[arg(long, value_enum, default_value = "simulated")]
1654    mode: FinancePaperModeArg,
1655
1656    /// Paper account name.
1657    #[arg(long, default_value = "default")]
1658    account: String,
1659
1660    /// Provider for trade/mark pricing (kalshi|polymarket).
1661    #[arg(long)]
1662    provider: Option<String>,
1663
1664    /// Market ticker or market id (required for --command trade).
1665    #[arg(long)]
1666    market: Option<String>,
1667
1668    /// Side (yes|no) for --command trade.
1669    #[arg(long, value_enum)]
1670    side: Option<FinancePaperSideArg>,
1671
1672    /// Order action (buy|sell) for --command trade.
1673    #[arg(long, value_enum)]
1674    action: Option<FinancePaperOrderActionArg>,
1675
1676    /// Quantity/contracts for --command trade.
1677    #[arg(long)]
1678    qty: Option<f64>,
1679
1680    /// Optional manual fill price in probability units [0,1]. If omitted, uses live midpoint.
1681    #[arg(long)]
1682    price: Option<f64>,
1683
1684    /// Starting paper cash for account init/reset (default: 10000).
1685    #[arg(long)]
1686    starting_cash: Option<f64>,
1687
1688    /// Trade history limit for --command trades (default: 50).
1689    #[arg(long)]
1690    limit: Option<usize>,
1691
1692    /// Optional custom cache dir or full state file path.
1693    #[arg(long)]
1694    cache_dir: Option<PathBuf>,
1695
1696    /// Output format (json only).
1697    #[arg(long, default_value = "json")]
1698    format: String,
1699
1700    /// Write full JSON output to a file instead of stdout.
1701    #[arg(long)]
1702    out: Option<PathBuf>,
1703}
1704
1705#[derive(clap::Args, Debug)]
1706struct FinanceFilingsArgs {
1707    /// Ticker to fetch filings for.
1708    #[arg(long, visible_alias = "tickers")]
1709    ticker: String,
1710
1711    /// Form types to include (comma-separated), e.g. 8-K,10-K,10-Q. Defaults to 8-K,10-K,10-Q.
1712    #[arg(long, value_delimiter = ',')]
1713    forms: Vec<String>,
1714
1715    /// Max number of filings to return.
1716    #[arg(long, default_value_t = 5)]
1717    limit: usize,
1718
1719    /// Download primary documents, save to cache, and include a text excerpt inline.
1720    #[arg(long)]
1721    include_text: bool,
1722
1723    /// Max chars for the inline excerpt (full text is still written to disk when --include-text is set).
1724    #[arg(long)]
1725    max_chars: Option<usize>,
1726
1727    /// Override cache directory (defaults to Eli's cache dir).
1728    #[arg(long)]
1729    cache_dir: Option<PathBuf>,
1730
1731    /// Output format (currently: json).
1732    #[arg(long, default_value = "json")]
1733    format: String,
1734
1735    /// Write full JSON output to a file instead of stdout.
1736    #[arg(long)]
1737    out: Option<PathBuf>,
1738}
1739
1740#[derive(clap::Args, Debug)]
1741struct FinanceTimeseriesArgs {
1742    /// Preset ticker group (macro, forex_majors, yield_curve, liquidity, crypto).
1743    /// Expands to predefined tickers with default range/granularity. User flags override defaults.
1744    #[arg(long)]
1745    preset: Option<String>,
1746
1747    /// Tickers to fetch (repeatable or comma-separated).
1748    #[arg(long, visible_alias = "ticker", value_delimiter = ',')]
1749    tickers: Vec<String>,
1750
1751    /// Optional file with tickers (one per line).
1752    #[arg(long)]
1753    tickers_file: Option<PathBuf>,
1754
1755    /// Lookback range (e.g. 1d, 12mo, 5y).
1756    #[arg(long, default_value = "1y")]
1757    range: String,
1758
1759    /// Candle size / sampling granularity (e.g. 10m, 1h, 1d, 1w, 1mo).
1760    #[arg(long, default_value = "1d")]
1761    granularity: String,
1762
1763    /// Explicit window start (RFC3339 or YYYY-MM-DD). Must be used with --end.
1764    #[arg(long)]
1765    start: Option<String>,
1766
1767    /// Explicit window end (RFC3339 or YYYY-MM-DD). Must be used with --start.
1768    #[arg(long)]
1769    end: Option<String>,
1770
1771    /// End timestamp for the window (RFC3339). If you pass YYYY-MM-DD, it's treated as end-of-day UTC. Defaults to now (UTC).
1772    #[arg(long)]
1773    as_of: Option<String>,
1774
1775    /// Data provider (auto | yahoo | fred | ibkr | pyth | binance). "auto" routes by ticker prefix: PYTH:/CLEV:/IBKR:/BN:/FRED: → matching provider; numeric (Polymarket) and KX*-prefix (Kalshi) auto-detected; bare names → Yahoo, with FRED fallback for macro-style IDs.
1776    #[arg(long, default_value = "auto")]
1777    provider: String,
1778
1779    /// Optional IBKR account code (e.g. U1234567). Used when --provider ibkr.
1780    #[arg(long)]
1781    ibkr_account: Option<String>,
1782
1783    /// Optional IBKR host override.
1784    #[arg(long)]
1785    ibkr_host: Option<String>,
1786
1787    /// Optional IBKR port override.
1788    #[arg(long)]
1789    ibkr_port: Option<u16>,
1790
1791    /// Optional IBKR client id override.
1792    #[arg(long)]
1793    ibkr_client_id: Option<i32>,
1794
1795    /// Optional IBKR market data type: 1 live, 2 frozen, 3 delayed, 4 delayed-frozen.
1796    #[arg(long)]
1797    ibkr_market_data_type: Option<i32>,
1798
1799    /// Optional explicit prediction market provider to include as a timeseries series (kalshi | polymarket).
1800    #[arg(long)]
1801    odds_provider: Option<String>,
1802
1803    /// Optional prediction market identifier. Kalshi: market ticker. Polymarket: market ID or slug.
1804    #[arg(long)]
1805    odds_market: Option<String>,
1806
1807    /// Prediction market side to include for --odds-market (yes | no). Defaults to yes.
1808    #[arg(long, default_value = "yes")]
1809    odds_side: String,
1810
1811    /// Safety cap for points per ticker.
1812    #[arg(long)]
1813    max_points_per_ticker: Option<usize>,
1814
1815    /// Override cache directory (defaults to Eli's cache dir).
1816    #[arg(long)]
1817    cache_dir: Option<PathBuf>,
1818
1819    /// Output format (currently: json).
1820    #[arg(long, default_value = "json")]
1821    format: String,
1822
1823    /// Write full JSON output to a file instead of stdout.
1824    #[arg(long)]
1825    out: Option<PathBuf>,
1826}
1827
1828#[derive(clap::Args, Debug)]
1829struct FinanceIbkrArgs {
1830    /// IBKR command surface.
1831    #[arg(long, value_enum)]
1832    command: FinanceIbkrCommandArg,
1833
1834    /// Optional IBKR account code (e.g. U1234567).
1835    #[arg(long)]
1836    account: Option<String>,
1837
1838    /// Optional IBKR host override.
1839    #[arg(long)]
1840    host: Option<String>,
1841
1842    /// Optional IBKR port override.
1843    #[arg(long)]
1844    port: Option<u16>,
1845
1846    /// Optional IBKR client id override.
1847    #[arg(long)]
1848    client_id: Option<i32>,
1849
1850    /// Optional IBKR market data type: 1 live, 2 frozen, 3 delayed, 4 delayed-frozen.
1851    #[arg(long)]
1852    market_data_type: Option<i32>,
1853
1854    /// Optional timeout in seconds for the bridge request.
1855    #[arg(long)]
1856    timeout_secs: Option<u64>,
1857
1858    /// Tickers for snapshot / timeseries commands (repeatable or comma-separated).
1859    #[arg(long, value_delimiter = ',')]
1860    tickers: Vec<String>,
1861
1862    /// Range for timeseries requests (e.g. 1d, 1mo, 1y).
1863    #[arg(long, default_value = "1mo")]
1864    range: String,
1865
1866    /// Granularity for timeseries requests (e.g. 1min, 5min, 1h, 1d).
1867    #[arg(long, default_value = "1day")]
1868    granularity: String,
1869
1870    /// Contract symbol for order placement.
1871    #[arg(long)]
1872    symbol: Option<String>,
1873
1874    /// Contract security type for orders (default: STK).
1875    #[arg(long)]
1876    sec_type: Option<String>,
1877
1878    /// Contract exchange (default: SMART).
1879    #[arg(long)]
1880    exchange: Option<String>,
1881
1882    /// Contract primary exchange.
1883    #[arg(long)]
1884    primary_exchange: Option<String>,
1885
1886    /// Contract currency (default: USD).
1887    #[arg(long)]
1888    currency: Option<String>,
1889
1890    /// Contract expiry / contract month (e.g. 20260320).
1891    #[arg(long)]
1892    expiry: Option<String>,
1893
1894    /// Contract strike price.
1895    #[arg(long)]
1896    strike: Option<f64>,
1897
1898    /// Contract right (C/P).
1899    #[arg(long)]
1900    right: Option<String>,
1901
1902    /// Contract multiplier.
1903    #[arg(long)]
1904    multiplier: Option<String>,
1905
1906    /// Trading class.
1907    #[arg(long)]
1908    trading_class: Option<String>,
1909
1910    /// Order side for place-order (BUY or SELL).
1911    #[arg(long)]
1912    side: Option<String>,
1913
1914    /// Order type for place-order (MKT, LMT, STP, STP LMT).
1915    #[arg(long)]
1916    order_type: Option<String>,
1917
1918    /// Quantity for place-order.
1919    #[arg(long)]
1920    quantity: Option<f64>,
1921
1922    /// Limit price for limit orders.
1923    #[arg(long)]
1924    limit_price: Option<f64>,
1925
1926    /// Stop price for stop orders.
1927    #[arg(long)]
1928    stop_price: Option<f64>,
1929
1930    /// Time in force (default: DAY).
1931    #[arg(long)]
1932    tif: Option<String>,
1933
1934    /// Order id for cancel-order.
1935    #[arg(long)]
1936    order_id: Option<i32>,
1937
1938    /// Optional account summary tag filter.
1939    #[arg(long)]
1940    tags: Option<String>,
1941
1942    /// Output format (json only).
1943    #[arg(long, default_value = "json")]
1944    format: String,
1945
1946    /// Write full JSON output to a file instead of stdout.
1947    #[arg(long)]
1948    out: Option<PathBuf>,
1949}
eli_cli/args.rs

eli_cli/
args.rs
