|
|
|
import { Database } from "./database.mjs";
|
|
|
|
import { PawSQLiteError } from "./pawsqlite_error.mjs";
|
|
|
|
import { enableDebug } from "./log.mjs";
|
|
|
|
|
|
|
|
|
|
|
|
const adapters = [];
|
|
|
|
|
|
|
|
|
|
|
|
export default {
|
|
|
|
open: async function(dbName, options = {}) {
|
|
|
|
const adapter = getAdapter(options.adapter);
|
|
|
|
|
|
|
|
let db = new Database(dbName, adapter);
|
|
|
|
await db.open();
|
|
|
|
return db;
|
|
|
|
},
|
|
|
|
delete: function(dbName, options = {}) {
|
|
|
|
const adapter = getAdapter(options.adapter);
|
|
|
|
|
|
|
|
return adapter.delete(dbName);
|
|
|
|
},
|
|
|
|
registerAdapter: function(adapter) {
|
|
|
|
adapters.push(wrapAdapter(adapter));
|
|
|
|
},
|
|
|
|
debug: enableDebug,
|
|
|
|
Error: PawSQLiteError
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
function wrapAdapter(adapter) {
|
|
|
|
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) {
|
|
|
|
const adapter = adapters.find((a) => a.name === adapterName);
|
|
|
|
|
|
|
|
if (!adapter) {
|
|
|
|
throw new PawSQLiteError(`Unknown Adapter: ${adapterName}`);
|
|
|
|
}
|
|
|
|
|
|
|
|
return adapter;
|
|
|
|
}
|