pullrequest

type ApproveHandler ¶

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

ApproveHandler adds a reaction when a review is submitted with state "approved".

func NewApproveHandler(
	messages SlackMessages,
	mappings RepoMappings,
	slackClient SlackClient,
	logger *slog.Logger,
	emoji string,
	detector *aireview.Detector,
) *ApproveHandler

func (h *ApproveHandler) Applicable(e Event) bool

func (h *ApproveHandler) Handle(ctx context.Context, e Event) error

type CloseHandler ¶

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

CloseHandler reacts to a PR being closed (merged or not). It updates the original Slack message with a [Merged]/[Closed] decoration and, if enabled, adds the corresponding reaction emoji.

func NewCloseHandler(
	messages SlackMessages,
	mappings RepoMappings,
	slackClient SlackClient,
	composer *slack.Composer,
	logger *slog.Logger,
	opts CloseOptions,
) *CloseHandler

func (h *CloseHandler) Applicable(e Event) bool

func (h *CloseHandler) Handle(ctx context.Context, e Event) error

type CloseOptions ¶

type CloseOptions struct {
	ReactionsEnabled bool
	MergedEmoji      string
	ClosedEmoji      string
}

CloseOptions tunes the CloseHandler. Reactions on close are toggleable because that's how the legacy PHP service exposed them.

type CommentedHandler ¶

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

CommentedHandler adds a reaction when a review is submitted or edited with state "commented".

func NewCommentedHandler(
	messages SlackMessages,
	mappings RepoMappings,
	slackClient SlackClient,
	logger *slog.Logger,
	emoji string,
	detector *aireview.Detector,
) *CommentedHandler

func (h *CommentedHandler) Applicable(e Event) bool

func (h *CommentedHandler) Handle(ctx context.Context, e Event) error

type Dispatcher ¶

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

Dispatcher routes an Event to the first registered EventHandler whose Applicable returns true. Handlers are checked in the order they were registered. If no handler matches, Dispatch logs a Debug line and returns nil (no error) so the HTTP layer still responds 200 OK.

func NewDispatcher(logger *slog.Logger, handlers ...EventHandler) *Dispatcher

func (d *Dispatcher) Dispatch(ctx context.Context, e Event) error

type DraftHandler ¶

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

DraftHandler reacts to a PR being converted back to draft. It removes the Slack notification and forgets the message TS — the PR will be re-announced when it's marked ready_for_review again.

func NewDraftHandler(
	messages SlackMessages,
	mappings RepoMappings,
	slackClient SlackClient,
	logger *slog.Logger,
) *DraftHandler

func (h *DraftHandler) Applicable(e Event) bool

func (h *DraftHandler) Handle(ctx context.Context, e Event) error

type Event ¶

type Event struct {
	GitHubEvent string
	Action      string
	Repository  string

	PR PR

	// Review is non-nil only for pull_request_review events.
	Review *Review

	// Sender identifies the actor that fired the webhook. Type is "User"
	// for humans and "Bot" for GitHub Apps (Copilot, dependabot, …).
	Sender Sender
}

Event is the immutable record of an incoming pull-request-related webhook, detached from any HTTP payload type. Handlers receive Event and decide via Applicable whether they should run.

type EventHandler ¶

type EventHandler interface {
	Applicable(Event) bool
	Handle(context.Context, Event) error
}

EventHandler is implemented by each PR-lifecycle handler.

Applicable inspects an event and returns true if Handle should run. The dispatcher invokes the first handler whose Applicable returns true and skips the rest — handlers are mutually exclusive.

type OpenHandler ¶

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

OpenHandler reacts to a PR being opened (non-draft) or marked ready_for_review. It posts the first Slack message for the PR and records the message TS for later updates.

func NewOpenHandler(
	messages SlackMessages,
	mappings RepoMappings,
	slackClient SlackClient,
	composer *slack.Composer,
	logger *slog.Logger,
) *OpenHandler

func (h *OpenHandler) Applicable(e Event) bool

func (h *OpenHandler) Handle(ctx context.Context, e Event) error

type PR ¶

type PR struct {
	Number int
	Title  string
	URL    string
	Author string
	Merged bool
	Draft  bool
}

PR holds the PR fields needed across handlers and the message composer.

type RepoMappings ¶

type RepoMappings interface {
	Get(ctx context.Context, repository string) (store.RepoMapping, error)
}

RepoMappings reads the per-repository routing to a Slack channel.

type RequestChangeHandler ¶

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

RequestChangeHandler adds a reaction when a review is submitted with state "changes_requested".

func NewRequestChangeHandler(
	messages SlackMessages,
	mappings RepoMappings,
	slackClient SlackClient,
	logger *slog.Logger,
	emoji string,
	detector *aireview.Detector,
) *RequestChangeHandler

func (h *RequestChangeHandler) Applicable(e Event) bool

func (h *RequestChangeHandler) Handle(ctx context.Context, e Event) error

type Review ¶

type Review struct {
	State string
}

Review carries the review state (approved | commented | changes_requested).

type Sender ¶ added in v0.5.0

type Sender struct {
	Login string
	Type  string
}

Sender identifies the actor on the webhook payload (the reviewer for review events, the PR author for `pull_request` opened events, etc.).

type SlackClient ¶

type SlackClient interface {
	PostMessage(ctx context.Context, channel, text string) (ts string, err error)
	UpdateMessage(ctx context.Context, channel, ts, text string) error
	DeleteMessage(ctx context.Context, channel, ts string) error
	AddReaction(ctx context.Context, channel, ts, name string) error
}

SlackClient is the subset of the slack package's client that handlers use.

type SlackMessages ¶

type SlackMessages interface {
	Save(ctx context.Context, m store.SlackMessage) error
	Get(ctx context.Context, repository string, prNumber int) (store.SlackMessage, error)
	Delete(ctx context.Context, repository string, prNumber int) error
}

SlackMessages reads and writes the per-PR Slack message TS record.