summaryrefslogtreecommitdiff
path: root/src/db.mjs
diff options
context:
space:
mode:
Diffstat (limited to 'src/db.mjs')
-rw-r--r--src/db.mjs57
1 files changed, 0 insertions, 57 deletions
diff --git a/src/db.mjs b/src/db.mjs
deleted file mode 100644
index 7d6c6c5..0000000
--- a/src/db.mjs
+++ /dev/null
@@ -1,57 +0,0 @@
-import assert from "node:assert/strict";
-import fs from "node:fs";
-import path from "node:path";
-import process from "node:process";
-import url from "node:url";
-import util from "node:util";
-
-import sqlite from "./sqlite.cjs";
-
-import * as u from "./utils.mjs";
-import * as accretion from "./accretion.mjs";
-
-
-export const promisifyDb = dbHandle => ({
- ref: dbHandle,
- all: util.promisify((...args) => dbHandle.all(...args)),
- exec: util.promisify((...args) => dbHandle.exec(...args)),
- run: util.promisify((...args) => dbHandle.run(...args)),
- each: (...args) =>
- new Promise((resolve, reject) => {
- const cb = args[args.length - 1];
- dbHandle.each(
- ...args.slice(0, args.length - 1),
- (err, row) => err ? reject(err) : cb(row),
- (err, data) => err ? reject(err) : resolve(data),
- );
- }),
- prepare: (...args) =>
- new Promise((resolve, reject) => {
- const mkStmt = stmtRef => ({
- ref: stmtRef,
- run: util.promisify((...args) => stmtRef.run(...args)),
- finalize: util.promisify((...args) => stmtRef.finalize(...args)),
- });
- const ref = dbHandle.prepare(
- ...args,
- err => err ? reject(err) : resolve(mkStmt(ref)),
- );
- }),
-});
-
-export const open = (...args) =>
- new Promise((resolve, reject) => {
- const dbName = args[0];
- assert(dbName);
- const ref = promisifyDb(new sqlite.Database(
- ...args,
- err => err ? reject(err) : resolve(ref),
- ));
- });
-
-export let handle = null;
-
-export const init = async (logFn, dbName = process.env.PAPO_DB_PATH || ":memory:") => {
- handle = await open(dbName);
- await accretion.runMigrations(logFn, handle);
-};