Merge pull request #24 from z23cc/fn-18-merge-crates

refactor(flowctl): merge 4 crates into 2 (core + cli)

Author: z23cc

flowctl/Cargo.lock

@@ -2,8 +2,6 @@
 resolver = "2"
 members = [
     "crates/flowctl-core",
-    "crates/flowctl-db",
-    "crates/flowctl-service",
     "crates/flowctl-cli",
 ]
 
@@ -56,8 +54,6 @@ trycmd = "0.15"
 
 # Internal crate references
 flowctl-core = { path = "crates/flowctl-core" }
-flowctl-db = { path = "crates/flowctl-db" }
-flowctl-service = { path = "crates/flowctl-service" }
 
 # ── Shared lint configuration ────────────────────────────────────────
 [workspace.lints.clippy]

flowctl/Cargo.toml

@@ -12,8 +12,6 @@ path = "src/main.rs"
 
 [dependencies]
 flowctl-core = { workspace = true }
-flowctl-db = { workspace = true }
-flowctl-service = { workspace = true }
 serde = { workspace = true }
 serde_json = { workspace = true }
 anyhow = { workspace = true }
@@ -34,5 +32,3 @@ trycmd = { workspace = true }
 tempfile = "3"
 serde_json = { workspace = true }
 flowctl-core = { workspace = true }
-flowctl-db = { workspace = true }
-flowctl-service = { workspace = true }

flowctl/crates/flowctl-cli/Cargo.toml

@@ -85,8 +85,7 @@ pub fn cmd_init(json: bool) {
     }
 
     // Ensure FlowStore dirs are ready
