import { z } from 'zod';
import * as react_jsx_runtime from 'react/jsx-runtime';
import React, { ReactNode } from 'react';

/**
 * Internal types for the Reactor SDK.
 *
 * All Zod schemas and derived TypeScript types live here.
 * Version constants are sourced from package.json via resolveJsonModule.
 */

declare const TrackCapabilitySchema: z.ZodObject<{
    name: z.ZodString;
    kind: z.ZodEnum<{
        video: "video";
        audio: "audio";
    }>;
    direction: z.ZodEnum<{
        recvonly: "recvonly";
        sendonly: "sendonly";
    }>;
}, z.core.$strip>;
declare const CommandCapabilitySchema: z.ZodObject<{
    name: z.ZodString;
    description: z.ZodString;
    schema: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
}, z.core.$strip>;
declare const CapabilitiesSchema: z.ZodObject<{
    protocol_version: z.ZodString;
    tracks: z.ZodArray<z.ZodObject<{
        name: z.ZodString;
        kind: z.ZodEnum<{
            video: "video";
            audio: "audio";
        }>;
        direction: z.ZodEnum<{
            recvonly: "recvonly";
            sendonly: "sendonly";
        }>;
    }, z.core.$strip>>;
    commands: z.ZodOptional<z.ZodArray<z.ZodObject<{
        name: z.ZodString;
        description: z.ZodString;
        schema: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
    }, z.core.$strip>>>;
    emission_fps: z.ZodOptional<z.ZodNullable<z.ZodNumber>>;
}, z.core.$strip>;
declare const SessionResponseSchema: z.ZodObject<{
    session_id: z.ZodString;
    state: z.ZodString;
    cluster: z.ZodString;
    model: z.ZodObject<{
        name: z.ZodString;
        version: z.ZodOptional<z.ZodString>;
    }, z.core.$strip>;
    server_info: z.ZodObject<{
        server_version: z.ZodString;
    }, z.core.$strip>;
    selected_transport: z.ZodOptional<z.ZodObject<{
        protocol: z.ZodString;
        version: z.ZodString;
    }, z.core.$strip>>;
    capabilities: z.ZodOptional<z.ZodObject<{
        protocol_version: z.ZodString;
        tracks: z.ZodArray<z.ZodObject<{
            name: z.ZodString;
            kind: z.ZodEnum<{
                video: "video";
                audio: "audio";
            }>;
            direction: z.ZodEnum<{
                recvonly: "recvonly";
                sendonly: "sendonly";
            }>;
        }, z.core.$strip>>;
        commands: z.ZodOptional<z.ZodArray<z.ZodObject<{
            name: z.ZodString;
            description: z.ZodString;
            schema: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodAny>>;
        }, z.core.$strip>>>;
        emission_fps: z.ZodOptional<z.ZodNullable<z.ZodNumber>>;
    }, z.core.$strip>>;
}, z.core.$strip>;
type TrackCapability = z.infer<typeof TrackCapabilitySchema>;
type CommandCapability = z.infer<typeof CommandCapabilitySchema>;
type SessionResponse = z.infer<typeof SessionResponseSchema>;
type Capabilities = z.infer<typeof CapabilitiesSchema>;

/**
 * Reference to an uploaded file, returned by {@link Reactor.uploadFile}.
 *
 * Pass a `FileRef` as a value in {@link Reactor.sendCommand} and it will
 * be serialized into the `uploads` section of the wire envelope, separate
 * from scalar arguments. The runtime resolves each reference to bytes
 * before dispatching the event to the model handler.
 */
declare class FileRef {
    readonly uploadId: string;
    readonly name: string;
    readonly mimeType: string;
    readonly size: number;
    constructor(uploadId: string, name: string, mimeType: string, size: number);
}

type ReactorStatus = "disconnected" | "connecting" | "waiting" | "ready";
/**
 * The message scope identifies the envelope layer a data channel message belongs to.
 * - "application": model-defined commands (client->runtime) and model-emitted payloads (runtime->client).
 * - "runtime": platform-level control messages (e.g., capabilities exchange).
 */
type MessageScope = "application" | "runtime";

interface ReactorError {
    code: string;
    message: string;
    timestamp: number;
    recoverable: boolean;
    component: "api" | "gpu";
    retryAfter?: number;
}
declare class ConflictError extends Error {
    constructor(message: string);
}
declare class AbortError extends Error {
    constructor(message: string);
}
/** Matches both our custom AbortError and the native DOMException thrown by fetch(). */
declare function isAbortError(error: unknown): boolean;
interface ReactorState$1 {
    status: ReactorStatus;
    lastError?: ReactorError;
}
/**
 * Options for configuring the connect polling behavior.
 */
interface ConnectOptions {
    /** Maximum number of SDP polling attempts before giving up. Default: 6. */
    maxAttempts?: number;
    /**
     * When true (default), sends `resume_track` for every recvonly track
     * immediately after the connection is established, causing the backend to
     * begin streaming those tracks — this preserves the pre-multi-connection
     * behaviour where output tracks flow automatically on connect. Set to false
     * to keep recvonly tracks paused on connect and resume them individually via
     * `resumeTrack()` (e.g. multi-connection apps that only subscribe to a
     * subset of peers).
     */
    autoResumeTracks?: boolean;
    /**
     * Attach to a session that already exists (e.g. one created by a backend)
     * instead of creating a new one. When set, `connect()` skips `POST /sessions`
     * and brings up the transport directly against this id. The JWT passed to
     * `connect()` must be valid for the account that owns the session.
     */
    sessionId?: string;
    /**
     * Use a specific WebRTC connection id instead of minting one. When omitted
     * (default), the transport registers a fresh connection (`POST .../connections`)
     * and the server mints the id. When set, the transport skips registration and
     * sends its SDP offer directly to that connection — so the id must already have
     * been registered under this session (e.g. a backend called `POST .../connections`
     * and handed the id to this client) and must still be open.
     *
     * `connect()` rejects if the id is invalid (out of the server's accepted range)
     * or if no open connection with that id exists for the session.
     */
    connectionId?: number;
}
/**
 * Transport-agnostic timing breakdown of the connect() handshake, recorded
 * once per connection and included in every subsequent {@link ConnectionStats}
 * update. All durations are in milliseconds (from `performance.now()`).
 *
 * For transport-specific timings (e.g. ICE negotiation, data channel open),
 * see the relevant transport stats type (e.g. {@link WebRTCTransportTimings}).
 */
