hooks

type Params ¶

type Params struct {
	fx.In

	Cfg *internal.Config `optional:"true"`
	L   *zap.Logger      `optional:"true"`
	DB  *gorm.DB         `name:"psql" optional:"true"`
	MW  metrics.Writer   `optional:"true"`
}

type SlackParams ¶ added in v0.19.927

type SlackParams struct {
	fx.In

	Cfg         *internal.Config    `optional:"true"`
	L           *zap.Logger         `optional:"true"`
	DB          *gorm.DB            `name:"psql" optional:"true"`
	SlackClient *slackclient.Client `optional:"true"`
	MW          metrics.Writer      `optional:"true"`
}

SlackParams declares the dependencies for the Slack signal lifecycle hook. All fields are optional (mirroring webhook.go's defensive constructor) so the hook can be wired into FX even when Slack isn't configured locally.

type SlackSignalLifecycleHook ¶ added in v0.19.927

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

SlackSignalLifecycleHook fans out workflow / step / approval lifecycle events to all active SlackChannelSubscriptions for the event's org.

Routing invariant (mirrors the model docs): a message lands in workspace T for org O iff installation T is active, org_link (T, O) is verified, and a channel sub (T, channel, O) is active. The hook resolves all three via per-event GORM lookups and posts via the handwritten Slack client.

Threading: per-(team, channel, workflow) anchor rows in slack_thread_anchors drive a parent post + threaded children pattern. The first event posts a parent, persists its ts, and threads itself under that parent. Subsequent events thread under the cached parent and best-effort edit the parent's rollup. Nested action_workflow_run sub-workflows are consolidated under the launching deploy step's workflow via the parent lookup.

Most enrichment helpers (enrichStep, lookupParent, buildContextLinks, lookupDeployTargetMeta, lookupSandboxRunTargetMeta, lookupApprovalResponse) live on WebhookSignalLifecycleHook in webhook.go and are reused via a lightweight delegate so both hooks share one source of truth for payload shape.

func NewSlackSignalLifecycleHook(params SlackParams) *SlackSignalLifecycleHook

func (h *SlackSignalLifecycleHook) AfterPhase(ctx context.Context, event signal.SignalPhaseEvent, outcome signal.SignalPhaseOutcome) error

func (h *SlackSignalLifecycleHook) BeforePhase(ctx context.Context, event signal.SignalPhaseEvent) (signal.BeforePhaseDecision, error)

func (h *SlackSignalLifecycleHook) Name() string

func (h *SlackSignalLifecycleHook) Supports(event signal.SignalPhaseEvent) bool

type WebhookSignalLifecycleHook ¶

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

func NewWebhookSignalLifecycleHook(params Params) *WebhookSignalLifecycleHook

func (h *WebhookSignalLifecycleHook) AfterPhase(ctx context.Context, event signal.SignalPhaseEvent, outcome signal.SignalPhaseOutcome) error

func (h *WebhookSignalLifecycleHook) BeforePhase(ctx context.Context, event signal.SignalPhaseEvent) (signal.BeforePhaseDecision, error)

func (h *WebhookSignalLifecycleHook) Name() string

func (h *WebhookSignalLifecycleHook) Supports(event signal.SignalPhaseEvent) bool