Monorepo for Tangled
tangled.org
knotmirror/xrpc: don't schedule pending on xrpc failure
Signed-off-by: Seongmin Lee <git@boltless.me>
-8
-8
knotmirror/xrpc/proxy.go
-8
knotmirror/xrpc/proxy.go
···
13
13
indigoxrpc "github.com/bluesky-social/indigo/xrpc"
14
14
"tangled.org/core/api/tangled"
15
15
"tangled.org/core/knotmirror/db"
16
-
"tangled.org/core/knotmirror/models"
17
16
)
18
17
19
18
var mirrorToKnotNSID = map[string]string{
···
47
46
func (x *Xrpc) resolveKnot(ctx context.Context, repoAt syntax.ATURI) (*knotInfo, error) {
48
47
repo, err := db.GetRepoByAtUri(ctx, x.db, repoAt)
49
48
if err == nil && repo != nil {
50
-
if repo.State != models.RepoStatePending && repo.State != models.RepoStateResyncing {
51
-
go func() {
52
-
if err := db.UpdateRepoState(context.Background(), x.db, repo.Did, repo.Rkey, models.RepoStatePending); err != nil {
53
-
x.logger.Error("failed to mark repo for resync after proxy", "err", err)
54
-
}
55
-
}()
56
-
}
57
49
knotURL := repo.KnotDomain
58
50
if !strings.Contains(repo.KnotDomain, "://") {
59
51
if host, _ := db.GetHost(ctx, x.db, repo.KnotDomain); host != nil {