interface ConnectionTimings {
    /** POST /sessions round-trip time */
    sessionCreationMs: number;
    /** Total time spent in transport.connect() (signaling, negotiation, etc.) */
    transportConnectingMs: number;
    /** End-to-end: connect() invocation → status "ready" */
    totalMs: number;
}
interface ConnectionStats {
    /** ICE candidate-pair round-trip time in milliseconds */
    rtt?: number;
    /** ICE candidate type: "host", "srflx", "prflx", or "relay" (TURN) */
    candidateType?: string;
    /** Estimated available incoming bitrate in bits/second */
    availableIncomingBitrate?: number;
    /** Estimated available outgoing bitrate in bits/second */
    availableOutgoingBitrate?: number;
    /** Real-time Incoming bitrate in bits/second */
    incomingBitrate?: number;
    /** Real-time Outgoing bitrate in bits/second */
    outgoingBitrate?: number;
    /** Received video frames per second */
    framesPerSecond?: number;
    /** Ratio of packets lost (0-1) */
    packetLossRatio?: number;
    /** Network jitter in seconds (from inbound-rtp) */
    jitter?: number;
    /** Timing breakdown of the initial connection handshake (set once, persisted until disconnect) */
    connectionTimings?: ConnectionTimings;
    timestamp: number;
}
type ReactorEvent = "statusChanged" | "sessionIdChanged" | "message" | "runtimeMessage" | "trackReceived" | "error" | "sessionExpirationChanged" | "capabilitiesReceived" | "statsUpdate";
/**
 * Severity tier of a content moderation event delivered as the inner
 * payload of a `runtimeMessage` with `type === "moderation"`.
 *
 * - `"warn"`: the input scored above the warn threshold but below the
 *   terminate threshold. The session continues; this is informational
 *   only.
 * - `"terminate"`: the input crossed the terminate threshold. The
 *   session will be ended shortly after this message is dispatched.
 */
type ModerationAction = "warn" | "terminate";
/**
 * Inner payload of a `runtimeMessage` with `type === "moderation"`.
 *
 * Surfaces a content-moderation outcome to the client app. Fires on
 * any moderatable input (free-text fields, file uploads) that the
 * configured moderation policy flags. Apps receive it by subscribing
 * to the existing `runtimeMessage` event and filtering on `type`:
 *
 *     reactor.on("runtimeMessage", (m) => {
 *       if (m?.type === "moderation") {
 *         const payload = m.data as ModerationEvent;
 *         // ...render banner, log, etc.
 *       }
 *     });
 */
interface ModerationEvent {
    /** Severity tier — `"warn"` continues the session, `"terminate"` ends it. */
    action: ModerationAction;
    /**
     * Modality of the flagged input. `"text"` for string fields,
     * `"image"` for `UploadedFile` payloads with an image MIME type.
     */
    input_kind: "text" | "image";
    /**
     * Name of the inbound command/event whose payload was flagged
     * (e.g. `"set_prompt"`, `"set_image"`, `"fileUploaded"`).
     */
    command: string;
    /** Category labels that flagged (e.g. `["sexual"]`, `["violence/graphic"]`). */
    categories: string[];
    /** Short human-readable summary suitable for UI rendering. */
    message: string;
}

/**
 * Lazy resolver for the Coordinator bearer token. The SDK calls this
 * immediately before each authenticated HTTP request, so short-lived
 * tokens (Clerk session JWTs, etc.) are refreshed transparently.
 * Returning `""` suppresses the `Authorization` header entirely.
 */
type JwtResolver = () => string | Promise<string>;
/** Static token, or a {@link JwtResolver} invoked per request. */
type JwtSource = string | JwtResolver;
/** Wrap a {@link JwtSource} into a {@link JwtResolver}. */
declare function normalizeJwtSource(source: JwtSource): JwtResolver;

/**
 * Stateless primitives for the Reactor recording feature.
 *
 * This module owns:
 * - Public-facing {@link Clip} type, {@link RecordingError} class, and
 *   the `RuntimeRecordingMessageType` enum.
 * - Wire schemas (`ClipReadyPayloadSchema`, `ClipFailedPayloadSchema`)
 *   plus `clipFromPayload` to convert snake_case wire payloads into
 *   camelCase `Clip` objects.
 * - HTTP helpers `fetchPlaylist` (deadline-driven polling) and
 *   `parsePlaylist` (HLS `.m3u8` parser).
 * - The `downloadClipAsFile` helper that streams the referenced
 *   fMP4 chunks, remuxes them into a flat social-media-ready MP4
 *   via `mp4box` (PTS=0, faststart, `major_brand=isom`), and
 *   returns a Blob for browser download.
 *
 * Stateful pieces (FIFO promise correlator, in-flight request
 * lifecycle, integration with Reactor's event bus) live in the
 * `RecordingClient` class in `core/RecordingClient.ts`.
 *
 * Wire contract is documented end-to-end in the *Video Recording
 * Feature* Notion page; the runtime side ships in
 * `reactor_runtime/recording/`.
 */

/**
 * Names of the runtime-scoped messages used by the recording feature.
 * Outbound names are sent via `Reactor.sendCommand(name, …, "runtime")`;
 * inbound names appear as `message.type` on `runtimeMessage` events.
 */
declare const RuntimeRecordingMessageType: {
    readonly REQUEST_CLIP: "requestClip";
    readonly REQUEST_RECORDING: "requestRecording";
    readonly CLIP_READY: "clipReady";
    readonly CLIP_FAILED: "clipFailed";
};
/** Discriminator on a {@link Clip}. `"snap"` from `requestClip`, `"recording"` from `requestRecording`. */
type ClipKind = "snap" | "recording";
/**
 * Resolved outcome of a {@link Reactor.requestClip} / {@link Reactor.requestRecording} call.
 *
 * The runtime returns immediately on every request — it does *not*
 * block until the in-progress chunk has been finalised. The response
 * is a *promise*: `endMarker` reflects wall-clock at request time
 * and may point inside a chunk ffmpeg is still writing. The
 * `/clips` manifest endpoint returns `202 Retry-After` while that
 * chunk is in flight; the SDK polls until `200`.
 *
 * - `startMarker` / `endMarker` / `nowMarker` are session-relative
 *   seconds since recorder start.
 * - `predictedReadyAtMs` is a **Unix epoch in milliseconds** — the
 *   runtime's estimate of when the boundary chunk will be servable
 *   by `/clips`. Compare against `Date.now()` to drive a "ready in
 *   Ns" indicator. The SDK uses this as the polling deadline: past
 *   `predictedReadyAtMs + slackMs` and still 202, the SDK fails with
 *   `CLIP_NOT_READY` on the assumption the runtime crashed.
 * - `playlistUrl` is short-lived in production (the embedded chunk
 *   URLs are presigned for a few minutes). Re-issuing the request
 *   produces a fresh URL with fresh presigning.
 */
interface Clip {
    sessionId: string;
    kind: ClipKind;
    startMarker: number;
    endMarker: number;
    nowMarker: number;
    predictedReadyAtMs: number;
    playlistUrl: string;
}
/**
 * Error thrown when a recording request cannot be served.
 *
 * `code` is a stable, machine-readable identifier; `reason` is the
 * raw string the runtime / manifest endpoint returned (passed through
 * verbatim from `clipFailed.reason`, the `/clips` HTTP body, or the
 * SDK's pre-flight check).
 */
declare class RecordingError extends Error {
    readonly code: "RECORDER_DISABLED" | "INVALID_DURATION" | "REQUEST_TIMEOUT" | "DISCONNECTED" | "CLIP_GONE" | "CLIP_NOT_READY" | "PLAYLIST_FETCH_FAILED" | "CHUNK_FETCH_FAILED" | "INVALID_PLAYLIST" | "DOWNLOAD_UNSUPPORTED" | "INTERNAL_ERROR";
    readonly reason: string;
    constructor(code: "RECORDER_DISABLED" | "INVALID_DURATION" | "REQUEST_TIMEOUT" | "DISCONNECTED" | "CLIP_GONE" | "CLIP_NOT_READY" | "PLAYLIST_FETCH_FAILED" | "CHUNK_FETCH_FAILED" | "INVALID_PLAYLIST" | "DOWNLOAD_UNSUPPORTED" | "INTERNAL_ERROR", reason: string);
}
/** `clipReady.data` payload as serialised by `ClipResult.to_dict()`. */
declare const ClipReadyPayloadSchema: z.ZodObject<{
    session_id: z.ZodString;
    kind: z.ZodEnum<{
        snap: "snap";
        recording: "recording";
    }>;
    start_marker: z.ZodNumber;
    end_marker: z.ZodNumber;
    now_marker: z.ZodNumber;
    predicted_ready_at_ms: z.ZodNumber;
    playlist_url: z.ZodString;
}, z.core.$loose>;
type ClipReadyPayload = z.infer<typeof ClipReadyPayloadSchema>;
/** `clipFailed.data` payload — short reason string from the runtime. */
declare const ClipFailedPayloadSchema: z.ZodObject<{
    reason: z.ZodDefault<z.ZodString>;
}, z.core.$loose>;
type ClipFailedPayload = z.infer<typeof ClipFailedPayloadSchema>;
/** Options for {@link clipFromPayload}. */
interface ParseClipOptions {
    /**
     * Coordinator base URL.  When set, resolves `payload.playlist_url`
     * against this base — used to convert the runtime's path-only
     * playlist URL (``/clips?session_id=…``) into an absolute URL the
     * browser/SDK can fetch.  Also handles the legacy case where an
     * older runtime emits an absolute URL bound to its own
     * ``0.0.0.0`` listener: the host/port are rewritten onto the
     * coordinator.
     */
    coordinatorBaseUrl?: string;
}
/**
 * Convert a validated {@link ClipReadyPayload} into the public {@link Clip}.
 * Pure: no IO, no side effects.
 */
declare function clipFromPayload(payload: ClipReadyPayload, options?: ParseClipOptions): Clip;
/**
 * Resolve `target` against `base`, returning an absolute URL.
 *
 * Two cases:
 *
 * * **Path-only / relative target** (no scheme — e.g. the
 *   runtime's current ``/clips?session_id=…`` shape): joined
 *   against ``base`` via ``new URL(target, base)``, preserving
 *   path, query, and fragment.
 * * **Absolute target** (``http://…`` / ``https://…``, e.g. a legacy
 *   runtime emitting a URL bound to its own ``0.0.0.0`` listener):
 *   scheme, hostname, and port are replaced with ``base``'s,
 *   preserving path, query, and fragment.
 *
 * Returns the original ``target`` on any parse failure rather than
 * throwing — the SDK consumes the URL eagerly and shouldn't break
 * a session over a malformed clip envelope.
 */
declare function rewriteUrlHost(target: string, base: string): string;
/** Internal — segments referenced by an HLS manifest, in playback order. */
interface ParsedPlaylist {
    initUrl: string;
    segmentUrls: string[];
}
/**
 * Default grace period after `predictedReadyAtMs` before
 * {@link fetchPlaylist} gives up.  Applied from
 * `max(predictedReadyAtMs, pollStart)` so late clicks still get the
 * full window.
 */
declare const DEFAULT_PLAYLIST_POLL_SLACK_MS = 15000;
interface FetchPlaylistOptions {
    /**
     * Unix epoch (ms) when the runtime predicts the boundary chunk will
     * be servable. Pass `clip.predictedReadyAtMs` here. When set, polling
     * continues until `predictedReadyAtMs + slackMs`; once past, a
     * stuck `202` produces `CLIP_NOT_READY` (assume runtime crashed).
     */
    predictedReadyAtMs?: number;
    /** Grace period after `predictedReadyAtMs`. Default {@link DEFAULT_PLAYLIST_POLL_SLACK_MS}. */
    slackMs?: number;
    /**
     * Hard cap on the per-poll wait. The server's `Retry-After` header is
     * honored but clamped. Default 2000 ms keeps pending UI snappy.
     */
    maxRetryDelayMs?: number;
    /** Floor on the per-poll wait so we don't hot-loop on cheap networks. Default 200 ms. */
    minRetryDelayMs?: number;
    /**
     * Fallback retry count used when `predictedReadyAtMs` is omitted
     * (e.g. someone calls `fetchPlaylist` directly with a saved URL,
     * outside of a fresh `Clip`). Default 5.
     */
    maxRetries?: number;
    /** Aborts in-flight fetches and the inter-poll sleep. */
    signal?: AbortSignal;
    /**
     * Coordinator JWT.  When set, attached as `Authorization: Bearer
     * <jwt>` on the manifest GET — the Coordinator hop.  In local mode
     * (HttpRuntime), leave undefined.
     */
    jwt?: string;
}
/**
 * Fetch the playlist URL, polling on `202 Accepted` (which the manifest
 * endpoint returns while the boundary chunk is still uploading).
 *
 * Polling deadline is driven by `predictedReadyAtMs + slackMs` when a
 * `Clip` was just minted by the runtime; without that field the
 * function falls back to `maxRetries` attempts. Either way:
 * - `200` → returns the manifest body.
 * - `410` / `404` → throws `CLIP_GONE`.
 * - `5xx`/other → throws `PLAYLIST_FETCH_FAILED` (no retry).
 * - Past the deadline / retries with stuck `202` → throws
 *   `CLIP_NOT_READY` (the runtime probably crashed mid-chunk).
 */
declare function fetchPlaylist(playlistUrl: string, options?: FetchPlaylistOptions): Promise<string>;
/**
 * Parse an HLS `.m3u8` body into the init segment URL plus the ordered
 * list of media segment URLs. Resolves relative URLs against the
 * playlist URL itself.
 */
