types

type Action string

type AgentData struct {
	Action  Action `json:"action" validate:"required,oneof=pull ack online offline message"`
	Version int    `json:"version" validate:"gte=0"`
	Content KV     `json:"content"`
}

type BotEvent struct {
	EventName string
	Uid       string
	Topic     string
	Param     KV
}

type ChartMsg struct {
	Title    string    `json:"title"`
	SubTitle string    `json:"sub_title"`
	XAxis    []string  `json:"x_axis"`
	Series   []float64 `json:"series"`
}

type Context struct {

	// TraceCtx carries the OpenTelemetry trace context for span propagation.
	// Set via SetTraceContext before calling SetTimeout to inherit the trace parent.
	TraceCtx context.Context

	// Message ID denormalized
	Id string
	// chat platform
	Platform string
	// channel or group
	Topic string
	// Sender's UserId as string.
	AsUser Uid

	// form Rule id
	FormRuleId string
	// form id
	FormId string

	// workflow rule id
	WorkflowRuleId string

	// event rule id
	EventRuleId string

	// HTTP method
	Method string
	// HTTP headers
	Headers map[string][]string
	// contains filtered or unexported fields
}

type DataEvent struct {
	EventID        string    `json:"event_id"`
	EventType      string    `json:"event_type"`
	Source         string    `json:"source"`
	Capability     string    `json:"capability"`
	Operation      string    `json:"operation"`
	Backend        string    `json:"backend"`
	App            string    `json:"app"`
	EntityID       string    `json:"entity_id"`
	CreatedAt      time.Time `json:"created_at"`
	IdempotencyKey string    `json:"idempotency_key"`
	UID            string    `json:"uid"`
	Topic          string    `json:"topic"`
	Data           KV        `json:"data"`
	Tags           KV        `json:"tags,omitempty"`
}

type DataFilter struct {
	Prefix       *string
	CreatedStart *time.Time
	CreatedEnd   *time.Time
}

type DurationDistribution struct {
	Pipeline []DurationEntry `json:"pipeline"`
	Step     []DurationEntry `json:"step"`
}

type DurationEntry struct {
	Bucket string `json:"bucket"`
	Count  int64  `json:"count"`
}

type EmptyMsg struct{}

type Error struct {
	Kind       error
	Code       string
	Message    string
	Capability string
	Operation  string
	Provider   string
	Retryable  bool
	Cause      error
}

type EventPayload struct {
	Typ string
	Src []byte
}

type Executor struct {
	Flag string
	Run  func(data KV) error
}

type FileDef struct {
	ObjHeader `bson:",inline"`
	// Name of the file
	Name string
	// Status of upload
	Status int
	// User who created the file
	User string
	// Type of the file.
	MimeType string
	// Size of the file in bytes.
	Size int64
	// Internal file location, i.e. path on disk or an S3 blob address.
	Location string
}

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

type FormField struct {
	Type        FormFieldType      `json:"type"`
	Key         string             `json:"key"`
	Value       any                `json:"value"`
	ValueType   FormFieldValueType `json:"value_type"`
	Label       string             `json:"label"`
	Placeholder string             `json:"placeholder"`
	Option      []string           `json:"option"`
	Rule        string             `json:"rule"`
}

type FormFieldType string

type FormFieldValueType string

type FormMsg struct {
	ID    string      `json:"id"`
	Title string      `json:"title"`
	Field []FormField `json:"field"`
}

type HtmlMsg struct {
	Raw string
}

type InfoMsg struct {
	Title string `json:"title"`
	Model any    `json:"model,omitempty"`
}

type InstructMsg struct {
	No       string
	Object   schema.InstructObject
	Bot      string
	Flag     string
	Content  KV
	Priority schema.InstructPriority
	State    schema.InstructState
	ExpireAt time.Time
}

type JobFilter struct {
	EndedAt time.Time
}

type KV map[string]any

type KVMsg map[string]any

type LinkMsg struct {
	Title string `json:"title"`
	Cover string `json:"cover"`
	Url   string `json:"url"`
}

type MarkdownMsg struct {
	Title string `json:"title"`
	Raw   string `json:"raw"`
}

type Message struct {
	Platform string
	Topic    string
	Payload  EventPayload
}

type ModuleEvent = BotEvent

type Mount struct {
	Type   string `json:"type,omitempty"`
	Source string `json:"source,omitempty"`
	Target string `json:"target,omitempty"`
}

type MsgPayload interface {
	Convert() any
}

type ObjHeader struct {
	// using string to get around rethinkdb's problems with uint64;
	// `bson:"_id"` tag is for mongodb to use as primary key '_id'.
	Id string `bson:"_id"`
	//id        Uid
	CreatedAt time.Time
	UpdatedAt time.Time
}

