rohit/probo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix wrong error type

Browse Source 
Signed-off-by: Bryan Frimin <bryan@getprobo.com>
This commit is contained in:
Bryan Frimin
2026-02-06 09:36:07 +01:00
parent 64fbad061d
commit a9a2e75c59
2 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/certmanager/provisioner.go
View File

@@ -21,7 +21,6 @@ import (
"strings" "strings"
"time" "time"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/log" "go.gearno.de/kit/log"
"go.gearno.de/kit/pg" "go.gearno.de/kit/pg"
"go.gearno.de/x/ref" "go.gearno.de/x/ref"
@@ -227,7 +226,7 @@ func (p *Provisioner) resetStaleDomain(
) error { ) error {
fullDomain := &coredata.CustomDomain{} fullDomain := &coredata.CustomDomain{}
if err := fullDomain.LoadByIDForUpdateSkipLocked(ctx, tx, coredata.NewNoScope(), p.encryptionKey, domain.ID); err != nil { if err := fullDomain.LoadByIDForUpdateSkipLocked(ctx, tx, coredata.NewNoScope(), p.encryptionKey, domain.ID); err != nil {
if errors.Is(err, pgx.ErrNoRows) { if errors.Is(err, coredata.ErrResourceNotFound) {
return nil return nil
} }
@@ -276,7 +275,7 @@ func (p *Provisioner) provisionDomainCertificate(
) error { ) error {
domain := &coredata.CustomDomain{} domain := &coredata.CustomDomain{}
if err := domain.LoadByIDForUpdateSkipLocked(ctx, tx, coredata.NewNoScope(), p.encryptionKey, domainID); err != nil { if err := domain.LoadByIDForUpdateSkipLocked(ctx, tx, coredata.NewNoScope(), p.encryptionKey, domainID); err != nil {
if errors.Is(err, pgx.ErrNoRows) { if errors.Is(err, coredata.ErrResourceNotFound) {
return nil return nil
} }

3
pkg/certmanager/renewer.go
View File

@@ -20,7 +20,6 @@ import (
"fmt" "fmt"
"time" "time"
"github.com/jackc/pgx/v5"
"go.gearno.de/kit/log" "go.gearno.de/kit/log"
"go.gearno.de/kit/pg" "go.gearno.de/kit/pg"
"go.probo.inc/probo/pkg/coredata" "go.probo.inc/probo/pkg/coredata"
@@ -132,7 +131,7 @@ func (r *Renewer) checkAndRenew(ctx context.Context) error {
func (r *Renewer) renewDomain(ctx context.Context, tx pg.Conn, domainID gid.GID) error { func (r *Renewer) renewDomain(ctx context.Context, tx pg.Conn, domainID gid.GID) error {
domain := &coredata.CustomDomain{} domain := &coredata.CustomDomain{}
if err := domain.LoadByIDForUpdateSkipLocked(ctx, tx, coredata.NewNoScope(), r.encryptionKey, domainID); err != nil { if err := domain.LoadByIDForUpdateSkipLocked(ctx, tx, coredata.NewNoScope(), r.encryptionKey, domainID); err != nil {
if errors.Is(err, pgx.ErrNoRows) { if errors.Is(err, coredata.ErrResourceNotFound) {
return nil return nil
} }