feat(migrations): use sqlite instead of sqlite3 to use migrations

migrations/001-initial-schema.sql

@@ -0,0 +1,25 @@
+-- Up
+CREATE TABLE comment (
+    id INTEGER PRIMARY KEY NOT NULL,
+    user_id NOT NULL,
+    slug CHAR(128) NOT NULL,
+    created_at TEXT NOT NULL,
+    comment CHAR(4000) NOT NULL,
+    rejected BOOLEAN,
+    approved BOOLEAN
+);
+
+CREATE TABLE user (
+    id INTEGER PRIMARY KEY NOT NULL,
+    name CHAR(128),
+    display_name CHAR(128),
+    provider CHAR(128),
+    provider_id CHAR(128),
+    created_at TEXT NOT NULL,
+    blocked BOOLEAN,
+    trusted BOOLEAN
+);
+
+-- Down
+DROP TABLE comment;
+DROP TABLE user;

migrations/002-settings.sql

@@ -0,0 +1,17 @@
+-- Up
+CREATE TABLE setting (
+    name CHAR(128) PRIMARY KEY NOT NULL,
+    active BOOLEAN NOT NULL
+);
+
+INSERT INTO setting (name, active) VALUES ('notification', 1);
+
+CREATE TABLE subscription (
+    endpoint CHAR(600) PRIMARY KEY NOT NULL,
+    publicKey CHAR(4096) NOT NULL,
+    auth CHAR(600) NOT NULL
+);
+
+-- Down
+DROP TABLE setting;
+DROP TABLE subscription;

package.json

@@ -15,13 +15,13 @@
     "passport-twitter": "^1.0.4",
     "pushover-notifications": "^0.2.4",
     "rss": "^1.2.2",
-    "sqlite3": "^3.1.13",
+    "sqlite": "^2.8.0",
     "unfetch": "^3.0.0"
   },
   "scripts": {
     "build": "rollup -cw",
-    "test": "http-server test -o 'http://localhost:8080/'",
-    "dev": "nodemon index.js"
+    "test": "http-server test -o 'http://localhost:8080/' -P 'http://localhost:3000/'",
+    "dev": "NODE_ENV=development nodemon index.js"
   },
   "description": "a simple node app for disqus-like drop-in commenting on static websites",
   "main": "index.js",

src/db/index.js

@@ -1,34 +1,17 @@
 const fs = require('fs');
 const path = require('path');
-const sqlite3 = require('sqlite3').verbose();
+const db = require('sqlite');
 const dbname = 'comments.db';
 const dbpath = path.resolve(__dirname, `../../${dbname}`);
-const schemapath = path.resolve(__dirname, `./schema.sql`);
-
-function connect() {
-  return new Promise((resolve, reject) => {
-    const db = new sqlite3.Database(dbpath, (err) => {
-      if (err) return reject(err);
-      console.log('connected to db.');
-      resolve(db);
-    });
-  });
-}
-
-function createSchema(db) {
-  return new Promise((resolve, reject) => {
-    db.all("SELECT name FROM sqlite_master WHERE type = 'table'", (err, rows) => {
-      if (err) return resolve(err);
-      if (!rows.length) return db.exec(fs.readFileSync(schemapath, 'utf-8'), () => resolve(db));
-
-      resolve(db);
-    });
-  });
-}
 
 // returns promise that passes db obj
 function init() {
-  return connect().then(db => createSchema(db));
+  return Promise.resolve(db.open(dbpath, { Promise }))
+  .then(db => db.migrate({
+    force: process.env.NODE_ENV === 'development' ? 'last' : false
+  }))
+  .then(db => db.driver) // @FIXME
+  .catch(err => console.error(err));
 }
 
 module.exports = {