declare function parsePlaylist(manifestBody: string, playlistUrl: string): ParsedPlaylist;
/**
 * Wrap an HLS manifest body in a `blob:` URL suitable for `<video src>`
 * or `hls.js`.  Bypasses the "player can't set Authorization headers"
 * problem: the manifest body is served from browser memory, and the
 * chunk URLs inside are already-signed S3 GETs.
 *
 * Path-only / relative chunk URLs in the body are absolutized against
 * ``playlistUrl`` first.  Without this rewrite the browser would
 * resolve them against the ``blob:`` URL's effective base — the page's
 * origin — and a local-dev frontend on (e.g.) port 3000 would issue
 * chunk fetches against its own dev server instead of the
 * HttpRuntime's ``/clips/chunks/...`` endpoint on port 8080.  In
 * production / kind-cluster mode the manifest already carries absolute
 * presigned S3 URLs and `resolveAgainst` is a no-op on them.
 *
 * Caller owns the returned URL — revoke it via `URL.revokeObjectURL`
 * when playback tears down.  Browser-only; throws `INVALID_PLAYLIST`
 * outside a DOM environment.
 */
declare function createPlayableManifestUrl(manifestBody: string, playlistUrl: string): string;
interface DownloadClipOptions {
    /**
     * Coordinator JWT.  Attached on the manifest GET only; the chunks
     * referenced inside the manifest are S3 presigned URLs and are
     * fetched unauthenticated.
     */
    jwt?: string;
    /** Forwarded to every request. Cancels both the playlist poll and any in-flight chunk fetches. */
    signal?: AbortSignal;
    /** Called after each chunk completes — useful for progress UI. */
    onProgress?: (info: {
        fetched: number;
        total: number;
        bytes: number;
    }) => void;
}
/**
 * Stream the chunks referenced by `clip.playlistUrl`, remux the
 * assembled bytes into a flat social-media-ready MP4, and (when
 * `filename` is non-null) trigger a browser-native `<a download>`.
 * Pass `filename: null` to skip the download trigger and just
 * receive the Blob.
 *
 * The remux step rewrites the container only — H.264 NAL units and
 * AAC packets pass through unchanged — so `start_time=0`,
 * `+faststart`, and `major_brand=isom` come for free without any
 * re-encode cost.  See {@link maybeRemux} for the fallback
 * semantics on the rare parse failure.
 */
declare function downloadClipAsFile(clip: Clip, filename?: string | null, options?: DownloadClipOptions): Promise<Blob>;

/**
 * Per-Reactor recording client.  Owns the FIFO promise correlator for
 * inbound `clipReady` / `clipFailed` runtime messages and the
 * lifecycle hooks (subscribe on construct, reject pending requests
 * on disconnect).  Reactor exposes thin delegations for the common
 * case; this class is exported for advanced consumers and isolated
 * testing.
 */

/** Default per-request timeout for `clipReady` / `clipFailed`. */
declare const DEFAULT_CLIP_REQUEST_TIMEOUT_MS = 10000;
/** Slim adapter the {@link RecordingClient} requires from its host. */
interface RecordingClientHost {
    /**
     * Subscribe to runtime-scoped messages on the data channel.
     * Returns an unsubscribe function. Mirrors the
     * `reactor.on("runtimeMessage", …)` pattern.
     */
    onRuntimeMessage: (handler: (message: unknown) => void) => () => void;
    /**
     * Subscribe to status changes (so the client can reject pending
     * requests on disconnect). Returns an unsubscribe function.
     */
    onStatusChanged: (handler: (status: ReactorStatus) => void) => () => void;
    /**
     * Send a runtime-scoped command on the data channel. The
     * `RecordingClient` uses this to fire `requestClip` /
     * `requestRecording`.
     */
    sendRuntimeCommand: (command: string, data: Record<string, unknown>) => Promise<void>;
    /** Current connection status — guards `requestClip` before it goes on the wire. */
    getStatus: () => ReactorStatus;
    /**
     * Coordinator base URL used to resolve `clip.playlistUrl` against.
     *
     * The runtime now emits a path-only ``playlist_url`` (e.g.
     * ``/clips?session_id=…``) so the SDK is the absolute-origin owner
     * for both local-dev (HttpRuntime on the SDK's ``apiUrl``) and
     * production (Coordinator on the SDK's ``apiUrl``).  We always
     * resolve against the ``Reactor``'s coordinator URL — there is no
     * remote-vs-local divergence on the read path.
     *
     * For backwards-compat with older runtimes that emitted absolute
     * URLs (scheme + host bound to the runtime's own listener,
     * e.g. ``http://0.0.0.0:8080/clips?…``), the same URL is also used
     * to rewrite the host onto the coordinator — see
     * ``rewriteUrlHost`` in ``utils/recording.ts``.
     */
    getCoordinatorBaseUrl: () => string | undefined;
}
declare class RecordingClient {
    private readonly host;
    private pendingClipRequests;
    /** Timeout applied per request; configurable for tests. */
    private readonly requestTimeoutMs;
    /** Cleanup handles for the host event subscriptions. */
    private readonly unsubscribers;
    constructor(host: RecordingClientHost, options?: {
        requestTimeoutMs?: number;
    });
    /**
     * Request a clip covering the last `durationSeconds` of the live
     * session.  See {@link Reactor.requestClip}.
     */
    requestClip(durationSeconds: number): Promise<Clip>;
    /**
     * Request a clip covering the entire session up to "now".  See
     * {@link Reactor.requestRecording}.
     */
    requestRecording(): Promise<Clip>;
    /**
     * Poll `/clips` and return the raw manifest body.  Same polling
     * semantics as the bare {@link fetchPlaylist} helper; the caller is
     * responsible for supplying the Coordinator JWT via `options.jwt`
     * (origin-scoped to `clip.playlistUrl`).  In local mode against the
     * HttpRuntime, `options.jwt` should be omitted.
     */
    fetchPlaylist(clip: Clip, options?: FetchPlaylistOptions): Promise<string>;
    /**
     * Fetch the manifest and return a `blob:` URL suitable for
     * `<video src>` / `hls.js`.  The player reads the manifest from
     * browser memory; chunk URLs inside are presigned S3 GETs.
     *
     * Caller owns the returned URL — revoke it via `URL.revokeObjectURL`
     * when playback tears down.  Pass `options.jwt` for production
     * `/clips` (the Coordinator hop) — see {@link FetchPlaylistOptions}.
     */
    getPlayableManifestUrl(clip: Clip, options?: FetchPlaylistOptions): Promise<string>;
    /**
     * Thin delegation to {@link downloadClipAsFile}.  Caller must pass
     * `options.jwt` in production — see {@link DownloadClipOptions}.
     */
    downloadClipAsFile(clip: Clip, filename?: string | null, options?: DownloadClipOptions): Promise<Blob>;
    /**
     * Drop every pending request and unsubscribe from host events.
     * Safe to call multiple times; further `requestClip` /
     * `requestRecording` calls after `destroy()` will hang waiting for
     * a response that will never arrive — host should not call into
     * the client after destroy.
     */
    destroy(): void;
    /**
     * Register a pending FIFO entry, send the runtime message via
     * the host, and resolve when the next `clipReady` / `clipFailed`
     * arrives.
     */
    private dispatchClipRequest;
    /**
     * Match inbound `clipReady` / `clipFailed` to the next pending
     * request FIFO; ignore every other runtime message type.
     */
    private onRuntimeMessage;
    private onStatusChanged;
    /** Reject every in-flight request with a typed disconnect error. */
    private rejectPending;
}

