mirror of
https://github.com/sipeed/NanoKVM.git
synced 2026-09-11 00:22:56 -05:00
be7584d908
Track capture results for each stream mode, broadcast status updates over WebSocket, and display localized warning/error overlays in the desktop view.
44 lines
734 B
Go
44 lines
734 B
Go
package ws
|
|
|
|
import (
|
|
"net/http"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/gorilla/websocket"
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
type Service struct{}
|
|
|
|
var upgrader = websocket.Upgrader{
|
|
ReadBufferSize: 1024,
|
|
WriteBufferSize: 1024,
|
|
CheckOrigin: func(r *http.Request) bool {
|
|
return true
|
|
},
|
|
}
|
|
|
|
func NewService() *Service {
|
|
return &Service{}
|
|
}
|
|
|
|
func (s *Service) Connect(c *gin.Context) {
|
|
ws, err := upgrader.Upgrade(c.Writer, c.Request, nil)
|
|
if err != nil {
|
|
log.Errorf("create websocket failed: %s", err)
|
|
return
|
|
}
|
|
|
|
log.Debug("websocket connected")
|
|
|
|
client := NewClient(ws)
|
|
|
|
manager := GetManager()
|
|
manager.AddClient(ws, client)
|
|
defer manager.RemoveClient(ws)
|
|
|
|
sendCaptureStatusSnapshot(client)
|
|
|
|
client.Start()
|
|
}
|