From 2b3d2697764f2aac6993879efe3fefa146609a71 Mon Sep 17 00:00:00 2001 From: Seongmin Lee Date: Wed, 15 Apr 2026 07:29:25 +0000 Subject: [PATCH] knotmirror/xrpc: don't schedule pending on xrpc failure Signed-off-by: Seongmin Lee --- knotmirror/xrpc/proxy.go | 8 -------- 1 file(s) changed, 0 insertion(s)(+), 8 deletion(s)(-) diff --git a/knotmirror/xrpc/proxy.go b/knotmirror/xrpc/proxy.go --- a/knotmirror/xrpc/proxy.go +++ b/knotmirror/xrpc/proxy.go @@ -13,7 +13,6 @@ "github.com/bluesky-social/indigo/atproto/syntax" indigoxrpc "github.com/bluesky-social/indigo/xrpc" "tangled.org/core/api/tangled" "tangled.org/core/knotmirror/db" - "tangled.org/core/knotmirror/models" ) var mirrorToKnotNSID = map[string]string{ @@ -47,13 +46,6 @@ func (x *Xrpc) resolveKnot(ctx context.Context, repoAt syntax.ATURI) (*knotInfo, error) { repo, err := db.GetRepoByAtUri(ctx, x.db, repoAt) if err == nil && repo != nil { - if repo.State != models.RepoStatePending && repo.State != models.RepoStateResyncing { - go func() { - if err := db.UpdateRepoState(context.Background(), x.db, repo.Did, repo.Rkey, models.RepoStatePending); err != nil { - x.logger.Error("failed to mark repo for resync after proxy", "err", err) - } - }() - } knotURL := repo.KnotDomain if !strings.Contains(repo.KnotDomain, "://") { if host, _ := db.GetHost(ctx, x.db, repo.KnotDomain); host != nil { -- tangled.sh