type PipelineStats struct {
	SuccessRateTrend     []SuccessRatePoint   `json:"success_rate_trend"`
	DurationDistribution DurationDistribution `json:"duration_distribution"`
	TriggerSourcePie     []TriggerSourceCount `json:"trigger_source_pie"`
}

type Registry struct {
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

type RetryConfig struct {
	MaxAttempts int           `json:"max_attempts" yaml:"max_attempts"` // Total execution attempts; 0 or 1 means no retry.
	Delay       time.Duration `json:"delay" yaml:"delay"`
	Backoff     string        `json:"backoff" yaml:"backoff"` // fixed | linear | exponential
	MaxDelay    time.Duration `json:"max_delay" yaml:"max_delay"`
	Jitter      bool          `json:"jitter" yaml:"jitter"`
	RetryOn     []string      `json:"retry_on,omitempty" yaml:"retry_on,omitempty"`
}

type Ruler interface {
	ID() string
	TYPE() RulesetType
}

type RulesetType string

type SuccessRatePoint struct {
	Date    string  `json:"date"`
	Total   int64   `json:"total"`
	Success int64   `json:"success"`
	Rate    float64 `json:"rate"`
}

type TableMsg struct {
	Title  string   `json:"title"`
	Header []string `json:"header"`
	Row    [][]any  `json:"row"`
}

type Task struct {
	ID          string            `json:"id,omitempty"`
	State       TaskState         `json:"state,omitempty"`
	CreatedAt   *time.Time        `json:"created_at,omitempty"`
	StartedAt   *time.Time        `json:"started_at,omitempty"`
	CompletedAt *time.Time        `json:"completed_at,omitempty"`
	FailedAt    *time.Time        `json:"failed_at,omitempty"`
	CMD         []string          `json:"cmd,omitempty"`
	Entrypoint  []string          `json:"entrypoint,omitempty"`
	Run         string            `json:"run,omitempty"`
	Image       string            `json:"image,omitempty"`
	Registry    *Registry         `json:"registry,omitempty"`
	Env         map[string]string `json:"env,omitempty"`
	Files       map[string]string `json:"files,omitempty"`
	Error       string            `json:"error,omitempty"`
	Pre         []*Task           `json:"pre,omitempty"`
	Post        []*Task           `json:"post,omitempty"`
	Mounts      []Mount           `json:"mounts,omitempty"`
	Networks    []string          `json:"networks,omitempty"`
	Retry       *TaskRetry        `json:"retry,omitempty"`
	Limits      *TaskLimits       `json:"limits,omitempty"`
	Timeout     string            `json:"timeout,omitempty"`
	Result      string            `json:"result,omitempty"`
	GPUs        string            `json:"gpus,omitempty"`
}

type TaskLimits struct {
	CPUs   string `json:"cpus,omitempty"`
	Memory string `json:"memory,omitempty"`
}

type TaskRetry struct {
	Limit    int `json:"limit,omitempty"`
	Attempts int `json:"attempts,omitempty"`
}

type TaskState string

type TextMsg struct {
	Text string `json:"text"`
}

type TriggerSourceCount struct {
	Source string `json:"source"`
	Count  int64  `json:"count"`
}

type Uid string

type WorkflowMetadata struct {
	Name           string               `json:"name" yaml:"name"`
	Describe       string               `json:"describe" yaml:"describe"`
	Resumable      bool                 `json:"resumable" yaml:"resumable"`
	MaxConcurrency int                  `json:"max_concurrency" yaml:"max_concurrency"` // 0 or 1 = sequential; >1 enables DAG-based parallel execution
	Triggers       []WorkflowTriggerDef `json:"triggers" yaml:"triggers"`
	Pipeline       []string             `json:"pipeline" yaml:"pipeline"`
	Tasks          []WorkflowTask       `json:"tasks" yaml:"tasks"`
}

type WorkflowTask struct {
	ID       string       `json:"id" yaml:"id"`
	Action   string       `json:"action" yaml:"action"`
	Describe string       `json:"describe,omitempty" yaml:"describe"`
	Params   KV           `json:"params,omitempty" yaml:"params"`
	Vars     []string     `json:"vars,omitempty" yaml:"vars"`
	Conn     []string     `json:"conn,omitempty" yaml:"conn"`
	Retry    *RetryConfig `json:"retry,omitempty" yaml:"retry,omitempty"`
}

type WorkflowTriggerDef struct {
	Type string `json:"type" yaml:"type"`
	Rule KV     `json:"rule,omitempty" yaml:"rule"`
}