"use strict";Object.defineProperty(exports, "__esModule", { value: true });exports.registerBuiltInApiProviders = registerBuiltInApiProviders;exports.resetApiProviders = resetApiProviders;exports.setBedrockProviderModule = setBedrockProviderModule;var _apiRegistry = require("../api-registry.js");
var _eventStream = require("../utils/event-stream.js");
var _anthropic = require("./anthropic.js");
var _azureOpenaiResponses = require("./azure-openai-responses.js");
var _google = require("./google.js");
var _googleGeminiCli = require("./google-gemini-cli.js");
var _googleVertex = require("./google-vertex.js");
var _mistral = require("./mistral.js");
var _openaiCodexResponses = require("./openai-codex-responses.js");
var _openaiCompletions = require("./openai-completions.js");
var _openaiResponses = require("./openai-responses.js");function _interopRequireWildcard(e, t) {if ("function" == typeof WeakMap) var r = new WeakMap(),n = new WeakMap();return (_interopRequireWildcard = function (e, t) {if (!t && e && e.__esModule) return e;var o,i,f = { __proto__: null, default: e };if (null === e || "object" != typeof e && "function" != typeof e) return f;if (o = t ? n : r) {if (o.has(e)) return o.get(e);o.set(e, f);}for (const t in e) "default" !== t && {}.hasOwnProperty.call(e, t) && ((i = (o = Object.defineProperty) && Object.getOwnPropertyDescriptor(e, t)) && (i.get || i.set) ? o(f, t, i) : f[t] = e[t]);return f;})(e, t);}
const dynamicImport = (specifier) => ((specifier) => new Promise((r) => r(`${specifier}`)).then((s) => jitiImport(s).then((m) => _interopRequireWildcard(m))))(specifier);
const BEDROCK_PROVIDER_SPECIFIER = "./amazon-" + "bedrock.js";
let bedrockProviderModuleOverride;
function setBedrockProviderModule(module) {
  bedrockProviderModuleOverride = module;
}
async function loadBedrockProviderModule() {
  if (bedrockProviderModuleOverride) {
    return bedrockProviderModuleOverride;
  }
  const module = await dynamicImport(BEDROCK_PROVIDER_SPECIFIER);
  return module;
}
function forwardStream(target, source) {
  (async () => {
    for await (const event of source) {
      target.push(event);
    }
    target.end();
  })();
}
function createLazyLoadErrorMessage(model, error) {
  return {
    role: "assistant",
    content: [],
    api: "bedrock-converse-stream",
    provider: model.provider,
    model: model.id,
    usage: {
      input: 0,
      output: 0,
      cacheRead: 0,
      cacheWrite: 0,
      totalTokens: 0,
      cost: { input: 0, output: 0, cacheRead: 0, cacheWrite: 0, total: 0 }
    },
    stopReason: "error",
    errorMessage: error instanceof Error ? error.message : String(error),
    timestamp: Date.now()
  };
}
function streamBedrockLazy(model, context, options) {
  const outer = new _eventStream.AssistantMessageEventStream();
  loadBedrockProviderModule().
  then((module) => {
    const inner = module.streamBedrock(model, context, options);
    forwardStream(outer, inner);
  }).
  catch((error) => {
    const message = createLazyLoadErrorMessage(model, error);
    outer.push({ type: "error", reason: "error", error: message });
    outer.end(message);
  });
  return outer;
}
function streamSimpleBedrockLazy(model, context, options) {
  const outer = new _eventStream.AssistantMessageEventStream();
  loadBedrockProviderModule().
  then((module) => {
    const inner = module.streamSimpleBedrock(model, context, options);
    forwardStream(outer, inner);
  }).
  catch((error) => {
    const message = createLazyLoadErrorMessage(model, error);
    outer.push({ type: "error", reason: "error", error: message });
    outer.end(message);
  });
  return outer;
}
function registerBuiltInApiProviders() {
  (0, _apiRegistry.registerApiProvider)({
    api: "anthropic-messages",
    stream: _anthropic.streamAnthropic,
    streamSimple: _anthropic.streamSimpleAnthropic
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "openai-completions",
    stream: _openaiCompletions.streamOpenAICompletions,
    streamSimple: _openaiCompletions.streamSimpleOpenAICompletions
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "mistral-conversations",
    stream: _mistral.streamMistral,
    streamSimple: _mistral.streamSimpleMistral
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "openai-responses",
    stream: _openaiResponses.streamOpenAIResponses,
    streamSimple: _openaiResponses.streamSimpleOpenAIResponses
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "azure-openai-responses",
    stream: _azureOpenaiResponses.streamAzureOpenAIResponses,
    streamSimple: _azureOpenaiResponses.streamSimpleAzureOpenAIResponses
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "openai-codex-responses",
    stream: _openaiCodexResponses.streamOpenAICodexResponses,
    streamSimple: _openaiCodexResponses.streamSimpleOpenAICodexResponses
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "google-generative-ai",
    stream: _google.streamGoogle,
    streamSimple: _google.streamSimpleGoogle
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "google-gemini-cli",
    stream: _googleGeminiCli.streamGoogleGeminiCli,
    streamSimple: _googleGeminiCli.streamSimpleGoogleGeminiCli
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "google-vertex",
    stream: _googleVertex.streamGoogleVertex,
    streamSimple: _googleVertex.streamSimpleGoogleVertex
  });
  (0, _apiRegistry.registerApiProvider)({
    api: "bedrock-converse-stream",
    stream: streamBedrockLazy,
    streamSimple: streamSimpleBedrockLazy
  });
}
function resetApiProviders() {
  (0, _apiRegistry.clearApiProviders)();
  registerBuiltInApiProviders();
}
registerBuiltInApiProviders(); /* v9-9bc7c3b343f5c9b6 */