types

type APIVersionRequestURI struct {
	APIVersion string `uri:"api_version" binding:"required,flowpipe_api_version"`
}

type CmdPipeline struct {
	Command       string                 `json:"command" binding:"required,oneof=run"`
	Args          map[string]interface{} `json:"args,omitempty"`
	ArgsString    map[string]string      `json:"args_string,omitempty"`
	ExecutionMode *string                `json:"execution_mode,omitempty" binding:"omitempty,oneof=synchronous asynchronous"`
	WaitRetry     *int                   `json:"wait_retry,omitempty" binding:"omitempty"`
}

type CmdProcess struct {
	Command             string `json:"command" binding:"required,oneof=run cancel pause resume"`
	PipelineExecutionID string `json:"pipeline_execution_id,omitempty" format:"^(pexec|exec)_[0-9a-v]{20}$"`
	Reason              string `json:"reason,omitempty"`
}

type EventLogEntry struct {
	EventType string          `json:"event_type"`
	Timestamp *time.Time      `json:"ts"`
	Payload   json.RawMessage `json:"payload"`
}

type FlowpipeRequire struct {
	MinVersionString string `json:"min_version,omitempty"`
}

type FpIntegration struct {
	Name            string  `json:"name"`
	Type            string  `json:"type"`
	Description     *string `json:"description,omitempty"`
	Title           *string `json:"title,omitempty"`
	FileName        string  `json:"file_name,omitempty"`
	StartLineNumber int     `json:"start_line_number,omitempty"`
	EndLineNumber   int     `json:"end_line_number,omitempty"`
	Url             *string `json:"url,omitempty"`

	// slack
	Token         *string `json:"token,omitempty"`
	SigningSecret *string `json:"signing_secret,omitempty"`
	Channel       *string `json:"channel,omitempty"`

	// slack & msteams
	WebhookUrl *string `json:"webhook_url,omitempty"`

	// email
	SmtpHost     *string  `json:"smtp_host,omitempty"`
	SmtpTls      *string  `json:"smtp_tls,omitempty"`
	SmtpPort     *int     `json:"smtp_port,omitempty"`
	SmtpsPort    *int     `json:"smtps_port,omitempty"`
	SmtpUsername *string  `json:"smtp_username,omitempty"`
	SmtpPassword *string  `json:"smtp_password,omitempty"`
	From         *string  `json:"from,omitempty"`
	To           []string `json:"to,omitempty"`
	Cc           []string `json:"cc,omitempty"`
	Bcc          []string `json:"bcc,omitempty"`
	Subject      *string  `json:"subject,omitempty"`
}

type FpNotifier struct {
	Name            string     `json:"name"`
	Description     *string    `json:"description,omitempty"`
	Title           *string    `json:"title,omitempty"`
	Notifies        []FpNotify `json:"notifies,omitempty"`
	FileName        string     `json:"file_name,omitempty"`
	StartLineNumber int        `json:"start_line_number,omitempty"`
	EndLineNumber   int        `json:"end_line_number,omitempty"`
}

type FpNotify struct {
	Integration *string `json:"integration,omitempty"`

	Cc          []string `json:"cc,omitempty"`
	Bcc         []string `json:"bcc,omitempty"`
	Channel     *string  `json:"channel,omitempty"`
	Description *string  `json:"description,omitempty"`
	Subject     *string  `json:"subject,omitempty"`
	Title       *string  `json:"title,omitempty"`
	To          []string `json:"to,omitempty"`
}

type FpPipeline struct {
	Name            string                     `json:"name"`
	Description     *string                    `json:"description,omitempty"`
	Mod             string                     `json:"mod"`
	Title           *string                    `json:"title,omitempty"`
	Documentation   *string                    `json:"documentation,omitempty"`
	FileName        string                     `json:"file_name,omitempty"`
	StartLineNumber int                        `json:"start_line_number,omitempty"`
	EndLineNumber   int                        `json:"end_line_number,omitempty"`
	Tags            map[string]string          `json:"tags,omitempty"`
	Steps           []modconfig.PipelineStep   `json:"steps,omitempty"`
	OutputConfig    []modconfig.PipelineOutput `json:"outputs,omitempty"`
	Params          []FpPipelineParam          `json:"params,omitempty"`
	RootMod         string                     `json:"root_mod"`
}

type FpPipelineExecution struct {
	ExecutionId         string                `json:"execution_id"`
	PipelineExecutionId string                `json:"pipeline_execution_id"`
	Status              string                `json:"status"`
	PipelineName        *string               `json:"pipeline,omitempty"`
	CreatedAt           *time.Time            `json:"created_at,omitempty"`
	Outputs             map[string]any        `json:"outputs,omitempty"`
	Errors              []modconfig.StepError `json:"errors,omitempty"`
}

type FpPipelineParam struct {
	Name        string  `json:"name"`
	Description *string `json:"description,omitempty"`
	Optional    *bool   `json:"optional,omitempty"`
	Default     any     `json:"default,omitempty"`
	Type        string  `json:"type"`
}

