Function make

packages/ai/amazon-bedrock/src/AmazonBedrockClient.ts:63–196

(options: {
  readonly apiUrl?: string | undefined
  readonly accessKeyId: string
  readonly secretAccessKey: Redacted.Redacted<string>
  readonly sessionToken?: Redacted.Redacted<string> | undefined
  readonly region?: string | undefined
  readonly transformClient?: (
    client: HttpClient.HttpClient
  ) => HttpClient.HttpClient
})

 * @category Constructors
 */
export const make = (options: {
  readonly apiUrl?: string | undefined
  readonly accessKeyId: string
  readonly secretAccessKey: Redacted.Redacted<string>
  readonly sessionToken?: Redacted.Redacted<string> | undefined
  readonly region?: string | undefined
  readonly transformClient?: (
    client: HttpClient.HttpClient
  ) => HttpClient.HttpClient
}) =>
  Effect.gen(function*() {
    const region = options.region ?? "us-east-1"

    const redactedHeaders = ["X-Amz-Security-Token"]

    yield* Effect.locallyScopedWith(Headers.currentRedactedNames, Arr.appendAll(redactedHeaders))

    const httpClient = (yield* HttpClient.HttpClient).pipe(
      HttpClient.mapRequest((request) =>
        request.pipe(
          HttpClientRequest.prependUrl(options.apiUrl ?? `https://bedrock-runtime.${region}.amazonaws.com`),
          HttpClientRequest.acceptJson
        )
      ),
      HttpClient.mapRequestEffect(Effect.fnUntraced(function*(request) {
        const originalHeaders = request.headers
        const signer = new AwsV4Signer({
          service: "bedrock",
          url: request.url,
          method: request.method,
          headers: Object.entries(originalHeaders),
          body: prepareBody(request.body),
          region,
          accessKeyId: options.accessKeyId,
          secretAccessKey: Redacted.value(options.secretAccessKey),
          ...(options.sessionToken ? { sessionToken: Redacted.value(options.sessionToken) } : {})
        })
        const { headers: signedHeaders } = yield* Effect.promise(() => signer.sign())
        const headers = Headers.merge(originalHeaders, Headers.fromInput(signedHeaders))
        return HttpClientRequest.setHeaders(request, headers)
      })),
      options.transformClient ? options.transformClient : identity
    )

    const httpClientOk = HttpClient.filterStatusOk(httpClient)

    const client = makeClient(httpClient, {
      transformClient: (client) =>
        AmazonBedrockConfig.getOrUndefined.pipe(
          Effect.map((config) => config?.transformClient ? config.transformClient(client) : client)
        )
    })

    const converse: (options: {
      readonly params?: { "anthropic-beta"?: string | undefined } | undefined
      readonly payload: typeof ConverseRequest.Encoded
    }) => Effect.Effect<ConverseResponse, AiError.AiError> = Effect.fnUntraced(
      function*(request) {