streamcontrol

type AbstractPlatformConfig = PlatformConfig[any, AbstractStreamProfile]

type AbstractStreamController interface {
	StreamController[AbstractStreamProfile]
	GetImplementation() StreamControllerCommons
	StreamProfileType() reflect.Type
}

type AbstractStreamProfile interface {
	GetParent() (ProfileName, bool)
	GetOrder() int
}

type Config map[PlatformName]*AbstractPlatformConfig

type ErrInvalidStreamProfileType struct {
	Received AbstractStreamProfile
	Expected AbstractStreamProfile
}

type ErrNoStreamControllerForProfile struct {
	StreamProfile AbstractStreamProfile
}

type PlatformConfig[T any, S StreamProfile] struct {
	Config         T
	StreamProfiles StreamProfiles[S]
}

type PlatformName string

type ProfileName string

type RawMessage json.RawMessage

type StreamController[ProfileType StreamProfile] interface {
	StreamControllerCommons

	ApplyProfile(ctx context.Context, profile ProfileType, customArgs ...any) error
	StartStream(ctx context.Context, title string, description string, profile ProfileType, customArgs ...any) error
}

type StreamControllerCommons interface {
	SetTitle(ctx context.Context, title string) error
	SetDescription(ctx context.Context, description string) error
	InsertAdsCuePoint(ctx context.Context, ts time.Time, duration time.Duration) error
	Flush(ctx context.Context) error
	EndStream(ctx context.Context) error
}

type StreamControllers []AbstractStreamController

type StreamProfile interface {
	AbstractStreamProfile
}

type StreamProfileBase struct {
	Parent ProfileName
	Order  int
}

type StreamProfiles[S StreamProfile] map[ProfileName]S