observedCertificates      observedCodecs             observedDataChannels
observedIceCandidates     observedIceCandidatesPair  observedIceTransports
observedInboundRtps       observedInboundTracks      observedMediaPlayouts
observedMediaSources      observedOutboundRtps       observedOutboundTracks
observedPeerConnectionTransports
observedRemoteInboundRtps observedRemoteOutboundRtps

new Observer<AppData>(config?: ObserverConfig<AppData>)

type ObserverConfig<AppData = Record<string, unknown>> = {
    // a call updates when any client does; the observer when any call does. Default true.
    autoUpdateOnCallUpdate?: boolean;

    appData?: AppData;

    closeClientIfIdleForMs?: number;
    closeCallIfEmptyForMs?: number;

    // appData factories — run when an entity is created without explicit appData.
    createCallAppData?: (p: { callId: string; observer: Observer }) => Record<string, unknown>;
    createClientAppData?: (p: { clientId: string; observedCall: ObservedCall }) => Record<string, unknown>;

    // per-client sink factory
    createClientSink?: (p: { clientId: string; observedCall: ObservedCall }) => ClientSampleSink | undefined;

    // per-call remote track resolver factory
    createRemoteTrackResolver?: (observedCall: ObservedCall) => RemoteTrackResolver | undefined;
};

type ObservedCallSettings<AppData = Record<string, unknown>> = {
    callId: string;
    appData?: AppData;
    // update this call whenever one of its clients accepts a sample. Default true.
    autoUpdateOnClientUpdate?: boolean;
    closeCallIfEmptyForMs?: number;
};

type ObservedClientSettings<AppData = Record<string, unknown>> = {
    clientId: string;
    appData?: AppData;
    closeClientIfIdleForMs?: number;
};

observedClient.injectEvent(event);
observedClient.injectIssue(issue);
observedClient.injectMetaData(meta);
observedClient.injectExtensionStat(stat);
observedClient.injectAttachment({ roomId });

outboundTrack.remoteInboundTracks;      // Set<ObservedInboundTrack> — every subscriber of this source
inboundTrack.remoteOutboundTrack;       // the publisher, or undefined if unlinked
inboundTrack.getInboundRtp();           // that receiver's RTP stats
observedCall.unconsumedOutboundTracks;  // published tracks with no subscriber at all

import { CallHealthAggregator } from "@observertc/observer-js";

const health = new CallHealthAggregator(observedCall).aggregate();

health.degradedRatio;          // 0.82 — distinguishes shared faults from individual ones
health.inboundDegradedRatio;   // receiving side → egress / downstream suspicion
health.outboundDegradedRatio;  // sending side  → ingress suspicion
health.rttInMs?.median;        // percentile rollups, never means
health.qualityLimitation;      // { cpu, bandwidth, other } client counts
health.clients;                // per-client entries with reasons, direction flags, TURN/TCP

import {
    percentile, median, summarize,
    counterDelta, robustZScore,
    SlidingWindow, TrendTester,
} from "@observertc/observer-js";