declare const DEFAULT_BASE_URL = "https://api.reactor.inc";
declare const OptionsSchema: z.ZodObject<{
    apiUrl: z.ZodDefault<z.ZodString>;
    modelName: z.ZodString;
    local: z.ZodDefault<z.ZodBoolean>;
    modelTracks: z.ZodOptional<z.ZodArray<z.ZodObject<{
        name: z.ZodString;
        kind: z.ZodEnum<{
            video: "video";
            audio: "audio";
        }>;
        direction: z.ZodEnum<{
            recvonly: "recvonly";
            sendonly: "sendonly";
        }>;
    }, z.core.$strip>>>;
}, z.core.$strip>;
type Options = z.input<typeof OptionsSchema>;

type EventHandler = (...args: any[]) => void;
declare class Reactor {
    private coordinatorClient;
    private transportClient;
    private status;
    private coordinatorUrl;
    private lastError?;
    private model;
    private sessionExpiration?;
    private local;
    private sessionId?;
    /**
     * True only when the active session was created by THIS connect flow
     * (via `createSession()`). False when the session was adopted via
     * `connect({ sessionId })`. We must never DELETE a session we did not
     * create — another client (or the backend that created it) owns its
     * lifecycle, so on disconnect/teardown/error an adopting client tears
     * down its own transport but leaves the session alive.
     */
    private createdSession;
    private connectStartTime?;
    private connectionTimings?;
    private capabilities?;
    private tracks;
    private presetTracks?;
    private autoResumeTracks;
    private sessionResponse?;
    private jwtResolver?;
    /** Per-Reactor recording client. See {@link RecordingClient}. */
    readonly recording: RecordingClient;
    constructor(options: Options);
    private eventListeners;
    /**
     * Returns the JWT resolver supplied to the most recent
     * {@link connect} call, or `undefined` if none was set (pre-connect
     * or local mode). Used by clip surfaces as a fallback when their
     * own `getJwt` prop is omitted.
     */
    getJwtResolver(): JwtResolver | undefined;
    on(event: ReactorEvent, handler: EventHandler): void;
    off(event: ReactorEvent, handler: EventHandler): void;
    emit(event: ReactorEvent, ...args: any[]): void;
    /**
     * Sends a command to the model via the data channel.
     *
     * When any value in `data` is a {@link FileRef}, it is automatically
     * extracted and serialized into a separate `uploads` section on the
     * wire, keyed by the parameter name.  Scalar values remain in `data`.
     */
    sendCommand(command: string, data: any, scope?: MessageScope): Promise<void>;
    /**
     * Uploads a file to the session's object store and returns a {@link FileRef}.
     *
     * Flow:
     *  1. POST /sessions/{id}/uploads → allocate presigned PUT URL
     *  2. PUT file bytes to the presigned URL
     *  3. Send `fileUploaded` notification on the runtime data channel
     *     (fires `@file_uploaded` on the model if registered)
     *  4. Return a `FileRef` to pass into {@link sendCommand}
     *
     * In local mode, the presigned URL returned by the runtime is rewritten
     * to use the SDK-configured base URL (scheme + host), so port-forwarded
     * setups work correctly (REA-1573).
     */
    uploadFile(file: File | Blob, options?: {
        name?: string;
    }): Promise<FileRef>;
    /**
     * Request a clip covering the last `durationSeconds` of the live
     * session. Capped server-side at `recording.clip_max_seconds`
     * (default 5 minutes). Resolves with a {@link Clip} whose
     * `playlistUrl` can be handed to any HLS-capable player.
     *
     * @throws {RecordingError} on invalid input, transport failure,
     *   timeout, runtime-side `clipFailed`, or disconnect mid-request.
     */
    requestClip(durationSeconds: number): Promise<Clip>;
    /**
     * Request a clip covering the entire session up to "now". Same
     * mechanics as {@link requestClip} with `start = 0`; only the
     * resolved {@link Clip.kind} discriminator differs.
     */
    requestRecording(): Promise<Clip>;
    /**
     * Stream the chunks referenced by `clip.playlistUrl` and trigger a
     * native browser download of the assembled fragmented-MP4 Blob.
     * Pass `filename: null` to skip the download trigger and receive
     * the Blob (useful for non-DOM consumers and tests).
     */
    downloadClipAsFile(clip: Clip, filename?: string | null, options?: DownloadClipOptions): Promise<Blob>;
    /**
     * Publishes a MediaStreamTrack to a named sendonly track.
     * The transceiver is already set up from capabilities — this just
     * calls replaceTrack() on the sender.
     */
    publishTrack(name: string, track: MediaStreamTrack): Promise<void>;
    unpublishTrack(name: string): Promise<void>;
    pauseTrack(name: string): void;
    resumeTrack(name: string): void;
    /**
     * Reconnects to an existing session with a fresh transport.
     */
    reconnect(options?: ConnectOptions): Promise<void>;
    /**
     * Connects to the coordinator, creates a session, then establishes
     * the transport using server-declared capabilities. `jwtToken` may
     * be a static string or a {@link JwtSource} resolver; pass a
     * resolver when the token is short-lived so each Coordinator HTTP
     * hop sees a fresh value.
     *
     * Pass `options.sessionId` to attach to a session that already exists
     * (e.g. one created by a backend) instead of creating a new one — session
     * creation is skipped and the transport is brought up against that id. The
     * `jwtToken` must be valid for the account that owns the session. Works in
     * local mode too (it looks the session up by id rather than starting one).
     */
    connect(jwtToken?: JwtSource, options?: ConnectOptions): Promise<void>;
    /**
     * Sets up event handlers for the transport client.
     * Each handler captures the client reference to ignore stale events.
     */
    private setupTransportHandlers;
    /**
     * Disconnects from both the transport and the coordinator.
     */
    disconnect(recoverable?: boolean): Promise<void>;
    getSessionId(): string | undefined;
    getStatus(): ReactorStatus;
    getState(): ReactorState$1;
    getLastError(): ReactorError | undefined;
    getCapabilities(): Capabilities | undefined;
    getSessionInfo(): SessionResponse | undefined;
    getStats(): ConnectionStats | undefined;
    private setSessionId;
    private setStatus;
    private setSessionExpiration;
    private resetConnectionTimings;
    private finalizeConnectionTimings;
    private createError;
}

