Standalone pushView, fix inc-false on non-existant paths

Author: mxstbr

src/db.js

@@ -15,31 +15,4 @@ const promisifiedDb = {
   close: db.close.bind(db),
 }
 
-// Atomic view pushing method, can safely be called multiple times without the
-// db messing up.
-const pushView = async (key, view) => {
-  const locks = {}
-  await push()
-
-  async function push() {
-    if (locks[key]) return setImmediate(push)
-    locks[key] = true
-
-    let views
-    if (promisifiedDb.has(key)) {
-      views = promisifiedDb.get(key).views
-    } else {
-      views = []
-    }
-
-    try {
-      await promisifiedDb.put(key, { views: views.concat([view]) })
-      delete locks[key]
-    } catch (err) {
-      throw err
-    }
-  }
-}
-
-module.exports = exports = promisifiedDb
-exports.pushView = pushView
+module.exports = promisifiedDb

src/index.js

@@ -2,6 +2,7 @@ const url = require('url')
 const { send, createError, sendError } = require('micro')
 
 const db = require('./db')
+const { pushView } = require('./utils')
 
 module.exports = async function (req, res) {
   const { pathname, query } = url.parse(req.url, /* parseQueryString */ true)
@@ -28,10 +29,10 @@ module.exports = async function (req, res) {
   try {
     // Add a view and send the total views back to the client
     if (shouldIncrement) {
-      await db.pushView(pathname, { time: Date.now() })
+      await pushView(pathname, { time: Date.now() })
     }
     if (req.method === 'GET') {
-      send(res, 200, { views: db.get(pathname).views.length })
+      send(res, 200, { views: db.has(pathname) ? db.get(pathname).views.length : 0 })
     } else {
       send(res, 200)
     }

src/utils.js

@@ -0,0 +1,30 @@
+const db = require('./db')
+
+// Atomic view pushing method, can safely be called multiple times without the
+// db messing up.
+const pushView = async (key, view) => {
+  const locks = {}
+  await push()
+
+  async function push() {
+    if (locks[key]) return setImmediate(push)
+    locks[key] = true
+
+    let views
+    if (db.has(key)) {
+      views = db.get(key).views
+    } else {
+      views = []
+    }
+
+    try {
+      await db.put(key, { views: views.concat([view]) })
+      delete locks[key]
+    } catch (err) {
+      throw err
+    }
+  }
+}
+
+module.exports = exports
+exports.pushView = pushView