From 38df7f1053732a9ad87c9e113869b70603a1616b Mon Sep 17 00:00:00 2001
From: Ben Ashton <ben@n0m.org>
Date: Mon, 1 Mar 2021 22:19:38 -0800
Subject: [PATCH] Unlink adapters. Add adapter registry

---
 src/pawsqlite.mjs | 61 +++++++++++++++++++++++++++++++++++++----------
 1 file changed, 48 insertions(+), 13 deletions(-)

diff --git a/src/pawsqlite.mjs b/src/pawsqlite.mjs
index b3408d6..d156c4e 100644
--- a/src/pawsqlite.mjs
+++ b/src/pawsqlite.mjs
@@ -2,9 +2,8 @@ import { Database } from "./database.mjs";
 import { PawSQLiteError } from "./pawsqlite_error.mjs";
 import { enableDebug } from "./log.mjs";
 
-// Adapters
-import { PSQLAdapter } from "./adapters/cordova_pawsqlite/psql_adapter.mjs";
-import { WebSQLAdapter } from "./adapters/websql/websql_adapter.mjs";
+
+const adapters = [];
 
 
 export default {
@@ -20,22 +19,58 @@ export default {
 
     return adapter.delete(dbName);
   },
+  registerAdapter: function(adapter) {
+    adapters.push(wrapAdapter(adapter));
+  },
   debug: enableDebug,
   Error: PawSQLiteError
 };
 
 
+function wrapAdapter() {
+  const wrapped = {};
+
+  ["name", "open", "close", "delete", "sql"].forEach((prop) => {
+    if (!(prop in adapter)) {
+      throw new PawSQLiteError(`Invalid adapter: missing property: ${ prop }`);
+    }
+
+    if (
+      prop === "name" && !(
+        typeof adapter[prop] === "string" ||
+        adapter[prop] instanceof String
+      ) ||
+      prop !== "name" && (
+        typeof adapter[prop] !== "function"
+      )
+    ) {
+      throw new PawSQLiteError("Invalid adapter: invalid type for property: " +
+        prop);
+    }
+
+    if (typeof adapter[prop] === "function") {
+      wrapped[prop] = async (...args) => {
+        try {
+          return await adapter[prop](...args);
+        } catch (err) {
+          throw PawSQLiteError.from(err);
+        }
+      };
+    } else {
+      wrapped[prop] = adapter[prop];
+    }
+  });
+
+  return wrapped;
+}
+
+
 function getAdapter(adapterName) {
-  if (!adapterName) {
-    adapterName = "pawsqlite";
-  } else {
-    adapterName = adapterName.toLowerCase();
-  }
-  if (adapterName === "pawsqlite") {
-    return PSQLAdapter;
-  } else if (adapterName === "websql") {
-    return WebSQLAdapter;
-  } else {
+  const adapter = adapters.find((a) => a.name === adapterName);
+
+  if (!adapter) {
     throw new PawSQLiteError(`Unknown Adapter: ${adapterName}`);
   }
+
+  return adapter;
 }
\ No newline at end of file