Add cache set-up access.

Author: jason-fox

iot-devices/app.js

@@ -5,6 +5,7 @@ const debug = require('debug')('devices:iot-device');
 const mqtt = require('mqtt');
 const logger = require('morgan');
 const IoTDevices = require('./models/devices');
+const MyCache = require('./lib/cache');
 
 /* global MQTT_CLIENT */
 const DEVICE_TRANSPORT = process.env.DUMMY_DEVICES_TRANSPORT || 'HTTP';
@@ -57,6 +58,11 @@ iotRouter.put('/devices/tractor', (req, res) => {
   res.status(204).send();
 });
 
+iotRouter.put('/devices', (req, res) => {
+  MyCache.setCacheValues(req.body);
+  res.status(204).send();
+});
+
 iotRouter.get('/animals', (req, res) => {
   IoTDevices.fireAnimalCollars();
   res.status(204).send();

iot-devices/lib/cache.js

@@ -31,6 +31,15 @@ exports.set = async function (key, value) {
   return await client.set(key, value);
 };
 
+exports.setCacheValues = function (data) {
+  Object.keys(data).forEach(async (key) => {
+    if (keys.includes(key) === false) {
+      keys.push(key);
+    }
+    await client.set(key, data[key]);
+  });
+};
+
 exports.keys = function () {
   return keys;
 };