Ruakij/rfmon-to-influx
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Returning packet not to loose information

Browse Source
This commit is contained in:
Ruakij 2021-11-24 23:13:35 +01:00
parent 66c0fdfe12
commit 09bea81058
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/streamHandler/PacketStreamFactory.js
View File

@ -45,8 +45,8 @@ class PacketStreamFactory extends Transform{
const lines = chunk.split('\n'); const lines = chunk.split('\n');
const header = lines.splice(0, 1)[0]; // Grab first line, 'lines' is now the payload const header = lines.splice(0, 1)[0]; // Grab first line, 'lines' is now the payload
this._handleHeader(packet, header); packet = this._handleHeader(packet, header);
this._handlePayload(packet, lines); packet = this._handlePayload(packet, lines);
logger.debug(packet); logger.debug(packet);
@ -102,11 +102,15 @@ class PacketStreamFactory extends Transform{
break; break;
} }
if(newPacket) packet = Object.assign(newPacket, packet); // Use new, more specific, packet and copy old data over if(newPacket) packet = Object.assign(newPacket, packet); // Use new, more specific, packet and copy old data over
return packet;
} }
_handlePayload(packet, data){ _handlePayload(packet, data){
// Get payload-Hex-Data. If there is no data: empty // Get payload-Hex-Data. If there is no data: empty
packet.payloadData = data.join('').match(/(?<=\s)([A-F0-9]{1,4}(?!(\.|x)))/igm)?.join('') ?? ''; packet.payloadData = data.join('').match(/(?<=\s)([A-F0-9]{1,4}(?!(\.|x)))/igm)?.join('') ?? '';
return packet;
} }
} }