diff options
author | 2025-05-08 10:18:07 +0100 | |
---|---|---|
committer | 2025-05-08 10:18:07 +0100 | |
commit | 5f1bc4f2807614dca1ac84136a5c355fde65543a (patch) | |
tree | c96e8074f112f7cf22f0182002ca40403a3720c3 /filamento/src/db.rs | |
parent | 8e6a02f16c3e542492241f585a91fa0100ea7e33 (diff) | |
download | luz-5f1bc4f2807614dca1ac84136a5c355fde65543a.tar.gz luz-5f1bc4f2807614dca1ac84136a5c355fde65543a.tar.bz2 luz-5f1bc4f2807614dca1ac84136a5c355fde65543a.zip |
feat(filamento): OPFS FileStore implementation
Diffstat (limited to '')
-rw-r--r-- | filamento/src/db.rs | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/filamento/src/db.rs b/filamento/src/db.rs index d2c24a2..e560443 100644 --- a/filamento/src/db.rs +++ b/filamento/src/db.rs @@ -55,9 +55,21 @@ impl Db { } #[cfg(target_arch = "wasm32")] + pub async fn create_connect_and_migrate_memory() -> Result<Self, DatabaseOpenError> { + let db = Connection::open("mem.db")?; + db.execute_batch(include_str!("../migrations/1.sql"))?; + Ok(Self { + db: Arc::new(Mutex::new(db)), + }) + } + + #[cfg(target_arch = "wasm32")] pub async fn create_connect_and_migrate( path: impl AsRef<Path>, ) -> Result<Self, DatabaseOpenError> { + // rusqlite::ffi::install_opfs_sahpool(Some(&rusqlite::ffi::OpfsSAHPoolCfg::default()), true) + // .await + // .unwrap(); let db = Connection::open(path)?; db.execute_batch(include_str!("../migrations/1.sql"))?; Ok(Self { |