activities

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

type ApprovalPlan struct {
	RunnerJobType app.RunnerJobType `json:"runner_job_type" temporaljson:"runner_job_type,omitempty"`
	PlanContents  []byte            `json:"plan_contents" temporaljson:"plan_contents,omitempty"`
}

type CheckNoopPlanRequest struct {
	StepTargetID string `validate:"required"`
}

type CheckOrgFeatureRequest struct {
	Feature string `validate:"required"`
}

type CheckWorkflowRetryableRequest struct {
	WorkflowID string `json:"workflow_id" validate:"required"`
}

type CheckWorkflowRetryableResponse struct {
	Retryable bool `json:"retryable"`
}

type CreateFlowStep struct {
	ID                  string                        `json:"id"`
	FlowID              string                        `json:"flow_id" validate:"required"`
	OwnerID             string                        `json:"owner_id" validate:"required"`
	OwnerType           string                        `json:"owner_type" validate:"required"`
	Status              app.CompositeStatus           `json:"status"`
	Name                string                        `json:"name"`
	Idx                 int                           `json:"idx"`
	ExecutionType       app.WorkflowStepExecutionType `json:"execution_type"`
	Metadata            pgtype.Hstore                 `json:"metadata"`
	Retryable           bool                          `json:"retryable"`
	Skippable           bool                          `json:"skippable"`
	GroupIdx            int                           `json:"group_idx"`
	GroupRetryIdx       int                           `json:"group_retry_idx"`
	WorkflowStepGroupID string                        `json:"workflow_step_group_id"`
	StepTargetType      string                        `json:"step_target_type"`
	StepTargetID        string                        `json:"step_target_id"`
	RetryIndex          int                           `json:"retry_index"`
	Timeout             time.Duration                 `json:"timeout"`

	StepQueueID   string `json:"step_queue_id"`
	TargetQueueID string `json:"target_queue_id"`

	// TODO(jm): this is being deprecated
	Signal      *app.Signal          `json:"signal"`
	QueueSignal *signaldb.SignalData `json:"queue_signal"`
}

type CreateFlowStepGroup struct {
	ID         string              `json:"id"`
	WorkflowID string              `json:"workflow_id" validate:"required"`
	GroupIdx   int                 `json:"group_idx"`
	Parallel   bool                `json:"parallel"`
	Name       string              `json:"name"`
	Status     app.CompositeStatus `json:"status"`
	Timeout    time.Duration       `json:"timeout"`
}

type CreateFlowStepGroupsRequest struct {
	Groups []CreateFlowStepGroup `json:"groups" validate:"required"`
}

type CreateFlowStepsRequest struct {
	Steps []CreateFlowStep `json:"steps" validate:"required"`
}

type CreateStepApprovalResponseRequest struct {
	StepApprovalID string                       `json:"step_approval_id" validate:"required"`
	Type           app.WorkflowStepResponseType `json:"type" validate:"required"`
	Note           string                       `json:"note" validate:"required"`
}

type CreateWorkflowRunRequest struct {
	WorkflowID    string              `json:"workflow_id" validate:"required"`
	Type          app.WorkflowRunType `json:"type" validate:"required"`
	TriggerStepID string              `json:"trigger_step_id,omitempty"`
	StartFromIdx  int                 `json:"start_from_idx"`
}

type EvaluateSinglePolicyRequest struct {
	PolicyID      string `json:"policy_id" validate:"required"`
	PolicyName    string `json:"policy_name"`
	Contents      string `json:"contents" validate:"required"`
	InputJSON     []byte `json:"input_json" validate:"required"`
	InputIndex    int    `json:"input_index"`                // Index of the input document being evaluated
	InputIdentity string `json:"input_identity" validate:""` // Human-readable input reference
}

type EvaluateSinglePolicyResult struct {
	Violations []PolicyViolation `json:"violations" temporaljson:"violations,omitempty"`
}

type ForwardApprovePlanRequest struct {
	StepID             string `json:"step_id" validate:"required"`
	ApprovalResponseID string `json:"approval_response_id"`
	ResponseType       string `json:"response_type"`
}

type ForwardApprovePlanResponse struct {
	StepID string `json:"step_id"`
}

type ForwardApproveStepToGroupRequest struct {
	StepID             string `json:"step_id" validate:"required"`
	StepGroupID        string `json:"step_group_id" validate:"required"`
	ApprovalResponseID string `json:"approval_response_id"`
	ResponseType       string `json:"response_type"`
}

type ForwardApproveStepToGroupResponse struct{}

type ForwardCancelStepRequest struct {
	StepID string `json:"step_id" validate:"required"`
}

type ForwardCancelStepResponse struct {
	StepID string `json:"step_id"`
}

type ForwardCancelStepToGroupRequest struct {
	StepID      string `json:"step_id" validate:"required"`
	StepGroupID string `json:"step_group_id" validate:"required"`
}

type ForwardCancelStepToGroupResponse struct{}

type ForwardCreateStepRetryRequest struct {
	StepID string `json:"step_id" validate:"required"`
}

type ForwardCreateStepRetryResponse struct {
	StepID    string `json:"step_id"`
	NewStepID string `json:"new_step_id"`
	Directive string `json:"directive"`
}

type ForwardGroupFinishedRequest struct {
	StepGroupID string `json:"step_group_id" validate:"required"`
}

type ForwardIsRetryableRequest struct {
	StepID string `json:"step_id" validate:"required"`
}

type ForwardIsRetryableResponse struct {
	Retryable  bool   `json:"retryable"`
	Skippable  bool   `json:"skippable"`
	AutoRetry  bool   `json:"auto_retry"`
	MaxRetries int    `json:"max_retries"`
	RetryGroup bool   `json:"retry_group"`
	RetryIndex int    `json:"retry_index"`
	StepID     string `json:"step_id"`
}

type ForwardRetryStepToGroupRequest struct {
	StepID      string `json:"step_id" validate:"required"`
	StepGroupID string `json:"step_group_id" validate:"required"`
}

type ForwardRetryStepToGroupResponse struct {
	Retryable bool `json:"retryable"`
}

type ForwardSkipStepRequest struct {
	StepID string `json:"step_id" validate:"required"`
}

type ForwardSkipStepResponse struct {
	StepID string `json:"step_id"`
}

type ForwardSkipStepToGroupRequest struct {
	StepID      string `json:"step_id" validate:"required"`
	StepGroupID string `json:"step_group_id" validate:"required"`
}

type ForwardSkipStepToGroupResponse struct {
	Skippable bool `json:"skippable"`
}

type ForwardStepFinishedRequest struct {
	StepID string `json:"step_id" validate:"required"`
}

type GetApprovalPlanRequest struct {
	StepTargetID string `validate:"required"`
}

type GetFlowRequest struct {
	ID string `validate:"required"`
}

type GetFlowStepRequest struct {
	FlowStepID string `json:"flow_step_id" validate:"required"`
}

type GetFlowStepsRequest struct {
	FlowID string `json:"flow_id" validate:"required"`
}

type GetRunnerJobExecutionRequest struct {
	RunnerJobID string `validate:"required"`
}

type GetRunnerJobExecutionResultRequest struct {
	RunnerJobExecutionID string `validate:"required"`
}

type GetRunnerJobRequest struct {
	RunnerJobOwnerID string `validate:"required"`
}

type GetStalePlanThresholdRequest struct{}

type GetStepErrorHintsRequest struct {
	StepID string `json:"step_id" validate:"required"`
}

type GetStepErrorHintsResponse struct {
	Hints compositeerrors.Hints `json:"hints,omitempty"`
}

type GroupFinishedResponse struct {
	Directive string `json:"directive"`
}

type Params struct {
	fx.In

	DB          *gorm.DB `name:"psql"`
	CHDB        *gorm.DB `name:"ch"`
	AppsHelpers *appshelpers.Helpers
	TClient     temporalclient.Client
	Cfg         *internal.Config
}

type PersistPolicyReportRequest struct {
	OrgID                          string            `json:"org_id" validate:"required"`
	AppID                          string            `json:"app_id" validate:"required"`
	InstallID                      *string           `json:"install_id"`
	InstallSandboxID               *string           `json:"install_sandbox_id"`
	ComponentID                    *string           `json:"component_id"`
	ComponentBuildID               *string           `json:"component_build_id"`
	WorkflowStepPolicyValidationID *string           `json:"workflow_step_policy_validation_id"`
	RunnerJobID                    *string           `json:"runner_job_id"`
	OwnerID                        string            `json:"owner_id" validate:"required"`
	OwnerType                      string            `json:"owner_type" validate:"required"`
	Violations                     []PolicyViolation `json:"violations"`
	PolicyIDs                      []string          `json:"policy_ids"`
	PolicyInputCounts              map[string]int    `json:"policy_input_counts"`
	DenyCount                      int               `json:"deny_count"`
	WarnCount                      int               `json:"warn_count"`
	PassCount                      int               `json:"pass_count"`

	// Human-readable names for display in reports
	OrgName       string `json:"org_name"`
	AppName       string `json:"app_name"`
	InstallName   string `json:"install_name"`
	ComponentName string `json:"component_name"`
}

type PersistPolicyReportResult struct {
	ReportID        string   `json:"report_id" temporaljson:"report_id,omitempty"`
	DenyCount       int      `json:"deny_count" temporaljson:"deny_count,omitempty"`
	WarnCount       int      `json:"warn_count" temporaljson:"warn_count,omitempty"`
	PassCount       int      `json:"pass_count" temporaljson:"pass_count,omitempty"`
	PassedPolicyIDs []string `json:"passed_policy_ids" temporaljson:"passed_policy_ids,omitempty"`
}

type PolicyToEvaluate struct {
	PolicyID      string `json:"policy_id" temporaljson:"policy_id,omitempty"`
	PolicyName    string `json:"policy_name" temporaljson:"policy_name,omitempty"`
	Contents      string `json:"contents" temporaljson:"contents,omitempty"`
	InputJSON     []byte `json:"input_json" temporaljson:"input_json,omitempty"`
	InputIndex    int    `json:"input_index" temporaljson:"input_index,omitempty"`       // Index of the input document
	InputIdentity string `json:"input_identity" temporaljson:"input_identity,omitempty"` // Human-readable input reference
}

type PolicyViolation = app.PolicyViolation

type PrepPolicyEvaluationRequest struct {
	StepTargetID   string `validate:"required"`
	StepTargetType string `validate:"required"`
}

type PrepPolicyEvaluationResult struct {
	Policies         []PolicyToEvaluate `json:"policies" temporaljson:"policies,omitempty"`
	HasPolicies      bool               `json:"has_policies" temporaljson:"has_policies,omitempty"`
	OrgID            string             `json:"org_id" temporaljson:"org_id,omitempty"`
	AppID            string             `json:"app_id" temporaljson:"app_id,omitempty"`
	InstallID        *string            `json:"install_id" temporaljson:"install_id,omitempty"`
	InstallSandboxID *string            `json:"install_sandbox_id" temporaljson:"install_sandbox_id,omitempty"`
	ComponentID      *string            `json:"component_id" temporaljson:"component_id,omitempty"`
	ComponentBuildID *string            `json:"component_build_id" temporaljson:"component_build_id,omitempty"`
	PolicyIDs        []string           `json:"policy_ids" temporaljson:"policy_ids,omitempty"`
	InputCount       int                `json:"input_count" temporaljson:"input_count,omitempty"`

	// Human-readable names for display in reports
	OrgName       string `json:"org_name" temporaljson:"org_name,omitempty"`
	AppName       string `json:"app_name" temporaljson:"app_name,omitempty"`
	InstallName   string `json:"install_name" temporaljson:"install_name,omitempty"`
	ComponentName string `json:"component_name" temporaljson:"component_name,omitempty"`
}

type ResetFlowFinishedAtRequest struct {
	ID string `validate:"required"`
}

type StepFinishedResponse struct {
	StepID    string     `json:"step_id"`
	Status    app.Status `json:"status"`
	Directive string     `json:"directive"`
}

type SyncNoopDeployOutputsRequest struct {
	StepID string `validate:"required"`
}

type UpdateFlowFinishedAtRequest struct {
	ID string `validate:"required"`
}

type UpdateFlowResultDirectiveRequest struct {
	FlowID    string `validate:"required"`
	Directive string // empty string is valid (used to clear the directive)
}

type UpdateFlowStartedAtRequest struct {
	ID string `validate:"required"`
}

type UpdateFlowStepFinishedAtRequest struct {
	ID string `validate:"required"`
}

type UpdateFlowStepGroupResultDirectiveRequest struct {
	StepGroupID string `validate:"required"`
	Directive   string // empty string is valid (used to clear the directive)
}

type UpdateFlowStepResultDirectiveRequest struct {
	StepID    string `validate:"required"`
	Directive string // empty string is valid (used to clear the directive)
}

type UpdateFlowStepRetriedRequest struct {
	StepID string `validate:"required"`
}

type UpdateFlowStepStartedAtRequest struct {
	ID string `validate:"required"`
}

type UpdateFlowStepTargetStatusRequest struct {
	StepID            string     `validate:"required"`
	Status            app.Status `validate:"required"`
	StatusDescription string
}

type UpdateWorkflowRunStatusRequest struct {
	RunID  string              `json:"run_id" validate:"required"`
	Status app.CompositeStatus `json:"status" validate:"required"`
}