type FpTrigger struct {
	Name            string              `json:"name"`
	Type            string              `json:"type"`
	Enabled         bool                `json:"enabled"`
	Description     *string             `json:"description,omitempty"`
	Pipelines       []FpTriggerPipeline `json:"pipelines,omitempty"`
	Url             *string             `json:"url,omitempty"`
	Title           *string             `json:"title,omitempty"`
	FileName        string              `json:"file_name,omitempty"`
	StartLineNumber int                 `json:"start_line_number,omitempty"`
	EndLineNumber   int                 `json:"end_line_number,omitempty"`
	Documentation   *string             `json:"documentation,omitempty"`
	Tags            map[string]string   `json:"tags,omitempty"`
	Schedule        *string             `json:"schedule,omitempty"`
	Query           *string             `json:"query,omitempty"`
}

type FpTriggerPipeline struct {
	CaptureGroup string `json:"capture_group"`
	Pipeline     string `json:"pipeline"`
}

type InputIDHash struct {
	ID   string `json:"id" uri:"id" binding:"required"`
	Hash string `json:"hash" uri:"hash" binding:"required"`
}

type IntegrationRequestURI struct {
	IntegrationName string `uri:"integration_name" binding:"required" format:"^[a-z_]{0,32}$"`
}

type ListIntegrationResponse struct {
	Items     []FpIntegration `json:"items"`
	NextToken *string         `json:"next_token,omitempty"`
}

type ListNotifierResponse struct {
	Items     []FpNotifier `json:"items"`
	NextToken *string      `json:"next_token,omitempty"`
}

type ListPipelineResponse struct {
	Items     []FpPipeline `json:"items"`
	NextToken *string      `json:"next_token,omitempty"`
}

type ListProcessLogJSONResponse struct {
	Items     []ProcessEventLog `json:"items"`
	NextToken *string           `json:"next_token,omitempty"`
}

type ListProcessLogResponse struct {
	Items     []EventLogEntry `json:"items"`
	NextToken *string         `json:"next_token,omitempty"`
}

type ListProcessResponse struct {
	Items     []Process `json:"items"`
	NextToken *string   `json:"next_token,omitempty"`
}

type ListRequestQuery struct {
	NextToken string `json:"next_token" form:"next_token" binding:"omitempty"`
	Limit     *int   `json:"limit,omitempty" form:"limit" binding:"omitempty"`
}

type ListTriggerResponse struct {
	Items     []FpTrigger `json:"items"`
	NextToken *string     `json:"next_token,omitempty"`
}

type ListVariableResponse struct {
	Items     []Variable `json:"items"`
	NextToken *string    `json:"next_token,omitempty"`
}

type Mod struct {
	Name          string     `json:"name"`
	Title         *string    `json:"title,omitempty"`
	Description   *string    `json:"description,omitempty"`
	Documentation *string    `json:"documentation,omitempty"`
	Color         *string    `json:"color,omitempty"`
	Categories    []string   `json:"categories,omitempty"`
	OpenGraph     *OpenGraph `json:"opengraph,omitempty"`
	Require       *Require   `json:"require,omitempty"`
}

type ModRequestURI struct {
	ModName string `uri:"mod_name" binding:"required" format:"^[a-z]{0,32}$"`
}

type ModVersionConstraint struct {
	// the fully qualified mod name, e.g. github.com/turbot/mod1
	Name          string `json:"name"`
	VersionString string `json:"version,omitempty"`
}

type NotifierRequestURI struct {
	NotifierName string `uri:"notifier_name" binding:"required" format:"^[a-z_]{0,32}$"`
}

type OpenGraph struct {
	// The opengraph description (og:description) of the mod, for use in social media applications
	Description *string `json:"description,omitempty"`
	Title       *string `json:"title,omitempty"`
}

type OutputMode enumflag.Flag

type ParsedErrorEvent struct {
	ParsedEvent
	Errors   []modconfig.StepError `json:"errors"`
	Output   map[string]any        `json:"attributes"`
	Duration *string               `json:"duration,omitempty"`
	// contains filtered or unexported fields
}

type ParsedEvent struct {
	ParsedEventPrefix
	Type     string `json:"event_type"`
	StepType string `json:"step_type"`
	Message  string `json:"message,omitempty"`
	// contains filtered or unexported fields
}

type ParsedEventPrefix struct {
	FullPipelineName string  `json:"full_pipeline_name"`
	PipelineName     string  `json:"pipeline_name"`
	FullStepName     *string `json:"full_step_name,omitempty"`
	StepName         *string `json:"step_name,omitempty"`
	ForEachKey       *string `json:"for_each_key,omitempty"`
	LoopIndex        *int    `json:"loop_index,omitempty"`
	RetryIndex       *int    `json:"retry_index,omitempty"`
	// contains filtered or unexported fields
}

type ParsedEventRegistryItem struct {
	Name    string
	Started time.Time
	Args    *modconfig.Input
}

type ParsedEventWithInput struct {
	ParsedEvent
	Input map[string]any `json:"args"`
	// contains filtered or unexported fields
}

