Added jetstream monitoring

1 files changed, 8 insertions, 0 deletions

diff --git a/main.go b/main.go
index 17eee09..adb0f91 100644
--- a/main.go
+++ b/main.go
@@ -88,9 +88,15 @@ func init() {
 		porxieAddr = "porxie:6314"
 	}
 
+	jetstreamURL := os.Getenv("JETSTREAM_URL")
+	if jetstreamURL == "" {
+		jetstreamURL = "wss://jetstream2.fr.hose.cam/subscribe"
+	}
+
 	config = &fetchers.Config{
 		SlingshotURL: slingshotURL,
 		PorxieURL:    fmt.Sprintf("http://%s", porxieAddr),
+		JetstreamURL: jetstreamURL,
 		PageSize:     50,
 		Logger:       logger,
 		Cache:        postCache,
@@ -449,6 +455,8 @@ func blobHandler(w http.ResponseWriter, r *http.Request) {
 func main() {
 	defer config.Cache.Close()
 
+	go fetchers.StartJetstream(config)
+
 	// serve static files
 	distFS, err := fs.Sub(embeddedFrontend, "frontend/dist")
 	if err != nil {