Commit 8e0457e5 by Chavee Issariyapat

support feed

parent 18ebc7d4
module.exports.create = create module.exports.create = create
const DEBUG = true; const DEBUG = false;
const events = require('events'); const events = require('events');
const cache = require('./cache'); const cache = require('./cache');
...@@ -226,6 +226,10 @@ const Coordinator = function(param={}) { ...@@ -226,6 +226,10 @@ const Coordinator = function(param={}) {
payload: payload payload: payload
}); });
} }
else if (topic.startsWith('@feed/data/updated')) {
that.flowemitter.pub(`flow:feed:${jsonpayload.deviceid}`, jsonpayload);
}
}); });
} }
......
{ {
"name": "flowagent", "name": "flowagent",
"version": "1.2.2", "version": "1.2.3",
"description": "", "description": "",
"main": "flowagent.js", "main": "flowagent.js",
"scripts": { "scripts": {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment