executeflow

type AppendStepRequest struct {
	Name          string                        `json:"name"`
	Signal        signaldb.SignalData           `json:"signal"`
	ExecutionType app.WorkflowStepExecutionType `json:"execution_type,omitempty"`
	// StepTargetType / StepTargetID identify the work this step drives (e.g. an
	// the inner signal's target row). StepTargetID also
	// serves as the append idempotency key: a retried append (Temporal update
	// retry or HTTP retry) with the same StepTargetID returns the existing
	// group/step instead of creating a duplicate.
	StepTargetType string `json:"step_target_type,omitempty"`
	StepTargetID   string `json:"step_target_id,omitempty"`
	Retryable      bool   `json:"retryable,omitempty"`
	Skippable      bool   `json:"skippable,omitempty"`
}

type AppendStepResponse struct {
	WorkflowID string `json:"workflow_id"`
	GroupID    string `json:"group_id"`
	StepID     string `json:"step_id"`
}

type ApproveStepRequest struct {
	StepID             string `json:"step_id"`
	ApprovalResponseID string `json:"approval_response_id"`
	ResponseType       string `json:"response_type"`
}

type ApproveStepResponse struct {
	WorkflowID string `json:"workflow_id"`
}

type CancelGroupRequest struct {
	// StepID is any step in the group to cancel. The handler resolves the
	// group from this step's GroupIdx and cancels all in-flight steps.
	StepID string `json:"step_id"`
}

type CancelGroupResponse struct {
	WorkflowID string `json:"workflow_id"`
}

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

type CancelStepResponse struct {
	WorkflowID string `json:"workflow_id"`
}

type CancelWorkflowResponse struct {
	WorkflowID string `json:"workflow_id"`
}

type IsRetryableResponse struct {
	Retryable bool   `json:"retryable"`
	StepID    string `json:"step_id"`
}

type PollNextStepResponse struct {
	StepID  string     `json:"step_id"`
	StepIdx int        `json:"step_idx"`
	Status  app.Status `json:"status"`
}

type RetryGroupRequest struct {
	// StepID is any step in the group to retry. The handler resolves the
	// group from this step's GroupIdx.
	StepID string `json:"step_id"`
}

type RetryGroupResponse struct {
	WorkflowID string `json:"workflow_id"`
	Retryable  bool   `json:"retryable"`
}

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

type RetryStepResponse struct {
	WorkflowID string `json:"workflow_id"`
	Retryable  bool   `json:"retryable"`
}

type Signal struct {
	// WorkflowID is the ID of the workflow to execute.
	WorkflowID string `json:"workflow_id"`

	// WorkflowType / OrgID / OrgName are resolved during Validate() from the
	// in-scope workflow record so the lifecycle hook can emit workflow.lifecycle
	// events without a fresh DB lookup. Empty until Validate runs.
	WorkflowType string `json:"workflow_type,omitempty"`
	OrgID        string `json:"org_id,omitempty"`
	OrgName      string `json:"org_name,omitempty"`

	// Conductor configuration — set by the creator when enqueuing.
	StepGroupQueueName     string `json:"step_group_queue_name"`
	StepQueueName          string `json:"step_queue_name"`
	StepTargetQueueName    string `json:"step_target_queue_name"`
	GenerateStepsQueueName string `json:"generate_steps_queue_name"`
	OwnerID                string `json:"owner_id"`
	OwnerType              string `json:"owner_type"`
	// OwnerName is the human-readable owner label resolved during Validate()
	// (e.g. install/app/app_branch name). Stamped onto SignalLifecycleContext
	// so workflow lifecycle webhook payloads carry owner_name without a
	// per-event DB lookup.
	OwnerName string `json:"owner_name,omitempty"`

	// Resident keeps the workflow alive after it runs 0->end: instead of
	// completing, the execute loop parks to accept run-a-step-in-between
	// updates (append/retry a step). Gated so ordinary workflows keep exact
	// run-to-completion semantics. Bounded by residentIdleTimeout — on idle
	// the loop returns cleanly and the workflow re-warms on the next dispatch.
	Resident bool `json:"resident,omitempty"`
	// contains filtered or unexported fields
}

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

type SkipStepResponse struct {
	WorkflowID string `json:"workflow_id"`
	Skippable  bool   `json:"skippable"`
}