mirrors/nginx-ui
1
0
Fork 0
mirror of https://github.com/0xJacky/nginx-ui.git synced 2025-05-11 18:35:51 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

feat: read sites access log and error log

Browse source
This commit is contained in:
0xJacky 2022-08-31 13:48:56 +08:00
parent ddaf3e8e60
commit 28168197b1
No known key found for this signature in database
GPG key ID: B6E4A6E4A561BAF0
5 changed files with 147 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

44
server/api/nginx_log.go
View file

@ -2,6 +2,7 @@ package api
import (
"encoding/json"
"github.com/0xJacky/Nginx-UI/server/pkg/nginx"
"github.com/0xJacky/Nginx-UI/server/settings"
"github.com/gin-gonic/gin"
"github.com/gorilla/websocket"
@ -10,11 +11,15 @@ import (
"io"
"log"
"net/http"
"path/filepath"
)
type controlStruct struct {
Fetch string `json:"fetch"`
Type string `json:"type"`
Fetch string `json:"fetch"`
Type string `json:"type"`
ConfName string `json:"conf_name"`
ServerIdx int `json:"server_idx"`
DirectiveIdx int `json:"directive_idx"`
}
func tailNginxLog(ws *websocket.Conn, controlChan chan controlStruct, errChan chan error) {
@ -33,11 +38,40 @@ func tailNginxLog(ws *websocket.Conn, controlChan chan controlStruct, errChan ch
seek.Offset = 0
seek.Whence = io.SeekEnd
}
var logPath string
switch control.Type {
case "site":
path := filepath.Join(nginx.GetNginxConfPath("sites-available"), control.ConfName)
config, err := nginx.ParseNgxConfig(path)
if err != nil {
errChan <- errors.Wrap(err, "error parsing ngx config")
return
}
logPath := settings.NginxLogSettings.AccessLogPath
if control.ServerIdx >= len(config.Servers) {
errChan <- errors.New("serverIdx out of range")
return
}
if control.DirectiveIdx >= len(config.Servers[control.ServerIdx].Directives) {
errChan <- errors.New("DirectiveIdx out of range")
return
}
directive := config.Servers[control.ServerIdx].Directives[control.DirectiveIdx]
if control.Type == "error" {
switch directive.Directive {
case "access_log", "error_log":
// ok
default:
errChan <- errors.New("directive.Params neither access_log nor error_log")
return
}
logPath = directive.Params
case "error":
logPath = settings.NginxLogSettings.ErrorLogPath
default:
logPath = settings.NginxLogSettings.AccessLogPath
}
// Create a tail
@ -61,7 +95,6 @@ func tailNginxLog(ws *websocket.Conn, controlChan chan controlStruct, errChan ch
return
}
case control = <-controlChan:
log.Println("control change")
next = true
break
}
@ -125,6 +158,7 @@ func NginxLog(c *gin.Context) {
if err = <-errChan; err != nil {
log.Println(err)
_ = ws.WriteMessage(websocket.TextMessage, []byte(err.Error()))
return
}
}