engine

type APIStep struct {
	Endpoint       string            `json:"endpoint" yaml:"endpoint"`
	Method         string            `json:"method" yaml:"method"`
	IncludeHeaders bool              `json:"include-headers" yaml:"include-headers"`
	CustomHeaders  map[string]string `json:"custom-headers" yaml:"custom-headers"`
	Payload        interface{}       `json:"payload" yaml:"payload"`
}

type Authorizer struct {
	Type    string `json:"type" yaml:"type"`
	AKey    string `json:"key" yaml:"key"`
	Input   string `json:"input" yaml:"input"`
	ExePath string `json:"exe-path" yaml:"exe-path"`
	Handler string `json:"handler" yaml:"handler"`
}

type CORS struct {
	AllowOrigin  string `json:"allow-origin" yaml:"allow-origin" default:"*"`
	AllowMethods string `json:"allow-methods" yaml:"allow-methods" default:"*"`
	AllowHeaders string `json:"allow-headers" yaml:"allow-headers" default:"*"`
	MaxAge       int64  `json:"maxage" yaml:"maxage"`
}

type Config struct {
	Port   int
	Prefix string
}

type ExecuteStep interface {
	Execute(*Workflow, map[string][]string, queryParams, map[string]interface{}) (interface{}, error)
}

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

type LogicStep struct {
	Runtime constants.Runtime `json:"runtime" yaml:"runtime"`
	ExePath string            `json:"exe-path" yaml:"exe-path"`
	Handler string            `json:"handler" yaml:"handler"`
	Params  interface{}       `json:"params" yaml:"params"`
}

type PrimaryKey struct {
	PKey  string `json:"key" yaml:"key"`
	Input string `json:"input" yaml:"input"`
}

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

type Step struct {
	LogicStep     `yaml:",inline"`
	APIStep       `yaml:",inline"`
	Name          string             `json:"name" yaml:"name"`
	ID            string             `json:"id" yaml:"id"`
	Type          constants.StepType `json:"type" yaml:"type"`
	Async         bool               `json:"async" yaml:"async"`
	Authorize     bool               `json:"authorize" yaml:"authorize"`
	Delay         string             `json:"delay" yaml:"delay"`
	Timeout       string             `json:"timeout" yaml:"timeout"`
	NextStep      string             `json:"next-step" yaml:"next-step"`
	Users         []string           `json:"users" yaml:"users"`
	Break         bool               `json:"break" yaml:"break"`
	Error         *StepError         `json:"on-error" yaml:"on-error"`
	PreCondition  interface{}        `json:"pre-condition" yaml:"pre-condition"`
	PostCondition interface{}        `json:"post-condition" yaml:"post-condition"`
}

type StepError struct {
	Retry bool   `json:"retry" yaml:"retry"`
	Goto  string `json:"goto" yaml:"goto"`
}

type Workflow struct {
	Name       string                 `json:"name" yaml:"name"`
	ID         string                 `json:"id" yaml:"id"`
	Version    string                 `json:"version" yaml:"version"`
	PrimaryKey []PrimaryKey           `json:"primary-key" yaml:"primary-key"`
	Authorizer *Authorizer            `json:"authorizer" yaml:"authorizer"`
	CORS       map[string]interface{} `json:"cors" yaml:"cors"`
	Steps      []Step                 `json:"steps" yaml:"steps"`
}