actions

type Action struct {
	Name        string       `yaml:"name"`
	Description string       `yaml:"description"`
	On          OnEvents     `yaml:"on"`
	Hooks       []ActionHook `yaml:"hooks"`
}

type ActionHook struct {
	ID          string            `yaml:"id"`
	Type        HookType          `yaml:"type"`
	Description string            `yaml:"description"`
	Properties  map[string]string `yaml:"properties"`
}

type ActionOn struct {
	Branches []string `yaml:"branches"`
}

type Deps struct {
	Source Source
	Output OutputWriter
}

type Event struct {
	EventID       uuid.UUID
	EventType     EventType
	EventTime     time.Time
	RepositoryID  string
	BranchID      string
	SourceRef     string
	CommitMessage string
	Committer     string
	Metadata      map[string]string
}

type EventType string

type FileRef struct {
	Path    string
	Address string
}

type Hook interface {
	Run(ctx context.Context, event Event, writer *HookOutputWriter) error
}

type HookOutputWriter struct {
	RunID      string
	ActionName string
	HookID     string
	Writer     OutputWriter
}

type HookType string

type MatchSpec struct {
	EventType EventType
	Branch    string
}

type NewHookFunc func(ActionHook, *Action) (Hook, error)

type OnEvents struct {
	PreMerge  *ActionOn `yaml:"pre-merge"`
	PreCommit *ActionOn `yaml:"pre-commit"`
}

type OutputWriter interface {
	OutputWrite(ctx context.Context, name string, reader io.Reader, size int64) error
}

type RunResult struct {
	RunID      string
	BranchID   string
	OnRef      string
	ActionName string
	EventType  EventType
	StartTime  time.Time
	EndTime    time.Time
	Passed     bool
}

type RunResultIter interface {
	Next() bool
	Value() RunResult
	// SeekGE seeks by start-time
	SeekGE(time.Time)
	Err() error
	Close()
}

type Service struct {
	DB db.Database
}

type Source interface {
	List(ctx context.Context) ([]FileRef, error)
	Load(ctx context.Context, name FileRef) ([]byte, error)
}

type Task struct {
	RunID  string
	Action *Action
	HookID string
	Hook   Hook
}

type TaskResult struct {
	RunID      string
	HookID     string
	HookType   string
	ActionName string
	StartTime  time.Time
	EndTime    time.Time
	Passed     bool
}

type TaskResultIter interface {
	Next() bool
	Value() TaskResult
	// SeekGE seeks by start-time
	SeekGE(time.Time)
	Err() error
	Close()
}

type Webhook struct {
	ID         string
	ActionName string
	URL        string
	Timeout    time.Duration
}

type WebhookEventInfo struct {
	EventType     string            `json:"event_type"`
	EventTime     string            `json:"event_time"`
	ActionName    string            `json:"action_name"`
	HookID        string            `json:"hook_id"`
	RepositoryID  string            `json:"repository_id"`
	BranchID      string            `json:"branch_id"`
	SourceRef     string            `json:"source_ref"`
	CommitMessage string            `json:"commit_message"`
	Committer     string            `json:"committer"`
	Metadata      map[string]string `json:"metadata"`
}