Add another challenge

Author: geek

challenge10/README.md

@@ -0,0 +1,5 @@
+FROM node:6-slim
+RUN mkdir -p /app
+ADD . /app
+RUN cd /app && npm install
+CMD node /app/actuator.js

challenge11/README.md

@@ -0,0 +1,14 @@
+'use strict';
+
+const Mqtt = require('mqtt');
+const Seneca = require('seneca');
+
+const mqtt = Mqtt.connect('mqtt://' + process.env.BROKER_HOST + ':1883');
+const seneca = Seneca();
+
+seneca.add({ role: 'actuate', cmd: 'set' }, (args, cb) => {
+  const payload = JSON.stringify({ 'offset': parseInt(args.offset, 10) });
+  mqtt.publish('temperature/1/set', new Buffer(payload), { qos: 0, retain: true }, cb);
+});
+
+seneca.listen({ port: process.env.ACTUATOR_PORT });

final/actuator/Dockerfile renamed to challenge11/actuator/Dockerfile

@@ -0,0 +1,15 @@
+{
+  "name": "actuator",
+  "version": "1.0.0",
+  "description": "",
+  "main": "actuator.js",
+  "scripts": {
+    "start": "node actuator.js"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "mqtt": "1.x.x",
+    "seneca": "2.x.x"
+  }
+}

final/actuator/actuator.js renamed to challenge11/actuator/actuator.js

@@ -0,0 +1,5 @@
+FROM node:6-slim
+RUN mkdir -p /app
+ADD . /app
+RUN cd /app && npm install
+CMD node /app/broker.js

final/actuator/package.json renamed to challenge11/actuator/package.json

@@ -0,0 +1,36 @@
+'use strict';
+
+const Mosca = require('mosca');
+const Seneca = require('seneca');
+
+
+const server = new Mosca.Server({});
+const seneca = Seneca();
+seneca.client({
+  host: process.env.SERIALIZER_HOST,
+  port: process.env.SERIALIZER_PORT,
+  pin: {
+    role: 'serialize', cmd: 'write'
+  }
+});
+
+server.published = (packet, client, cb) => {
+  if (!packet.topic.match(/temperature\/[0-9]+\/read/)) {
+    return cb();
+  }
+
+  const body = parse(packet.payload);
+
+  body.role = 'serialize';
+  body.cmd = 'write';
+  seneca.act(body, cb);
+};
+
+function parse (body) {
+  try {
+    return JSON.parse(body);
+  }
+  catch (err) {
+    return null;
+  }
+}

final/broker/Dockerfile renamed to challenge11/broker/Dockerfile

@@ -0,0 +1,15 @@
+{
+  "name": "broker",
+  "version": "1.0.0",
+  "description": "",
+  "main": "broker.js",
+  "scripts": {
+    "start": "node broker.js"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "mosca": "2.x.x",
+    "seneca": "2.x.x"
+  }
+}

final/broker/broker.js renamed to challenge11/broker/broker.js

@@ -0,0 +1,5 @@
+FROM node:6-slim
+RUN mkdir -p /app
+ADD . /app
+RUN cd /app && npm install
+CMD node /app/index.js

final/broker/package.json renamed to challenge11/broker/package.json

@@ -0,0 +1,90 @@
+'use strict';
+
+const Path = require('path');
+const Hapi = require('hapi');
+const Inert = require('inert');
+const Moment = require('moment');
+const Seneca = require('seneca');
+const WebStream = require('./webStream');
+
+const seneca = Seneca();
+seneca.client({host: process.env.SERIALIZER_HOST, port: process.env.SERIALIZER_PORT, pin: {role: 'serialize', cmd: 'read'}});
+seneca.client({host: process.env.ACTUATOR_HOST, port: process.env.ACTUATOR_PORT, pin: {role: 'actuate', cmd: 'set'}});
+
+
+const serverConfig = {
+  connections: {
+    routes: {
+      files: {
+        relativeTo: Path.join(__dirname, 'public')
+      }
+    }
+  }
+};
+
+const server = new Hapi.Server(serverConfig);
+server.connection({ port: process.env.FRONTEND_PORT });
+server.register(Inert, () => {
+  server.route({
+    method: 'GET',
+    path: '/set',
+    handler: (request, reply) => {
+      seneca.act({
+        role: 'actuate',
+        cmd: 'set', offset:
+        request.query.offset
+      }, (err) => {
+        if (err) {
+          return reply({ result: err });
+        }
+
+        reply({result: 'ok'});
+      });
+    }
+  });
+
+  server.route({
+    method: 'GET',
+    path: '/{param*}',
+    handler: {
+      directory: {
+        path: '.',
+        redirectToSlash: true,
+        index: true
+      }
+    }
+  });
+
+  const webStream = WebStream(server.listener);
+
+  let lastEmitted = 0;
+  let i = 0;
+  setInterval(() => {
+    seneca.act({
+      role: 'serialize',
+      cmd: 'read',
+      sensorId: '1',
+      start: Moment().subtract(10, 'minutes').utc().format(),
+      end: Moment().utc().format()
+    }, (err, data) => {
+      let toEmit = [];
+
+      data[0].forEach((point) => {
+        if (Moment(point.time).unix() > lastEmitted) {
+          lastEmitted = Moment(point.time).unix();
+          point.time = (new Date(point.time)).getTime();
+          toEmit.push(point);
+        }
+      });
+      if (toEmit.length) {
+        console.log('will emit');
+        console.log(toEmit);
+        webStream.emit(toEmit);
+      }
+    });
+  }, 1000);
+
+  server.start(() => {
+    console.log(`listening at http://localhost:${server.info.port}`);
+  });
+});

final/frontend/Dockerfile renamed to challenge11/frontend/Dockerfile

@@ -0,0 +1,23 @@
+{
+  "name": "api",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "lint": "belly-button",
+    "start": "node index.js"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "end-of-stream": "1.x.x",
+    "hapi": "14.x.x",
+    "inert": "4.x.x",
+    "moment": "2.x.x",
+    "seneca": "2.x.x",
+    "websocket-stream": "3.x.x"
+  },
+  "devDependencies": {
+    "belly-button": "2.0.x"
+  }
+}

final/frontend/index.js renamed to challenge11/frontend/index.js

@@ -0,0 +1,28 @@
+<!doctype html>
+<html>
+  <head>
+  <title>Charting frontend</title>
+  <link rel="icon" href="data:;base64,iVBORw0KGgo=">
+  <link type="text/css" rel="stylesheet" href="/lib/rickshaw.min.css">
+  <script src="/lib/d3.min.js"></script>
+  <script src="/lib/jquery.js"></script>
+  <script src="/lib/lodash.min.js"></script>
+  <script src="/lib/rickshaw.min.js"></script>
+  </head>
+  <body>
+  <div id='header'>
+    <h2>Temperature Sensor 1</h2>
+  </div>
+  <div id="controls">
+    <input type='text' id='offset'></input>
+    <button type='button' id='setOffset'>set</button>
+  </div>
+  <div id="chart_container">
+    <div id="chart"></div>
+    <div id="timeline"></div>
+    <div id="preview"></div>
+  </div>
+  </body>
+  <script src="/js/bundle.js"></script>
+</html>
+