domain

type BootParam string

type EntrypointDto struct {
	Msg  string `yaml:"msg" json:"msg"`
	Bus  string `yaml:"bus" json:"bus"`
	Step string `yaml:"step" json:"step"`
}

type OperationDto struct {
	Name   string `yaml:"name,omitempty" json:"name,omitempty"`
	Bus    string `yaml:"bus" json:"bus"`
	OnDone string `yaml:"onDone" json:"onDone,omitempty"`
	OnFail string `yaml:"onFail" json:"onFail,omitempty"`
}

type SagaDto struct {
	Kind        string          `yaml:"kind" json:"-"`
	Id          string          `yaml:"id" json:"id"`
	Name        string          `yaml:"name,omitempty" json:"name,omitempty"`
	Bus         string          `yaml:"bus" json:"bus"`
	Timeout     string          `yaml:"timeout,omitempty" json:"timeout,omitempty"`
	Entrypoints []EntrypointDto `yaml:"entrypoints" json:"entrypoints,omitempty"`
	Steps       []StepDto       `yaml:"steps" json:"steps,omitempty"`
}

type SagaServiceConfig struct {
	Dir string `config:"sagas-dir,required"`
	Ext string `config:"sagas-ext,required"`
}

type Service interface {
	Register(dto SagaDto) error
}

type StepDto struct {
	Id         string         `yaml:"id" json:"id"`
	Name       string         `yaml:"name,omitempty" json:"name,omitempty"`
	Timeout    string         `yaml:"timeout,omitempty" json:"timeout,omitempty"`
	Skip       []string       `yaml:"skip,omitempty" json:"skip,omitempty"`
	Operations []OperationDto `yaml:"operations" json:"operations"`
	After      string         `yaml:"after" json:"after,omitempty"`
}