Function handler

packages/backend/src/function/billing/fetch-usage.ts:25–46

(event: SQSEvent)

import { disposable } from "@console/core/util/disposable";

export async function handler(event: SQSEvent) {
  console.log("got", event.Records.length, "records");
  for (const record of event.Records) {
    const evt = JSON.parse(record.body);
    console.log(record.body);
    await withActor(
      {
        type: "system",
        properties: {
          workspaceID: evt.workspaceID,
        },
      },
      async () => {
        if (evt.price === "invocations") {
          await processInvocations(evt.stageID);
        } else if (evt.price === "resources") {
          await processResources(evt.workspaceID);
        }
      },
    );
  }
}

async function processInvocations(stageID: string) {
  const stage = await Stage.fromID(stageID);