summaryrefslogtreecommitdiffstats
path: root/internal/app/app.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/app/app.go')
-rw-r--r--internal/app/app.go11
1 files changed, 9 insertions, 2 deletions
diff --git a/internal/app/app.go b/internal/app/app.go
index 0b78baf..ccb8483 100644
--- a/internal/app/app.go
+++ b/internal/app/app.go
@@ -15,6 +15,7 @@ import (
"cep.is/telegrambot/internal/bot"
"cep.is/telegrambot/internal/config"
+ "cep.is/telegrambot/internal/lookup"
"cep.is/telegrambot/internal/telegram"
)
@@ -34,22 +35,28 @@ type App struct {
// The whole-call timeout of the cep.is client is the shutdown grace on purpose:
// handling one update is what a termination signal waits for, so a lookup must
// not be allowed to outlast that budget.
+//
+// The client goes to the bot wrapped in [lookup.Client], which is what keeps the
+// municipality the API names on a 404. The wrapper has its own short timeout,
+// deliberately far below the grace: it is a footnote on an answer that is
+// already writable.
func New(ctx context.Context, cfg config.Config, logger *slog.Logger) (*App, error) {
if logger == nil {
logger = slog.Default()
}
- lookups, err := cepis.New(
+ cepisClient, err := cepis.New(
cepis.WithBaseURL(cfg.CepisBaseURL),
cepis.WithTimeout(cfg.RequestTimeout),
cepis.WithMaxAttempts(cfg.MaxAttempts),
cepis.WithBackoff(cfg.BackoffBase, cfg.BackoffMax),
cepis.WithTotalTimeout(cfg.ShutdownGrace),
- cepis.WithUserAgent("cepis-telegram/0.1.0 (+https://cep.is)"),
+ cepis.WithUserAgent("cepis-telegram/0.2.0 (+https://cep.is)"),
)
if err != nil {
return nil, fmt.Errorf("app: cep.is client: %w", err)
}
+ lookups := lookup.New(cepisClient)
api, err := telegram.New(cfg.Token,
telegram.WithBaseURL(cfg.TelegramAPIBaseURL),