-    let store = flowctl_db::FlowStore::new(flow_dir.clone());
-    if let Err(e) = store.ensure_dirs() {
+    if let Err(e) = flowctl_core::json_store::ensure_dirs(&flow_dir) {
         eprintln!("warning: failed to ensure store dirs: {e}");
     }
 

flowctl/crates/flowctl-cli/src/commands/admin/init.rs

@@ -726,8 +726,7 @@ pub fn cmd_doctor(json_mode: bool, workflow: bool) {
 
         // Check 7: stale file locks
         {
-            let store = flowctl_db::FlowStore::new(flow_dir.clone());
-            match store.locks().list() {
+            match flowctl_core::json_store::locks_read(&flow_dir) {
                 Ok(locks) if !locks.is_empty() => {
                     checks.push(json!({"name": "stale_locks", "status": "warn", "message": format!("{} file lock(s) active — verify with 'flowctl lock-check'", locks.len())}));
                 }

flowctl/crates/flowctl-cli/src/commands/admin/status.rs

@@ -8,7 +8,7 @@ use clap::Subcommand;
 use serde_json::Value;
 
 use flowctl_core::approvals::{ApprovalKind, ApprovalStatus, CreateApprovalRequest};
-use flowctl_service::approvals::FileApprovalStore;
+use flowctl_core::approvals::FileApprovalStore;
 
 use crate::output::{error_exit, json_output};
 
@@ -80,8 +80,7 @@ pub fn dispatch(cmd: &ApprovalCmd, json: bool) {
 
 fn open_local_store() -> FileApprovalStore {
     let flow_dir = get_flow_dir();
-    let store = flowctl_db::FlowStore::new(flow_dir);
-    FileApprovalStore::new(store)
+    FileApprovalStore::new(flow_dir)
 }
 
 // ── Payload parsing ─────────────────────────────────────────────────

flowctl/crates/flowctl-cli/src/commands/approval.rs

@@ -10,7 +10,7 @@ use serde_json::json;
 use crate::output::{error_exit, json_output, pretty_output};
 
 use flowctl_core::id::is_epic_id;
-use flowctl_db::{FlowStore, GapEntry};
+use flowctl_core::json_store::{self, GapEntry};
 
 use super::helpers::get_flow_dir;
 
@@ -112,8 +112,8 @@ fn validate_epic(_json: bool, epic_id: &str) {
     error_exit(&format!("Epic not found: {}", epic_id));
 }
 
-fn gap_store() -> FlowStore {
-    FlowStore::new(get_flow_dir())
+fn gap_flow_dir() -> std::path::PathBuf {
+    get_flow_dir()
 }
 
 // ── Commands ───────────────────────────────────────────────────────
@@ -126,10 +126,9 @@ fn cmd_gap_add(
     source: &str,
 ) {
     validate_epic(json_mode, epic_id);
-    let store = gap_store();
-    let gap_store = store.gaps();
+    let flow_dir = gap_flow_dir();
 
-    let mut gaps = gap_store.read(epic_id).unwrap_or_default();
+    let mut gaps = json_store::gaps_read(&flow_dir, epic_id).unwrap_or_default();
 
     // Check for existing gap with same capability (idempotent)
     let cap_lower = capability.trim().to_lowercase();
@@ -166,7 +165,7 @@ fn cmd_gap_add(
         resolved: false,
     });
 
-    if let Err(e) = gap_store.write(epic_id, &gaps) {
+    if let Err(e) = json_store::gaps_write(&flow_dir, epic_id, &gaps) {
         error_exit(&format!("Failed to add gap: {e}"));
     }
 
@@ -190,8 +189,8 @@ fn cmd_gap_add(
 
 fn cmd_gap_list(json_mode: bool, epic_id: &str, status_filter: Option<&str>) {
     validate_epic(json_mode, epic_id);
-    let store = gap_store();
-    let gaps = store.gaps().read(epic_id).unwrap_or_default();
+    let flow_dir = gap_flow_dir();
+    let gaps = json_store::gaps_read(&flow_dir, epic_id).unwrap_or_default();
 
     let filtered: Vec<&GapEntry> = gaps.iter().filter(|g| {
         match status_filter {
@@ -244,9 +243,8 @@ fn cmd_gap_resolve(
     _evidence: &str,
 ) {
     validate_epic(json_mode, epic_id);
-    let store = gap_store();
-    let gap_st = store.gaps();
-    let mut gaps = gap_st.read(epic_id).unwrap_or_default();
+    let flow_dir = gap_flow_dir();
+    let mut gaps = json_store::gaps_read(&flow_dir, epic_id).unwrap_or_default();
 
     if let Some(direct_id) = gap_id_direct {
         let gap_id: u32 = direct_id
@@ -259,7 +257,7 @@ fn cmd_gap_resolve(
             error_exit(&format!("Gap {} not found", gap_id));
         }
 
-        gap_st.write(epic_id, &gaps).unwrap_or_else(|e| {
+        json_store::gaps_write(&flow_dir, epic_id, &gaps).unwrap_or_else(|e| {
             error_exit(&format!("Failed to resolve gap: {e}"));
         });
 
@@ -281,7 +279,7 @@ fn cmd_gap_resolve(
             error_exit(&format!("Gap for capability '{}' not found", cap));
         }
 
-        gap_st.write(epic_id, &gaps).unwrap_or_else(|e| {
+        json_store::gaps_write(&flow_dir, epic_id, &gaps).unwrap_or_else(|e| {
             error_exit(&format!("Failed to resolve gap: {e}"));
         });
 
@@ -301,8 +299,8 @@ fn cmd_gap_resolve(
 
 fn cmd_gap_check(json_mode: bool, epic_id: &str) {
     validate_epic(json_mode, epic_id);
-    let store = gap_store();
-    let all_gaps = store.gaps().read(epic_id).unwrap_or_default();
+    let flow_dir = gap_flow_dir();
+    let all_gaps = json_store::gaps_read(&flow_dir, epic_id).unwrap_or_default();
 
     let open_blocking: Vec<&GapEntry> = all_gaps
         .iter()

flowctl/crates/flowctl-cli/src/commands/gap.rs

@@ -149,7 +149,7 @@ fn copy_dir_recursive(src: &Path, dst: &Path) -> Result<(), std::io::Error> {
 /// Returns the number of mutations applied. Calls `error_exit` on failure.
 pub fn apply_changes(flow_dir: &Path, changes: &flowctl_core::changes::Changes) -> usize {
     use crate::output::error_exit;
-    use flowctl_service::changes::ChangesApplier;
+    use flowctl_core::changes::ChangesApplier;
 
     if changes.is_empty() {
         return 0;

flowctl/crates/flowctl-cli/src/commands/helpers.rs

@@ -10,7 +10,7 @@ use serde_json::json;
 use crate::output::{error_exit, json_output, pretty_output};
 use super::helpers::get_flow_dir;
 
-use flowctl_db::FlowStore;
+use flowctl_core::json_store;
 
 #[derive(Subcommand, Debug)]
 pub enum LogCmd {
@@ -65,7 +65,6 @@ fn cmd_log_decision(
     task_id: Option<&str>,
 ) {
     let flow_dir = get_flow_dir();
-    let store = FlowStore::new(flow_dir);
 
     let epic = epic_id.unwrap_or("_global");
 
@@ -80,7 +79,7 @@ fn cmd_log_decision(
         "timestamp": chrono::Utc::now().to_rfc3339(),
     });
 
-    if let Err(e) = store.events().append(&event.to_string()) {
+    if let Err(e) = json_store::events_append(&flow_dir, &event.to_string()) {
         error_exit(&format!("Failed to log decision: {e}"));
     }
 
@@ -100,9 +99,8 @@ fn cmd_log_decision(
 
 fn cmd_log_decisions(json_mode: bool, epic_id: Option<&str>, limit: usize) {
     let flow_dir = get_flow_dir();
-    let store = FlowStore::new(flow_dir);
 
-    let all_lines = store.events().read_all().unwrap_or_else(|e| {
+    let all_lines = json_store::events_read_all(&flow_dir).unwrap_or_else(|e| {
         error_exit(&format!("Failed to query decisions: {e}"));
     });
 

flowctl/crates/flowctl-cli/src/commands/log.rs

@@ -1,6 +1,6 @@
 //! Outputs commands: write, list, show.
 //!
-//! Thin CLI wrapper over `flowctl_service::outputs::OutputsStore`. Provides
+//! Thin CLI wrapper over `flowctl_core::outputs::OutputsStore`. Provides
 //! a lightweight narrative handoff layer at `.flow/outputs/<task-id>.md` that
 //! workers populate in Phase 9 and read during Phase 2 re-anchor.
 
@@ -11,7 +11,7 @@ use clap::Subcommand;
 use serde_json::json;
 
 use flowctl_core::id::is_task_id;
-use flowctl_service::outputs::OutputsStore;
+use flowctl_core::outputs::OutputsStore;
 
 use crate::output::{error_exit, json_output};