feat(core,github): PollerDeps host-hook parity — six execution-pipeline hooks + config-driven board wiring (#71 PR-C) (#76)

- core: TaskChecker, ExecutionChecker, PreFlightJudger (+Verdict), ExecutionSaver,
  IssueMetricsRecorder, RateLimitScheduler interfaces + 7 PollerDeps fields
  (incl. ProjectPath). RateLimitScheduler is a deliberate seam, not a port:
  the host classifies rate-limit errors and queues retries on its own
  scheduler, so the SDK never imports host task/rate-limit types.
- github poller: wire all six hooks into both dispatch paths mirroring the
  host-side semantics — pre-flight judge (fail-open, needs-clarification
  label + comment + declined record on reject, no markProcessed), task-queued
  gate after retry grace, completed-execution guard (fail-open, marks
  processed on hit), InvalidateCompletion on retry-ready re-dispatch,
  rate-limited handler errors stay marked with 'rate_limited' outcome metric.
- github adapter: bridge the new deps; construct ProjectBoardSource/Sync from
  ProjectBoardConfig (new SourceEnabled field) so board mode is config-driven.
- sdk/core api.golden re-blessed: additive-only (+39 lines, no deletions).

Author: alekspetrov

sdk/core/api.golden

@@ -55,6 +55,15 @@ type ChatDeps struct {
 	Handler MessageHandler
 }
 
+type ExecutionChecker interface {
+	HasCompletedExecution(taskID, projectPath string) (bool, error)
+	InvalidateCompletion(taskID, projectPath string) error
+}
+
+type ExecutionSaver interface {
+	SaveDeclinedExecution(taskID, projectPath, status, reason string) error
+}
+
 type Identity struct {
 	UserID string
 	DisplayName string
@@ -78,6 +87,10 @@ type IssueHandler interface {
 
 type IssueHandlerFunc func(ctx context.Context, ev IssueEvent) (*IssueResult, error)
 
+type IssueMetricsRecorder interface {
+	RecordIssueProcessed(result string)
+}
+
 type IssueResult struct {
 	Success bool
 	Skipped bool
@@ -143,6 +156,17 @@ type PollerDeps struct {
 	MaxConcurrent int
 	Handler IssueHandler
 	OnPRCreated func(ev PRCreatedEvent)
+	TaskChecker TaskChecker
+	ExecutionChecker ExecutionChecker
+	ProjectPath string
+	PreFlightJudge PreFlightJudger
+	ExecutionSaver ExecutionSaver
+	IssueMetricsRecorder IssueMetricsRecorder
+	RateLimitScheduler RateLimitScheduler
+}
+
+type PreFlightJudger interface {
+	JudgeIssue(ctx context.Context, title, body, repoContext string) (Verdict, error)
 }
 
 type ProcessedStore interface {
@@ -152,6 +176,21 @@ type ProcessedStore interface {
 	Load(source, repo string) (map[string]time.Time, error)
 }
 
+type RateLimitScheduler interface {
+	QueueRetryIfRateLimited(taskID, title, body, errText string) bool
+}
+
+type TaskChecker interface {
+	IsTaskQueued(taskID string) bool
+}
+
+type Verdict struct {
+	Accepted bool
+	Decision string
+	Reason string
+	Confidence float64
+}
+
 type WebhookCapable interface {
 	Adapter
 	WebhookSource() string

sdk/core/registry.go

@@ -119,8 +119,64 @@ type ActiveExecutionLister interface {
 	ListActiveTaskIDs(ctx context.Context) ([]string, error)
 }
 
+// TaskChecker reports whether a task is currently queued or in-progress in
+// the consuming application's execution pipeline. Pollers consult it during
+// retry-grace evaluation so an issue whose task is still running is not
+// re-dispatched.
+type TaskChecker interface {
+	IsTaskQueued(taskID string) bool
+}
+
+// ExecutionChecker verifies whether a completed execution record exists for a
+// task, preventing re-dispatch when a tracker-side "done" marker failed to
+// apply. InvalidateCompletion deletes a stale completed record so an explicit
+// retry is not silently no-op'd.
+type ExecutionChecker interface {
+	HasCompletedExecution(taskID, projectPath string) (bool, error)
+	InvalidateCompletion(taskID, projectPath string) error
+}
+
+// Verdict is the result of a pre-flight judgment on an issue.
+type Verdict struct {
+	Accepted   bool
+	Decision   string
+	Reason     string
+	Confidence float64
+}
+
+// PreFlightJudger evaluates issues before dispatch so pollers do not burn
+// worker slots on vague, ambiguous, or otherwise unactionable issues.
+type PreFlightJudger interface {
+	JudgeIssue(ctx context.Context, title, body, repoContext string) (Verdict, error)
+}
+
+// ExecutionSaver persists pre-flight rejection records for observability.
+type ExecutionSaver interface {
+	SaveDeclinedExecution(taskID, projectPath, status, reason string) error
+}
+
+// IssueMetricsRecorder records issue processing outcomes (e.g. "rate_limited").
+type IssueMetricsRecorder interface {
+	RecordIssueProcessed(result string)
+}
+
+// RateLimitScheduler lets the consuming application classify a handler error
+// as a rate limit and queue the issue for a timed retry on its own scheduler.
+// QueueRetryIfRateLimited returns true when the error was recognized as a
+// rate limit and a retry was queued — the poller then leaves the issue
+// unmarked so the scheduler owns the retry. Returning false hands the error
+// back to the poller's standard failure path.
+//
+// This is a deliberate seam rather than a concrete scheduler dependency:
+// error classification and task construction stay host-side, so the SDK never
+// imports the application's task or rate-limit types.
+type RateLimitScheduler interface {
+	QueueRetryIfRateLimited(taskID, title, body, errText string) bool
+}
+
 // PollerDeps provides shared infrastructure to adapter pollers. Consuming
-// applications supply these — the SDK never constructs them itself.
+// applications supply these — the SDK never constructs them itself. All
+// fields except Handler are optional; nil disables the corresponding hook.
 type PollerDeps struct {
 	// ProcessedStore deduplicates issues across restarts.
 	ProcessedStore ProcessedStore
@@ -131,6 +187,23 @@ type PollerDeps struct {
 	Handler IssueHandler
 	// OnPRCreated fires after an adapter opens a PR/MR for an issue.
 	OnPRCreated func(ev PRCreatedEvent)
+	// TaskChecker skips retry re-dispatch while a task is still queued/running.
+	TaskChecker TaskChecker
+	// ExecutionChecker prevents re-dispatch when a completed execution record
+	// exists. Its lookups (and ExecutionSaver records) are scoped by ProjectPath.
+	ExecutionChecker ExecutionChecker
+	// ProjectPath identifies the local project checkout used to scope
+	// ExecutionChecker/ExecutionSaver records.
+	ProjectPath string
+	// PreFlightJudge evaluates issue quality before dispatch; rejections are
+	// surfaced on the tracker and the issue is not dispatched.
+	PreFlightJudge PreFlightJudger
+	// ExecutionSaver persists pre-flight rejection records.
+	ExecutionSaver ExecutionSaver
+	// IssueMetricsRecorder records issue processing outcomes.
+	IssueMetricsRecorder IssueMetricsRecorder
+	// RateLimitScheduler queues timed retries for rate-limited handler errors.
+	RateLimitScheduler RateLimitScheduler
 }
 
 // --- Registry ---

sdk/integrations/github/adapter.go

@@ -109,6 +109,39 @@ func (a *Adapter) NewPoller(deps core.PollerDeps) core.Poller {
 			})
 		}))
 	}
+	if deps.TaskChecker != nil {
+		opts = append(opts, WithTaskChecker(deps.TaskChecker))
+	}
+	if deps.ExecutionChecker != nil {
+		opts = append(opts, WithExecutionChecker(deps.ExecutionChecker, deps.ProjectPath))
+	}
+	if deps.PreFlightJudge != nil {
+		opts = append(opts, WithPreFlightJudge(deps.PreFlightJudge))
+	}
+	if deps.ExecutionSaver != nil {
+		opts = append(opts, WithExecutionSaver(deps.ExecutionSaver))
+	}
+	if deps.IssueMetricsRecorder != nil {
+		opts = append(opts, WithIssueMetricsRecorder(deps.IssueMetricsRecorder))
+	}
+	if deps.RateLimitScheduler != nil {
+		opts = append(opts, WithRateLimitScheduler(deps.RateLimitScheduler))
+	}
+
+	// Board layer is config-driven, not a PollerDeps hook: construct the board
+	// source/sync from ProjectBoardConfig so hosts get board mode by config alone.
+	if pb := a.config.ProjectBoard; pb != nil && pb.Enabled {
+		parts := strings.SplitN(repo, "/", 2)
+		if len(parts) == 2 {
+			ownerName, repoName := parts[0], parts[1]
+			if bs := NewProjectBoardSync(client, pb, ownerName); bs != nil && pb.GetStatuses().InProgress != "" {
+				opts = append(opts, WithBoardSync(bs, pb.GetStatuses().InProgress))
+			}
+			if pb.SourceEnabled {
+				opts = append(opts, WithProjectBoardSource(NewProjectBoardSource(client, pb, ownerName, repoName)))
+			}
+		}
+	}
 
 	// NewPoller can only fail on invalid repo format; DefaultConfig guarantees "unknown/unknown"
 	// as a fallback so this is always valid after the check above.