factory

func CreateCommandConsumer ¶

func CreateCommandConsumer(
	saramaClientProvider libkafka.SaramaClientProvider,
	syncProducer libkafka.SyncProducer,
	db libkv.DB,
	ghClient pkg.GitHubClient,
	createSender task.CreateCommandSender,
	taskCreationFilter filter.TaskCreationFilter,
	trustDecision trust.Trust,
	stage string,
	maxSlugLen int,
	maxTitleLen int,
	taskSuffix string,
	metrics pkg.Metrics,
	topicPrefix base.TopicPrefix,
	currentDateTime libtime.CurrentDateTimeGetter,
) run.Func

CreateCommandConsumer wires a run.Func that consumes TriggerPRReviewCommand messages from the github-pr watcher's request topic and runs them through the single-PR review pipeline (GitHub fetch → filter → trust → publish).

currentDateTime is the injected libtime.CurrentDateTimeGetter passed through to the trigger executor so it can derive a time-salted task identifier when the TriggerPRReviewCommand has Force=true (spec 067). The non-force path does not consult the clock.

The function is pure composition: no business logic, no conditionals. It uses cdb.RunCommandConsumerTxDefault (auto-wraps the transaction) per the go-cqrs/auto-tx-wrapper-no-manual-wrap rule — do NOT manually wrap the executor with kv.NewTransactionMiddleware.

func CreateGitHubAppClient ¶

func CreateGitHubAppClient(
	ctx context.Context,
	appID int64,
	installationID int64,
	pemKey []byte,
) (*http.Client, error)

CreateGitHubAppClient creates an HTTP client authenticated as a GitHub App installation.

func CreateKafkaSender ¶

func CreateKafkaSender(
	syncProducer libkafka.SyncProducer,
	topicPrefix base.TopicPrefix,
) task.CreateCommandSender

CreateKafkaSender constructs a typed create-task command sender backed by a Kafka sync producer.

func CreateSinglePRTriggerHandler ¶

func CreateSinglePRTriggerHandler(
	sender command.TriggerPRReviewCommandSender,
) handler.SinglePRTriggerHandler

CreateSinglePRTriggerHandler wires the thin CQRS handler that publishes a TriggerPRReviewCommand to Kafka for each valid /trigger request. All GitHub/filter/trust work lives in the in-pod command consumer (see pkg/command.NewTriggerPRReviewCommandExecutor).

func CreateTriggerPRReviewCommandSender ¶

func CreateTriggerPRReviewCommandSender(
	ctx context.Context,
	syncProducer libkafka.SyncProducer,
	topicPrefix base.TopicPrefix,
) command.TriggerPRReviewCommandSender

CreateTriggerPRReviewCommandSender constructs a typed trigger-PR-review command sender backed by a Kafka sync producer. This is the HTTP-side sender: the /trigger handler publishes TriggerPRReviewCommand messages through it.

CommandCreator and Initiator are built once here and reused across every SendCommand call (per cqrs/docs/producing-commands.md "Factory Wiring"; matches trading/frontend/command's reference impl).

func CreateWatcher ¶

func CreateWatcher(
	ghClient pkg.GitHubClient,
	createSender task.CreateCommandSender,
	cursorPath string,
	startTime libtime.DateTime,
	scope string,
	taskCreationFilter filter.TaskCreationFilter,
	stage string,
	metrics pkg.Metrics,
	trustDecision trust.Trust,
	maxSlugLen int,
	maxTitleLen int,
	taskSuffix string,
) pkg.Watcher

CreateWatcher wires all dependencies and returns a ready-to-use Watcher.