interface ReactorState {
    status: ReactorStatus;
    /**
     * Media tracks received from the model, keyed by track name.
     *
     * Each entry maps a recvonly track name (e.g. `"main_video"`,
     * `"main_audio"`) to the live `MediaStreamTrack` delivered by the model.
     */
    tracks: Record<string, MediaStreamTrack>;
    lastError?: ReactorError;
    sessionId?: string;
    sessionExpiration?: number;
    /** Token source for Coordinator HTTP calls — see {@link JwtSource}. */
    jwtToken?: JwtSource;
    /**
     * Default connect options set by the provider. Applied as base values
     * whenever `connect()` is called without explicit options, so that
     * provider-level settings like `autoResumeTracks` are honoured for
     * both autoConnect and manual connect calls.
     */
    connectOptions?: ConnectOptions;
}
interface ReactorActions {
    sendCommand(command: string, data: any, scope?: MessageScope): Promise<void>;
    /**
     * Connect the underlying {@link Reactor}. `options` is forwarded verbatim —
     * pass `options.sessionId` to attach to an existing session instead of
     * creating one (see {@link ConnectOptions}).
     */
    connect(jwtToken?: JwtSource, options?: ConnectOptions): Promise<void>;
    disconnect(recoverable?: boolean): Promise<void>;
    publish(name: string, track: MediaStreamTrack): Promise<void>;
    unpublish(name: string): Promise<void>;
    reconnect(options?: ConnectOptions): Promise<void>;
    uploadFile(file: File | Blob, options?: {
        name?: string;
    }): Promise<FileRef>;
    /**
     * Capture the trailing `durationSeconds` of the live session as a
     * clip.  Top-level alias for `internal.reactor.requestClip(…)` —
     * lifted onto the store so consumers don't have to reach through
     * `internal.reactor` for the common case.  See
     * {@link Reactor.requestClip}.
     */
    requestClip(durationSeconds: number): Promise<Clip>;
    /**
     * Capture the entire session up to "now" as a clip.  Top-level
     * alias for `internal.reactor.requestRecording()`.  See
     * {@link Reactor.requestRecording}.
     */
    requestRecording(): Promise<Clip>;
    /**
     * Stream the chunks referenced by `clip.playlistUrl` and trigger a
     * native browser download of the assembled MP4.  Top-level alias
     * for `internal.reactor.downloadClipAsFile(…)`.  See
     * {@link Reactor.downloadClipAsFile}.
     */
    downloadClipAsFile(clip: Clip, filename?: string | null, options?: DownloadClipOptions): Promise<Blob>;
}
interface ReactorInternalState {
    reactor: Reactor;
}
type ReactorStore = ReactorState & ReactorActions & {
    internal: ReactorInternalState;
};
interface ReactorInitializationProps extends Options {
    /** Token source for the underlying {@link Reactor} — see {@link JwtSource}. */
    jwtToken?: JwtSource;
    /** Default connect options applied when `connect()` is called without explicit options. */
    connectOptions?: ConnectOptions;
}

/**
 * Options for the React provider's connect behavior.
 * Extends the core ConnectOptions with autoConnect for the React lifecycle.
 */
interface ReactorConnectOptions extends ConnectOptions {
    /** Whether to automatically connect when the provider mounts. Default: false. */
    autoConnect?: boolean;
}
interface ReactorProviderProps extends Omit<ReactorInitializationProps, "jwtToken"> {
    connectOptions?: ReactorConnectOptions;
    /**
     * Static JWT token. Use when you hold a long-lived SDK JWT (e.g.
     * minted via `/tokens`). For short-lived tokens use {@link getJwt}.
     */
    jwtToken?: string;
    /**
     * Lazy JWT resolver invoked immediately before each Coordinator
     * HTTP request. Preferred for short-lived tokens. Wins over
     * {@link jwtToken} when both are provided.
     */
    getJwt?: JwtResolver;
    children?: ReactNode;
}
declare function ReactorProvider({ children, connectOptions, jwtToken, getJwt, ...props }: ReactorProviderProps): react_jsx_runtime.JSX.Element;
declare function useReactorStore<T = ReactorStore>(selector: (state: ReactorStore) => T): T;

interface ReactorViewProps {
    /**
     * The name of the recvonly track to render.
     * Must match a track name declared in the server capabilities.
     * Check the model's documentation for available track names.
     * Defaults to `"main_video"`.
     */
    track?: string;
    /**
     * Optional name of a recvonly audio track to play alongside the video
     * (e.g. `"main_audio"`). The audio is mixed into the same `<video>` element.
     * Check the model's documentation for available track names.
     */
    audioTrack?: string;
    width?: number;
    height?: number;
    className?: string;
    style?: React.CSSProperties;
    videoObjectFit?: NonNullable<React.VideoHTMLAttributes<HTMLVideoElement>["style"]>["objectFit"];
    /**
     * Controls whether inbound audio plays.  Default is `true`
     * (muted) when no `audioTrack` is set — keeps the underlying
     * `<video>` element within browser autoplay policies; `false`
     * when an `audioTrack` is set.  Pass an explicit value to
     * override either default.
     */
    muted?: boolean;
}
declare function ReactorView({ track, audioTrack, width, height, className, style, videoObjectFit, muted, }: ReactorViewProps): react_jsx_runtime.JSX.Element;

interface ReactorControllerProps {
    className?: string;
    style?: React.CSSProperties;
}
declare function ReactorController({ className, style, }: ReactorControllerProps): react_jsx_runtime.JSX.Element;

interface WebcamStreamProps {
    /**
     * The name of the sendonly **video** track to publish the webcam to.
     * Must match a track name declared in the server capabilities.
     * Check the model's documentation for available track names.
     */
    track: string;
    /**
     * Capture and publish the microphone alongside the webcam.  Pass
     * `true` for default constraints, or an explicit
     * `MediaTrackConstraints` to control sample rate / device / echo
     * cancellation.  Requires {@link audioTrack} so the SDK knows
     * which sendonly track to publish the mic to.  Default `false`.
     */
    audio?: boolean | MediaTrackConstraints;
    /**
     * The name of the sendonly **audio** track to publish the mic to.
     * Ignored when {@link audio} is `false` (the default); required
     * otherwise.
     */
    audioTrack?: string;
    className?: string;
    style?: React.CSSProperties;
    videoConstraints?: MediaTrackConstraints;
    showWebcam?: boolean;
    videoObjectFit?: NonNullable<React.VideoHTMLAttributes<HTMLVideoElement>["style"]>["objectFit"];
    /**
     * Fires once `getUserMedia` is rejected with `NotAllowedError`
     * or `PermissionDeniedError`.
     */
    onPermissionDenied?: () => void;
    /**
     * Fires after the local media stream has been published (both
     * video and audio when {@link audio} is enabled).  Re-fires
     * after a reconnect.
     */
    onPublished?: () => void;
    /**
     * Fires on non-permission `getUserMedia` failures and on
     * publish / unpublish rejections.  Permission denials route to
     * {@link onPermissionDenied} instead.
     */
    onError?: (error: Error) => void;
}
declare function WebcamStream({ track, audio, audioTrack, className, style, videoConstraints, showWebcam, videoObjectFit, onPermissionDenied, onPublished, onError, }: WebcamStreamProps): react_jsx_runtime.JSX.Element;

