Implement Database.close()

Author: penberg

docs/api.md

@@ -74,7 +74,7 @@ Executes a SQL statement.
 
 ### close() ⇒ this
 
-This function is currently not supported.
+Closes the database connection.
 
 # class Statement
 

index.js

@@ -5,7 +5,7 @@ const { load, currentTarget } = require('@neon-rs/load');
 // Static requires for bundlers.
 if (0) { require('./.targets'); }
 
-const { databaseOpen, databaseOpenWithRpcSync, databaseSync, databaseExec, databasePrepare, statementRaw, statementGet, statementRun, statementRows, rowsNext } = load(__dirname) || require(`@libsql/experimental-${currentTarget()}`);
+const { databaseOpen, databaseOpenWithRpcSync, databaseClose, databaseSync, databaseExec, databasePrepare, statementRaw, statementGet, statementRun, statementRows, rowsNext } = load(__dirname) || require(`@libsql/experimental-${currentTarget()}`);
 
 /**
  * Database represents a connection that can prepare and execute SQL statements.
@@ -109,8 +109,11 @@ class Database {
         databaseExec.call(this.db, sql);
     }
 
+    /**
+     * Closes the database connection.
+     */
     close() {
-        throw new Error("not implemented")
+        databaseSync.call(this.db);
     }
 
     defaultSafeIntegers(...args) {

src/lib.rs

@@ -38,6 +38,13 @@ impl Database {
         Ok(cx.boxed(db))
     }
 
+    fn js_close(mut cx: FunctionContext) -> JsResult<JsUndefined> {
+        let db = cx.this().downcast_or_throw::<JsBox<Database>, _>(&mut cx)?;
+        db.db.close();
+        Ok(cx.undefined())
+    }
+
+
     fn js_sync(mut cx: FunctionContext) -> JsResult<JsUndefined> {
         let db = cx.this().downcast_or_throw::<JsBox<Database>, _>(&mut cx)?;
         db.rt.block_on(db.db.sync()).unwrap();
@@ -289,6 +296,7 @@ fn convert_row_raw(
 fn main(mut cx: ModuleContext) -> NeonResult<()> {
     cx.export_function("databaseOpen", Database::js_open)?;
     cx.export_function("databaseOpenWithRpcSync", Database::js_open_with_rpc_sync)?;
+    cx.export_function("databaseClose", Database::js_close)?;
     cx.export_function("databaseSync", Database::js_sync)?;
     cx.export_function("databaseExec", Database::js_exec)?;
     cx.export_function("databasePrepare", Database::js_prepare)?;