deblan/capture
deblan/capture
1
1
Fork 0
Code Issues Pull requests Packages Projects Releases 6 Wiki Activity

Prevent code repetition

Browse source
This commit is contained in:
Fabricio 2021-04-06 07:33:05 -03:00
parent 3f79d04161
commit af79036aa1
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
main.go
View file

@ -66,16 +66,16 @@ func NewDashboardConnHandler(srv *CaptureService, cfg Config) http.HandlerFunc {
w.Header().Set("Cache-Control", "no-cache")
w.Header().Set("Connection", "keep-alive")
// Send the config.
jsn, _ := json.Marshal(cfg)
fmt.Fprintf(w, "event: config\ndata: %s\n\n", jsn)
w.(http.Flusher).Flush()
// Send the captures.
for {
jsn, _ := json.Marshal(srv.DashboardItems())
fmt.Fprintf(w, "event: captures\ndata: %s\n\n", jsn)
sendEvent := func(event string, data interface{}) {
jsn, _ := json.Marshal(data)
fmt.Fprintf(w, "event: %s\ndata: %s\n\n", event, jsn)
w.(http.Flusher).Flush()
}
sendEvent("config", cfg)
for {
sendEvent("captures", srv.DashboardItems())
select {
case <-srv.Updated():