From e7a1d76f0562deaf990563394a1f6ede5cef4924 Mon Sep 17 00:00:00 2001
From: Guillermo Serrahima <dev@vylion.com>
Date: Thu, 16 Jul 2026 01:34:56 +0200
Subject: Added jetstream monitoring

---
 main.go | 8 ++++++++
 1 file changed, 8 insertions(+)

(limited to 'main.go')

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 {
-- 
cgit v1.2.3