omgbase-sync 1.0.0

omgbase sync: workspace discovery and repo selection, the source registry and settings, checkpoints and the filesystem freshness sweep, the adapter stdio protocol client, the coordinator over an engine client, the writer lock and watch lease — Rust implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

# omgbase-sync

The omgbase sync layer, Rust implementation of `spec/sync`: how bytes get
*between* an omgbase repository (an `omgbase-store` database) and the places
they live.

- **Workspace** (§1): `.omgbase/` discovery by walking up, `Workspace::open`
  / `find` / `locate` (`--workspace` > `OMGBASE_WORKSPACE` > discovery),
  repos with their *derived* root path, and `select_repo` as a pure function
  over `[(slug, root_path)]` + `cwd` + an optional slug.
- **Registry** (§2): `ensure_adapter`, `create_source` (mints `src`),
  `delete_source`, `attach` / `detach`, `sources_for_repo`, `ensure_repo`
  (mints `rp` and the `<slug>-fs` source), `render_config_flags` with
  JavaScript stringification of scalars.
- **Settings** (§3): the workspace layer and a repo's own blob, `deep_merge`,
  `resolve_settings`.
- **Checkpoints and the filesystem fast path** (§4): a `FileSystem` seam
  (`RealFileSystem`, `MemFileSystem` for fixtures — the walk visits each
  directory's entries in bytewise name order, depth-first), `process_checkpoint`, `sweep_plan` as a
  pure function over the `file_stats` cache and a snapshot, `freshness_sweep`,
  `record_file_stat`, `detect_disk_drift`, `rebuild_file_stats`,
  `recover_repo`, `repos_status`, `sync_status`.
- **The adapter protocol** (§5): the `SyncSource` trait and `ExternalSource`,
  which spawns an adapter with `args + render_config_flags(config)` and the
  source's `env` and speaks the NDJSON handshake / request / response
  protocol (ids from 1), with the watch stream on a channel. `pipe` offers an
  in-memory pipe and a scripted adapter for driving it without a process.
- **Driver and coordinator** (§6): `reconcile_changes`, `attach_source`, the
  `EngineClient` trait with `InProcessEngineClient` over the store
  (`observe_many`, `observe_delete`, `changes_since`, `read_doc`), and
  `Coordinator::{sync_in, reconcile, sync_out, watch_in}`.
- **Locks** (§7): `WriterLock` (`O_EXCL`, pid JSON, dead holders stolen,
  25 ms poll / 5 s timeout) and `WatchLease`; liveness via `kill(pid, 0)`.

```rust,no_run
use omgbase_reconcile::Config;
use omgbase_store::Store;
use omgbase_sync::{fs::RealFileSystem, freshness, registry};

let mut store = Store::open(".omgbase/omgbase.db")?;
let repo = registry::ensure_repo(&mut store, "notes", Some("/home/me/notes"))?;
let sweep = freshness::freshness_sweep(
    &mut store, &repo, &RealFileSystem, "/home/me/notes".as_ref(),
    "2026-09-26T10:00:00.000Z", None, &Config::default(),
)?;
println!("{} files scanned, changed: {}", sweep.scanned, sweep.changed);
# Ok::<(), omgbase_sync::Error>(())
```

Conformance: `tests/spec.rs` runs every case under `spec/sync/cases`
(`pure`, `registry`, `checkpoint`, `protocol` — adapter transcripts over an
in-process pipe, coordinator scripts against a recording engine client),
gated by `tests/spec-passing.txt` while the port runs behind the fixtures.
The crate version tracks `spec/sync/VERSION` (`1.0`).

Unix only: lock-holder liveness uses `kill(pid, 0)`.