FilterId

type FilterIdType = string & {
  readonly [brand]: "FilterId";
};

import * as FilterId from './primitives/FilterId/index.js';

const id = FilterId.from("0x1");

const str = FilterId.toString(id); // "0x1"

const equal = FilterId.equals(id1, id2);

// eth_newFilter (log filter)
const filterId = await rpc.eth_newFilter({
  fromBlock: "latest",
  address: "0x...",
  topics: [eventSig]
});

// eth_newBlockFilter (block hashes)
const blockFilterId = await rpc.eth_newBlockFilter();

// eth_newPendingTransactionFilter (pending tx hashes)
const txFilterId = await rpc.eth_newPendingTransactionFilter();

// Returns new logs/blocks/txs since last poll
const changes = await rpc.eth_getFilterChanges(filterId);

// Returns all logs matching filter
const logs = await rpc.eth_getFilterLogs(filterId);

// Remove filter from node
const success = await rpc.eth_uninstallFilter(filterId);

import * as FilterId from './primitives/FilterId/index.js';
import * as LogFilter from './primitives/LogFilter/index.js';
import * as Address from './primitives/Address/index.js';

// Create log filter
const filter = LogFilter.from({
  fromBlock: "latest",
  address: Address.from("0x..."),
  topics: [eventSignature]
});

// Install filter on node
const filterIdStr = await rpc.eth_newFilter(filter);
const filterId = FilterId.from(filterIdStr);

// Poll every 15 seconds
const interval = setInterval(async () => {
  try {
    const logs = await rpc.eth_getFilterChanges(filterId);
    console.log(`Got ${logs.length} new logs`);
  } catch (error) {
    // Filter expired - recreate
    if (error.message.includes('filter not found')) {
      clearInterval(interval);
      // Recreate filter...
    }
  }
}, 15000);

// Cleanup
process.on('SIGINT', async () => {
  await rpc.eth_uninstallFilter(filterId);
  clearInterval(interval);
});