Function readMessage

packages/infra/src/ClusterCosmos.ts:371–376

(id: string, partitionKey: string)

    annotateDb({ operation, system: "cosmosdb", collection: containerId, entity: "cluster-message-storage" })

  const readMessage = (id: string, partitionKey: string) =>
    Effect.tryPromise(() => container.item(id, partitionKey).read<MessageDoc>()).pipe(
      Effect.tap(annotateItem),
      Effect.map((resp) => Option.fromNullishOr(resp.resource)),
      Effect.catchIf(isNotFound, () => Effect.succeed(Option.none()))
    )

  const queryMessages = (query: string, parameters: ReadonlyArray<CosmosParameter>) =>
    Effect