broadcast

type Backend interface {
	// Name is a short stable identifier used in logs and stats.
	Name() string
	// Accepts reports whether this backend wants calls from the named
	// trunking system. An unfiltered backend accepts every system.
	Accepts(systemName string) bool
	// Send delivers the call. A non-nil error triggers a retry.
	Send(ctx context.Context, c *Call) error
}

type BroadcastifyConfig struct {
	// Name is an optional label used in logs; defaults to
	// "broadcastify".
	Name string
	// APIKey is the Broadcastify Calls API key for the system.
	APIKey string
	// SystemID is the numeric Broadcastify Calls system ID.
	SystemID int
	// Systems restricts the feed to these trunking-system names.
	// Empty streams every system.
	Systems []string
	// Endpoint overrides the upload API URL (tests). Empty uses the
	// production endpoint.
	Endpoint string
}

type Call struct {
	System         string
	Protocol       string
	Talkgroup      uint32
	TalkgroupLabel string
	Source         uint32
	FrequencyHz    uint32
	// ChannelID / RFSS / Site / NAC / Timeslot carry the P25 site
	// identity decoded off the control channel (issue #698). They let a
	// metadata sink (the webhook) label a call by site for downstream
	// dashboards instead of resolving an opaque channel ID by hand. All
	// stay zero on non-P25 calls and until the site's status TSBKs land;
	// audio-upload backends ignore them.
	ChannelID uint8
	RFSS      uint8
	Site      uint8
	NAC       uint16
	Timeslot  uint8
	Encrypted bool
	// AlgorithmID / KeyID surface the P25 encryption parameters when
	// the in-call signalling has revealed them. Zero on clear calls
	// and on encrypted calls whose Encryption Sync never arrived
	// before the call ended. Aggregators that accept the fields can
	// thread them into their API payload; aggregators that don't will
	// just ignore them.
	AlgorithmID   uint8
	KeyID         uint16
	Emergency     bool
	PatchedGroups []uint32
	StartedAt     time.Time
	EndedAt       time.Time
	AudioPath     string // .wav on disk written by the recorder
	SampleRate    int
	// contains filtered or unexported fields
}

type IcecastConfig struct {
	// Name is an optional log label; defaults to "icecast".
	Name string
	// Host and Port address the Icecast server.
	Host string
	Port int
	// Mount is the mountpoint path (e.g. "/gophertrunk"). A leading
	// slash is added when missing.
	Mount string
	// Username is the source username; defaults to "source".
	Username string
	// Password is the source password.
	Password string
	// StreamName is advertised to listeners via the Ice-Name header.
	StreamName string
	// SampleRate is the PCM rate used to synthesise inter-call
	// silence; defaults to 8000.
	SampleRate int
	// Systems restricts the feed to these trunking-system names.
	// Empty streams every system.
	Systems []string
}

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

type NormalizeConfig struct {
	Enabled bool
	Params  loudness.NormalizeParams
}

type OpenMHzConfig struct {
	// Name is an optional log label; defaults to "openmhz".
	Name string
	// APIKey is the OpenMHz system API key.
	APIKey string
	// ShortName is the OpenMHz system short name (the path segment in
	// the upload URL).
	ShortName string
	// Systems restricts the feed to these trunking-system names.
	// Empty streams every system.
	Systems []string
	// Endpoint overrides the API base URL (tests). Empty uses the
	// production endpoint.
	Endpoint string
}

type Options struct {
	Bus *events.Bus
	Log *slog.Logger
	// Backends is the set of outbound destinations. A Manager with no
	// backends is valid but inert.
	Backends []Backend
	// MinDuration drops calls shorter than this from every backend.
	// Zero streams calls of any length.
	MinDuration time.Duration
	// Workers is the number of concurrent upload goroutines. Default 2.
	Workers int
	// MaxRetries is the per-backend retry budget on a failed Send.
	// Default 3.
	MaxRetries int
	// RetryBase is the first backoff delay; it doubles per attempt.
	// Default 2s.
	RetryBase time.Duration
	// Normalize, when Enabled, loudness-normalizes the distributed MP3
	// copy in memory (the on-disk WAV is left pristine). Off by default.
	Normalize NormalizeConfig
}

type RdioScannerConfig struct {
	// Name is an optional log label; defaults to "rdioscanner".
	Name string
	// URL is the RdioScanner base URL (e.g. "https://scanner.example").
	// The "/api/call-upload" path is appended automatically.
	URL string
	// APIKey is the RdioScanner system API key.
	APIKey string
	// SystemID is the numeric RdioScanner system ID.
	SystemID int
	// Systems restricts the feed to these trunking-system names.
	// Empty streams every system.
	Systems []string
	// Loc is the timezone the dateTime RFC3339 value renders in. Nil means
	// time.Local. RdioScanner parses dateTime as an instant, so the offset-
	// bearing RFC3339 (e.g. +02:00, or Z for UTC) is unambiguous.
	Loc *time.Location
}

type Stats struct {
	Queued   int            `json:"queued"`
	Dropped  int            `json:"dropped"`
	Sent     map[string]int `json:"sent"`
	Failed   map[string]int `json:"failed"`
	Backends []string       `json:"backends"`
}

type WebhookConfig struct {
	// Name is an optional log label; defaults to "webhook".
	Name string
	// URL is the endpoint the call payload is POSTed to (required).
	URL string
	// AuthHeader, when set, is sent verbatim as the Authorization header
	// (e.g. "Bearer <token>"). Empty omits the header.
	AuthHeader string
	// IncludeAudio, when true, embeds the MP3-encoded call audio as a
	// base64 string in the payload (audio_base64 / audio_format). Off by
	// default so the webhook stays a lightweight metadata feed; consumers
	// that want audio can opt in.
	IncludeAudio bool
	// Systems restricts the feed to these trunking-system names. Empty
	// streams every system.
	Systems []string
	// Loc is the timezone the StartedAt/EndedAt RFC3339 timestamps render in.
	// Nil means time.Local. The daemon passes display.timezone so the payload
	// matches the operator's other timestamps; the format stays RFC3339, so the
	// offset (e.g. +02:00, or Z for UTC) keeps the instant unambiguous.
	Loc *time.Location
}