model

type ActionDef struct {
	Id             int              `json:"id"`
	Type           string           `json:"type"`
	Name           string           `json:"name"`
	InputParams    map[string]any   `json:"parameters"`
	Next           map[string][]int `json:"next"`
	Expression     string           `json:"expression"`
	Join           int              `json:"join"`
	DelaySeconds   int              `json:"delaySeconds"`
	Event          string           `json:"event"`
	TimeoutSeconds int              `json:"timeoutSeconds"`
}

type ActionDefinition struct {
	Name              string      `json:"name"`
	RetryCount        int         `json:"retry_count"`
	RetryAfterSeconds int         `json:"retry_after_seconds"`
	RetryPolicy       RetryPolicy `json:"retry_policy"`
	TimeoutSeconds    int         `json:"timeout_seconds"`
}

type ActionExecutionRequest struct {
	WorkflowName string
	FlowId       string
	ActionId     int
	ActionName   string
	ActionType   ActionType
}

type ActionType string

type FlowContext struct {
	Id               string         `json:"id"`
	CurrentActionIds map[int]int    `json:"currentActionIds"`
	Data             map[string]any `json:"data"`
	State            FlowState      `json:"flowState"`
	Event            string         `json:"event"`
	ExecutedActions  map[int]bool   `json:"executedActions"`
}

type FlowExecutionRequest struct {
	WorkflowName string
	FlowId       string
	Event        string
	ActionId     int
	DataMap      map[string]any
	RequestType  FlowExecutionType
}

type FlowExecutionType string

type FlowState string

type FlowStateChangeRequest struct {
	WorkflowName string
	FlowId       string
	State        FlowState
}

type RetryPolicy string

type Workflow struct {
	Name       string      `json:"name"`
	RootAction int         `json:"rootAction"`
	Actions    []ActionDef `json:"actions"`
	OnFailure  string      `json:"onFailure"`
	OnSuccess  string      `json:"onSuccess"`
}

type WorkflowEvent struct {
	Name   string `json:"name"`
	FlowId string `json:"flowId"`
	Event  string `json:"event"`
}

type WorkflowRequest struct {
	Name   string `json:"name"`
	FlowId string `json:"flowId"`
}

type WorkflowRunRequest struct {
	Name  string         `json:"name"`
	Input map[string]any `json:"input"`
}