hive-system.fs.core — io.github.hive-agi/hive-system 0.3.6

IPathQuery implementation backed by babashka.fs. All operations return hive-dsl Results for railway composition.

Convenience API (stateless, default instance): (exists? path) → Result<boolean> (directory? path) → Result<boolean> (absolute-dir? path) → Result<boolean> (resolve-first-dir [...]) → Result<string> (find-files path exts) → Result<vec<string>> (expand-path path exts) → vec<string> (rescue-wrapped)

DIP: consumers depend on IPathQuery protocol, not this impl. Swap FsPathQuery for a test double via make-path-query or protocol.

absolute-dir? clj

(absolute-dir? path)

Check if path is both absolute and an existing directory. Returns Result<boolean>. Railway-safe.

absolute? clj

(absolute? path)

Check if path is absolute. Returns Result<boolean> (pure, no IO).

cargo-scan clj

(cargo-scan
  root-path
  {:keys [marker read-marker max-depth concurrency timeout-ms skip-dirs]
   :or
     {max-depth 5 concurrency 8 timeout-ms 10000 skip-dirs default-skip-dirs}})

Parallel directory scanner using hive-weave/bounded-pmap. Walks root, finds directories containing :marker file. Fan-out at top level, single-threaded per subtree.

opts: :marker — filename to look for (e.g. ".hive-project.edn") :read-marker — fn (dir-path) -> data, called when marker found :max-depth — max recursion depth (default 5) :concurrency — parallel workers (default 8) :timeout-ms — per-subtree timeout (default 10000) :skip-dirs — set of dir names to skip (default: default-skip-dirs)

Returns Result<vec<{:path str :marker-data any}>>.

children clj

(children dir)

(children dir opts)

List immediate children. Returns Result<vec<string>>. opts: {:filter :dirs|:files|:all, :skip #{"node_modules" ...}}

directory? clj

(directory? path)

Check if path is directory. Returns Result<boolean>.

exists? clj

(exists? path)

Check path existence. Returns Result<boolean>.

expand-path clj

(expand-path path exts)

(expand-path path exts opts)

Expand a path to matching files. Directory → pruned recursive walk. File matching exts → [file]. Nonexistent → []. Error (incl. interrupt) → []. Returns plain vec (not Result) — rescue-wrapped for pipeline use. opts is passed through to find-files (:skip-dirs, :max-depth).

(expand-path "/src" #{"clj" "cljs"}) => ["/src/foo.clj" "/src/bar/baz.cljs"]

file? clj

(file? path)

Check if path is regular file. Returns Result<boolean>.

find-files clj

(find-files path exts)

(find-files path exts {:keys [skip-dirs max-depth]})

Recursively find files matching extensions under path. If path is a file matching exts, returns [path]. If path is a directory, walks it, pruning :skip-dirs and hidden entries. Returns Result<vec<string>>.

opts: :skip-dirs — dir names never descended into (default: default-skip-dirs). The root is always walked, even when its own name is in the set. :max-depth — cap the walk depth (default: unlimited).

The walk is interrupt-aware: on an interrupted thread it terminates and the Result is (err :fs/find-failed {:class "...InterruptedException"}), with the interrupt flag left SET so the caller still observes its own cancellation.

(find-files "/src" #{"clj" "cljs" "cljc"}) => (ok ["/src/a.clj" "/src/b/c.cljs"])

make-path-query clj

(make-path-query)

Create a FsPathQuery instance. For DI injection or test doubles.

resolve-first-dir clj

(resolve-first-dir candidates)

Try candidate paths in order, return first existing directory. Skips nil candidates. Returns Result<string> or err :fs/no-matching-dir.

(resolve-first-dir [nil (hcr-lookup project-id) (str hive-root "/" project-id)])

resolve-path clj

(resolve-path base & segments)

Join + normalize path segments. Returns Result<string>.