Make sqlite3 work with async/await

async-await-sqlite3.ts

import * as sq3 from "sqlite3";

interface IRunFunction {
  (sql: string): Promise<Database>;
  (sql: string, ...params: any[]): Promise<Database>;
}

interface IGetFunction {
  (sql: string): any;
  (sql: string, ...params: any[]): any;
}

export interface Database {
  run: IRunFunction;
  get: IGetFunction;
}

const Database = (filename: string = ""): Promise<Database> => {
  return new Promise<Database>((resolve) => {
    const db = new (sq3.verbose()).Database(filename, (err) => {
      if (err) throw err;
      resolve(wrapDb(db));
    });
  });
};

const createRunFunc = (db: sq3.Database): IRunFunction => {
  return (sql: string, ...params: any[]): Promise<Database> => {
    return new Promise((resolve) => {
      db.run(sql, params, (err) => {
        if (err) throw err;
        resolve(wrapDb(db));
      });
    });
  };
};

const createGetFunc = (db: sq3.Database): IGetFunction => {
  return (sql: string, ...params: any[]): Promise<Database> => {
    return new Promise((resolve) => {
      db.get(sql, params, (err, row) => {
        if (err) throw err;
        resolve(row);
      });
    });
  };
};

const wrapDb = (db: sq3.Database): Database => ({
  run: createRunFunc(db),
  get: createGetFunc(db)
});

export default {
  Database
};