Skip to content

Commit

Permalink
fix requestCrawl forwarding
Browse files Browse the repository at this point in the history
  • Loading branch information
bnewbold committed Nov 20, 2024
1 parent 6b6afc0 commit a954f91
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 0 deletions.
1 change: 1 addition & 0 deletions bgs/bgs.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
1 change: 1 addition & 0 deletions bgs/handlers.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
}
Expand Down
1 change: 1 addition & 0 deletions cmd/bigsky/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand Down

0 comments on commit a954f91

Please sign in to comment.