From 2158a910a2546e3cb7b7d48355df2dfc4cf0a80c Mon Sep 17 00:00:00 2001 From: Bryan Frimin Date: Wed, 1 Oct 2025 09:16:48 +0200 Subject: [PATCH] Style Signed-off-by: Bryan Frimin --- pkg/certmanager/provisioner.go | 61 ++++++++++++++++++---------------- 1 file changed, 32 insertions(+), 29 deletions(-) diff --git a/pkg/certmanager/provisioner.go b/pkg/certmanager/provisioner.go index 5457cf211..8329d7528 100644 --- a/pkg/certmanager/provisioner.go +++ b/pkg/certmanager/provisioner.go @@ -75,37 +75,40 @@ func (p *Provisioner) Run(ctx context.Context) error { } func (p *Provisioner) checkPendingDomains(ctx context.Context) error { - return p.pg.WithConn(ctx, func(conn pg.Conn) error { - var domains coredata.CustomDomains - if err := domains.ListDomainsWithPendingHTTPChallenges(ctx, conn, coredata.NewNoScope()); err != nil { - return fmt.Errorf("cannot load domains with pending challenges: %w", err) - } + return p.pg.WithConn( + ctx, + func(conn pg.Conn) error { + var domains coredata.CustomDomains + if err := domains.ListDomainsWithPendingHTTPChallenges(ctx, conn, coredata.NewNoScope()); err != nil { + return fmt.Errorf("cannot load domains with pending challenges: %w", err) + } + + if len(domains) == 0 { + return nil + } + + p.logger.InfoCtx(ctx, "found domains needing SSL provisioning", log.Int("count", len(domains))) + + for _, domain := range domains { + select { + case <-ctx.Done(): + return ctx.Err() + default: + } + + if err := p.provisionDomainCertificate(ctx, conn, domain); err != nil { + p.logger.ErrorCtx( + ctx, + "cannot provision certificate for domain", + log.String("domain", domain.Domain), + log.Error(err), + ) + } + } - if len(domains) == 0 { return nil - } - - p.logger.InfoCtx(ctx, "found domains needing SSL provisioning", log.Int("count", len(domains))) - - for _, domain := range domains { - select { - case <-ctx.Done(): - return ctx.Err() - default: - } - - if err := p.provisionDomainCertificate(ctx, conn, domain); err != nil { - p.logger.ErrorCtx( - ctx, - "cannot provision certificate for domain", - log.String("domain", domain.Domain), - log.Error(err), - ) - } - } - - return nil - }) + }, + ) } func (p *Provisioner) provisionDomainCertificate(