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"`
}

type ActionExecutionRequest struct {
	WorkflowName string `json:"wfName"`
	TaskName     string `json:"taskName"`
	FlowId       string `json:"flowId"`
	ActionId     int    `json:"actionId"`
	TryNumber    int    `json:"tryNumber"`
}

type FlowContext struct {
	Id            string         `json:"id"`
	CurrentAction int            `json:"currentAction"`
	Data          map[string]any `json:"data"`
	State         FlowState      `json:"flowState"`
	TTL           uint64         `json:"ttl"`
	Event         string         `json:"event"`
}

type FlowState string

type RetryPolicy string

type TaskDef 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 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 WorkflowRunRequest struct {
	Name  string         `json:"name"`
	Input map[string]any `json:"input"`
}