full-chaos
diff --git a/‎.claude/settings.json‎
Lines changed: 3 additions & 3 deletions b/‎.claude/settings.json‎
Lines changed: 3 additions & 3 deletions
diff --git a/‎Cargo.lock‎
Lines changed: 38 additions & 0 deletions b/‎Cargo.lock‎
Lines changed: 38 additions & 0 deletions
diff --git a/‎crates/threads-cli/Cargo.toml‎
Lines changed: 6 additions & 0 deletions b/‎crates/threads-cli/Cargo.toml‎
Lines changed: 6 additions & 0 deletions
diff --git a/‎crates/threads-cli/src/cli.rs‎
Lines changed: 146 additions & 0 deletions b/‎crates/threads-cli/src/cli.rs‎
Lines changed: 146 additions & 0 deletions
@@ -30,9 +30,9 @@
       "Bash(sqlite3*)",
       "Bash(rm -rf target)",
       "Bash(touch*)",
-      "Read(/Users/chris/projects/full-chaos/threads-cli/**)",
-      "Write(/Users/chris/projects/full-chaos/threads-cli/**)",
-      "Edit(/Users/chris/projects/full-chaos/threads-cli/**)"
+      "Read(/Users/chris/projects/full-chaos/**)",
+      "Write(/Users/chris/projects/full-chaos/**)",
+      "Edit(/Users/chris/projects/full-chaos/**)"
     ]
   }
 }
@@ -18,11 +18,17 @@ threads-store.workspace = true
 threads-ingest.workspace = true
 
 anyhow.workspace = true
+chrono.workspace = true
 clap.workspace = true
+csv.workspace = true
 dirs.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 toml.workspace = true
 tokio.workspace = true
 tracing.workspace = true
 tracing-subscriber.workspace = true
+url.workspace = true
+
+[dev-dependencies]
+tempfile.workspace = true
@@ -0,0 +1,146 @@
+use std::path::PathBuf;
+
+use clap::{ArgAction, Parser, Subcommand, ValueEnum};
+
+#[derive(Debug, Parser)]
+#[command(
+    name = "threads-cli",
+    version,
+    about = "Ingest, model, search, and export Threads content via the official Threads Graph API."
+)]
+pub struct Cli {
+    /// Override the config-file path (default: ~/.config/threads-cli/config.toml).
+    #[arg(long, global = true)]
+    pub config: Option<PathBuf>,
+
+    /// Override the SQLite store path (default: ~/.local/share/threads-cli/store.db).
+    #[arg(long, global = true)]
+    pub db: Option<PathBuf>,
+
+    /// Increase logging verbosity (-v, -vv, -vvv).
+    #[arg(short, long, action = ArgAction::Count, global = true)]
+    pub verbose: u8,
+
+    /// Output format for commands that render records.
+    #[arg(long, value_enum, default_value_t = OutputFormatArg::Human, global = true)]
+    pub format: OutputFormatArg,
+
+    #[command(subcommand)]
+    pub command: Command,
+}
+
+#[derive(Copy, Clone, Debug, ValueEnum)]
+pub enum OutputFormatArg {
+    Human,
+    Json,
+    Jsonl,
+    Csv,
+}
+
+impl From<OutputFormatArg> for crate::output::OutputFormat {
+    fn from(v: OutputFormatArg) -> Self {
+        match v {
+            OutputFormatArg::Human => Self::Human,
+            OutputFormatArg::Json => Self::Json,
+            OutputFormatArg::Jsonl => Self::Jsonl,
+            OutputFormatArg::Csv => Self::Csv,
+        }
+    }
+}
+
+#[derive(Debug, Subcommand)]
+pub enum Command {
+    /// Interactively register credentials for the Meta Threads app.
+    Init(InitArgs),
+
+    /// Authentication subcommands.
+    #[command(subcommand)]
+    Auth(AuthCommand),
+
+    /// Ingest records from the provider into the local store.
+    #[command(subcommand)]
+    Ingest(IngestCommand),
+
+    /// Show a post, optionally the full thread rooted at it.
+    Show(ShowArgs),
+
+    /// Full-text search the local store.
+    Search(SearchArgs),
+
+    /// Export records from the store.
+    Export(ExportArgs),
+}
+
+#[derive(Debug, clap::Args)]
+pub struct InitArgs {
+    /// Overwrite an existing config file.
+    #[arg(long)]
+    pub force: bool,
+}
+
+#[derive(Debug, Subcommand)]
+pub enum AuthCommand {
+    /// Run OAuth flow and store the access token.
+    Login,
+    /// Show the current token status.
+    Status,
+    /// Remove the stored token.
+    Logout,
+}
+
+#[derive(Debug, Subcommand)]
+pub enum IngestCommand {
+    /// Ingest the authenticated user's threads + replies.
+    Me,
+    /// Ingest a single thread (root + descendants).
+    Thread {
+        /// The root post id.
+        post_id: String,
+    },
+    /// BFS descend fetch_replies from every post you authored, up to
+    /// `--depth` levels deep. Populates replies-to-your-replies (and their
+    /// branching conversation trees) into the local store. Requires a prior
+    /// `ingest me` so the store knows which posts you own.
+    Engagement {
+        /// Max BFS depth below each seed. Real Threads conversations
+        /// rarely exceed 4-5 levels; 8 is a safe default.
+        #[arg(long, default_value_t = 8)]
+        depth: u32,
+    },
+}
+
+#[derive(Debug, clap::Args)]
+pub struct ShowArgs {
+    /// The post id to show.
+    pub post_id: String,
+    /// Show the full thread rooted at this post (recursive CTE).
+    #[arg(long)]
+    pub thread: bool,
+}
+
+#[derive(Debug, clap::Args)]
+pub struct SearchArgs {
+    /// The FTS5 MATCH query.
+    pub query: String,
+    /// Limit the number of results.
+    #[arg(long, default_value_t = 20)]
+    pub limit: usize,
+}
+
+#[derive(Debug, clap::Args)]
+pub struct ExportArgs {
+    /// Write to a file instead of stdout.
+    #[arg(long)]
+    pub out: Option<PathBuf>,
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use clap::CommandFactory;
+
+    #[test]
+    fn cli_structure_is_valid() {
+        Cli::command().debug_assert();
+    }
+}
Original file line number	Diff line number	Diff line change
`@@ -30,9 +30,9 @@`
`30`	`30`	`"Bash(sqlite3*)",`
`31`	`31`	`"Bash(rm -rf target)",`
`32`	`32`	`"Bash(touch*)",`
`33`		`- "Read(/Users/chris/projects/full-chaos/threads-cli/**)",`
`34`		`- "Write(/Users/chris/projects/full-chaos/threads-cli/**)",`
`35`		`- "Edit(/Users/chris/projects/full-chaos/threads-cli/**)"`
	`33`	`+ "Read(/Users/chris/projects/full-chaos/**)",`
	`34`	`+ "Write(/Users/chris/projects/full-chaos/**)",`
	`35`	`+ "Edit(/Users/chris/projects/full-chaos/**)"`
`36`	`36`	`]`
`37`	`37`	`}`
`38`	`38`	`}`