Add viewlog controller
This commit is contained in:
parent
f0427c6508
commit
4bd4c0417c
|
|
@ -10,8 +10,6 @@ import (
|
||||||
"net/http"
|
"net/http"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
type WebSocketController struct {
|
type WebSocketController struct {
|
||||||
beego.Controller
|
beego.Controller
|
||||||
}
|
}
|
||||||
|
|
@ -28,16 +26,12 @@ func (c *WebSocketController) Prepare() {
|
||||||
c.Data["version"] = variables.Version
|
c.Data["version"] = variables.Version
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// Get method handles GET requests for WebSocketController.
|
// Get method handles GET requests for WebSocketController.
|
||||||
func (c *WebSocketController) Get() {
|
func (c *WebSocketController) Get() {
|
||||||
c.Data["hostWS"] = "ws://" + c.Ctx.Request.Host + variables.WebSocketLogRoute
|
c.Data["hostWS"] = "ws://" + c.Ctx.Request.Host + variables.WebSocketLogRoute
|
||||||
c.TplName = "watchlog.tpl"
|
c.TplName = "watchlog.tpl"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// Join method handles WebSocket requests for WebSocketController.
|
// Join method handles WebSocket requests for WebSocketController.
|
||||||
func (this *WebSocketController) Join() {
|
func (this *WebSocketController) Join() {
|
||||||
// Upgrade from http request to WebSocket.
|
// Upgrade from http request to WebSocket.
|
||||||
|
|
@ -52,7 +46,6 @@ func (this *WebSocketController) Join() {
|
||||||
|
|
||||||
watchlog.ListWebSocket.PushFront(ws)
|
watchlog.ListWebSocket.PushFront(ws)
|
||||||
|
|
||||||
|
|
||||||
// Message receive loop.
|
// Message receive loop.
|
||||||
for {
|
for {
|
||||||
_, _, err := ws.ReadMessage()
|
_, _, err := ws.ReadMessage()
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue