syncular_client/
lib.rs

1//! # syncular-client — Syncular v2 Rust client core (POC stage 2)
2//!
3//! A clean-room client implementation of the SPEC.md client-behavior
4//! contract on rusqlite local storage, consuming the committed `ssp2`
5//! codec as its wire layer. Built without reading the v1 Rust tree or the
6//! v2 TypeScript client — the conformance catalog (packages/conformance)
7//! is the proof that both cores implement one written protocol.
8//!
9//! The API is synchronous request/response: the host drives `sync()` /
10//! `sync_until_idle()` and feeds inbound realtime traffic through
11//! `on_realtime_text` / `on_realtime_binary`. Scheduling is host policy
12//! (§8.4); the core exposes the coalesced `sync_needed` signal only.
13
14pub mod api;
15#[cfg(feature = "bench-internals")]
16mod bench;
17pub mod client;
18/// §5.10.5 native CRDT helpers (the `crdt-yjs` feature) — the Rust face of the
19/// Yjs binding, mirroring `@syncular/crdt-yjs`. Off by default (dependency-lean).
20#[cfg(feature = "crdt-yjs")]
21pub mod crdt;
22/// Shared blocking HTTP/WebSocket host transport for Rust-backed bindings.
23/// The network stack is feature-gated; its no-network shape remains available
24/// in dependency-lean builds so host code needs only one transport type.
25pub mod native_transport;
26mod progress;
27pub use progress::{
28    ProgressObserver, ProgressPhase, ProgressState, ProgressSubscription, SyncProgress,
29    SyncProgressListener,
30};
31/// RFC 0005 previous-version context: the persisted schema descriptor, the
32/// bounded capture, and the sibling container FILE beside the replica.
33pub mod previous_version;
34pub mod query_guard;
35pub mod realtime_round;
36pub mod remote;
37pub mod schema;
38pub mod transport;
39pub mod values;
40
41pub use api::{
42    creation_time_bucket, last, ClientChangeBatch, ClientDiagnosticsHost, ClientDiagnosticsLease,
43    ClientDiagnosticsReplica, ClientDiagnosticsRequest, ClientDiagnosticsSchema,
44    ClientDiagnosticsSnapshot, ClientDiagnosticsStorage, ClientLimits, CommandEffects,
45    CommitOperation, CommitOperationOutcome, CommitOutcome, CommitOutcomeQuery,
46    CommitOutcomeResolution, CommitOutcomeStatus, ConflictRecord, CoverageSnapshot,
47    DiagnosticLastChange, DiagnosticLastRound, DiagnosticQueryFailure, DiagnosticRoundCounters,
48    DiagnosticSubscription, ExpectedDiagnosticSubscription, FetchedBlob, LocalDataPurgeInput,
49    LocalDataPurgeResult, LocalDataPurgeTarget, LocalDataRebootstrapInput,
50    LocalDataRebootstrapResult, Mutation, PresencePeer, QueryOwner, QueryReadFailure, QueryRow,
51    QuerySnapshot, QueryValue, RealtimePolicy, RealtimeState, RejectionRecord,
52    ResolveCommitOutcomeInput, RetainedCommitRow, RowState, SchemaFloor, SubscriptionStateView,
53    SyncIntent, SyncOutcome, SyncReport, SyncStatusSnapshot, TableChange, TimeBucketUnit,
54    WindowBase, WindowChange, WindowCoverage, WindowState, WindowUnitRef,
55    CLIENT_DIAGNOSTICS_VERSION, MAX_DIAGNOSTIC_EXPECTED_SUBSCRIPTIONS,
56    MAX_DIAGNOSTIC_QUERY_FAILURES, REALTIME_LOST_CODE, REALTIME_UNAVAILABLE_CODE,
57};
58pub use client::{FileQuerySnapshotReader, SyncClient, SECURITY_PREFLIGHT_REQUIRED_CODE};
59pub use schema::{compile_schema, parse_schema_json, ClientSchema};
60pub use transport::{BlobDownload, BlobUploadGrant, SegmentRequest, Transport, TransportError};
61
62// Re-export the SSP2 stream scanner (§8.7 round-response reassembly) so the
63// native transports (FFI + Tauri plugin) reach it through their existing
64// `syncular-client` dependency, without each adding a direct `ssp2` path dep.
65pub use realtime_round::{RealtimeRound, RoundInbound, REALTIME_TAG_DELTA, REALTIME_TAG_ROUND};
66pub use remote::{
67    PreparedRemoteCommit, RemoteBytes, RemoteClientError, RemoteCommandResult, RemoteCommitInput,
68    RemoteCommitResult, RemoteQueryResult, SyncRemoteClient,
69};
70pub use ssp2::{MessageStreamScanner, ScannedMessage};
syncular_client/lib.rs

syncular_client/
lib.rs
