import * as Alchemy from "alchemy";import * as Cloudflare from "alchemy/Cloudflare";import * as Crypto from "effect/Crypto";import * as Context from "effect/Context";import * as DateTime from "effect/DateTime";import * as Effect from "effect/Effect";import * as Layer from "effect/Layer";import * as Schema from "effect/Schema"; import type { RelayDeliveryResult } from "@t3tools/contracts/relay"; import {  sanitizeAgentActivityAggregateState,  sanitizeApnsNotificationPayload,} from "./agentActivityPayloads.ts";import {  expiresAtForJob,  makeApnsDeliveryJobPayload,  signApnsDeliveryJob,  type ApnsDeliveryJobPayload,  type SignedApnsDeliveryJob,} from "./apnsDeliveryJobs.ts";import * as RelayConfiguration from "../Config.ts"; export class ApnsDeliveryQueueSendError extends Schema.TaggedErrorClass<ApnsDeliveryQueueSendError>()(  "ApnsDeliveryQueueSendError",  { cause: Schema.Defect() },) {  override get message(): string {    return "Failed to enqueue APNs delivery";  }} export type ApnsDeliveryQueueError = ApnsDeliveryQueueSendError; export class ApnsDeliveryQueueSender extends Context.Service<  ApnsDeliveryQueueSender,  {    readonly send: (body: SignedApnsDeliveryJob) => Effect.Effect<void, ApnsDeliveryQueueSendError>;  }>()("t3code-relay/agentActivity/ApnsDeliveryQueue/ApnsDeliveryQueueSender") {} export class ApnsDeliveryQueue extends Context.Service<  ApnsDeliveryQueue,  {    readonly enqueueLiveActivity: (input: {      readonly kind: ApnsDeliveryJobPayload["kind"];      readonly userId: string;      readonly deviceId: string;      readonly token: string;      readonly aggregate: ApnsDeliveryJobPayload["aggregate"];    }) => Effect.Effect<RelayDeliveryResult, ApnsDeliveryQueueError>;    readonly enqueuePushNotification: (input: {      readonly userId: string;      readonly deviceId: string;      readonly token: string;      readonly notification: NonNullable<ApnsDeliveryJobPayload["notification"]>;    }) => Effect.Effect<RelayDeliveryResult, ApnsDeliveryQueueError>;  }>()("t3code-relay/agentActivity/ApnsDeliveryQueue") {} export const make = Effect.gen(function* () {  const sender = yield* ApnsDeliveryQueueSender;  const crypto = yield* Crypto.Crypto;  const config = yield* RelayConfiguration.RelayConfiguration;   return ApnsDeliveryQueue.of({    enqueueLiveActivity: Effect.fn("relay.apns_delivery_queue.enqueue_live_activity")(      function* (input) {        yield* Effect.annotateCurrentSpan({          "relay.mobile.device_id": input.deviceId,          "relay.delivery.kind": input.kind,        });        const now = yield* DateTime.now;        const jobId = yield* crypto.randomUUIDv4.pipe(          Effect.mapError((cause) => new ApnsDeliveryQueueSendError({ cause })),        );        yield* Effect.annotateCurrentSpan({ "relay.delivery.job_id": jobId });        const payload = makeApnsDeliveryJobPayload({          ...input,          aggregate:            input.aggregate === null ? null : sanitizeAgentActivityAggregateState(input.aggregate),          jobId,          createdAt: DateTime.formatIso(now),          expiresAt: expiresAtForJob(now.epochMilliseconds),        });        const signed = signApnsDeliveryJob({          secret: config.apnsDeliveryJobSigningSecret,          payload,        });        yield* sender.send(signed);        return {          deviceId: input.deviceId,          kind: input.kind,          ok: true,          queued: true,          apnsStatus: null,          apnsReason: null,          apnsId: null,        };      },    ),    enqueuePushNotification: Effect.fn("relay.apns_delivery_queue.enqueue_push_notification")(      function* (input) {        yield* Effect.annotateCurrentSpan({          "relay.mobile.device_id": input.deviceId,          "relay.delivery.kind": "push_notification",          "relay.environment_id": input.notification.environmentId,          "relay.thread_id": input.notification.threadId,        });        const now = yield* DateTime.now;        const jobId = yield* crypto.randomUUIDv4.pipe(          Effect.mapError((cause) => new ApnsDeliveryQueueSendError({ cause })),        );        yield* Effect.annotateCurrentSpan({ "relay.delivery.job_id": jobId });        const payload = makeApnsDeliveryJobPayload({          kind: "push_notification",          userId: input.userId,          deviceId: input.deviceId,          token: input.token,          aggregate: null,          notification: sanitizeApnsNotificationPayload(input.notification),          jobId,          createdAt: DateTime.formatIso(now),          expiresAt: expiresAtForJob(now.epochMilliseconds),        });        const signed = signApnsDeliveryJob({          secret: config.apnsDeliveryJobSigningSecret,          payload,        });        yield* sender.send(signed);        return {          deviceId: input.deviceId,          kind: "push_notification" as const,          ok: true,          queued: true,          apnsStatus: null,          apnsReason: null,          apnsId: null,        };      },    ),  });}); export const layer = Layer.effect(ApnsDeliveryQueue, make); export const layerCloudflareQueues = (  sender: Cloudflare.QueueSender,  alchemyRuntimeContext: Alchemy.BaseRuntimeContext,) =>  layer.pipe(    Layer.provide(      Layer.succeed(        ApnsDeliveryQueueSender,        ApnsDeliveryQueueSender.of({          send: (body) =>            sender.send(body).pipe(              Effect.mapError((cause) => new ApnsDeliveryQueueSendError({ cause })),              Effect.provideService(Alchemy.RuntimeContext, alchemyRuntimeContext),            ),        }),      ),    ),  );