Function queryReplies

packages/infra/src/ClusterCosmos.ts:386–392

(query: string, parameters: ReadonlyArray<CosmosParameter>)

      )

  const queryReplies = (query: string, parameters: ReadonlyArray<CosmosParameter>) =>
    Effect
      .tryPromise(() => container.items.query<ReplyDoc>({ query, parameters: Array.from(parameters) }).fetchAll())
      .pipe(
        Effect.tap(annotateFeed),
        Effect.map((resp) => resp.resources)
      )

  const lastReply = (replyId: string | null) =>
    replyId === null