Stream.Transform.Integrate.

// You can import any library supported by Deno.
import type { Block } from "https://esm.sh/@apibara/indexer/starknet";
import { hash, uint256 } from "https://esm.run/starknet";
import { formatUnits } from "https://esm.run/viem";

import { filter, eventToTableRow } from "./utils";

const DECIMALS = 18;

// Define what data to stream and where to store the result.
export const config = {
  network: "starknet",
  filter,
  sinkType: "postgres",
  sinkOptions: {
    tableName: "transfers",
  },
};

// Transform data using Typescript or Javascript.
export default function decodeTransfersInBlock({ header, events }: Block) {
  const { blockNumber, blockHash, timestamp } = header;
  return events.map(({ event, receipt }) => {
    const { transactionHash } = receipt;
    const row = eventToTableRow(event)

    return {
      ...row,
      transactionHash
    };
  });
}