Compare commits
2 Commits
32e50f783c
...
cd8db56678
Author | SHA1 | Date | |
---|---|---|---|
cd8db56678 | |||
c15fa92174 |
36
src/adapter_wrapper.mjs
Normal file
36
src/adapter_wrapper.mjs
Normal file
@ -0,0 +1,36 @@
|
|||||||
|
export 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;
|
||||||
|
}
|
@ -1,4 +1,5 @@
|
|||||||
import { Database } from "./database.mjs";
|
import { Database } from "./database.mjs";
|
||||||
|
import { wrapAdapter } from "./adapter_wrapper.mjs";
|
||||||
import { PawSQLiteError } from "./pawsqlite_error.mjs";
|
import { PawSQLiteError } from "./pawsqlite_error.mjs";
|
||||||
import { enableDebug } from "./log.mjs";
|
import { enableDebug } from "./log.mjs";
|
||||||
|
|
||||||
@ -20,55 +21,25 @@ export default {
|
|||||||
return adapter.delete(dbName);
|
return adapter.delete(dbName);
|
||||||
},
|
},
|
||||||
registerAdapter: function(adapter) {
|
registerAdapter: function(adapter) {
|
||||||
adapters.push(wrapAdapter(adapter));
|
const wrapped = wrapAdapter(adapter);
|
||||||
|
|
||||||
|
if (getAdapter(wrapped.name)) {
|
||||||
|
throw new PawSQLiteError(`An adapter with the name: ${ wrapped.name } ` +
|
||||||
|
`Already exists`);
|
||||||
|
}
|
||||||
|
|
||||||
|
adapters.push(wrapped);
|
||||||
},
|
},
|
||||||
debug: enableDebug,
|
debug: enableDebug,
|
||||||
Error: PawSQLiteError
|
Error: PawSQLiteError
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
function wrapAdapter(adapter) {
|
|
||||||
const wrapped = {};
|
|
||||||
|
|
||||||
["name", "open", "close", "delete", "sql"].forEach((prop) => {
|
function getAdapter(adapterName, silent=false) {
|
||||||
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);
|
const adapter = adapters.find((a) => a.name === adapterName);
|
||||||
|
|
||||||
if (!adapter) {
|
if (!(silent || adapter)) {
|
||||||
throw new PawSQLiteError(`Unknown Adapter: ${adapterName}`);
|
throw new PawSQLiteError(`Unknown Adapter: ${adapterName}`);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user