import type * as Cloudflare from "alchemy/Cloudflare";import * as Effect from "effect/Effect"; import * as FcmDeliveries from "./FcmDeliveries.ts"; export const processMessage = Effect.fn("relay.fcm_delivery_queue.process_message")(function* (  message: Cloudflare.Queues.Message<unknown>,) {  const deliveries = yield* FcmDeliveries.FcmDeliveries;  yield* deliveries.process(message.body).pipe(    Effect.matchEffect({      onFailure: (error) =>        Effect.gen(function* () {          // Decide this message's outcome before Alchemy acknowledges the batch.          // Cloudflare keeps the first ack/retry decision for each message.          message.retry();          yield* Effect.logWarning("FCM queue delivery failed; retrying message", {            messageId: message.id,            errorTag: error._tag,          });        }),      onSuccess: () => Effect.sync(() => message.ack()),    }),  );});