mirror of
https://github.com/Viren070/AIOStreams.git
synced 2025-12-01 23:14:04 +01:00
fix(sel): correct filter function syntax for stream message comparison
This commit is contained in:
@@ -508,11 +508,11 @@ export abstract class StreamExpressionEngine {
|
|||||||
} else if (mode !== 'exact' && mode !== 'includes') {
|
} else if (mode !== 'exact' && mode !== 'includes') {
|
||||||
throw new Error("Mode must be either 'exact' or 'includes'");
|
throw new Error("Mode must be either 'exact' or 'includes'");
|
||||||
}
|
}
|
||||||
return streams.filter((stream) => {
|
return streams.filter((stream) =>
|
||||||
mode == 'exact'
|
mode == 'exact'
|
||||||
? messages.includes(stream.message || '')
|
? messages.includes(stream.message || '')
|
||||||
: messages.some((m) => (stream.message || '').includes(m));
|
: messages.some((m) => (stream.message || '').includes(m))
|
||||||
});
|
);
|
||||||
};
|
};
|
||||||
|
|
||||||
this.parser.functions.count = function (streams: ParsedStream[]) {
|
this.parser.functions.count = function (streams: ParsedStream[]) {
|
||||||
|
|||||||
Reference in New Issue
Block a user