packages/ai/src/media-model.ts

Rama dev · réplica de lectura del repositorio original.

import { Effect } from "effect"
import { Endpoint } from "./route/endpoint.js"
import { MediaRoute } from "./route/media.js"
import type { MediaProtocol } from "./route/media-protocol.js"
import {
  AIError,
  InvalidRequestError,
  ModelID,
  ProviderID,
  type HttpOptions,
  type ProviderOptions,
} from "./schema/index.js"

/**
 * What every media model carries: ids, the configured route, and deployment `http` overlays. Modality classes
 * (`ImageModel`, `VideoModel`, `SpeechModel`, `TranscriptionModel`) extend it with their route type and a nominal
 * marker so one cannot stand in for the other in requests.
 */
export class MediaModel<Route, Options> {
  // As with `LanguageModel`, the route type is erased over `Options`; `fromRoute` and the constructor trust that the
  // route accepts every request this model's `Options` admit.
  declare protected readonly _Options: Options
  readonly id: ModelID
  readonly provider: ProviderID
  readonly route: Route
  readonly http?: HttpOptions
  /** Defaults under each request's `providerOptions`, such as options a provider package reads from its settings. */
  readonly providerOptions?: ProviderOptions

  constructor(input: MediaModel.Input<Route>) {
    this.id = ModelID.make(input.id)
    this.provider = ProviderID.make(input.provider)
    this.route = input.route
    this.http = input.http
    this.providerOptions = input.providerOptions
  }
}

export namespace MediaModel {
  export type Options = ProviderOptions

  export interface Input<Route> {
    readonly id: string | ModelID
    readonly provider: string | ProviderID
    readonly route: Route
    readonly http?: HttpOptions
    readonly providerOptions?: ProviderOptions
  }

  /** A protocol plus its canonical start path; `ModelInput.baseURL` overrides `baseURL` per deployment. */
  export interface RouteInput<Request extends MediaRoute.MediaRequest, Protocol> {
    readonly protocol: Protocol
    readonly path: Endpoint.EndpointPart<MediaProtocol.Body, Request>
    readonly baseURL?: string
    /** Headers the protocol requires on every call, such as a pinned API version; deployment headers win. */
    readonly headers?: Record<string, string>
  }

  export type InlineRouteInput<Request extends MediaRoute.MediaRequest, Response> = RouteInput<
    Request,
    MediaProtocol.Inline<Request, Response>
  >

  export type StreamRouteInput<Request extends MediaRoute.MediaRequest, Event, Frame, State> = RouteInput<
    MediaProtocol.Addressed<Request>,
    MediaProtocol.Streamed<Request, Event, Frame, State>
  >

  export type QueuedRouteInput<Request extends MediaRoute.MediaRequest, Response, Token> = RouteInput<
    Request,
    MediaProtocol.Queued<Request, Response, Token>
  >

  export type AnyRouteInput<Request extends MediaRoute.MediaRequest, Event, Response, Frame, State, Token> =
    | InlineRouteInput<Request, Response>
    | StreamRouteInput<Request, Event, Frame, State>
    | QueuedRouteInput<Request, Response, Token>
}

/** Compose a protocol route input with one deployment through `MediaRoute.inline`, `queued`, or `stream`. */
export const composeRoute = <Request extends MediaRoute.MediaRequest, Event, Response, Frame, State, Token>(
  route: MediaModel.AnyRouteInput<Request, Event, Response, Frame, State, Token>,
  input: MediaRoute.ModelInput,
  collect: (events: ReadonlyArray<Event>) => Effect.Effect<Response, AIError>,
): MediaRoute.AnyRoute<Request, Event, Response> => {
  if (isStreamInput(route)) return MediaRoute.stream({ ...composition(route, input), collect })
  if (isQueuedInput(route)) return MediaRoute.queued(composition(route, input))
  return MediaRoute.inline(composition(route, input))
}

const composition = <Request extends MediaRoute.MediaRequest, Protocol>(
  route: MediaModel.RouteInput<Request, Protocol>,
  input: MediaRoute.ModelInput,
): MediaRoute.Composition<Request> & { readonly protocol: Protocol } => ({
  protocol: route.protocol,
  endpoint: Endpoint.path(route.path, { baseURL: input.baseURL ?? route.baseURL }),
  auth: input.auth,
  headers:
    route.headers === undefined && input.headers === undefined ? undefined : { ...route.headers, ...input.headers },
})

const isStreamInput = <Request extends MediaRoute.MediaRequest, Event, Response, Frame, State, Token>(
  route: MediaModel.AnyRouteInput<Request, Event, Response, Frame, State, Token>,
): route is MediaModel.StreamRouteInput<Request, Event, Frame, State> => route.protocol.kind === "stream"

const isQueuedInput = <Request extends MediaRoute.MediaRequest, Event, Response, Frame, State, Token>(
  route: MediaModel.AnyRouteInput<Request, Event, Response, Frame, State, Token>,
): route is MediaModel.QueuedRouteInput<Request, Response, Token> => route.protocol.kind === "queued"

/** Lift a synchronous Schema-class constructor into a typed `InvalidRequest` failure. */
export const tryRequest = <A>(make: () => A): Effect.Effect<A, AIError> =>
  Effect.try({
    try: make,
    catch: (error) =>
      error instanceof AIError
        ? error
        : new AIError({
            reason: new InvalidRequestError({
              message: error instanceof Error ? error.message : String(error),
              cause: error,
            }),
          }),
  })