feat: refactor to separate pure Rust

Author: pmorris-dev

Cargo.lock

@@ -3,6 +3,7 @@ resolver = "3"
 members = [
    "crates/sqlx-sqlite-conn-mgr",
    "crates/sqlx-sqlite-observer",
+   "crates/sqlx-sqlite-toolkit",
 ]
 
 [package]
@@ -33,6 +34,15 @@ sqlx = { version = "0.8.6", features = ["sqlite", "json", "time", "runtime-tokio
 # Connection manager
 sqlx-sqlite-conn-mgr = { path = "crates/sqlx-sqlite-conn-mgr" }
 
+# Toolkit (high-level API — builders, transactions, decoding)
+sqlx-sqlite-toolkit = { path = "crates/sqlx-sqlite-toolkit", features = ["observer"] }
+
+# Observer types (for payload conversion)
+sqlx-sqlite-observer = { path = "crates/sqlx-sqlite-observer", features = ["conn-mgr"] }
+
+# Async stream support for observer subscriptions
+futures = "0.3"
+
 [build-dependencies]
 tauri-plugin = { version = "2.5.1", features = ["build"] }
 

Cargo.toml

@@ -21,18 +21,50 @@ SQLite database interface for Tauri applications using
    * **Type Safety**: Full TypeScript bindings
    * **Migration Support**: SQLx's migration framework
    * **Resource Management**: Proper cleanup on application exit
+   * **Optional Change Notifications**: SQLite hooks for reactive change notifications
 
 ## Architecture
 
+The plugin is built from three standalone Rust crates, each usable independently
+without Tauri:
+
+```text
+┌───────────────────────────────────────────────────────────────┐
+│                   tauri-plugin-sqlite (src/)                  │
+│         Tauri commands, state management, permissions         │
+├───────────────────────────────────────────────────────────────┤
+│                   sqlx-sqlite-toolkit (crate)                 │
+│            DatabaseWrapper, builders, transactions            │
+│          JSON decoding, optional observer integration         │
+├───────────────────────────────────────────────────────────────┤
+│  sqlx-sqlite-conn-mgr (crate) │  sqlx-sqlite-observer (crate) │
+│  Connection pools,            │  Change notifications         │
+│  single writer,               │  via SQLite hooks             │
+│  WAL mode, attached           │  broadcast streams            │
+│  databases                    │  (optional)                   │
+└───────────────────────────────┴───────────────────────────────┘
+```
+
+   * **[`sqlx-sqlite-conn-mgr`](crates/sqlx-sqlite-conn-mgr/)** — Low-level connection
+     management: read pool, exclusive writer, WAL mode, attached databases
+   * **[`sqlx-sqlite-observer`](crates/sqlx-sqlite-observer/)** — Reactive change
+     notifications using SQLite's native preupdate/commit/rollback hooks
+   * **[`sqlx-sqlite-toolkit`](crates/sqlx-sqlite-toolkit/)** — High-level API:
+     `DatabaseWrapper`, builder-pattern queries, interruptible transactions, JSON
+     type decoding. Optionally integrates the observer behind a feature flag.
+   * **`tauri-plugin-sqlite` (this package)** — Thin Tauri layer: IPC commands, path
+     resolution, state management, permissions
+
+### Query Routing
+
 | Operation Type       | Method          | Pool Used        | Concurrency         |
 | -------------------- | --------------- | ---------------- | ------------------- |
 | SELECT (multiple)    | `fetchAll()`    | Read pool        | Multiple concurrent |
 | SELECT (single)      | `fetchOne()`    | Read pool        | Multiple concurrent |
 | INSERT/UPDATE/DELETE | `execute()`     | Write connection | Serialized          |
 | DDL (CREATE, etc.)   | `execute()`     | Write connection | Serialized          |
 
-See [`crates/sqlx-sqlite-conn-mgr/README.md`](crates/sqlx-sqlite-conn-mgr/README.md) for
-connection manager internals.
+See individual crate READMEs for detailed API documentation.
 
 ## Installation
 

README.md

@@ -11,6 +11,11 @@ fn main() {
       "close",
       "close_all",
       "remove",
+      "get_migration_events",
+      "observe",
+      "subscribe",
+      "unsubscribe",
+      "unobserve",
    ])
    .build();
 }

api-iife.js