/**
 * Video preview for a captured {@link Clip}.
 *
 * Renders an HLS manifest through the browser's native
 * ``<video controls>`` element.  On Safari / iOS the manifest is
 * attached directly (native HLS support).  On Chrome / Firefox / Edge
 * ``hls.js`` is dynamically imported — declared as an **optional peer
 * dependency** so consumers who don't use this component aren't billed
 * the ~80 KB.  If ``hls.js`` isn't installed and native HLS isn't
 * available the player surfaces an inline error overlay; the
 * underlying chunks remain downloadable via {@link useClipDownload} /
 * {@link ClipDownloadButton} (which don't depend on hls.js at all).
 *
 * **Preview only.**  This component intentionally does *not* render a
 * download UI.  Compose it with {@link ClipDownloadButton} or build
 * your own download surface around {@link useClipDownload} — the
 * separation keeps both pieces independently extendible and avoids
 * baking layout decisions into the SDK.
 *
 * Unlike {@link ReactorView} / {@link WebcamStream} this component
 * **does not require a ``ReactorProvider``** in the tree.  It
 * operates on the ``Clip`` value alone, so it stays usable after
 * ``reactor.disconnect()`` and works with clips loaded from
 * fixtures, server logs, or any other source. When a
 * ``ReactorProvider`` is mounted above, an omitted ``getJwt``
 * inherits the provider's resolver.
 *
 * @example Compose with the download button (explicit `getJwt`):
 * ```tsx
 * <div>
 *   <ClipPlayer clip={clip} getJwt={() => jwt} />
 *   <ClipDownloadButton clip={clip} getJwt={() => jwt} />
 * </div>
 * ```
 *
 * @example Local dev (HttpRuntime, no auth on /clips):
 * ```tsx
 * <ClipPlayer clip={clip} />
 * ```
 */
interface ClipPlayerProps {
    /**
     * The captured clip to play.  When this prop changes by reference
     * the player re-fetches the manifest and re-attaches the player.
     */
    clip: Clip;
    /**
     * Lazy resolver for the Coordinator JWT used on the ``/clips``
     * manifest GET. Called at request time so token refreshes are
     * picked up automatically.
     *
     * - **Production:** required outside a ``<ReactorProvider>``;
     *   optional inside one (inherits the provider's resolver).
     * - **Local-dev (HttpRuntime):** omit — ``/clips`` is auth-free.
     *
     * Chunk URLs inside the manifest are presigned (prod) or
     * unauthenticated (local) and are fetched without
     * ``Authorization`` in either case.
     */
    getJwt?: () => string | Promise<string>;
    /**
     * Override the grace period beyond ``clip.predictedReadyAtMs``
     * before the SDK gives up polling the ``/clips`` manifest endpoint
     * with ``CLIP_NOT_READY``.  Defaults to
     * {@link DEFAULT_PLAYLIST_POLL_SLACK_MS} (15 s) — enough for snap
     * clips, but long-running session recordings may legitimately need
     * a minute or more for the final boundary chunk to finish encoding
     * + uploading, in which case pass a larger value (e.g. ``120_000``
     * for two-minute grace).  Forwarded directly to
     * {@link fetchPlaylist}'s ``slackMs`` option — see that helper for
     * the polling semantics.
     */
    slackMs?: number;
    /** Play automatically once the manifest is attached. Default ``true``. */
    autoPlay?: boolean;
    /**
     * Start muted.  Default ``true`` because browser autoplay policies
     * block audio-bearing video from playing without a user gesture;
     * the user can unmute via the native ``<video controls>``.
     */
    muted?: boolean;
    className?: string;
    style?: React.CSSProperties;
    /**
     * Fires when the player enters its inline error state.  Receives
     * the originating error: a ``RecordingError`` for manifest-fetch
     * failures, a plain ``Error`` for hls.js / native playback or
     * missing-peer-dep cases.
     */
    onError?: (error: Error) => void;
}
declare function ClipPlayer({ clip, getJwt, slackMs, autoPlay, muted, className, style, onError, }: ClipPlayerProps): react_jsx_runtime.JSX.Element;

/**
 * State machine for an in-progress clip download.
 *
 * - ``idle``: no download in flight (initial state, and what the hook
 *   returns to after a successful save).
 * - ``downloading``: chunks are being fetched.  ``fetched`` and
 *   ``total`` count the number of chunks (init segment + media
 *   segments) — useful for a progress bar.  ``total`` is 0 until the
 *   manifest is parsed and the chunk count is known.
 * - ``error``: most recent attempt failed; the ``message`` is suitable
 *   for surfacing inline.  ``RecordingError`` instances are formatted
 *   as ``"<CODE>: <reason>"`` for grep-ability.
 */
type ClipDownloadState = {
    kind: "idle";
} | {
    kind: "downloading";
    fetched: number;
    total: number;
} | {
    kind: "error";
    message: string;
};
interface UseClipDownloadOptions {
    /**
     * Filename used when the browser save dialog opens.  Pass ``null``
     * to skip the ``<a download>`` trigger entirely — the returned
     * Blob is still resolved so the caller can ``URL.createObjectURL``
     * it or re-upload it.  Default ``"reactor-clip.mp4"``.
     */
    filename?: string | null;
    /**
     * Lazy resolver for the Coordinator JWT used on the ``/clips``
     * manifest GET.  Called on every {@link download} invocation, so
     * token refreshes are picked up automatically.
     *
     * Optional inside a ``<ReactorProvider>`` (inherits the provider's
     * resolver) and in local-dev mode. See
     * {@link ClipPlayerProps.getJwt}.
     */
    getJwt?: () => string | Promise<string>;
}
interface UseClipDownloadResult {
    /** Current state of the most recent download attempt. */
    state: ClipDownloadState;
    /**
     * Trigger a download.  Resolves with the assembled fragmented-MP4
     * Blob, or ``undefined`` if a download was already in flight (the
     * call is a no-op in that case — guarding against double-click is
     * the hook's responsibility, not the caller's).
     *
     * Errors are caught and surfaced via {@link state} — the returned
     * Promise still resolves to ``undefined`` rather than rejecting,
     * because the typical caller is a click handler that doesn't await.
     * Use ``state.kind === "error"`` to drive failure UI.
     */
    download: () => Promise<Blob | undefined>;
    /** Reset to ``idle``.  Does *not* cancel an in-flight download. */
    reset: () => void;
}
/**
 * Headless download primitive for a {@link Clip}.
 *
 * Wraps {@link downloadClipAsFile} in a React state machine so the
 * consumer can render any button they want, anywhere they want, and
 * still get progress + error feedback.  Used internally by
 * {@link ClipPlayer}'s built-in download button — when you need
 * custom placement or styling, set ``showDownloadButton={false}`` on
 * the player and call this hook directly.
 *
 * Stable callback identity: ``download`` and ``reset`` are the same
 * function reference across renders, so they're safe to pass through
 * memoized children without forcing re-renders.
 *
 * @example Render a download button anywhere in your tree:
 * ```tsx
 * function ClipCard({ clip }: { clip: Clip }) {
 *   const jwt = useReactor((s) => s.jwtToken);
 *   const { state, download } = useClipDownload(clip, {
 *     filename: `snap-${clip.sessionId}.mp4`,
 *     getJwt: jwt ? () => jwt : undefined,
 *   });
 *   return (
 *     <button onClick={download} disabled={state.kind === "downloading"}>
 *       {state.kind === "downloading"
 *         ? `${state.fetched}/${state.total}`
 *         : state.kind === "error"
 *           ? "Retry"
 *           : "Download"}
 *     </button>
 *   );
 * }
 * ```
 */
