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
	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
}

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"`
}