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

Now using internal buffer-system

Browse Source
This commit is contained in:
Ruakij 2021-11-24 20:00:05 +01:00
parent 4f1463eb4f
commit 368b6585ba
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/streamHandler/RegexBlockStream.js
View File

@ -1,3 +1,4 @@
const logger = require.main.require("./helper/logger.js")("RegexBlockStream");
const { Transform } = require('stream') const { Transform } = require('stream')
/** /**
@ -22,12 +23,11 @@ class RegexBlockStream extends Transform{
this.matcher = matcher; this.matcher = matcher;
this.withholdLastBlock = withholdLastBlock; this.withholdLastBlock = withholdLastBlock;
this.matchAllOnFlush = matchAllOnFlush; this.matchAllOnFlush = matchAllOnFlush;
this._buffer = "";
} }
_transform(chunk, encoding, next){ _transform(chunk, encoding, next){
chunk = this._buffer + chunk; // Add previous buffer to current chunk chunk = this.readableBuffer.length? this.readableBuffer.join() + chunk: chunk; // Add previous buffer to current chunk
this.readableBuffer.length && this.readableBuffer.clear(); // Clear buffer once we read it
let matches = chunk.match(this.matcher); // Match let matches = chunk.match(this.matcher); // Match
if(matches){ if(matches){
@ -35,7 +35,7 @@ class RegexBlockStream extends Transform{
chunk = this._writeMatches(matches, chunk); chunk = this._writeMatches(matches, chunk);
} }
this._buffer = chunk; // Store remaining data in buffer this.readableBuffer.push(chunk); // Store remaining data in buffer
next(); // Get next chunk next(); // Get next chunk
} }
@ -51,8 +51,9 @@ class RegexBlockStream extends Transform{
_flush(next){ _flush(next){
if(matchAllOnFlush){ // When requested, we'll match one last time over the remaining buffer if(matchAllOnFlush){ // When requested, we'll match one last time over the remaining buffer
let matches = this._buffer.match(this.matcher); // Match remaining buffer let chunk = this.readableBuffer.toString();
_writeMatches(this._buffer); // Write matches including last element let matches = chunk.match(this.matcher); // Match remaining buffer
_writeMatches(matches); // Write matches including last element
} }
next(); // Tell system we are done next(); // Tell system we are done