Function lastRepliesById

packages/infra/src/ClusterCosmos.ts:781–799

(
  docs: ReadonlyArray<MessageDoc>,
  activeRequestIds: ReadonlySet<string>,
  queryReplies: (
    query: string,
    parameters: ReadonlyArray<CosmosParameter>
  ) => Effect.Effect<Array<ReplyDoc>, E>
)

}

const lastRepliesById = <E>(
  docs: ReadonlyArray<MessageDoc>,
  activeRequestIds: ReadonlySet<string>,
  queryReplies: (
    query: string,
    parameters: ReadonlyArray<CosmosParameter>
  ) => Effect.Effect<Array<ReplyDoc>, E>
) => {
  const replyIds = Array.from(
    new Set(docs
      .flatMap((doc) => activeRequestIds.has(doc.requestId) || doc.lastReplyId === null ? [] : [doc.lastReplyId]))
  )
  if (!Arr.isArrayNonEmpty(replyIds)) return Effect.succeed(new Map<string, Reply.Encoded>())
  return queryReplies(
    "SELECT * FROM c WHERE c.type = 'reply' AND ARRAY_CONTAINS(@replyIds, c.rowid)",
    [{ name: "@replyIds", value: replyIds }]
  )
    .pipe(Effect.map((replies) => new Map(replies.map((reply) => [reply.rowid, replyFromDoc(reply)]))))
}

export const makeRunnerStorage = Effect.fnUntraced(function*(options?: {
  readonly prefix?: string | undefined