🚡 Add all the things and all the work.

Author: tdeekens

.gitignore

@@ -0,0 +1,47 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules
+jspm_packages
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity

.nvmrc

@@ -0,0 +1 @@
+7.0.0

.travis.yml

@@ -0,0 +1,10 @@
+language: node_js
+cache: yarn
+node_js:
+  - '6'
+  - '7'
+before_install:
+notifications:
+  email: false
+  slack:
+    secure: Q2NlerQC8kgzjkD3gnMFs4VPJ35UMZ8tG6tj/PAHCK4U0iPBJ2Um6WxEa9JvvFe2eXiAIZhq2ZWhfU2cPh/fOYIQYNxGeXFJ8SfnXIJiCzEWCzFtNvRQt1scjukXNPxnvvvT/xP/hfmc9/7EnwlgAQoEQ+1SlMjKIc71g3qzvSw=

conferences/.dev

@@ -0,0 +1,2 @@
+exports port=4000
+exports host=localhost

conferences/.dockerignore

@@ -0,0 +1,9 @@
+root = true
+
+[*]
+charset = utf-8
+indent_style = space
+indent_size = 2
+end_of_line = lf
+insert_final_newline = true
+trim_trailing_whitespace = true

conferences/.editorconfig

@@ -0,0 +1,44 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules
+jspm_packages
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz

conferences/.gitignore

@@ -0,0 +1 @@
+7.1.0

conferences/.nvmrc

@@ -0,0 +1,2 @@
+exports port=4000
+exports host=0.0.0.0

conferences/.prod

@@ -0,0 +1,2 @@
+exports port=0
+exports host=localhost

conferences/.test

@@ -0,0 +1,21 @@
+FROM node:7
+
+ENV appDir /var/www/app/conferences
+ENV NODE_ENV prod
+ENV NODE_PATH .
+
+RUN mkdir -p ${appDir}
+RUN curl -o- -L https://yarnpkg.com/install.sh | bash
+
+WORKDIR ${appDir}
+
+COPY package.json ${appDir}
+COPY yarn.lock ${appDir}
+
+RUN $HOME/.yarn/bin/yarn install
+
+COPY . ${appDir}
+
+EXPOSE 4000
+
+CMD ["node", "server.js"]

conferences/Dockerfile

@@ -0,0 +1,15 @@
+const env = process.env.NODE_ENV
+const production = 'prod'
+const development = 'dev'
+
+function isProduction() {
+  return env === production
+}
+
+exports.default = {
+  env,
+  production,
+  development
+}
+
+exports.isProduction = isProduction

conferences/envs.js

@@ -0,0 +1,26 @@
+const uuid = require('node-uuid')
+const faker = require('faker')
+
+function generate() {
+  return {
+    id: uuid.v4(),
+    name: `${faker.company.catchPhraseAdjective()}-${faker.company.bsBuzz()}`,
+    from: faker.date.future(),
+    until: faker.date.future(),
+    price: faker.finance.amount()
+  }
+}
+
+function byId(id) {
+  const conference = generate()
+  conference.id = id
+
+  return conference
+}
+
+function latest(amount) {
+  return [...Array(amount)].map(generate)
+}
+
+exports.latest = latest
+exports.byId = byId

conferences/models/conference/fixtures.js

@@ -0,0 +1,21 @@
+const { isProduction } = require('envs')
+const fixture = require('models/conference/fixtures')
+
+function latest(amount) {
+  if (isProduction()) {
+    throw new Error('No production database yet.')
+  } else {
+    return fixture.latest(amount)
+  }
+}
+
+function byId(id) {
+  if (isProduction()) {
+    throw new Error('No production database yet.')
+  } else {
+    return fixture.byId(id)
+  }
+}
+
+exports.latest = latest
+exports.byId = byId

conferences/models/conference/index.js

@@ -0,0 +1,25 @@
+const test = require('ava')
+const model = require('models/conference')
+
+test('latest', t => {
+  const amount = 2
+  const conferences = model.latest(amount)
+
+  t.is(conferences.length, amount)
+
+  conferences.forEach(conference => {
+    t.truthy(conference.id)
+    t.truthy(conference.name)
+    t.truthy(conference.from)
+    t.truthy(conference.until)
+    t.truthy(conference.price)
+  })
+})
+
+test('byId', t => {
+  const id = 'abc-edf'
+  const conference = model.byId(id)
+
+  t.truthy(conference)
+  t.is(conference.id, id)
+})

