Function claimMessageRead

packages/infra/src/ClusterCosmos.ts:416–428

(doc: MessageDoc, now: number)

      )

  const claimMessageRead = (doc: MessageDoc, now: number) =>
    Effect
      .tryPromise(() =>
        container.item(doc.id, doc._partitionKey).patch<MessageDoc>(
          [{ op: "set", path: "/lastRead", value: now }],
          { accessCondition: { type: "IfMatch", condition: doc._etag ?? "" } }
        )
      )
      .pipe(
        Effect.tap(annotateItem),
        Effect.as(true),
        Effect.catchIf(isPreconditionFailed, () => Effect.succeed(false))
      )

  const batchDocs = <A extends { readonly id: string; readonly _partitionKey: string }>(
    docs: ReadonlyArray<A>,