@@ -13,11 +13,11 @@ keywords = ["sqlite", "sqlx", "reactive", "observer", "database"]
 categories = ["database", "asynchronous"]
 
 [features]
-conn-mgr = ["dep:sqlx-sqlite-conn-mgr"]
 # Bundle SQLite by default - preupdate hooks require SQLITE_ENABLE_PREUPDATE_HOOK
 # which most system SQLite libraries don't have enabled.
 default = ["bundled"]
 bundled = ["libsqlite3-sys/bundled"]
+conn-mgr = ["dep:sqlx-sqlite-conn-mgr"]
 
 [dependencies]
 tokio = { version = "1.49.0", features = ["sync"] }
@@ -29,7 +29,7 @@ regex = "1.12.3"
 sqlx = { version = "0.8.6", features = ["sqlite", "runtime-tokio"], default-features = false }
 # Required for preupdate_hook - SQLite must be compiled with SQLITE_ENABLE_PREUPDATE_HOOK
 libsqlite3-sys = { version = "0.30.1", features = ["preupdate_hook"] }
-sqlx-sqlite-conn-mgr = { version = "0.8.6", optional = true }
+sqlx-sqlite-conn-mgr = { path = "../sqlx-sqlite-conn-mgr", version = "0.8.6", optional = true }
 
 [dev-dependencies]
 tokio = { version = "1.49.0", features = ["full", "macros"] }

build.rs

@@ -62,19 +62,19 @@ The library uses SQLite's native hooks for transaction-safe change tracking:
 │ (captures data) │     │  (Vec<Event>)   │     │                 │
 └─────────────────┘     └────────┬────────┘     └─────────────────┘
                                  │                       ▲
-                    ┌────────────┼────────────┐          │
-                    │            │            │          │
-              ┌─────▼────┐  ┌────▼─────┐      │          │
-              │  COMMIT  │  │ ROLLBACK │      │          │
-              └─────┬────┘  └────┬─────┘      │          │
-                    │            │            │          │
-                    ▼            ▼            │          │
-              on_commit()   on_rollback()     │          │
-                    │            │            │          │
-                    │       buffer.clear()    │          │
-                    │       (discard)         │          │
-                    │                         │          │
-                    └─────────────────────────┴──────────┘
+                    ┌────────────|                       │
+                    │            │                       │
+              ┌─────▼────┐  ┌────▼─────┐                 │
+              │  COMMIT  │  │ ROLLBACK │                 │
+              └─────┬────┘  └────┬─────┘                 │
+                    │            │                       │
+                    ▼            ▼                       │
+              on_commit()   on_rollback()                │
+                    │            │                       │
+                    │       buffer.clear()               │
+                    │       (discard)                    │
+                    │                                    │
+                    └────────────────────────────────────┘
                             change_tx.send()
                             (publish)
 ```
@@ -283,6 +283,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let config = ObserverConfig::new()
         .with_tables(["users"])
         .with_capture_values(false);
+
     let observer = SqliteObserver::new(
         SqlitePool::connect("sqlite:mydb.db").await?,
         config,

crates/sqlx-sqlite-observer/Cargo.toml

@@ -0,0 +1,29 @@
+[package]
+name = "sqlx-sqlite-toolkit"
+# Sync major.minor with major.minor of SQLx crate
+version = "0.8.6"
+license = "MIT"
+edition = "2024"
+rust-version = "1.89"
+
+[features]
+default = []
+observer = ["dep:sqlx-sqlite-observer"]
+
+[dependencies]
+sqlx-sqlite-conn-mgr = { path = "../sqlx-sqlite-conn-mgr" }
+sqlx-sqlite-observer = { path = "../sqlx-sqlite-observer", features = ["conn-mgr"], optional = true }
+sqlx = { version = "0.8.6", features = ["sqlite", "json", "time", "runtime-tokio"] }
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+thiserror = "2.0"
+indexmap = { version = "2.12", features = ["serde"] }
+base64 = "0.22"
+time = "0.3"
+uuid = { version = "1.11", features = ["v4"] }
+tokio = { version = "1.48.0", features = ["sync", "rt"] }
+tracing = { version = "0.1", default-features = false, features = ["std", "release_max_level_off"] }
+
+[dev-dependencies]
+tempfile = "3.23.0"
+tokio = { version = "1.48.0", features = ["rt-multi-thread", "macros"] }