feat(daemon): add flow_dir to DaemonState, migrate list handlers

Add flow_dir: PathBuf to DaemonState for json_store access.
Migrate epics_handler and tasks_handler from DB to json_store.
Remaining handlers (epic create/plan, task CRUD, dag) still use DB
for writes — gradual migration continues in task .11.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: z23cc

flowctl/crates/flowctl-daemon/src/handlers/common.rs

@@ -62,6 +62,7 @@ pub struct DaemonState {
     pub runtime: DaemonRuntime,
     pub event_bus: flowctl_scheduler::EventBus,
     pub db: libsql::Connection,
+    pub flow_dir: std::path::PathBuf,
 }
 
 /// Map service-layer errors to HTTP-appropriate AppErrors.

flowctl/crates/flowctl-daemon/src/handlers/mod.rs

@@ -73,13 +73,12 @@ pub async fn status_handler(State(state): State<AppState>) -> impl IntoResponse
     )
 }
 
-/// GET /api/v1/epics -- list epics from the database.
+/// GET /api/v1/epics -- list epics from JSON files.
 pub async fn epics_handler(
     State(state): State<AppState>,
 ) -> Result<Json<serde_json::Value>, AppError> {
-    let conn = state.db.clone();
-    let repo = flowctl_db::EpicRepo::new(conn);
-    let epics = repo.list(None).await?;
+    let epics = flowctl_core::json_store::epic_list(&state.flow_dir)
+        .map_err(|e| AppError::Internal(format!("json_store error: {e}")))?;
     let value = serde_json::to_value(&epics)
         .map_err(|e| AppError::Internal(format!("serialization error: {e}")))?;
     Ok(Json(value))
@@ -90,12 +89,12 @@ pub async fn tasks_handler(
     State(state): State<AppState>,
     axum::extract::Query(params): axum::extract::Query<TasksQuery>,
 ) -> Result<Json<serde_json::Value>, AppError> {
-    let conn = state.db.clone();
-    let repo = flowctl_db::TaskRepo::new(conn);
     let tasks = if let Some(ref epic_id) = params.epic_id {
-        repo.list_by_epic(epic_id).await?
+        flowctl_core::json_store::task_list_by_epic(&state.flow_dir, epic_id)
+            .map_err(|e| AppError::Internal(format!("json_store error: {e}")))?
     } else {
-        repo.list_all(None, None).await?
+        flowctl_core::json_store::task_list_all(&state.flow_dir)
+            .map_err(|e| AppError::Internal(format!("json_store error: {e}")))?
     };
     let value = serde_json::to_value(&tasks)
         .map_err(|e| AppError::Internal(format!("serialization error: {e}")))?;

flowctl/crates/flowctl-daemon/src/server.rs

@@ -29,10 +29,15 @@ pub async fn create_state(runtime: DaemonRuntime, event_bus: flowctl_scheduler::
         .with_context(|| format!("failed to open db in {}", working_dir.display()))?;
     let conn = db.connect().context("failed to connect to libsql db")?;
     let cancel = runtime.cancel.clone();
+    // .flow/.state/ → parent is .flow/
+    let flow_dir = runtime.paths.state_dir.parent()
+        .map(|p| p.to_path_buf())
+        .unwrap_or_else(|| working_dir.to_path_buf());
     let state = Arc::new(DaemonState {
         runtime,
         event_bus,
         db: conn,
+        flow_dir,
     });
     Ok((state, cancel))
 }