activities

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

type ChildWorkflowInput struct {
	WorkflowName string                 `json:"workflow_name"`
	Sync         bool                   `json:"sync"`
	Inputs       map[string]interface{} `json:"inputs"`
	Timeout      float64                `json:"timeout"`
	ParentID     string                 `json:"parent_id"`
}

type FailActivity struct{}

type FailInput struct {
	Message string `json:"message"`
}

type FailOutput struct{}

type FileActivity struct{}

type FileInput struct {
	Operation   string `json:"operation"`   // read, write, append, delete, exists, mkdir, list
	Path        string `json:"path"`        // file or directory path
	Content     string `json:"content"`     // content to write (for write/append operations)
	Permissions string `json:"permissions"` // file permissions (e.g., "0644", "0755")
	CreateDirs  bool   `json:"create_dirs"` // create parent directories if they don't exist
}

type HTTPActivity struct{}

type HTTPInput struct {
	URL             string            `json:"url"`
	Method          string            `json:"method"` // GET, POST, PUT, DELETE, etc.
	Headers         map[string]string `json:"headers"`
	Body            string            `json:"body"`             // JSON string or plain text
	JSONPayload     map[string]any    `json:"json_payload"`     // Alternative to body for JSON
	Timeout         float64           `json:"timeout"`          // in seconds, default 30
	FollowRedirects bool              `json:"follow_redirects"` // default true
}

type HTTPOutput struct {
	StatusCode    int               `json:"status_code"`
	Status        string            `json:"status"`
	Headers       map[string]string `json:"headers"`
	Body          string            `json:"body"`
	JSONResponse  map[string]any    `json:"json_response,omitempty"`
	Success       bool              `json:"success"`
	ContentLength int64             `json:"content_length"`
}

type JSONActivity struct{}

type JSONInput struct {
	Operation string `json:"operation"`  // parse, stringify, query, merge, validate
	Data      string `json:"data"`       // JSON string to work with
	Query     string `json:"query"`      // JSONPath-like query (simplified)
	MergeWith string `json:"merge_with"` // JSON string to merge with
}

type PrintActivity struct{}

type PrintInput struct {
	Message string `json:"message"`
	Args    []any  `json:"args"`
}

type RandomActivity struct{}

type RandomInput struct {
	Type    string   `json:"type"`    // uuid, number, string, choice, boolean
	Min     float64  `json:"min"`     // minimum value for number generation
	Max     float64  `json:"max"`     // maximum value for number generation
	Length  int      `json:"length"`  // length for string generation
	Choices []string `json:"choices"` // choices for selection
	Count   int      `json:"count"`   // number of items to generate
	Charset string   `json:"charset"` // character set for string generation
	Seed    int64    `json:"seed"`    // seed for reproducible randomness
}

type ScriptActivity struct{}

type ScriptParams struct {
	Code string `json:"code"`
}

type ShellActivity struct{}

type ShellInput struct {
	Command     string            `json:"command"`
	Args        []string          `json:"args"`
	WorkingDir  string            `json:"working_dir"`
	Environment map[string]string `json:"environment"`
	Timeout     float64           `json:"timeout"` // in seconds, 0 means no timeout
}

type TimeActivity struct{}

type TimeInput struct {
	UTC bool `json:"utc"`
}

type WaitActivity struct{}

type WaitInput struct {
	Seconds float64 `json:"seconds"`
}