+6

cmd/palomar/main.go

reviewed

··· 158 158 Value: 100, 159 159 EnvVars: []string{"PALOMAR_PLC_RATE_LIMIT"}, 160 160 }, 161 161 + &cli.BoolFlag{ 162 162 + Name: "discover-repos", 163 163 + Usage: "if true, discover repositories from the Relay", 164 164 + EnvVars: []string{"PALOMAR_DISCOVER_REPOS"}, 165 165 + Value: false, 166 166 + }, 161 167 }, 162 168 Action: func(cctx *cli.Context) error { 163 169 logger := slog.New(slog.NewJSONHandler(os.Stdout, &slog.HandlerOptions{

+4 -1

search/firehose.go

reviewed

··· 52 52 return fmt.Errorf("loading backfill jobs: %w", err) 53 53 } 54 54 go s.bf.Start() 55 55 - go s.discoverRepos() 55 55 + 56 56 + if s.enableRepoDiscovery { 57 57 + go s.discoverRepos() 58 58 + } 56 59 57 60 d := websocket.DefaultDialer 58 61 u, err := url.Parse(s.bgshost)

+12 -8

search/server.go

reviewed

··· 37 37 38 38 bfs *backfill.Gormstore 39 39 bf *backfill.Backfiller 40 40 + 41 41 + enableRepoDiscovery bool 40 42 } 41 43 42 44 type LastSeq struct { ··· 51 53 Logger *slog.Logger 52 54 BGSSyncRateLimit int 53 55 IndexMaxConcurrency int 56 56 + DiscoverRepos bool 54 57 } 55 58 56 59 func NewServer(db *gorm.DB, escli *es.Client, dir identity.Directory, config Config) (*Server, error) { ··· 76 79 } 77 80 78 81 s := &Server{ 79 79 - escli: escli, 80 80 - profileIndex: config.ProfileIndex, 81 81 - postIndex: config.PostIndex, 82 82 - db: db, 83 83 - bgshost: config.BGSHost, // NOTE: the original URL, not 'bgshttp' 84 84 - bgsxrpc: bgsxrpc, 85 85 - dir: dir, 86 86 - logger: logger, 82 82 + escli: escli, 83 83 + profileIndex: config.ProfileIndex, 84 84 + postIndex: config.PostIndex, 85 85 + db: db, 86 86 + bgshost: config.BGSHost, // NOTE: the original URL, not 'bgshttp' 87 87 + bgsxrpc: bgsxrpc, 88 88 + dir: dir, 89 89 + logger: logger, 90 90 + enableRepoDiscovery: config.DiscoverRepos, 87 91 } 88 92 89 93 bfstore := backfill.NewGormstore(db)