clawbot
3e261d2f01
Some checks failed
check / check (push) Has been cancelled
Per-webhook archive writers are now evicted when the webhook or its last database target is deleted, and a background sweeper prunes expired rows from idle archives that no longer receive writes. Archive files themselves are never deleted.
65 lines
1.6 KiB
Go
65 lines
1.6 KiB
Go
// Package main is the entry point for the webhooker application.
|
|
package main
|
|
|
|
import (
|
|
"go.uber.org/fx"
|
|
"sneak.berlin/go/webhooker/internal/config"
|
|
"sneak.berlin/go/webhooker/internal/database"
|
|
"sneak.berlin/go/webhooker/internal/delivery"
|
|
"sneak.berlin/go/webhooker/internal/globals"
|
|
"sneak.berlin/go/webhooker/internal/handlers"
|
|
"sneak.berlin/go/webhooker/internal/healthcheck"
|
|
"sneak.berlin/go/webhooker/internal/logger"
|
|
"sneak.berlin/go/webhooker/internal/middleware"
|
|
"sneak.berlin/go/webhooker/internal/server"
|
|
"sneak.berlin/go/webhooker/internal/session"
|
|
)
|
|
|
|
// Build-time variables set via -ldflags.
|
|
//
|
|
//nolint:gochecknoglobals // Build-time variables injected by the linker.
|
|
var (
|
|
version = "dev"
|
|
appname = "webhooker"
|
|
)
|
|
|
|
func main() {
|
|
globals.Appname = appname
|
|
globals.Version = version
|
|
|
|
fx.New(
|
|
fx.Provide(
|
|
globals.New,
|
|
logger.New,
|
|
config.New,
|
|
database.New,
|
|
database.NewWebhookDBManager,
|
|
database.NewRetentionReaper,
|
|
healthcheck.New,
|
|
session.New,
|
|
handlers.New,
|
|
middleware.New,
|
|
delivery.New,
|
|
delivery.NewArchiveSweeper,
|
|
// Wire *delivery.Engine as delivery.Notifier so the
|
|
// webhook handler can notify the engine of new deliveries.
|
|
func(e *delivery.Engine) delivery.Notifier { return e },
|
|
// Wire *delivery.Engine as delivery.WebhookEvictor so
|
|
// deleting a webhook releases its archive writer.
|
|
func(e *delivery.Engine) delivery.WebhookEvictor {
|
|
return e
|
|
},
|
|
server.New,
|
|
),
|
|
fx.Invoke(
|
|
func(
|
|
*server.Server,
|
|
*delivery.Engine,
|
|
*database.RetentionReaper,
|
|
*delivery.ArchiveSweeper,
|
|
) {
|
|
},
|
|
),
|
|
).Run()
|
|
}
|