f6fac6c4bc
Fix bin/publish: use correct .env path for rspade_system Fix bin/publish script: prevent grep exit code 1 from terminating script 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>
47 lines
677 B
JavaScript
Executable File
47 lines
677 B
JavaScript
Executable File
'use strict';
|
|
const {Transform} = require('stream');
|
|
|
|
class ObjectTransform extends Transform {
|
|
constructor() {
|
|
super({
|
|
objectMode: true
|
|
});
|
|
}
|
|
}
|
|
|
|
class FilterStream extends ObjectTransform {
|
|
constructor(filter) {
|
|
super();
|
|
this._filter = filter;
|
|
}
|
|
|
|
_transform(data, encoding, callback) {
|
|
if (this._filter(data)) {
|
|
this.push(data);
|
|
}
|
|
|
|
callback();
|
|
}
|
|
}
|
|
|
|
class UniqueStream extends ObjectTransform {
|
|
constructor() {
|
|
super();
|
|
this._pushed = new Set();
|
|
}
|
|
|
|
_transform(data, encoding, callback) {
|
|
if (!this._pushed.has(data)) {
|
|
this.push(data);
|
|
this._pushed.add(data);
|
|
}
|
|
|
|
callback();
|
|
}
|
|
}
|
|
|
|
module.exports = {
|
|
FilterStream,
|
|
UniqueStream
|
|
};
|