Nodered-Timeserver: device display
This commit is contained in:
parent
d4a23c35af
commit
ee3be4ecad
@ -1,4 +1,11 @@
|
|||||||
[
|
[
|
||||||
|
{
|
||||||
|
"id": "449c1517.e25f4c",
|
||||||
|
"type": "tab",
|
||||||
|
"label": "Timeserver MQTT",
|
||||||
|
"disabled": false,
|
||||||
|
"info": ""
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"id": "49e3c067.e782e",
|
"id": "49e3c067.e782e",
|
||||||
"type": "change",
|
"type": "change",
|
||||||
@ -49,7 +56,7 @@
|
|||||||
"to": "",
|
"to": "",
|
||||||
"reg": false,
|
"reg": false,
|
||||||
"x": 240,
|
"x": 240,
|
||||||
"y": 464,
|
"y": 500,
|
||||||
"wires": [
|
"wires": [
|
||||||
[
|
[
|
||||||
"84f1cda2.069e7"
|
"84f1cda2.069e7"
|
||||||
@ -82,7 +89,7 @@
|
|||||||
"retain": "",
|
"retain": "",
|
||||||
"broker": "2a15ab6f.ab2244",
|
"broker": "2a15ab6f.ab2244",
|
||||||
"x": 730,
|
"x": 730,
|
||||||
"y": 464,
|
"y": 500,
|
||||||
"wires": []
|
"wires": []
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
@ -135,7 +142,7 @@
|
|||||||
"action": "",
|
"action": "",
|
||||||
"pretty": false,
|
"pretty": false,
|
||||||
"x": 580,
|
"x": 580,
|
||||||
"y": 464,
|
"y": 500,
|
||||||
"wires": [
|
"wires": [
|
||||||
[
|
[
|
||||||
"72d5e7ee.d1eba8"
|
"72d5e7ee.d1eba8"
|
||||||
@ -165,7 +172,7 @@
|
|||||||
"action": "",
|
"action": "",
|
||||||
"property": "payload.payload_raw",
|
"property": "payload.payload_raw",
|
||||||
"x": 420,
|
"x": 420,
|
||||||
"y": 464,
|
"y": 500,
|
||||||
"wires": [
|
"wires": [
|
||||||
[
|
[
|
||||||
"dac8aafa.389298"
|
"dac8aafa.389298"
|
||||||
@ -212,11 +219,11 @@
|
|||||||
"type": "function",
|
"type": "function",
|
||||||
"z": "449c1517.e25f4c",
|
"z": "449c1517.e25f4c",
|
||||||
"name": "Generate Time Answer",
|
"name": "Generate Time Answer",
|
||||||
"func": "/* LoRaWAN Timeserver\n\nconstruct 6 byte timesync_answer from gateway timestamp and node's time_sync_req\n\nbyte meaning\n0 sequence number (taken from node's time_sync_req)\n1..4 current second (from epoch time 1970)\n5 1/250ths fractions of current second\n\n*/\n\nfunction timecompare(a, b) {\n \n const timeA = a.time;\n const timeB = b.time;\n\n let comparison = 0;\n if (timeA > timeB) {\n comparison = 1;\n } else if (timeA < timeB) {\n comparison = -1;\n }\n return comparison;\n}\n\nlet confidence = 2000; // max millisecond diff gateway time to server time\n\nvar gateways = msg.payload.metadata.gateways;\nvar gateway_time = gateways.map(gw => {\n return {\n time: new Date(gw.time),\n eui: gw.gtw_id,\n }\n });\nvar server_time = new Date(msg.payload.metadata.time);\n\n// validate all gateway timestamps against lorawan server_time (which is assumed to be recent)\nvar gw_timestamps = gateway_time.filter(function (element) {\n return ((element.time > (server_time - confidence) && element.time <= server_time));\n});\n\n// if no timestamp left, we have no valid one and exit\nif (gw_timestamps.length === 0) return null;\n\n// sort time array in ascending order to find most recent timestamp for time answer\ngw_timestamps.sort(timecompare);\n\nvar timestamp = gw_timestamps[0].time;\nvar eui = gw_timestamps[0].eui;\nvar offset = server_time - timestamp;\n\nvar seconds = Math.floor(timestamp/1000);\nvar fractions = (timestamp % 1000) / 4;\nvar seqno = msg.payload.payload_raw[0];\n\nlet buf = new ArrayBuffer(6);\nnew DataView(buf).setUint8(0, seqno);\nnew DataView(buf).setUint32(1, seconds);\nnew DataView(buf).setUint8(5, fractions);\n\nmsg.payload = new Buffer(new Uint8Array(buf));\nvar infoMsg = { payload: eui };\nvar offsetMsg = { payload: offset };\n\nreturn [infoMsg, offsetMsg, msg];",
|
"func": "/* LoRaWAN Timeserver\n\nconstruct 6 byte timesync_answer from gateway timestamp and node's time_sync_req\n\nbyte meaning\n0 sequence number (taken from node's time_sync_req)\n1..4 current second (from epoch time 1970)\n5 1/250ths fractions of current second\n\n*/\n\nfunction timecompare(a, b) {\n \n const timeA = a.time;\n const timeB = b.time;\n\n let comparison = 0;\n if (timeA > timeB) {\n comparison = 1;\n } else if (timeA < timeB) {\n comparison = -1;\n }\n return comparison;\n}\n\nlet confidence = 2000; // max millisecond diff gateway time to server time\n\nvar device = msg.payload.dev_id;\nvar gateways = msg.payload.metadata.gateways;\nvar gateway_time = gateways.map(gw => {\n return {\n time: new Date(gw.time),\n eui: gw.gtw_id,\n }\n });\nvar server_time = new Date(msg.payload.metadata.time);\n\n// validate all gateway timestamps against lorawan server_time (which is assumed to be recent)\nvar gw_timestamps = gateway_time.filter(function (element) {\n return ((element.time > (server_time - confidence) && element.time <= server_time));\n});\n\n// if no timestamp left, we have no valid one and exit\nif (gw_timestamps.length === 0) return null;\n\n// sort time array in ascending order to find most recent timestamp for time answer\ngw_timestamps.sort(timecompare);\n\nvar timestamp = gw_timestamps[0].time;\nvar eui = gw_timestamps[0].eui;\nvar offset = server_time - timestamp;\n\nvar seconds = Math.floor(timestamp/1000);\nvar fractions = (timestamp % 1000) / 4;\nvar seqno = msg.payload.payload_raw[0];\n\nlet buf = new ArrayBuffer(6);\nnew DataView(buf).setUint8(0, seqno);\nnew DataView(buf).setUint32(1, seconds);\nnew DataView(buf).setUint8(5, fractions);\n\nmsg.payload = new Buffer(new Uint8Array(buf));\nvar infoMsg = { payload: eui };\nvar offsetMsg = { payload: offset };\nvar deviceMsg = { payload: device };\n\nreturn [infoMsg, offsetMsg, deviceMsg, msg];",
|
||||||
"outputs": 3,
|
"outputs": 4,
|
||||||
"noerr": 0,
|
"noerr": 0,
|
||||||
"x": 360,
|
"x": 360,
|
||||||
"y": 320,
|
"y": 340,
|
||||||
"wires": [
|
"wires": [
|
||||||
[
|
[
|
||||||
"37722d4b.08e3c2",
|
"37722d4b.08e3c2",
|
||||||
@ -226,6 +233,9 @@
|
|||||||
[
|
[
|
||||||
"46ce842a.614d5c"
|
"46ce842a.614d5c"
|
||||||
],
|
],
|
||||||
|
[
|
||||||
|
"a5dbb4ef.019168"
|
||||||
|
],
|
||||||
[
|
[
|
||||||
"49e3c067.e782e"
|
"49e3c067.e782e"
|
||||||
]
|
]
|
||||||
@ -233,6 +243,7 @@
|
|||||||
"outputLabels": [
|
"outputLabels": [
|
||||||
"gw_eui",
|
"gw_eui",
|
||||||
"offset_ms",
|
"offset_ms",
|
||||||
|
"device",
|
||||||
"time_sync_ans"
|
"time_sync_ans"
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
@ -241,7 +252,7 @@
|
|||||||
"type": "debug",
|
"type": "debug",
|
||||||
"z": "449c1517.e25f4c",
|
"z": "449c1517.e25f4c",
|
||||||
"name": "Timeserver Gw",
|
"name": "Timeserver Gw",
|
||||||
"active": true,
|
"active": false,
|
||||||
"tosidebar": false,
|
"tosidebar": false,
|
||||||
"console": false,
|
"console": false,
|
||||||
"tostatus": true,
|
"tostatus": true,
|
||||||
@ -264,7 +275,7 @@
|
|||||||
"format": "{{msg.payload}}",
|
"format": "{{msg.payload}}",
|
||||||
"layout": "col-center",
|
"layout": "col-center",
|
||||||
"x": 810,
|
"x": 810,
|
||||||
"y": 340,
|
"y": 336,
|
||||||
"wires": []
|
"wires": []
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
@ -290,7 +301,7 @@
|
|||||||
"seg1": "",
|
"seg1": "",
|
||||||
"seg2": "",
|
"seg2": "",
|
||||||
"x": 710,
|
"x": 710,
|
||||||
"y": 420,
|
"y": 416,
|
||||||
"wires": []
|
"wires": []
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
@ -302,11 +313,11 @@
|
|||||||
"width": 0,
|
"width": 0,
|
||||||
"height": 0,
|
"height": 0,
|
||||||
"name": "Recent server",
|
"name": "Recent server",
|
||||||
"label": "",
|
"label": "Gateway",
|
||||||
"format": "{{msg.payload}}",
|
"format": "{{msg.payload}}",
|
||||||
"layout": "col-center",
|
"layout": "col-center",
|
||||||
"x": 700,
|
"x": 700,
|
||||||
"y": 380,
|
"y": 376,
|
||||||
"wires": []
|
"wires": []
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
@ -318,13 +329,29 @@
|
|||||||
"outputs": 1,
|
"outputs": 1,
|
||||||
"noerr": 0,
|
"noerr": 0,
|
||||||
"x": 670,
|
"x": 670,
|
||||||
"y": 340,
|
"y": 336,
|
||||||
"wires": [
|
"wires": [
|
||||||
[
|
[
|
||||||
"8712a5ac.ed18e8"
|
"8712a5ac.ed18e8"
|
||||||
]
|
]
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
"id": "a5dbb4ef.019168",
|
||||||
|
"type": "ui_text",
|
||||||
|
"z": "449c1517.e25f4c",
|
||||||
|
"group": "edb7cc8d.a3817",
|
||||||
|
"order": 1,
|
||||||
|
"width": 0,
|
||||||
|
"height": 0,
|
||||||
|
"name": "Recent Device",
|
||||||
|
"label": "Device",
|
||||||
|
"format": "{{msg.payload}}",
|
||||||
|
"layout": "col-center",
|
||||||
|
"x": 700,
|
||||||
|
"y": 456,
|
||||||
|
"wires": []
|
||||||
|
},
|
||||||
{
|
{
|
||||||
"id": "2a15ab6f.ab2244",
|
"id": "2a15ab6f.ab2244",
|
||||||
"type": "mqtt-broker",
|
"type": "mqtt-broker",
|
||||||
|
Loading…
Reference in New Issue
Block a user