diff --git a/internal/db/models/reverse_proxy_dao.go b/internal/db/models/reverse_proxy_dao.go index 5c01ca75..9c1483c3 100644 --- a/internal/db/models/reverse_proxy_dao.go +++ b/internal/db/models/reverse_proxy_dao.go @@ -96,6 +96,7 @@ func (this *ReverseProxyDAO) ComposeReverseProxyConfig(reverseProxyId int64) (*s config.RequestHost = reverseProxy.RequestHost config.RequestURI = reverseProxy.RequestURI config.StripPrefix = reverseProxy.StripPrefix + config.AutoFlush = reverseProxy.AutoFlush == 1 schedulingConfig := &serverconfigs.SchedulingConfig{} if len(reverseProxy.Scheduling) > 0 && reverseProxy.Scheduling != "null" { @@ -216,7 +217,7 @@ func (this *ReverseProxyDAO) UpdateReverseProxyBackupOrigins(reverseProxyId int6 } // 修改是否启用 -func (this *ReverseProxyDAO) UpdateReverseProxy(reverseProxyId int64, requestHost string, requestURI string, stripPrefix string) error { +func (this *ReverseProxyDAO) UpdateReverseProxy(reverseProxyId int64, requestHost string, requestURI string, stripPrefix string, autoFlush bool) error { if reverseProxyId <= 0 { return errors.New("invalid reverseProxyId") } @@ -226,6 +227,7 @@ func (this *ReverseProxyDAO) UpdateReverseProxy(reverseProxyId int64, requestHos op.RequestHost = requestHost op.RequestURI = requestURI op.StripPrefix = stripPrefix + op.AutoFlush = autoFlush _, err := this.Save(op) return err } diff --git a/internal/db/models/reverse_proxy_model.go b/internal/db/models/reverse_proxy_model.go index 4537e3b7..aa183ff3 100644 --- a/internal/db/models/reverse_proxy_model.go +++ b/internal/db/models/reverse_proxy_model.go @@ -13,6 +13,7 @@ type ReverseProxy struct { StripPrefix string `field:"stripPrefix"` // 去除URL前缀 RequestHost string `field:"requestHost"` // 请求Host RequestURI string `field:"requestURI"` // 请求URI + AutoFlush uint8 `field:"autoFlush"` // 是否自动刷新缓冲区 State uint8 `field:"state"` // 状态 CreatedAt uint64 `field:"createdAt"` // 创建时间 } @@ -29,6 +30,7 @@ type ReverseProxyOperator struct { StripPrefix interface{} // 去除URL前缀 RequestHost interface{} // 请求Host RequestURI interface{} // 请求URI + AutoFlush interface{} // 是否自动刷新缓冲区 State interface{} // 状态 CreatedAt interface{} // 创建时间 } diff --git a/internal/db/models/server_dao.go b/internal/db/models/server_dao.go index 8e5781da..6afac423 100644 --- a/internal/db/models/server_dao.go +++ b/internal/db/models/server_dao.go @@ -118,6 +118,7 @@ func (this *ServerDAO) CreateServer(adminId int64, userId int64, serverType serv if len(excludeNodesJSON) > 0 { op.ExcludeNodes = excludeNodesJSON } + op.GroupIds = "[]" op.Version = 1 op.IsOn = 1 diff --git a/internal/rpc/services/service_reverse_proxy.go b/internal/rpc/services/service_reverse_proxy.go index d8e68de5..b7be1a1f 100644 --- a/internal/rpc/services/service_reverse_proxy.go +++ b/internal/rpc/services/service_reverse_proxy.go @@ -129,7 +129,7 @@ func (this *ReverseProxyService) UpdateReverseProxy(ctx context.Context, req *pb return nil, err } - err = models.SharedReverseProxyDAO.UpdateReverseProxy(req.ReverseProxyId, req.RequestHost, req.RequestURI, req.StripPrefix) + err = models.SharedReverseProxyDAO.UpdateReverseProxy(req.ReverseProxyId, req.RequestHost, req.RequestURI, req.StripPrefix, req.AutoFlush) if err != nil { return nil, err }