Stream Bytes

import { createOurPay } from "@ourpay-dev/sdk/2026-10";

const ourpay = createOurPay({
  accessToken: process.env.OURPAY_ACCESS_TOKEN ?? "",
});

async function recordStreamBytes(
  externalCustomerId: string,
  transferId: string,
  bytes: number,
) {
  await ourpay.events.ingest({
    events: [
      {
        name: "stream.transfer",
        external_id: transferId,
        external_customer_id: externalCustomerId,
        metadata: { bytes },
      },
    ],
  });
}