core.flows #

fn new(args CoordinatorArgs) !Coordinator

enum StepStatus {
	pending
	running
	success
	error
	skipped
}

struct Coordinator {
pub mut:
	name         string
	current_step string // links to steps dict
	steps        map[string]&Step
	logger       logger.Logger
	ai           ?aiclient.AIClient
	redis        ?&redisclient.Redis
}

fn (c Coordinator) clear_redis() !

fn (c Coordinator) get_all_steps_state() ![]map[string]string

Get all steps state from redis (for UI dashboard)

fn (c Coordinator) get_step_state(step_name string) !map[string]string

Get step state from redis

fn (mut c Coordinator) run() !

Run the entire flow starting from current_step

fn (mut c Coordinator) run_step(mut step Step) !

Run a single step, including error and next steps

fn (mut c Coordinator) step_current() !&Step

fn (mut c Coordinator) step_new(args StepNewArgs) !&Step

add step to it

struct CoordinatorArgs {
pub mut:
	name  string @[required]
	redis ?&redisclient.Redis
	ai    ?aiclient.AIClient = none
}

struct Step {
pub mut:
	status      StepStatus = .pending
	started_at  i64 // Unix timestamp
	finished_at i64
	error_msg   string
	name        string
	description string
	main_step   fn (mut s Step) ! @[required]
	context     map[string]string
	error_steps []string
	next_steps  []string
	error       string
	logs        []logger.LogItem
	params      paramsparser.Params
	coordinator &Coordinator
}

fn (mut s Step) error_step_add(s2 &Step)

fn (mut s Step) next_step_add(s2 &Step)

fn (mut s Step) log(l logger.LogItemArgs) !

fn (mut s Step) store_redis() !

fn (s Step) to_json() !string

struct StepJSON {
pub:
	name        string
	description string
	status      string
	error       string
	logs_count  int
	started_at  i64
	finished_at i64
	duration    i64 // milliseconds
}

struct StepNewArgs {
pub mut:
	name        string
	description string
	f           fn (mut s Step) ! @[required]
	context     map[string]string
	error_steps []string
	next_steps  []string
	error       string
	params      paramsparser.Params
}