Track Activity of Specific Builders Using Hypercore Streams on Quicknode

gistfile1.txt

function main(payload) {
  const { data = [], metadata } = payload;

  const builders = new Set([
    "0xb84168cf3be63c6b8dad05ff5d755e97432ff80b",
  ]);

  const matchedEvents = [];

  for (const block of data) {
    const events = Array.isArray(block?.events) ? block.events : [];

    for (const event of events) {
      const trade = event?.[1];
      const builder = trade?.builder;

      if (typeof builder === "string" && builders.has(builder)) {
        matchedEvents.push(event);
      }
    }
  }

  if (matchedEvents.length === 0) {
    return null;
  }

  return {
    data: {
      events: matchedEvents,
      metadata,
    },
  };
}

https://dashboard.quicknode.com/streams/new