fix(connectStream): add FILTER_LIMIT in filters

This commit is contained in:
P. Reis 2024-06-28 15:28:29 -03:00
parent bdd3b2224e
commit 701049d931

View file

@ -85,7 +85,7 @@ function connectStream(socket: WebSocket) {
send(['EOSE', subId]);
try {
for await (const msg of pubsub.req(filters, { signal: controller.signal })) {
for await (const msg of pubsub.req(filters.concat({ limit: FILTER_LIMIT }), { signal: controller.signal })) {
if (msg[0] === 'EVENT') {
send(['EVENT', subId, msg[2]]);
}