stream

type Endpoint struct {
	EndpointID int `json:"endpointId" db:"endpoint_id"`
	// Application defines which RTMP application this is valid for
	Application string `json:"application"`
	// Name is the unique name given in an application
	Name string `json:"name"`
	// Pwd defines an extra layer of security for authentication
	Pwd *string `json:"pwd,omitempty"`
	// StartValid defines the optional start time that this endpoint becomes valid
	StartValid *time.Time `json:"startValid,omitempty"`
	// EndValid defines the optional end time that this endpoint stops being valid
	EndValid *time.Time `json:"endValid,omitempty"`
	// Notes is an optional internal note for the endpoint
	Notes *string `json:"notes,omitempty"`
	// Active indicates if this endpoint is currently being used
	Active bool `json:"active"`
	// Blocked prevents the endpoint from going live
	Blocked bool `json:"blocked"`
	// AutoRemove indicates that this endpoint can be automatically removed when the end valid time comes, optional
	AutoRemove bool `json:"autoRemove,omitempty"`
}

type EndpointAddEditDTO struct {
	// Application defines which RTMP application this is valid for
	Application string `json:"application"`
	// Name is the unique name given in an application
	Name string `json:"name"`
	// Pwd defines an extra layer of security for authentication
	Pwd *string `json:"pwd,omitempty"`
	// StartValid defines the optional start time that this endpoint becomes valid, RFC3339
	StartValid *time.Time `json:"startValid,omitempty"`
	// EndValid defines the optional end time that this endpoint stops being valid, RFC3339
	EndValid *time.Time `json:"endValid,omitempty"`
	// Notes is an optional internal note for the endpoint
	Notes *string `json:"notes,omitempty"`
	// Blocked prevents the endpoint from going live, optional defaults to false
	Blocked bool `json:"blocked,omitempty"`
	// AutoRemove indicates that this endpoint can be automatically removed when the end valid time comes, optional
	AutoRemove bool `json:"autoRemove,omitempty"`
}

type EndpointDB struct {
	EndpointID  int         `json:"endpointId" db:"endpoint_id"`
	Application string      `json:"application" db:"application"`
	Name        string      `json:"name" db:"name"`
	Pwd         null.String `json:"pwd" db:"pwd"`
	StartValid  null.Time   `json:"startValid" db:"start_valid"`
	EndValid    null.Time   `json:"endValid" db:"end_valid"`
	Notes       null.String `json:"notes" db:"notes"`
	Active      bool        `json:"active" db:"active"`
	Blocked     bool        `json:"blocked" db:"blocked"`
	AutoRemove  bool        `json:"autoRemove" db:"auto_remove"`
}

type FindEndpoint struct {
	// EndpointID is the unique database id of the stream
	EndpointID *int `json:"endpointId,omitempty"`
	// Application defines which RTMP application this is valid for
	Application *string `json:"application,omitempty"`
	// Name is the unique name given in an application
	Name *string `json:"name,omitempty"`
	// Pwd defines an extra layer of security for authentication
	Pwd *string `json:"pwd,omitempty"`
}

type Repo interface {
	ListEndpoints(ctx context.Context) ([]EndpointDB, error)
	FindEndpoint(ctx context.Context, findEndpoint FindEndpoint) (EndpointDB, error)
	GetEndpointByID(ctx context.Context, endpointID int) (EndpointDB, error)
	GetEndpointByApplicationNamePwd(ctx context.Context, application, name, pwd string) (EndpointDB, error)

	SetEndpointActiveByID(ctx context.Context, endpointID int) error
	SetEndpointInactiveByApplicationNamePwd(ctx context.Context, application, name, pwd string) error

	AddEndpoint(ctx context.Context, endpointNew EndpointAddEditDTO) (EndpointDB, error)
	EditEndpoint(ctx context.Context, endpointID int, endpointEdit EndpointAddEditDTO) (EndpointDB, error)
	DeleteEndpoint(ctx context.Context, endpointID int) error
}

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