Software shaped around the way you work.

type ReadEvent = { tag: string; time: number };

async function collect(reader: Reader) {
  const events = await reader.scan();
  return events
    .filter(event => event.tag.length > 0)
    .map(event => ({
      id: event.tag,
      timestamp: event.time,
      source: reader.id
    }));
}

const batch = await collect(reader);
await eventStore.append(batch);
await queue.publish("events.ready", batch);

type ReadEvent = { tag: string; time: number };

async function collect(reader: Reader) {
  const events = await reader.scan();
  return events
    .filter(event => event.tag.length > 0)
    .map(event => ({
      id: event.tag,
      timestamp: event.time,
      source: reader.id
    }));
}

const batch = await collect(reader);
await eventStore.append(batch);
await queue.publish("events.ready", batch);