tangled.org / core
Monorepo for Tangled tangled.org
854
fork

Configure Feed

Select the types of activity you want to include in your feed.

knotmirror/xrpc: don't schedule pending on xrpc failure #288

open opened by
boltless.me targeting master from sl/upukwxsowwop
STACK 4
#290 appview,knotmirror: prefer knotmirror to load blobs
0
#0
#289 knotmirror/xrpc: log with xrpc method name
0
#1
#288 knotmirror/xrpc: don't schedule pending on xrpc failure
0
#1
#287 knotmirror: add scheme to proxy hosts
0
#1
Labels

None yet.

assignee

None yet.

Participants 1
AT URI
at://did:plc:xasnlahkri4ewmbuzly2rlc5/sh.tangled.repo.pull/3mkshc6jpjc22
-8
Diff #1
-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 {

History

2 rounds 0 comments
sign up or login to add to the discussion
boltless.me submitted #1
interdiff
1 commit
expand
63a03c6d
knotmirror/xrpc: don't schedule pending on xrpc failure
merge conflicts detected
expand
  • knotmirror/xrpc/proxy.go:54
expand 0 comments
boltless.me submitted #0
diff
1 commit
expand
06c25fad
knotmirror/xrpc: don't schedule pending on xrpc failure
expand 0 comments