remote

Author: penberg

examples/remote/package.json

@@ -11,6 +11,6 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "libsql": "^0.1.0"
+    "libsql": "../.."
   }
 }

index.d.ts

@@ -5,6 +5,9 @@
 
 export interface Options {
   timeout?: number
+  authToken?: string
+  syncUrl?: string
+  syncPeriod?: number
 }
 export declare function databasePrepareSync(db: Database, sql: string): Statement
 export interface RunResult {

src/lib.rs

@@ -172,6 +172,9 @@ pub struct Database {
 #[napi(object)]
 pub struct Options {
     pub timeout: Option<f64>,
+    pub authToken: Option<String>,
+    pub syncUrl: Option<String>,
+    pub syncPeriod: Option<f64>,
 }
 
 impl Drop for Database {
@@ -187,8 +190,37 @@ impl Database {
         ensure_logger();
         let rt = runtime()?;
         let remote = is_remote_path(&path);
+
         let db = if remote {
-            todo!("Remote databases are not supported yet");
+            let auth_token = opts
+                .as_ref()
+                .and_then(|o| o.authToken.as_ref())
+                .cloned()
+                .unwrap_or_default();
+
+            let builder = libsql::Builder::new_remote(path.clone(), auth_token);
+            rt.block_on(builder.build()).map_err(Error::from)?
+        } else if let Some(options) = &opts {
+            if let Some(sync_url) = &options.syncUrl {
+                let auth_token = options
+                    .authToken
+                    .as_ref()
+                    .cloned()
+                    .unwrap_or_default();
+
+                let mut builder = libsql::Builder::new_remote_replica(path.clone(), sync_url.clone(), auth_token);
+
+                if let Some(period) = options.syncPeriod {
+                    if period > 0.0 {
+                        builder = builder.sync_interval(std::time::Duration::from_secs_f64(period));
+                    }
+                }
+
+                rt.block_on(builder.build()).map_err(Error::from)?
+            } else {
+                let builder = libsql::Builder::new_local(&path);
+                rt.block_on(builder.build()).map_err(Error::from)?
+            }
         } else {
             let builder = libsql::Builder::new_local(&path);
             rt.block_on(builder.build()).map_err(Error::from)?
@@ -197,7 +229,7 @@ impl Database {
         let default_safe_integers = AtomicBool::new(false);
         let memory = path == ":memory:";
         let timeout = match opts {
-            Some(opts) => opts.timeout.unwrap_or(0.0),
+            Some(ref opts) => opts.timeout.unwrap_or(0.0),
             None => 0.0,
         };
         if timeout > 0.0 {