feat: try to recreate the SSE connection if the sse was defined

Author: adilsitos

packages/proxy/resync.go

@@ -361,14 +361,19 @@ func runProjectSecretsRefresh(cache *Cache, domainURL *url.URL, httpClient *http
 		Msg("Project secrets refresh completed")
 }
 
-func startProjectPollingLoop(ctx context.Context, cache *Cache, domainURL *url.URL, httpClient *http.Client, projectId, envSlug string, interval time.Duration) {
+func startProjectPollingLoop(ctx context.Context, cache *Cache, domainURL *url.URL, httpClient *http.Client, projectId, envSlug string, interval time.Duration, onPollComplete func()) {
 	ticker := time.NewTicker(interval)
 	defer ticker.Stop()
 
+	firstTick := true
 	for {
 		select {
 		case <-ticker.C:
 			runProjectSecretsRefresh(cache, domainURL, httpClient, projectId, envSlug)
+			if !firstTick && onPollComplete != nil {
+				onPollComplete()
+			}
+			firstTick = false
 		case <-ctx.Done():
 			return
 		}

packages/proxy/sse.go

@@ -375,7 +375,20 @@ func (m *SSEManager) transitionToPolling(projectId, environmentSlug string) {
 	// Resync the project cache immediately — events might have been missed during the outage
 	go runProjectSecretsRefresh(m.cache, m.domainURL, m.resyncHttpClient, projectId, environmentSlug)
 
-	go startProjectPollingLoop(pollCtx, m.cache, m.domainURL, m.resyncHttpClient, projectId, environmentSlug, pollingFallbackInterval)
+	// On each polling tick (except the first), attempt SSE reconnection
+	retrySSE := func() {
+		m.mu.Lock()
+		ps, ok := m.pollingProjects[projectId]
+		if !ok || ps.retryingSSE {
+			m.mu.Unlock()
+			return
+		}
+		ps.retryingSSE = true
+		m.mu.Unlock()
+		go m.attemptSSEReconnection(projectId, environmentSlug)
+	}
+
+	go startProjectPollingLoop(pollCtx, m.cache, m.domainURL, m.resyncHttpClient, projectId, environmentSlug, pollingFallbackInterval, retrySSE)
 }
 
 func (m *SSEManager) cancelPollingIfActive(projectId string) {