Function queue

services/notifications/src/queue-consumer.ts:12–25

(batch: MessageBatch<ReceiptCheckMessage>, env: Env)

};

export async function queue(batch: MessageBatch<ReceiptCheckMessage>, env: Env): Promise<void> {
  for (const msg of batch.messages) {
    try {
      await processReceiptCheck(env, msg.body);
      msg.ack();
    } catch (err) {
      console.error('Receipt check failed, will retry', {
        ticketCount: msg.body.ticketTokenPairs.length,
        error: err instanceof Error ? err.message : String(err),
      });
      msg.retry();
    }
  }
}

async function processReceiptCheck(env: Env, message: ReceiptCheckMessage): Promise<void> {
  const accessToken = await env.EXPO_ACCESS_TOKEN.get();