fix requestCrawl forwarding (#835)

bluesky-social · Nov 20, 2024 · d619a37 · d619a37
2 parents 6b6afc0 + a954f91
commit d619a37
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/bgs/bgs.go b/bgs/bgs.go
@@ -192,6 +192,7 @@ func NewBGS(db *gorm.DB, ix *indexer.Indexer, repoman *repomgr.RepoManager, evtm
 	compactor.Start(bgs)
 	bgs.compactor = compactor
 
+	bgs.nextCrawlers = config.NextCrawlers
 	bgs.httpClient.Timeout = time.Second * 5
 
 	return bgs, nil

diff --git a/bgs/handlers.go b/bgs/handlers.go
@@ -202,6 +202,7 @@ func (s *BGS) handleComAtprotoSyncRequestCrawl(ctx context.Context, body *comatp
 					} else if response.StatusCode != http.StatusOK {
 						log.Warnw("requestCrawl forward failed", "status", response.Status)
 					}
+					log.Infow("requestCrawl forward successful", "host", rpu, "status", response.Status)
 				}
 			}(blob)
 		}

diff --git a/cmd/bigsky/main.go b/cmd/bigsky/main.go
@@ -449,6 +449,7 @@ func runBigsky(cctx *cli.Context) error {
 			if err != nil {
 				return fmt.Errorf("failed to parse next-crawler url: %w", err)
 			}
+			log.Infow("configuring relay for requestCrawl", "host", nextCrawlerUrls[i])
 		}
 		bgsConfig.NextCrawlers = nextCrawlerUrls
 	}