api

type BaseClient interface {
	Domain() string

	Stop() error
}

type CurrentStateHandler interface {
	HandleCurrentStateEvent(domain string, activityID string, currentState *types.Inventory)
}

type DesiredStateClient interface {
	BaseClient

	Start(StateHandler) error

	SendDesiredState(string, *types.DesiredState) error
	SendDesiredStateCommand(string, *types.DesiredStateCommand) error
	SendCurrentStateGet(string) error
}

type DesiredStateFeedbackHandler interface {
	HandleDesiredStateFeedbackEvent(domain string, activityID string, baseline string, status types.StatusType, message string, actions []*types.Action)
}

type OwnerConsentAgentClient interface {
	BaseClient

	Start(OwnerConsentAgentHandler) error
	SendOwnerConsentFeedback(string, *types.OwnerConsentFeedback) error
}

type OwnerConsentAgentHandler interface {
	HandleOwnerConsent(string, int64, *types.OwnerConsent) error
}

type OwnerConsentClient interface {
	BaseClient

	Start(OwnerConsentHandler) error
	SendOwnerConsent(string, *types.OwnerConsent) error
}

type OwnerConsentHandler interface {
	HandleOwnerConsentFeedback(string, int64, *types.OwnerConsentFeedback) error
}

type StateHandler interface {
	HandleDesiredStateFeedback(string, int64, *types.DesiredStateFeedback) error
	HandleCurrentState(string, int64, *types.Inventory) error
}

type UpdateAgent interface {
	Start(context.Context) error
	Stop() error
}

type UpdateAgentClient interface {
	BaseClient

	Start(UpdateAgentHandler) error

	SendCurrentState(string, *types.Inventory) error
	SendDesiredStateFeedback(string, *types.DesiredStateFeedback) error
}

type UpdateAgentHandler interface {
	HandleDesiredState(string, int64, *types.DesiredState) error
	HandleDesiredStateCommand(string, int64, *types.DesiredStateCommand) error
	HandleCurrentStateGet(string, int64) error
}

type UpdateManager interface {
	Name() string

	SetCallback(callback UpdateManagerCallback)
	WatchEvents(ctx context.Context)

	Apply(ctx context.Context, activityID string, desiredState *types.DesiredState)
	Command(ctx context.Context, activityID string, command *types.DesiredStateCommand)
	Get(ctx context.Context, activityID string) (*types.Inventory, error)

	Dispose() error
}

type UpdateManagerCallback interface {
	DesiredStateFeedbackHandler
	CurrentStateHandler
}

type UpdateManagerConfig struct {
	Name           string `json:"-"`
	RebootRequired bool   `json:"rebootRequired"`
	ReadTimeout    string `json:"readTimeout"`
}

type UpdateOrchestrator interface {
	Apply(context.Context, map[string]UpdateManager, string, *types.DesiredState, DesiredStateFeedbackHandler) bool

	DesiredStateFeedbackHandler
	OwnerConsentHandler
}