camfarm

type Addrs struct {
	RTSP *net.TCPAddr
}

type AuthSpec struct {
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

type Camera struct {
	// contains filtered or unexported fields
}

type CameraSpec struct {
	// ID is operator-chosen and appears in the camera's RTSP path.
	ID     string      `json:"id"`
	Source SourceSpec  `json:"source,omitempty"`
	Video  VideoSpec   `json:"video,omitempty"`
	Faults []FaultSpec `json:"faults,omitempty"`
	Auth   AuthSpec    `json:"auth,omitempty"`
}

type DiscoverySpec struct {
	// Mode is "multicast" or "unicast".
	Mode string `json:"mode"`
	// Interface selects the interface (name or IP) that joins the multicast
	// group. Multicast mode only.
	Interface string `json:"interface,omitempty"`
	// Addr is the UDP address to bind in unicast mode, e.g. 127.0.0.1:0.
	// Required for unicast; forbidden for multicast.
	Addr string `json:"addr,omitempty"`
	// AnnounceAddr is where Hello and Bye go. Unicast mode only; empty
	// disables announcements.
	AnnounceAddr string `json:"announceAddr,omitempty"`
}

type Event struct {
	Seq    uint64     `json:"seq"`
	Type   EventType  `json:"type"`
	Camera string     `json:"camera"`
	Fault  *FaultSpec `json:"fault,omitempty"`
	// FrameIndex is the frame a fault change took effect on; -1 for add/remove.
	FrameIndex int `json:"frameIndex"`
	// Clock names what FrameIndex counts: "frame" or "request". Empty for
	// add/remove.
	Clock string `json:"clock,omitempty"`
}

type EventType string

type FaultCount struct {
	Applied    uint64
	Suppressed uint64
}

type FaultSpec struct {
	// Kind names a catalogued fault.
	Kind string `json:"kind"`
	// Rate is the probability for rate-based faults, in [0,1].
	Rate float64 `json:"rate,omitempty"`
	// ProtectKeyframes never applies frame_drop or packet_loss to a
	// random-access frame.
	ProtectKeyframes bool `json:"protectKeyframes,omitempty"`
	// MeanBurst, for packet_loss, selects burst loss when greater than 1.
	MeanBurst float64 `json:"meanBurst,omitempty"`
	// KeepEvery, for keyframe_starvation, delivers every Nth keyframe.
	KeepEvery int `json:"keepEvery,omitempty"`
	// On, for rtsp_error, names the failing method: describe, setup, play or all.
	On string `json:"on,omitempty"`
	// Status, for rtsp_error, is the RTSP status code of the reply.
	Status int `json:"status,omitempty"`
	// OnlyRequest, for rtsp_error and sdp_lie, fires on the Nth matching request only.
	OnlyRequest int `json:"onlyRequest,omitempty"`
	// AfterFrames, for teardown, is the frames delivered before teardown.
	AfterFrames int `json:"afterFrames,omitempty"`
	// Mode selects a variant of teardown (close, reset) or sdp_lie (codec,
	// sprop, resolution, contentBase).
	Mode string `json:"mode,omitempty"`
	// MaxMs, for jitter, bounds each frame's random delay in milliseconds.
	MaxMs int `json:"maxMs,omitempty"`
	// HoldFrames, for burst_delivery, is the frames held before a burst.
	HoldFrames int `json:"holdFrames,omitempty"`
	// ReorderDepth, for pts_dts_mismatch, is how far timestamps run out of order.
	ReorderDepth int `json:"reorderDepth,omitempty"`
	// DelayMs, for pts_delayed, is a constant timestamp lag in milliseconds.
	DelayMs int `json:"delayMs,omitempty"`
	// DriftPpm, for pts_delayed, is a timestamp drift in parts per million.
	DriftPpm int `json:"driftPpm,omitempty"`
}

type Fleet struct {
	// contains filtered or unexported fields
}

type JournalEntry struct {
	Seq    uint64    `json:"seq"`
	Action string    `json:"action"` // add, remove, inject, clear
	Camera string    `json:"camera"`
	Fault  FaultSpec `json:"fault"`
	// FrameIndex is when a fault change landed. It depends on when the change
	// was requested, which is the limit of replaying an interactive run.
	FrameIndex int `json:"frameIndex"`
	// Clock says whether FrameIndex counts frames (per-frame faults) or RTSP
	// requests (control-plane faults). Part of the replay hash.
	Clock string `json:"clock,omitempty"`
}

type ListenSpec struct {
	// Host defaults to 127.0.0.1, so a test fixture is not exposed to the
	// network by accident.
	Host string `json:"host,omitempty"`
	// AdvertiseHost, when set, is the host written into every URL a client is
	// told to dial (RTSP URLs, ONVIF endpoints and XAddrs, stream URIs,
	// WS-Discovery XAddrs, the dashboard's links), instead of Host. Host
	// stays the bind address. It is required when Host is a wildcard
	// (0.0.0.0 or ::), as in a container. It must be a bare host or IP. The
	// ports in those URLs are the real bound ports, so a published container
	// port must equal the container port, or the ports must be fixed.
	AdvertiseHost string `json:"advertiseHost,omitempty"`
	// RTSPPort of zero requests an ephemeral port, readable back via
	// Fleet.Addr.
	RTSPPort int `json:"rtspPort,omitempty"`
	// ONVIFPort of zero requests an ephemeral port for the ONVIF HTTP
	// listener, readable back via Camera.ONVIFEndpoint.
	ONVIFPort int `json:"onvifPort,omitempty"`
	// Discovery, when set, makes the fleet answer WS-Discovery probes. Nil
	// (the default) leaves discovery off and the spec's hash unchanged.
	// Enabling it changes Spec.Hash() and therefore the replay line, so a run
	// with discovery on does not share a replay line with the same fleet
	// without it.
	Discovery *DiscoverySpec `json:"discovery,omitempty"`
}

type SourceKind string

type SourceSpec struct {
	// Kind defaults to SourceFixture.
	Kind SourceKind `json:"kind,omitempty"`
	// Path is required when Kind is SourceFile.
	Path string `json:"path,omitempty"`
}

type Spec struct {
	// Seed roots every random decision the fleet makes.
	Seed    uint64       `json:"seed"`
	Cameras []CameraSpec `json:"cameras"`
	Listen  ListenSpec   `json:"listen,omitempty"`

	// Log receives fleet events. Nil means silent, which is the default: a
	// consumer may run camfarm inside a process whose stdout carries a protocol
	// stream, so nothing is ever written there.
	Log *slog.Logger `json:"-"`
}

type Stats struct {
	// Seed is this camera's derived seed, not the fleet root.
	Seed uint64
	// FramesServed counts access units served. It is monotonic across loops of
	// the source, so it doubles as the camera's position in the run.
	FramesServed uint64
	// LoopsCompleted counts completed passes over the source media.
	LoopsCompleted uint64
	// FaultsFired counts fault decisions that have fired for this camera. For
	// packet_loss it counts frames that had loss, not packets; use FaultCounts
	// for packet counts.
	FaultsFired uint64
	// FaultCounts tallies each fault kind's effects: frames dropped, packets
	// or keyframes withheld (Applied) and decisions spared by
	// ProtectKeyframes (Suppressed). Never nil.
	FaultCounts map[string]FaultCount
	// OutboundRTPPackets counts RTP packets sent on this camera's stream,
	// read from the RTSP stream's own counters.
	OutboundRTPPackets uint64
	// OutboundBytes counts bytes sent on this camera's stream, read from the
	// RTSP stream's own counters.
	OutboundBytes uint64
	// Readers is the number of sessions currently set up against this
	// camera. Unlike the other fields, it is a live count, not a running
	// total.
	Readers int
}

type Status struct {
	ID      string
	RTSPURL string
	Source  string
	Codec   string
	Width   int
	Height  int
	FPS     float64
	Readers int
}

type TB interface {
	Cleanup(func())
	Fatalf(format string, args ...any)
	Helper()
}

type VideoSpec struct {
	Codec  string  `json:"codec,omitempty"`
	Width  int     `json:"width,omitempty"`
	Height int     `json:"height,omitempty"`
	FPS    float64 `json:"fps,omitempty"`
}