Update backfill package to use HTTP/HTTPS for getRepo always (bluesky…

…-social#875)
itaru2622 · Dec 12, 2024 · 749cc07 · 749cc07
2 parents 5ee8937 + cc407d9
commit 749cc07
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/backfill/backfill.go b/backfill/backfill.go
@@ -140,6 +140,14 @@ func NewBackfiller(
 	if opts == nil {
 		opts = DefaultBackfillOptions()
 	}
+
+	// Convert wss:// or ws:// to https:// or http://
+	if strings.HasPrefix(opts.RelayHost, "wss://") {
+		opts.RelayHost = "https://" + opts.RelayHost[6:]
+	} else if strings.HasPrefix(opts.RelayHost, "ws://") {
+		opts.RelayHost = "http://" + opts.RelayHost[5:]
+	}
+
 	return &Backfiller{
 		Name:                  name,
 		Store:                 store,