declare function useClipDownload(clip: Clip, options?: UseClipDownloadOptions): UseClipDownloadResult;

/**
 * Standalone download button for a captured {@link Clip}.
 *
 * Drops anywhere in your UI — modal headers, list rows, hover menus,
 * floating action buttons — and is responsible for nothing more than
 * triggering a download and reflecting its state.  Internally wraps
 * {@link useClipDownload}; for completely custom UIs (progress bars,
 * menu items, post-download blob handling) call that hook directly.
 *
 * Styling is intentionally minimal.  Override via ``className``,
 * ``style``, or replace the inner content with the ``children``
 * render-prop.  No CSS file is shipped — every default style is
 * inline so it loses to anything the consumer provides.
 *
 * @example Default label, state-aware:
 * ```tsx
 * <ClipDownloadButton clip={clip} getJwt={() => jwt} />
 * ```
 *
 * @example Custom label that follows the state:
 * ```tsx
 * <ClipDownloadButton clip={clip} getJwt={() => jwt}>
 *   {(s) => (s.kind === "downloading" ? `${s.fetched}/${s.total}` : "Save MP4")}
 * </ClipDownloadButton>
 * ```
 *
 * @example Static label:
 * ```tsx
 * <ClipDownloadButton clip={clip} getJwt={() => jwt}>Save</ClipDownloadButton>
 * ```
 */
interface ClipDownloadButtonProps {
    /** The clip to download. */
    clip: Clip;
    /**
     * Lazy JWT resolver. Optional inside a ``<ReactorProvider>``
     * (inherits the provider's resolver) and in local-dev mode. See
     * {@link ClipPlayerProps.getJwt}.
     */
    getJwt?: () => string | Promise<string>;
    /** Filename for the saved MP4.  Default ``"reactor-clip.mp4"``. */
    filename?: string;
    /**
     * Inner content of the button.  Three forms:
     *
     * - **Omitted** — renders a sensible default label that follows
     *   the state (``"Download"`` / ``"Downloading 3/8…"`` / etc.).
     * - **`ReactNode`** — static label.  No state-driven text.
     * - **`(state) => ReactNode`** — state-aware render function;
     *   use for custom progress strings, spinners, etc.
     */
    children?: React.ReactNode | ((state: ClipDownloadState) => React.ReactNode);
    /** Forwarded to the underlying ``<button>``. */
    className?: string;
    /** Forwarded to the underlying ``<button>`` — merges *after* the defaults so each property overrides. */
    style?: React.CSSProperties;
    /** Forwarded to the underlying ``<button>``.  ORed with the internal "downloading" state. */
    disabled?: boolean;
    /**
     * Fires when the download completes with the assembled MP4 ``Blob``.
     */
    onSuccess?: (blob: Blob) => void;
    /**
     * Fires when the download fails.  Message mirrors the in-button
     * state — ``"<CODE>: <reason>"`` for ``RecordingError``s, the
     * plain error message otherwise.
     */
    onError?: (error: Error) => void;
}
declare function ClipDownloadButton({ clip, getJwt, filename, children, className, style, disabled, onSuccess, onError, }: ClipDownloadButtonProps): react_jsx_runtime.JSX.Element;

/**
 * Generic hook for accessing selected parts of the Reactor store.
 *
 * @param selector - A function that selects part of the store state.
 * @returns The selected slice from the store.
 */
declare function useReactor<T>(selector: (state: ReactorStore) => T): T;
/**
 * Hook for receiving model application messages.
 *
 * Only fires for messages sent by the model via `get_ctx().send()`.
 * Internal platform-level messages (e.g. capabilities) are NOT delivered here.
 *
 * @param handler - Callback invoked with each application message payload.
 */
declare function useReactorMessage(handler: (message: any) => void): void;
/**
 * Hook for receiving internal platform-level (runtime) messages.
 *
 * This is intended for advanced use cases that need access to the runtime
 * control layer, such as capabilities negotiation. Model application messages
 * sent via `get_ctx().send()` are NOT delivered through this hook — use
 * {@link useReactorMessage} for those.
 *
 * @param handler - Callback invoked with each runtime message payload.
 */
declare function useReactorInternalMessage(handler: (message: any) => void): void;
/**
 * Hook that returns the current connection stats (RTT, etc.).
 * Updates every ~2s while connected. Returns undefined when disconnected.
 */
declare function useStats(): ConnectionStats | undefined;

export { AbortError, type Capabilities, type Clip, ClipDownloadButton, type ClipDownloadButtonProps, type ClipDownloadState, type ClipFailedPayload, type ClipKind, ClipPlayer, type ClipPlayerProps, type ClipReadyPayload, type CommandCapability, ConflictError, type ConnectOptions, type ConnectionStats, type ConnectionTimings, DEFAULT_BASE_URL, DEFAULT_CLIP_REQUEST_TIMEOUT_MS, DEFAULT_PLAYLIST_POLL_SLACK_MS, type DownloadClipOptions, type FetchPlaylistOptions, FileRef, type JwtResolver, type JwtSource, type MessageScope, type ModerationAction, type ModerationEvent, type Options, type ParseClipOptions, Reactor, type ReactorConnectOptions, ReactorController, type ReactorControllerProps, type ReactorError, type ReactorEvent, ReactorProvider, type ReactorState$1 as ReactorState, type ReactorStatus, type ReactorStore, ReactorView, type ReactorViewProps, RecordingClient, type RecordingClientHost, RecordingError, RuntimeRecordingMessageType, type SessionResponse, type TrackCapability, type UseClipDownloadOptions, type UseClipDownloadResult, WebcamStream, type WebcamStreamProps, clipFromPayload, createPlayableManifestUrl, downloadClipAsFile, fetchPlaylist, isAbortError, normalizeJwtSource, parsePlaylist, rewriteUrlHost, useClipDownload, useReactor, useReactorInternalMessage, useReactorMessage, useReactorStore, useStats };