mirror of
https://github.com/tiennm99/miti99bot.git
synced 2026-09-20 04:23:43 +00:00
tiennm99
35ad4cb997
Implements Phases 02 (partial) and 03 of the go-port-cloud-run plan. Introduces module framework with per-module KV prefix isolation, health check endpoint, request timeout protection, and comprehensive test coverage. Cloud Run deployment deferred to Phase 01. Security hardening: constant-time secret comparison, cron auth bridge, and secrets stripped from dependency environment exports. Includes Dockerfile, GitHub CI workflow (vet + race + build), and integration tests for module lifecycle.
31 lines
1.0 KiB
Go
31 lines
1.0 KiB
Go
package modules
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
)
|
|
|
|
// ErrCronNotFound is returned when /cron/{name} addresses an unregistered cron.
|
|
var ErrCronNotFound = errors.New("cron not found")
|
|
|
|
// DispatchScheduled runs the cron registered under name with the per-module
|
|
// prefixed Deps the registry stored at Build time. Returns ErrCronNotFound if
|
|
// no module owns that name — Cloud Scheduler hitting an unknown route is a
|
|
// configuration bug worth surfacing as a 404 at the HTTP layer.
|
|
//
|
|
// The handler runs synchronously in the calling goroutine; ctx propagates
|
|
// cancellation/timeout from the HTTP request.
|
|
func DispatchScheduled(ctx context.Context, name string, reg *Registry) error {
|
|
cron, ok := reg.Cron(name)
|
|
if !ok {
|
|
return fmt.Errorf("%w: %q", ErrCronNotFound, name)
|
|
}
|
|
deps, ok := reg.CronDeps(name)
|
|
if !ok {
|
|
// Should be impossible: Build always co-registers cron and cronDeps.
|
|
return fmt.Errorf("modules: cron %q has no registered deps (registry corruption)", name)
|
|
}
|
|
return cron.Handler(ctx, deps)
|
|
}
|