Function queryMessages

packages/infra/src/ClusterCosmos.ts:378–384

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

    )

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

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