How you have created these strings in your second posting (4th post)?
What is the output when you use the standard settings:
the result is a set of 5 messages with buffers of different lengths ... continously repaeted
That looks perfect . so the first string should be filtered out by the complete flow. - so in my opinion you can try the flow.
This looks to match the correct scheme.
OK - so in principle it is working but we need somehow splitting the stream at the correct positions.
could it be that /n is the wrong character to split the stream ?
these strings are FAR to short:
thats how the green ones start and they are MUCH longer ...
So I have now an idea how to get it probably correct - separated.
can you use your serial node in that way - that single bytes will be the output (no character specified)
or buffer = 0
So unfortunately is the split node not working as expected. In my opinion an issue should be raised.
Originally I expected that the split node would work to analyse the data stream:
However the split not works not properly - so the data stream is splitted each time a byte with value 36 is recognized - and not the whole buffer means 2 bytes with value 36.
So I wrote 2 function nodes - the first node splits a stream into parts splitted by 2 bytes - defined as header:
const header = Buffer.from([0x24,0x24]);
The second function node filters all messages in combination of header and command.
const filter = Buffer.from([0x24,0x24,0x56]);
So I hope the flow will work:
[
{
"id": "868aa4256ca689ac",
"type": "function",
"z": "78d94accf7f5ec3c",
"name": "Analyse stream",
"func": "if (msg.flush){\n msg.payload=context.get(\"buffer\");\n context.set(\"buffer\",undefined);\n return msg;\n}\n\n\nconst header = Buffer.from([0x24,0x24]);\nvar buffer = context.get(\"buffer\")||Buffer.alloc(0);\n\nvar arr = [buffer, msg.payload];\n\nmsg.payload = undefined;\nbuffer = Buffer.concat(arr);\n\n\nif (buffer.indexOf(header) >= 0 ) {\n var tmp = buffer.slice(2);\n var arrSliced =[]; \n \n var i = tmp.indexOf(header);\n\n if (tmp.indexOf(header) >= 0 ){ \n arrSliced[0] = buffer.slice(0, i + 2);\n buffer = buffer.slice(i + 2); \n if (arrSliced[0].indexOf(header) >= 0) msg.payload = arrSliced[0];\n if (msg.payload.equals(header)) msg.payload = \"\";\n }\n \n}\n\ncontext.set(\"buffer\",buffer);\nif (msg.payload) return msg;\n \n\n",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 2120,
"y": 4160,
"wires": [
[
"4ba58e3fe27b80d3"
]
]
},
{
"id": "4ba58e3fe27b80d3",
"type": "function",
"z": "78d94accf7f5ec3c",
"name": "filter command",
"func": "const filter = Buffer.from([0x24,0x24,0x56]);\nif (Buffer.isBuffer(msg.payload)) {\n if (filter.equals(msg.payload.slice(0,3))) return msg;\n}",
"outputs": 1,
"noerr": 0,
"initialize": "",
"finalize": "",
"libs": [],
"x": 2320,
"y": 4160,
"wires": [
[
"850b1c253ed01d58",
"623dcd793312299e"
]
]
},
{
"id": "57f673a1708bf489",
"type": "debug",
"z": "78d94accf7f5ec3c",
"name": "",
"active": true,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "false",
"statusVal": "",
"statusType": "auto",
"x": 2690,
"y": 4160,
"wires": []
},
{
"id": "850b1c253ed01d58",
"type": "buffer-parser",
"z": "78d94accf7f5ec3c",
"name": "",
"data": "payload",
"dataType": "msg",
"specification": "spec",
"specificationType": "ui",
"items": [
{
"type": "byte",
"name": "Header",
"offset": 0,
"length": 2,
"offsetbit": 0,
"scale": "1",
"mask": ""
},
{
"type": "hex",
"name": "Command",
"offset": 2,
"length": 1,
"offsetbit": 0,
"scale": "1",
"mask": ""
},
{
"type": "uint8",
"name": "DataLength",
"offset": 3,
"length": 1,
"offsetbit": 0,
"scale": "1",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell1",
"offset": 4,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell2",
"offset": 6,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell3",
"offset": 8,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell4",
"offset": 10,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell5",
"offset": 12,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell6",
"offset": 14,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell7",
"offset": 16,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell8",
"offset": 18,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell9",
"offset": 20,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell10",
"offset": 22,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell11",
"offset": 24,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell12",
"offset": 26,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell13",
"offset": 28,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell14",
"offset": 30,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell15",
"offset": 32,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint16be",
"name": "Cell16",
"offset": 34,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint32le",
"name": "Wh",
"offset": 36,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint32le",
"name": "Ah",
"offset": 40,
"length": 1,
"offsetbit": 0,
"scale": "/1000",
"mask": ""
},
{
"type": "uint8",
"name": "CheckSum",
"offset": 44,
"length": 1,
"offsetbit": 0,
"scale": "1",
"mask": ""
}
],
"swap1": "",
"swap2": "",
"swap3": "",
"swap1Type": "swap",
"swap2Type": "swap",
"swap3Type": "swap",
"msgProperty": "payload",
"msgPropertyType": "str",
"resultType": "keyvalue",
"resultTypeType": "return",
"multipleResult": false,
"fanOutMultipleResult": false,
"setTopic": true,
"outputs": 1,
"x": 2510,
"y": 4160,
"wires": [
[
"57f673a1708bf489"
]
]
},
{
"id": "4ccf16891a5588e8",
"type": "inject",
"z": "78d94accf7f5ec3c",
"name": "",
"props": [
{
"p": "payload"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"payload": "[36,36,86,45,12,253,13,4,13,4,13,2,13,3,13,4,13,6,13,1,13,8,13,2,13,5,12,254,13,6,12,251,13,15,12,252,118,254,213,2,99,20,14,0,149]",
"payloadType": "bin",
"x": 2130,
"y": 4200,
"wires": [
[
"4ba58e3fe27b80d3"
]
]
},
{
"id": "c4f48b5d708eb501",
"type": "inject",
"z": "78d94accf7f5ec3c",
"name": "",
"props": [
{
"p": "flush",
"v": "true",
"vt": "bool"
}
],
"repeat": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"topic": "",
"x": 1900,
"y": 4200,
"wires": [
[
"868aa4256ca689ac"
]
]
},
{
"id": "623dcd793312299e",
"type": "debug",
"z": "78d94accf7f5ec3c",
"name": "",
"active": false,
"tosidebar": true,
"console": false,
"tostatus": false,
"complete": "false",
"statusVal": "",
"statusType": "auto",
"x": 2530,
"y": 4120,
"wires": []
}
]
One supplement:
As the buffers of the analyse node are sent only when the next header is detected - the last buffer remains in the context. To flush this buffer a msg.flush with a boolean true has to be sent to empty the node. So an additional trigger node is recommended, when the stream of bytes stopped.