type ParsedEventWithOutput struct {
	ParsedEvent
	Output     map[string]any `json:"attributes"`
	StepOutput map[string]any `json:"step_output"`
	Duration   *string        `json:"duration,omitempty"`
	// contains filtered or unexported fields
}

type ParsedHeader struct {
	ExecutionId string `json:"execution_id"`
	IsStale     bool   `json:"is_stale"`
	LastLoaded  string `json:"last_loaded"`
}

type PipelineExecutionResponse map[string]interface{}

type PipelineRequestQuery struct {
	ExecutionMode *string `json:"execution_mode" form:"execution_mode" binding:"omitempty,oneof=synchronous asynchronous"`
}

type PipelineRequestURI struct {
	PipelineName string `uri:"pipeline_name" binding:"required" format:"^[a-z_]{0,32}$"`
}

type PrintableIntegration struct {
	Items []FpIntegration
}

type PrintableNotifier struct {
	Items []FpNotifier
}

type PrintableParsedEvent struct {
	Items    []sanitize.SanitizedStringer
	Registry map[string]ParsedEventRegistryItem
	// contains filtered or unexported fields
}

type PrintablePipeline struct {
	Items []FpPipeline
}

type PrintablePipelineExecution struct {
	Items []FpPipelineExecution
}

type PrintableProcess struct {
	Items []Process
}

type PrintableServerOutput struct {
	Items []sanitize.SanitizedStringer
}

type PrintableTrigger struct {
	Items []FpTrigger
}

type PrintableVariable struct {
	Items []Variable
}

type Process struct {
	ID        string    `json:"execution_id"`
	Pipeline  string    `json:"pipeline"`
	Status    string    `json:"status"`
	CreatedAt time.Time `json:"created_at"`
}

type ProcessEventLog struct {
	EventType string     `json:"event_type"`
	Timestamp *time.Time `json:"ts"`
	// Setting the type as string for now, as the CLI need to print the payload
	Payload string `json:"payload"`
}

type ProcessEventLogs []ProcessEventLog

type ProcessOutputData struct {
	ID     string                 `json:"process_id"`
	Output map[string]interface{} `json:"output"`
}

type ProcessPayload struct {
	PipelineName        string              `json:"name"`
	PipelineExecutionID string              `json:"pipeline_execution_id"`
	Event               ProcessPayloadEvent `json:"event"`
}

type ProcessPayloadEvent struct {
	CreatedAt time.Time `json:"created_at"`
}

type ProcessRequestURI struct {
	// TODO: do we want to pass the ExecutionID or PipelineExecutionID? The log is stored under ExecutionID but the execution works with PipelineExecutionID
	// ProcessId string `uri:"process_id" binding:"required" format:"^(pexec|exec)_[0-9a-v]{20}$"`
	ProcessId string `uri:"process_id" binding:"required" format:"^exec_[0-9a-v]{20}$"`
}

type Require struct {
	Flowpipe *FlowpipeRequire       `json:"flowpipe,omitempty"`
	Mods     []ModVersionConstraint `json:"mods,omitempty"`
}

type SafeMap[K comparable, V any] struct {
	// contains filtered or unexported fields
}

type ServerOutput struct {
	ServerOutputPrefix
	Message string
}

type ServerOutputError struct {
	ServerOutputPrefix
	Message string
	Error   error
}

type ServerOutputLoaded struct {
	ServerOutputPrefix
	ModName  string
	IsReload bool
}

type ServerOutputPrefix struct {
	TimeStamp time.Time
	Category  string
	// contains filtered or unexported fields
}

type ServerOutputQueryTriggerRun struct {
	ServerOutputPrefix
	TriggerName string
	Inserted    int
	Updated     int
	Deleted     int
}

type ServerOutputStatusChange struct {
	ServerOutputPrefix
	Status     string
	Content    string
	Additional int
}

type ServerOutputTrigger struct {
	ServerOutputPrefix
	Name     string
	Type     string
	Enabled  *bool
	Schedule *string
	Method   *string
	Url      *string
	Sql      *string
}

type ServerOutputTriggerExecution struct {
	ServerOutputPrefix
	TriggerName  string
	PipelineName string
}

type Stack struct {
	ID         string            `json:"id"`
	Status     string            `json:"status"`
	StepStatus map[int]string    `json:"pipeline_step_status"`
	Stacks     map[string]*Stack `json:"children"`
}

type TriggerRequestURI struct {
	TriggerName string `uri:"trigger_name" binding:"required" format:"^[a-z]{0,32}$"`
}

type Variable struct {
	Type        string  `json:"type"`
	Name        string  `json:"name"`
	Description *string `json:"description,omitempty"`
	Default     any     `json:"default"`
	Value       any     `json:"value"`
}

type VariableRequestURI struct {
	VariableName string `uri:"variable_name" binding:"required" format:"^[a-z]{0,32}$"`
}

type WebhookRequestQuery struct {
	WaitTime *int `json:"wait_time" form:"wait_time" binding:"omitempty"`
}

type WebhookRequestUri struct {
	Hook string `json:"hook" uri:"hook" binding:"required"`
	Hash string `json:"hash" uri:"hash" binding:"required"`
}