English firehose

gistfile1.txt

import { Firehose } from '@skyware/firehose';
const firehose = new Firehose({ relay: 'wss://bsky.network' });

const queue = [];

firehose.on('commit', (message) => {
  for (const op of message.ops) {
    if (!op.record) {
      continue;
    }
    if (!op.record?.text) {
      continue;
    }
    if (!op.record?.langs?.includes('en')) {
      continue;
    }
    queue.push(op);
    const uri = 'at://' + message.repo + '/' + op.path;
    console.log('Operation:', JSON.stringify(op));
  }
});

firehose.start();
setInterval(() => {
  const all = queue.map((c) => {
    JSON.stringify(c);
  });
  console.log(all.join('\n') + '\n');
  queue.length = 0;
}, 500);

Looks suspciously like I'm double logging here doesn't it?