conferences/models/conference/index.test.js

@@ -0,0 +1,38 @@
+{
+  "name": "colloq-conferences",
+  "version": "1.0.0",
+  "description": "Confernces service",
+  "main": "index.js",
+  "scripts": {
+    "start": "pm2 start processes.json",
+    "stop": "pm2 stop processes.json",
+    "dev:watch": "NODE_ENV=dev NODE_PATH=. DEBUG=* nodemon server.js",
+    "dev:inspect": "NODE_ENV=dev NODE_PATH=. DEBUG=* node --inspect server.js",
+    "test": "NODE_ENV=test NODE_PATH=. ava",
+    "docker:build": "docker build -t $(whoami)/conferences .",
+    "docker:start": "docker run -p 4000:4000 -d --name conferences $(whoami)/conferences",
+    "docker:stop": "docker stop conferences",
+    "docker:rm": "docker rm $(docker ps -a -q)"
+  },
+  "author": "Tobias Deekens <[email protected]> (http://tdeekens.name/)",
+  "license": "MIT",
+  "engines": {
+    "node": ">=7",
+    "npm": ">3"
+  },
+  "dependencies": {
+    "debug": "2.2.0",
+    "hapi": "15.2.0",
+    "metrics-os": "1.0.1",
+    "node-env-file": "0.1.8",
+    "node-fetch": "1.6.3",
+    "node-uuid": "1.4.7",
+    "pm2": "2.0.19"
+  },
+  "devDependencies": {
+    "ava": "^0.18.1",
+    "faker": "3.1.0",
+    "nodemon": "1.11.0",
+    "supertest": "^3.0.0"
+  }
+}

conferences/package.json

@@ -0,0 +1,15 @@
+{
+  "apps": [{
+    "name": "conferences",
+    "script": "node",
+    "args": "server.js",
+    "merge_logs": true,
+    "max_restarts": 20,
+    "instances": 4,
+    "max_memory_restart": "200M",
+    "env": {
+      "NODE_ENV": "prod",
+      "NODE_PATH": "."
+    }
+  }]
+}

conferences/processes.json

@@ -0,0 +1,19 @@
+const debug = require('debug')('http-conferences')
+const model = require('models/conference')
+
+exports.default = (req, reply) => {
+  const { id } = req.params
+  let conferences
+
+  debug('Start fetching conferences')
+
+  if (id) {
+    conferences = model.byId(id)
+  } else {
+    conferences = model.latest(20)
+  }
+
+  debug('...finished fetching conferences')
+
+  reply(conferences || {})
+}

conferences/routes/conferences/get.js

@@ -0,0 +1,48 @@
+const test = require('ava')
+const { default: server } = require('server')
+
+test('GET / statusCode', async t => {
+  await server.inject({
+    url: '/',
+    method: 'GET'
+  }).then(({ statusCode }) => {
+    t.is(statusCode, 200)
+  })
+})
+
+test('GET / headers', async t => {
+  await server.inject({
+    url: '/',
+    method: 'GET'
+  }).then(({ headers }) => {
+    t.is(headers['content-type'], 'application/json; charset=utf-8')
+  })
+})
+
+test('GET / properties', async t => {
+  await server.inject({
+    url: '/',
+    method: 'GET'
+  }).then(({ result: conferences }) => {
+    conferences.forEach(conference => {
+      t.truthy(conference.id)
+      t.truthy(conference.name)
+      t.truthy(conference.from)
+      t.truthy(conference.until)
+      t.truthy(conference.price)
+    })
+  })
+})
+
+test('GET /:id', async t => {
+  await server.inject({
+    url: '/abc-def',
+    method: 'GET'
+  }).then(({ result: conference }) => {
+    t.truthy(conference.id)
+    t.truthy(conference.name)
+    t.truthy(conference.from)
+    t.truthy(conference.until)
+    t.truthy(conference.price)
+  })
+})

conferences/routes/conferences/get.test.js

@@ -0,0 +1,11 @@
+const { default: getConferences } = require('routes/conferences/get')
+
+function attachRoute(server) {
+  server.route({
+    method: 'GET',
+    path: '/{id?}',
+    handler: getConferences
+  })
+}
+
+exports.default = attachRoute

conferences/routes/conferences/index.js

@@ -0,0 +1,3 @@
+exports.default = (req, reply) => {
+  reply({ status: 'ok' })
+}