Stage/4

.env-sample

@@ -1,2 +1,3 @@
 PORT=1234
 APP_NAME=remind.ist
+DATABASE_URL=postgres://

.gitignore

@@ -85,3 +85,6 @@ typings/
 
 .DS_Store
 .env
+
+# Because I am sick of messing with the merge conflicts of this file
+package-lock.json

actions/index.js

@@ -0,0 +1,15 @@
+// actions/index.js
+
+const glob = require('glob')
+
+module.exports = glob.sync(
+  './actions/**/*.js',
+  { ignore: [ './actions/index.js' ] }
+).reduce((actions, filename) => {
+  const pathTokens = filename.split('/')
+  const key = pathTokens[pathTokens.length - 1].slice(0, -3)
+
+  actions[key] = require(`.${filename}`)
+
+  return actions
+}, {})

actions/newReminder.js

@@ -0,0 +1,10 @@
+// actions/newReminder.js
+
+module.exports = async (db, { email, message, send_at }) => {
+  const { rows: [ reminder ] } = await db.query(
+    'INSERT INTO reminders (email, message, send_at) VALUES ($1, $2, $3) RETURNING *',
+    [ email, message, send_at ]
+  )
+
+  return reminder
+}

app.js

@@ -1,3 +1,10 @@
+// app.js
+
 const server = require('./initialisers/http')
+const db = require('./initialisers/postgres')
+
+const run = () => {
+  server({ db })
+}
 
-server()
+run()

bin/db/init

@@ -0,0 +1,23 @@
+#!/usr/bin/env node
+
+if (!process.env.DATABASE_URL) require('dotenv').config()
+
+const { readFileSync } = require('fs')
+
+const db = require('../../initialisers/postgres')
+
+const run = () => new Promise(async resolve => {
+  const schema = readFileSync('./sql/schema.sql', { encoding: 'utf8' })
+
+try {
+    console.info(`=> Running db query:\n`, schema)
+    await db.query(schema)
+  } catch (error) {
+    console.error(`=> Error running query:\n`, schema, error)
+    return resolve(1)
+  }
+
+  return resolve(0)
+})
+
+run().then(process.exit)

initialisers/http.js

@@ -2,26 +2,36 @@ if (!process.env.PORT) require('dotenv').config()
 
 const { createServer } = require('http')
 
-const serveStaticFile = require('../lib/responder')
+const { serveStaticFile, serveRoute } = require('../lib/responder')
 const errors = require('../config/errors')
 
 const { PORT, APP_NAME } = process.env
 
-module.exports = () => {
-  const server = createServer(async ({ url }, response) => {
-    const urlTokens = url.split('.')
-    const extension = urlTokens.length > 1 ? `${urlTokens[urlTokens.length - 1].toLowerCase().trim()}` : false
-    const isRoot = [ '', '/' ].indexOf(url) > -1
-    const path = isRoot ? '/index.html' : url
+module.exports = ({ db }) => {
+  const server = createServer(async (request, response) => {
+    const urlTokens = request.url.split('.')
+    const extension = urlTokens.length > 1 ? urlTokens[urlTokens.length - 1].toLowerCase().trim() : false
+    const serveResponse = extension ? serveStaticFile : serveRoute
+    const responseParams = { path: request.url }
+
+    if (extension) {
+      responseParams.extension = extension
+    } else {
+      responseParams.request = request
+      responseParams.context = {
+        app_name: APP_NAME
+      }
+      responseParams.db = db
+    }
 
     try {
-      return await serveStaticFile({ file: path, extension: isRoot ? 'html' : extension }, response)
+      return await serveResponse(responseParams, response)
     } catch (error) {
       console.error(error)
       const errorData = errors(error)
 
       return await serveStaticFile({
-        file: '/error.html',
+        path: '/error.html',
         extension: 'html',
         statusCode: errorData.code
       }, response)

initialisers/postgres.js

@@ -0,0 +1,9 @@
+// initialisers/postgres.js
+
+const { Pool } = require('pg')
+
+const { DATABASE_URL } = process.env
+
+if (!DATABASE_URL) throw new Error('DATABASE_URL not set!')
+
+module.exports = new Pool({ connectionString: DATABASE_URL })

lib/responder.js

@@ -1,15 +1,19 @@
-const { open } = require('fs').promises
+const { readFileSync, promises: { open } } = require('fs')
 const { lookup } = require('mime-types')
+const Handlebars = require('handlebars')
 
 const { STATIC_EXTENSIONS } = require('../config/constants')
 
-const serveStaticFile = async ({ file, extension, statusCode }, response) => {
+const routes = require('../routes')
+const basePage = readFileSync(`./templates/template.hbs`, { encoding: 'utf8' })
+
+const serveStaticFile = async ({ path, extension, statusCode }, response) => {
   if (STATIC_EXTENSIONS.indexOf(extension) === -1) throw new Error('not_found')
 
   let fileHandle
 
   try {
-    fileHandle = await open(`./public/${file}`, 'r')
+    fileHandle = await open(`./public/${path}`, 'r')
     const staticFile = await fileHandle.readFile()
 
     const mime = lookup(extension)
@@ -28,4 +32,19 @@ const serveStaticFile = async ({ file, extension, statusCode }, response) => {
   }
 }
 
-module.exports = serveStaticFile
+const serveRoute = async ({ request, context, db }, response) => {
+  const key = `${request.method}:${request.url}`
+  const route = routes[key]
+
+  if (!route) throw new Error('not_found')
+
+  Handlebars.registerPartial('content', route.body)
+  const hbs = Handlebars.compile(basePage)
+
+  let routeContext = {}
+  if (route.data) routeContext = await route.data({ request, db })
+
+  return response.end(hbs({ ...context, ...routeContext }))
+}
+
+module.exports = { serveStaticFile, serveRoute }