this repo has no description
replace some more bgs/relay log lines
+5
-6
+5
-6
cmd/relay/main.go
+5
-6
cmd/relay/main.go
···
52
52
},
53
53
&cli.StringFlag{
54
54
Name: "db-url",
55
-
Usage: "database connection string for BGS database",
55
+
Usage: "database connection string for relay database",
56
56
Value: "sqlite://./data/relay/relay.sqlite",
57
57
EnvVars: []string{"DATABASE_URL"},
58
58
},
···
156
156
app.Action = runRelay
157
157
return app.Run(os.Args)
158
158
}
159
-
160
159
161
160
func runRelay(cctx *cli.Context) error {
162
161
// Trap SIGINT to trigger a shutdown.
···
257
256
258
257
ratelimitBypass := cctx.String("bsky-social-rate-limit-skip")
259
258
260
-
logger.Info("constructing bgs")
259
+
logger.Info("constructing relay service")
261
260
bgsConfig := libbgs.DefaultBGSConfig()
262
261
bgsConfig.SSL = !cctx.Bool("crawl-insecure-ws")
263
262
bgsConfig.ConcurrencyPerPDS = cctx.Int64("concurrency-per-pds")
···
313
312
logger.Info("received shutdown signal")
314
313
errs := bgs.Shutdown()
315
314
for err := range errs {
316
-
logger.Error("error during BGS shutdown", "err", err)
315
+
logger.Error("error during shutdown", "err", err)
317
316
}
318
317
case err := <-bgsErr:
319
318
if err != nil {
320
-
logger.Error("error during BGS startup", "err", err)
319
+
logger.Error("error during startup", "err", err)
321
320
}
322
321
logger.Info("shutting down")
323
322
errs := bgs.Shutdown()
324
323
for err := range errs {
325
-
logger.Error("error during BGS shutdown", "err", err)
324
+
logger.Error("error during shutdown", "err", err)
326
325
}
327
326
}
328
327