Kieran/snort
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: use command queue for batch event write

Browse Source
This commit is contained in:
Kieran
2024-01-19 13:25:14 +00:00
parent 72b98a4ab5
commit da6fa415dd
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
packages/worker-relay/src/worker.ts
View File

@ -31,9 +31,14 @@ let eventWriteQueue: Array<NostrEvent> = [];
async function insertBatch() { async function insertBatch() {
// Only insert event batches when the command queue is empty // Only insert event batches when the command queue is empty
// This is to make req's execute first and not block them // This is to make req's execute first and not block them
if (relay && eventWriteQueue.length > 0 && cmdQueue.length === 0) { if (eventWriteQueue.length > 0 && cmdQueue.length === 0) {
relay.eventBatch(eventWriteQueue); await barrierQueue(cmdQueue, async () => {
eventWriteQueue = []; if (relay) {
const toWrite = [...eventWriteQueue];
eventWriteQueue = [];
relay.eventBatch(toWrite);
}
});
} }
setTimeout(() => insertBatch(), 100); setTimeout(() => insertBatch(), 100);
} }