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 string `json:"startValid,omitempty"`
	// EndValid defines the optional end time that this endpoint stops being valid
	EndValid string `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 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 NewEditEndpoint 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 string `json:"startValid,omitempty"`
	// EndValid defines the optional end time that this endpoint stops being valid, RFC3339
	EndValid string `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 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

	NewEndpoint(ctx context.Context, endpoint EndpointDB) (EndpointDB, error)
	EditEndpoint(ctx context.Context, e EndpointDB) error
	DeleteEndpoint(ctx context.Context, endpointID int) error
}

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