fix: eventstream subscription string ack

SevenTV · Dec 4, 2023 · 97e478d · 97e478d
1 parent d54d684
commit 97e478d
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/internal/app/routes.go b/internal/app/routes.go
@@ -3,7 +3,7 @@ package app
 func (s *Server) setRoutes() {
 	s.router.Use(s.Middleware())
 	s.router.HandleFunc("/v3", s.handleV3)
-	s.router.HandleFunc("/v3{sub?:\\@(.*)}", s.handleV3)
+	s.router.HandleFunc("/v3{sub:\\@(.*)}", s.handleV3)
 
 	s.router.HandleFunc("/health", s.HandleHealth)
 }
diff --git a/internal/app/v3/v3.go b/internal/app/v3/v3.go
@@ -35,8 +35,6 @@ func SSE(gctx global.Context, conn client.Connection, w http.ResponseWriter, r *
 
 	conn.SetWriter(bufio.NewWriter(w), f)
 
-	conn.Read(gctx)
-
 	go func() {
 		<-conn.OnReady() // wait for the connection to be ready
 		if conn.Context().Err() != nil {
@@ -83,5 +81,7 @@ func SSE(gctx global.Context, conn client.Connection, w http.ResponseWriter, r *
 		}
 	}()
 
+	conn.Read(gctx)
+
 	return nil
 }
diff --git a/terraform/variables.tf b/terraform/variables.tf
@@ -39,7 +39,7 @@ variable "image_pull_policy" {
 
 variable "heartbeat_interval" {
   type    = number
-  default = 28000
+  default = 45000
 }
 
 variable "subscription_limit" {