Function lastReply

packages/infra/src/ClusterCosmos.ts:394–400

(replyId: string | null)

      )

  const lastReply = (replyId: string | null) =>
    replyId === null
      ? Effect.succeed(Option.none<Reply.Encoded>())
      : queryReplies("SELECT * FROM c WHERE c.type = 'reply' AND c.rowid = @id", [{ name: "@id", value: replyId }])
        .pipe(
          Effect.map((docs) => Option.map(Option.fromNullishOr(docs[0]), replyFromDoc))
        )

  const markReplyAcked = (requestId: string, replyId: string) =>
    Effect