handler_events.go

package main

import (
	"fmt"
	"net/http"
	"htmxx/service"
)

func (h *application) EventsHandler(w http.ResponseWriter, r *http.Request) {
	// handle SSE events
	fmt.Println("Client Connected")
	w.Header().Set("Content-Type", "text/event-stream")
	w.Header().Set("Cache-Control", "no-cache")
	w.Header().Set("Connection", "keep-alive")

	var channel = make(chan service.Event)
	h.eventsService.AddChannel(&channel)
	defer func() {
		close(channel)
	}()

	flusher, ok := w.(http.Flusher)
	if !ok {
		http.Error(w, "Streaming unsupported!", http.StatusInternalServerError)
	}

	for {
		select {
		case message := <-channel:
			_, err := fmt.Fprintf(w, "event: %s\ndata: %s\n\n", message.EventName, message.Data)
			if err != nil {

				fmt.Println(fmt.Printf("Error sending message: %v", err))
			}
			flusher.Flush()
		case <-r.Context().Done():
			h.eventsService.RemoveChannel(&channel)
			return
		}
	}
}