Struct SyncularCore 

pub struct SyncularCore { /* private fields */ }

The Tauri-free core: one client, its owned transport, explicit scheduling state, and the pending exact-event queue. Lives on ONE owning thread.

Implementations

impl SyncularCore

pub fn new(config: &Value) -> Result<Self, String>

Build a core from the plugin config JSON (baseUrl, headers, …). A baseUrl under the native-transport feature owns a real HTTP+WS transport; without it the core is client-local only (tests, offline).

pub fn new_with_notify( config: &Value, notify: Option<Arc<dyn Fn() + Send + Sync>>, ) -> Result<Self, String>

pub fn command(&mut self, command: &Value) -> Value

Run one JSON command ({"method","params"}) through the shared router, then drain inbound realtime traffic and exact core events. Returns the driver-protocol {"result"|"error"} reply.

pub fn query(&mut self, sql: &str, params: Value) -> Value

The syncular_query fast path: arbitrary read-only SQL over the local database. Routed through the same query command so there is one implementation (the router owns it); this wrapper spares the JS bridge from wrapping the method/params envelope for the hot live-query path.

pub fn take_sync_intent(&mut self) -> SyncIntent

Consume the next coalesced host schedule. Interactive work preempts a pending retry; background work keeps the earliest real deadline.

pub fn sync_until_idle(&mut self) -> Value

Run one syncUntilIdle round for the background host loop, deriving events afterwards. A no-op (empty reply) before create.

pub fn poll_transport(&mut self)

Owner-mailbox wake from the native realtime reader.

pub fn drain_events(&mut self) -> Vec<Event>

Drain every event queued since the last call (the host thread pushes them onto the Tauri channel). Mirrors the FFI poll_event, batched.

pub fn set_headers(&mut self, headers: Vec<(String, String)>)

Replace the transport’s request headers (RFC 0002 §2.3 — rotating auth without tearing the plugin down). See HostTransport::set_headers for the HTTP/WS pickup semantics.

pub fn shutdown(&mut self)

Release the socket/reader thread. Idempotent.