mirror of https://github.com/1Panel-dev/1Panel
372 lines
8.6 KiB
Go
372 lines
8.6 KiB
Go
package components
|
|
|
|
import (
|
|
"errors"
|
|
)
|
|
|
|
type Server struct {
|
|
Comment string
|
|
Listens []*ServerListen
|
|
Directives []IDirective
|
|
Line int
|
|
}
|
|
|
|
func (s *Server) GetCodeBlock() string {
|
|
return ""
|
|
}
|
|
|
|
func NewServer(directive IDirective) (*Server, error) {
|
|
server := &Server{}
|
|
if block := directive.GetBlock(); block != nil {
|
|
server.Line = directive.GetBlock().GetLine()
|
|
server.Comment = block.GetComment()
|
|
directives := block.GetDirectives()
|
|
for _, dir := range directives {
|
|
switch dir.GetName() {
|
|
case "listen":
|
|
server.Listens = append(server.Listens, NewServerListen(dir.GetParameters(), dir.GetLine()))
|
|
default:
|
|
server.Directives = append(server.Directives, dir)
|
|
}
|
|
}
|
|
return server, nil
|
|
}
|
|
return nil, errors.New("server directive must have a block")
|
|
}
|
|
|
|
func (s *Server) GetName() string {
|
|
return "server"
|
|
}
|
|
|
|
func (s *Server) GetParameters() []string {
|
|
return []string{}
|
|
}
|
|
|
|
func (s *Server) GetBlock() IBlock {
|
|
return s
|
|
}
|
|
|
|
func (s *Server) GetComment() string {
|
|
return s.Comment
|
|
}
|
|
|
|
func (s *Server) GetDirectives() []IDirective {
|
|
directives := make([]IDirective, 0)
|
|
for _, ls := range s.Listens {
|
|
directives = append(directives, ls)
|
|
}
|
|
directives = append(directives, s.Directives...)
|
|
return directives
|
|
}
|
|
|
|
func (s *Server) FindDirectives(directiveName string) []IDirective {
|
|
directives := make([]IDirective, 0)
|
|
for _, directive := range s.Directives {
|
|
if directive.GetName() == directiveName {
|
|
directives = append(directives, directive)
|
|
}
|
|
if directive.GetBlock() != nil {
|
|
directives = append(directives, directive.GetBlock().FindDirectives(directiveName)...)
|
|
}
|
|
}
|
|
if directiveName == "listen" {
|
|
for _, listen := range s.Listens {
|
|
params := []string{listen.Bind}
|
|
params = append(params, listen.Parameters...)
|
|
if listen.DefaultServer != "" {
|
|
params = append(params, DefaultServer)
|
|
}
|
|
directives = append(directives, &Directive{
|
|
Name: "listen",
|
|
Parameters: params,
|
|
})
|
|
}
|
|
}
|
|
return directives
|
|
}
|
|
|
|
func (s *Server) UpdateDirective(key string, params []string) {
|
|
if key == "" || len(params) == 0 {
|
|
return
|
|
}
|
|
if key == "listen" {
|
|
defaultServer := false
|
|
paramLen := len(params)
|
|
if paramLen > 0 && params[paramLen-1] == "default_server" {
|
|
params = params[:paramLen-1]
|
|
defaultServer = true
|
|
}
|
|
s.UpdateListen(params[0], defaultServer, params[1:]...)
|
|
return
|
|
}
|
|
|
|
directives := s.Directives
|
|
index := -1
|
|
for i, dir := range directives {
|
|
if dir.GetName() == key {
|
|
if IsRepeatKey(key) {
|
|
oldParams := dir.GetParameters()
|
|
if !(len(oldParams) > 0 && oldParams[0] == params[0]) {
|
|
continue
|
|
}
|
|
}
|
|
index = i
|
|
break
|
|
}
|
|
}
|
|
newDirective := &Directive{
|
|
Name: key,
|
|
Parameters: params,
|
|
}
|
|
if index > -1 {
|
|
directives[index] = newDirective
|
|
} else {
|
|
directives = append(directives, newDirective)
|
|
}
|
|
s.Directives = directives
|
|
}
|
|
|
|
func (s *Server) RemoveDirective(key string, params []string) {
|
|
directives := s.Directives
|
|
var newDirectives []IDirective
|
|
for _, dir := range directives {
|
|
if dir.GetName() == key {
|
|
if len(params) == 0 {
|
|
continue
|
|
}
|
|
oldParams := dir.GetParameters()
|
|
if key == "location" {
|
|
if len(params) == len(oldParams) {
|
|
exist := true
|
|
for i := range params {
|
|
if params[i] != oldParams[i] {
|
|
exist = false
|
|
break
|
|
}
|
|
}
|
|
if exist {
|
|
continue
|
|
}
|
|
}
|
|
} else {
|
|
if oldParams[0] == params[0] {
|
|
continue
|
|
}
|
|
}
|
|
}
|
|
newDirectives = append(newDirectives, dir)
|
|
}
|
|
s.Directives = newDirectives
|
|
}
|
|
|
|
func (s *Server) GetLine() int {
|
|
return s.Line
|
|
}
|
|
|
|
func (s *Server) AddListen(bind string, defaultServer bool, params ...string) {
|
|
listen := &ServerListen{
|
|
Bind: bind,
|
|
Parameters: params,
|
|
}
|
|
if defaultServer {
|
|
listen.DefaultServer = DefaultServer
|
|
}
|
|
s.Listens = append(s.Listens, listen)
|
|
}
|
|
|
|
func (s *Server) UpdateListen(bind string, defaultServer bool, params ...string) {
|
|
listen := &ServerListen{
|
|
Bind: bind,
|
|
Parameters: params,
|
|
}
|
|
if defaultServer {
|
|
listen.DefaultServer = DefaultServer
|
|
}
|
|
var newListens []*ServerListen
|
|
exist := false
|
|
for _, li := range s.Listens {
|
|
if li.Bind == bind {
|
|
exist = true
|
|
newListens = append(newListens, listen)
|
|
} else {
|
|
newListens = append(newListens, li)
|
|
}
|
|
}
|
|
if !exist {
|
|
newListens = append(newListens, listen)
|
|
}
|
|
|
|
s.Listens = newListens
|
|
}
|
|
|
|
func (s *Server) DeleteListen(bind string) {
|
|
var newListens []*ServerListen
|
|
for _, li := range s.Listens {
|
|
if li.Bind != bind {
|
|
newListens = append(newListens, li)
|
|
}
|
|
}
|
|
s.Listens = newListens
|
|
}
|
|
|
|
func (s *Server) DeleteServerName(name string) {
|
|
var names []string
|
|
dirs := s.FindDirectives("server_name")
|
|
params := dirs[0].GetParameters()
|
|
for _, param := range params {
|
|
if param != name {
|
|
names = append(names, param)
|
|
}
|
|
}
|
|
s.UpdateServerName(names)
|
|
}
|
|
|
|
func (s *Server) AddServerName(name string) {
|
|
dirs := s.FindDirectives("server_name")
|
|
params := dirs[0].GetParameters()
|
|
params = append(params, name)
|
|
s.UpdateServerName(params)
|
|
}
|
|
|
|
func (s *Server) UpdateServerName(names []string) {
|
|
s.UpdateDirective("server_name", names)
|
|
}
|
|
|
|
func (s *Server) UpdateRoot(path string) {
|
|
s.UpdateDirective("root", []string{path})
|
|
}
|
|
|
|
func (s *Server) UpdateRootLocation() {
|
|
newDir := Directive{
|
|
Name: "location",
|
|
Parameters: []string{"/"},
|
|
Block: &Block{},
|
|
}
|
|
block := &Block{}
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "root",
|
|
Parameters: []string{"index.html"},
|
|
})
|
|
newDir.Block = block
|
|
}
|
|
|
|
func (s *Server) UpdateRootProxy(proxy []string) {
|
|
newDir := Directive{
|
|
Name: "location",
|
|
Parameters: []string{"/"},
|
|
Block: &Block{},
|
|
}
|
|
block := &Block{}
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "proxy_pass",
|
|
Parameters: proxy,
|
|
})
|
|
newDir.Block = block
|
|
s.UpdateDirectiveBySecondKey("location", "/", newDir)
|
|
}
|
|
|
|
func (s *Server) UpdatePHPProxy(proxy []string, localPath string) {
|
|
newDir := Directive{
|
|
Name: "location",
|
|
Parameters: []string{"~ [^/]\\.php(/|$)"},
|
|
Block: &Block{},
|
|
}
|
|
block := &Block{}
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "fastcgi_pass",
|
|
Parameters: proxy,
|
|
})
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "include",
|
|
Parameters: []string{"fastcgi-php.conf"},
|
|
})
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "include",
|
|
Parameters: []string{"fastcgi_params"},
|
|
})
|
|
if localPath == "" {
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "set",
|
|
Parameters: []string{"$real_script_name", "$fastcgi_script_name"},
|
|
})
|
|
ifDir := &Directive{
|
|
Name: "if",
|
|
Parameters: []string{"($fastcgi_script_name ~ \"^(.+?\\.php)(/.+)$\")"},
|
|
}
|
|
ifDir.Block = &Block{
|
|
Directives: []IDirective{
|
|
&Directive{
|
|
Name: "set",
|
|
Parameters: []string{"$real_script_name", "$1"},
|
|
},
|
|
&Directive{
|
|
Name: "set",
|
|
Parameters: []string{"$path_info", "$2"},
|
|
},
|
|
},
|
|
}
|
|
block.Directives = append(block.Directives, ifDir)
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "fastcgi_param",
|
|
Parameters: []string{"SCRIPT_FILENAME", "$document_root$real_script_name"},
|
|
})
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "fastcgi_param",
|
|
Parameters: []string{"SCRIPT_NAME", "$real_script_name"},
|
|
})
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "fastcgi_param",
|
|
Parameters: []string{"PATH_INFO", "$path_info"},
|
|
})
|
|
} else {
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "fastcgi_param",
|
|
Parameters: []string{"SCRIPT_FILENAME", localPath},
|
|
})
|
|
}
|
|
newDir.Block = block
|
|
s.UpdateDirectiveBySecondKey("location", "~ [^/]\\.php(/|$)", newDir)
|
|
}
|
|
|
|
func (s *Server) UpdateDirectiveBySecondKey(name string, key string, directive Directive) {
|
|
directives := s.Directives
|
|
index := -1
|
|
for i, dir := range directives {
|
|
if dir.GetName() == name && dir.GetParameters()[0] == key {
|
|
index = i
|
|
break
|
|
}
|
|
}
|
|
if index > -1 {
|
|
directives[index] = &directive
|
|
} else {
|
|
directives = append(directives, &directive)
|
|
}
|
|
s.Directives = directives
|
|
}
|
|
|
|
func (s *Server) RemoveListenByBind(bind string) {
|
|
var listens []*ServerListen
|
|
for _, listen := range s.Listens {
|
|
if listen.Bind != bind {
|
|
listens = append(listens, listen)
|
|
}
|
|
}
|
|
s.Listens = listens
|
|
}
|
|
|
|
func (s *Server) AddHTTP2HTTPS() {
|
|
newDir := Directive{
|
|
Name: "if",
|
|
Parameters: []string{"($scheme = http)"},
|
|
Block: &Block{},
|
|
}
|
|
block := &Block{}
|
|
block.Directives = append(block.Directives, &Directive{
|
|
Name: "return",
|
|
Parameters: []string{"301", "https://$host$request_uri"},
|
|
})
|
|
newDir.Block = block
|
|
s.UpdateDirectiveBySecondKey("if", "($scheme", newDir)
|
|
}
|