tui

type ExplorerData struct {
	Recent   func(ctx context.Context, limit int) ([]RecentItem, error)
	Jobs     func(ctx context.Context) ([]JobRow, error)
	JobItems func(ctx context.Context, id string) ([]JobItem, error)
	Feed     Feed
	Usage    func(ctx context.Context, days int) (*account.Usage, error)

	// Stream management from the Streams tab.
	AddStream    func(ctx context.Context, url string, radioID int) error
	RemoveStream func(ctx context.Context, radioID int) error
	SetStreamURL func(ctx context.Context, radioID int, url string) error
}

type Feed interface {
	Stations(ctx context.Context) ([]Station, error)
	Plays(ctx context.Context, radioID int, limit int) ([]Play, error)
}

type FeedFuncs struct {
	StationsFunc func(ctx context.Context) ([]Station, error)
	PlaysFunc    func(ctx context.Context, radioID int, limit int) ([]Play, error)
}

type Health struct {
	Code    int       `json:"code"`
	Message string    `json:"message"`
	At      time.Time `json:"at"`
}

type JobItem struct {
	Index  int             `json:"index"`
	Input  string          `json:"input"`
	State  string          `json:"state"` // pending, done, failed
	Result json.RawMessage `json:"result,omitempty"`
	Err    string          `json:"error,omitempty"`
}

type JobRow struct {
	ID      string    `json:"id"`
	Command []string  `json:"command"`
	Created time.Time `json:"created"`
	Total   int       `json:"total"`
	Done    int       `json:"done"`
	Failed  int       `json:"failed"`
	Status  string    `json:"status"`
}

type NowPlayingLine struct {
	app.ResultView
	RadioID int
	URL     string
	State   string
	Playing bool
	At      time.Time
	Elapsed time.Duration
	Played  time.Duration
	Ended   time.Time
	Ago     time.Duration
	Length  time.Duration
}

type NowPlayingOptions struct {
	NoArt, Notify bool
	// Once prints the current song of each station and exits.
	Once bool
	// Format is a text/template over NowPlayingLine, printed per song
	// change (or once with Once), for status bars.
	Format string
	// Timeout stops the run after this long (0: run until interrupted).
	Timeout time.Duration
	// Interval is how often stream results are re-read (default 5 s).
	Interval time.Duration
	// Context cancels the run (Ctrl-C). Defaults to context.Background().
	Context context.Context
}

type Play struct {
	RadioID int
	// At is when AudD detected the start of the song.
	At time.Time
	// PlayLength is how long the song had played when AudD reported it, in
	// seconds (from the callback's play_length).
	PlayLength int
	// TrackLength is the full song length, when metadata includes it.
	TrackLength time.Duration
	app.ResultView
	// Raw is the original song object from the API, when known.
	Raw json.RawMessage
}

type PlayState string

type PlayStore interface {
	// Plays returns up to limit plays of a stream, newest first.
	Plays(radioID int, limit int) ([]Play, error)
	// AddPlay saves a play; duplicates (same stream and timestamp) are ignored.
	AddPlay(p Play) error
}

type RecentItem struct {
	Source string          `json:"source"` // file path or URL
	At     time.Time       `json:"at"`
	Result json.RawMessage `json:"result"` // the API result (object, or array for enterprise)
}

type Station struct {
	RadioID int     `json:"radio_id"`
	URL     string  `json:"url,omitempty"`
	Running bool    `json:"stream_running"`
	Health  *Health `json:"health,omitempty"` // latest health notification, if any
	// StatusUnknown is set when the stream list could not be read, so
	// whether the stream runs is not known.
	StatusUnknown bool `json:"-"`
}

type StoreFeed struct {
	StationsFunc func(ctx context.Context) ([]Station, error)
	Store        PlayStore
	// Recent fetches the recent-results endpoint for a stream.
	Recent func(ctx context.Context, radioID int) ([]Play, error)
	// RecorderRunning reports whether a recorder keeps a stream current
	// (it has written a heartbeat for the stream within HeartbeatWindow).
	RecorderRunning func(radioID int) bool
	Now             func() time.Time
	// contains filtered or unexported fields
}