Skip to content

Commit 15b1772

Browse files
committed
update: read deviceId from payload
1 parent f945cd6 commit 15b1772

File tree

2 files changed

+14
-8
lines changed

2 files changed

+14
-8
lines changed

coap-broker-server-events.js

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,17 @@
1-
var server = require('../libs/coap-broker');
1+
var server = require('./libs/coap-broker');
22

3-
var onmessage = function(message) {
4-
var obj = JSON.parse(message.data);
3+
var onmessage = function(payload) {
4+
var obj = JSON.parse(payload.data);
5+
var paths = payload.pathname.split('/');
6+
var deviceId = paths[2];
57

6-
console.log('<DATA> ' + message.data);
8+
console.log('[', deviceId, ']', payload.data);
79
};
810

911
var onnewthing = function(thing) {
1012
var data = JSON.stringify(thing);
13+
14+
console.log('<NEW_THING> ' + data);
1115
};
1216

1317
server.start({

websocket-broker-server-events.js

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,11 @@
1-
var server = require('../libs/websocket-broker');
1+
var server = require('./libs/websocket-broker');
22

3-
var onmessage = function(message) {
4-
var obj = JSON.parse(message.data);
3+
var onmessage = function(payload) {
4+
var obj = JSON.parse(payload.data);
5+
var paths = payload.pathname.split('/');
6+
var deviceId = paths[2];
57

6-
console.log('<DATA> ' + message.data);
8+
console.log('[', deviceId, ']', payload.data);
79
};
810

911
var onnewthing = function(thing) {

0 commit comments

Comments
 (0)