mirror of
https://github.com/Yonle/bostr.git
synced 2025-10-04 18:02:29 +02:00
@@ -321,8 +321,8 @@ function newConn(addr, id) {
|
|||||||
// If it's at the limit, Send EOSE to client and delete pendingEOSE of subID
|
// If it's at the limit, Send EOSE to client and delete pendingEOSE of subID
|
||||||
|
|
||||||
// Skip if EOSE has been omitted
|
// Skip if EOSE has been omitted
|
||||||
if (!client.pendingEOSE.has(data[1]) || !client.subs.get(data[1])?[0]?.limit || client.pause_subs.has(data[1])) return;
|
if (!client.pendingEOSE.has(data[1]) || !client.subs.get(data[1])[0]?.limit || client.pause_subs.has(data[1])) return;
|
||||||
if (client.events.get(data[1]).size >= client.subs.get(data[1])?[0]?.limit) {
|
if (client.events.get(data[1]).size >= client.subs.get(data[1])[0]?.limit) {
|
||||||
// Once reached to <filter.limit>, send EOSE to client.
|
// Once reached to <filter.limit>, send EOSE to client.
|
||||||
client.send(JSON.stringify(["EOSE", data[1]]));
|
client.send(JSON.stringify(["EOSE", data[1]]));
|
||||||
if (pause_on_limit || cache_relays?.includes(relay.url)) {
|
if (pause_on_limit || cache_relays?.includes(relay.url)) {
|
||||||
|
Reference in New Issue
Block a user