api/controller/gateway.go
Rama main · réplica de lectura del repositorio original.
// RAINBOND, Application Management Platform
// Copyright (C) 2014-2017 Goodrain Co., Ltd.
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version. For any non-GPL usage of Rainbond,
// one or multiple Commercial Licenses authorized by Goodrain Co., Ltd.
// must be obtained first.
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <http://www.gnu.org/licenses/>.
package controller
import (
"fmt"
"net/http"
"net/url"
"strconv"
"strings"
"github.com/goodrain/rainbond/api/handler"
api_model "github.com/goodrain/rainbond/api/model"
ctxutil "github.com/goodrain/rainbond/api/util/ctx"
"github.com/goodrain/rainbond/config/configs"
dbmodel "github.com/goodrain/rainbond/db/model"
"github.com/goodrain/rainbond/mq/client"
httputil "github.com/goodrain/rainbond/util/http"
"github.com/jinzhu/gorm"
"github.com/sirupsen/logrus"
k8svalidation "k8s.io/apimachinery/pkg/util/validation"
)
// GatewayStruct -
type GatewayStruct struct {
MQClient client.MQClient
}
// HTTPRule is used to add, update or delete http rule which enables
// external traffic to access applications through the gateway
func (g *GatewayStruct) HTTPRule(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case "POST":
g.addHTTPRule(w, r)
case "PUT":
g.updateHTTPRule(w, r)
case "DELETE":
g.deleteHTTPRule(w, r)
}
}
// GatewayCertificate k8s gateway certificate related operations
func (g *GatewayStruct) GatewayCertificate(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case "PUT":
g.updateGatewayCertificate(w, r)
case "POST":
g.addGatewayCertificate(w, r)
case "DELETE":
g.deleteGatewayCertificate(w, r)
}
}
// GatewayClientCA manages client certificate authorities used by inbound gateway mTLS.
func (g *GatewayStruct) GatewayClientCA(w http.ResponseWriter, r *http.Request) {
tenant := r.Context().Value(ctxutil.ContextKey("tenant")).(*dbmodel.Tenants)
switch r.Method {
case http.MethodGet:
statuses, err := handler.GetGatewayHandler().ListGatewayClientCAs(tenant.Namespace)
if err != nil {
httputil.ReturnError(r, w, http.StatusInternalServerError, "failed to list gateway client CAs")
return
}
httputil.ReturnSuccess(r, w, statuses)
case http.MethodPost, http.MethodPut:
var req api_model.GatewayClientCA
if !httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil) {
return
}
var err error
if r.Method == http.MethodPost {
err = handler.GetGatewayHandler().AddGatewayClientCA(tenant.Namespace, &req)
} else {
err = handler.GetGatewayHandler().UpdateGatewayClientCA(tenant.Namespace, &req)
}
if err != nil {
httputil.ReturnError(r, w, http.StatusBadRequest, err.Error())
return
}
httputil.ReturnSuccess(r, w, nil)
case http.MethodDelete:
name := r.URL.Query().Get("name")
if name == "" {
httputil.ReturnError(r, w, http.StatusBadRequest, "client CA name is required")
return
}
if err := handler.GetGatewayHandler().DeleteGatewayClientCA(tenant.Namespace, name); err != nil {
httputil.ReturnError(r, w, http.StatusBadRequest, err.Error())
return
}
httputil.ReturnSuccess(r, w, nil)
}
}
// BatchGatewayHTTPRoute k8s gateway http route batch operation
func (g *GatewayStruct) BatchGatewayHTTPRoute(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case "GET":
g.batchGetGatewayHTTPRoute(w, r)
}
}
// GatewayHTTPRoute k8s gateway http route related operations
func (g *GatewayStruct) GatewayHTTPRoute(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case "GET":
g.getGatewayHTTPRoute(w, r)
case "PUT":
g.updateGatewayHTTPRoute(w, r)
case "POST":
g.addGatewayHTTPRoute(w, r)
case "DELETE":
g.deleteGatewayHTTPRoute(w, r)
}
}
func validateDomain(domain string) []string {
if strings.TrimSpace(domain) == "" {
return nil
}
var errs []string
if strings.Contains(domain, "*") {
errs = k8svalidation.IsWildcardDNS1123Subdomain(domain)
} else {
errs = k8svalidation.IsDNS1123Subdomain(domain)
}
return errs
}
func (g *GatewayStruct) addGatewayCertificate(w http.ResponseWriter, r *http.Request) {
var req api_model.GatewayCertificate
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
err := handler.GetGatewayHandler().AddGatewayCertificate(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while add gateway certificate: %v", err))
return
}
httputil.ReturnSuccess(r, w, "添加成功")
}
func (g *GatewayStruct) updateGatewayCertificate(w http.ResponseWriter, r *http.Request) {
var req api_model.GatewayCertificate
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
err := handler.GetGatewayHandler().UpdateGatewayCertificate(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while update gateway certificate: %v", err))
return
}
httputil.ReturnSuccess(r, w, "更新成功")
}
func (g *GatewayStruct) deleteGatewayCertificate(w http.ResponseWriter, r *http.Request) {
name := r.FormValue("name")
namespace := r.FormValue("namespace")
err := handler.GetGatewayHandler().DeleteGatewayCertificate(name, namespace)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while delete gateway certificate: %v", err))
return
}
httputil.ReturnSuccess(r, w, "删除成功")
}
func (g *GatewayStruct) addGatewayHTTPRoute(w http.ResponseWriter, r *http.Request) {
var req api_model.GatewayHTTPRouteStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
res, err := handler.GetGatewayHandler().AddGatewayHTTPRoute(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while adding gateway http rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, res)
}
func (g *GatewayStruct) getGatewayHTTPRoute(w http.ResponseWriter, r *http.Request) {
name := r.FormValue("name")
namespace := r.FormValue("namespace")
route, err := handler.GetGatewayHandler().GetGatewayHTTPRoute(name, namespace)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while get gateway http rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, route)
}
func (g *GatewayStruct) deleteGatewayHTTPRoute(w http.ResponseWriter, r *http.Request) {
name := r.FormValue("name")
namespace := r.FormValue("namespace")
appID := r.FormValue("app_id")
operator := r.FormValue("operator")
err := handler.GetGatewayHandler().DeleteGatewayHTTPRoute(name, namespace, appID, operator)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while delete gateway http rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, "删除成功")
}
func (g *GatewayStruct) updateGatewayHTTPRoute(w http.ResponseWriter, r *http.Request) {
var req api_model.GatewayHTTPRouteStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
res, err := handler.GetGatewayHandler().UpdateGatewayHTTPRoute(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while update gateway http rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, res)
}
func (g *GatewayStruct) batchGetGatewayHTTPRoute(w http.ResponseWriter, r *http.Request) {
namespace := r.FormValue("namespace")
appID := r.FormValue("app_id")
data, err := handler.GetGatewayHandler().BatchGetGatewayHTTPRoute(namespace, appID)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while batch get gateway http rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, data)
}
func (g *GatewayStruct) addHTTPRule(w http.ResponseWriter, r *http.Request) {
var req api_model.AddHTTPRuleStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
// verify request
values := url.Values{}
if req.ContainerPort == 0 {
values["container_port"] = []string{"The container_port field is required"}
}
if strings.Replace(req.CertificateID, " ", "", -1) != "" {
if req.Certificate == "" {
values["certificate"] = []string{"The certificate field is required"}
}
if req.PrivateKey == "" {
values["private_key"] = []string{"The private_key field is required"}
}
}
errs := validateDomain(req.Domain)
if errs != nil && len(errs) > 0 {
logrus.Debugf("Invalid domain: %s", strings.Join(errs, ";"))
values["domain"] = []string{"The domain field is invalid"}
}
if len(values) != 0 {
httputil.ReturnValidationError(r, w, values)
return
}
h := handler.GetGatewayHandler()
err := h.AddHTTPRule(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while adding http rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, req)
}
func (g *GatewayStruct) updateHTTPRule(w http.ResponseWriter, r *http.Request) {
var req api_model.UpdateHTTPRuleStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
// verify request
values := url.Values{}
if strings.Replace(req.CertificateID, " ", "", -1) != "" {
if req.Certificate == "" {
values["certificate"] = []string{"The certificate field is required"}
}
if req.PrivateKey == "" {
values["private_key"] = []string{"The private_key field is required"}
}
}
if len(req.RuleExtensions) > 0 {
for _, re := range req.RuleExtensions {
if re.Key == "" {
values["key"] = []string{"The key field is required"}
break
}
if re.Value == "" {
values["value"] = []string{"The value field is required"}
break
}
}
}
errs := validateDomain(req.Domain)
if errs != nil && len(errs) > 0 {
logrus.Debugf("Invalid domain: %s", strings.Join(errs, ";"))
values["domain"] = []string{"The domain field is invalid"}
}
if len(values) != 0 {
httputil.ReturnValidationError(r, w, values)
return
}
h := handler.GetGatewayHandler()
err := h.UpdateHTTPRule(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while "+
"updating http rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, "success")
}
func (g *GatewayStruct) deleteHTTPRule(w http.ResponseWriter, r *http.Request) {
var req api_model.DeleteHTTPRuleStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
h := handler.GetGatewayHandler()
err := h.DeleteHTTPRule(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while delete http rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, "success")
}
// TCPRule is used to add, update or delete tcp rule which enables
// external traffic to access applications through the gateway
func (g *GatewayStruct) TCPRule(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case "POST":
g.AddTCPRule(w, r)
case "PUT":
g.updateTCPRule(w, r)
case "DELETE":
g.deleteTCPRule(w, r)
}
}
// AddTCPRule adds a tcp rule
func (g *GatewayStruct) AddTCPRule(w http.ResponseWriter, r *http.Request) {
var req api_model.AddTCPRuleStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
h := handler.GetGatewayHandler()
// verify request
values := url.Values{}
apiConfig := configs.Default().APIConfig
if req.ContainerPort == 0 {
values["container_port"] = []string{"The container_port field is required"}
}
if req.Port == 0 {
values["port"] = []string{"The port field is required"}
} else if req.Port <= apiConfig.MinExtPort {
values["port"] = []string{fmt.Sprintf("The port field should be greater than %d", apiConfig.MinExtPort)}
} else {
// check if the port exists
if h.TCPIPPortExists(req.IP, req.Port) {
values["port"] = []string{fmt.Sprintf("The ip %s port(%v) already exists", req.IP, req.Port)}
}
}
if len(req.RuleExtensions) > 0 {
for _, re := range req.RuleExtensions {
if re.Key == "" {
values["key"] = []string{"The key field is required"}
break
}
if re.Value == "" {
values["value"] = []string{"The value field is required"}
break
}
}
}
if len(values) != 0 {
httputil.ReturnValidationError(r, w, values)
return
}
err := h.AddTCPRule(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while "+
"adding tcp rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, "success")
}
func (g *GatewayStruct) updateTCPRule(w http.ResponseWriter, r *http.Request) {
var req api_model.UpdateTCPRuleStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
h := handler.GetGatewayHandler()
// verify reqeust
values := url.Values{}
apiConfig := configs.Default().APIConfig
if req.Port != 0 && req.Port <= apiConfig.MinExtPort {
values["port"] = []string{fmt.Sprintf("The port field should be greater than %d", apiConfig.MinExtPort)}
}
if len(req.RuleExtensions) > 0 {
for _, re := range req.RuleExtensions {
if re.Key == "" {
values["key"] = []string{"The key field is required"}
break
}
if re.Value == "" {
values["value"] = []string{"The value field is required"}
break
}
}
}
if len(values) != 0 {
httputil.ReturnValidationError(r, w, values)
return
}
err := h.UpdateTCPRule(&req, apiConfig.MinExtPort)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while "+
"updating tcp rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, "success")
}
func (g *GatewayStruct) deleteTCPRule(w http.ResponseWriter, r *http.Request) {
var req api_model.DeleteTCPRuleStruct
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
h := handler.GetGatewayHandler()
err := h.DeleteTCPRule(&req)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while "+
"deleting tcp rule: %v", err))
return
}
httputil.ReturnSuccess(r, w, "success")
}
// GetAvailablePort returns a available port
func (g *GatewayStruct) GetAvailablePort(w http.ResponseWriter, r *http.Request) {
h := handler.GetGatewayHandler()
lock, _ := strconv.ParseBool(r.FormValue("lock"))
res, err := h.GetAvailablePort("0.0.0.0", lock)
if err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Unexpected error occorred while "+
"getting available port: %v", err))
return
}
httputil.ReturnSuccess(r, w, res)
}
// RuleConfig is used to add, update or delete rule config.
func (g *GatewayStruct) RuleConfig(w http.ResponseWriter, r *http.Request) {
var req api_model.RuleConfigReq
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
sid := r.Context().Value(ctxutil.ContextKey("service_id")).(string)
eventID := r.Context().Value(ctxutil.ContextKey("event_id")).(string)
req.ServiceID = sid
req.EventID = eventID
if err := handler.GetGatewayHandler().RuleConfig(&req); err != nil {
httputil.ReturnError(r, w, 500, fmt.Sprintf("Rule id: %s; error update rule config: %v", req.RuleID, err))
return
}
httputil.ReturnSuccess(r, w, "success")
}
// Certificate -
func (g *GatewayStruct) Certificate(w http.ResponseWriter, r *http.Request) {
switch r.Method {
case "PUT":
g.updCertificate(w, r)
}
}
// updCertificate updates certificate and refresh http rules based on certificate id
func (g *GatewayStruct) updCertificate(w http.ResponseWriter, r *http.Request) {
var req api_model.UpdCertificateReq
ok := httputil.ValidatorRequestStructAndErrorResponse(r, w, &req, nil)
if !ok {
return
}
if err := handler.GetGatewayHandler().UpdCertificate(&req); err != nil {
logrus.Errorf("update certificate: %v", err)
if err == gorm.ErrRecordNotFound {
httputil.ReturnError(r, w, 404, err.Error())
return
}
httputil.ReturnError(r, w, 500, err.Error())
return
}
httputil.ReturnSuccess(r, w, nil)
}
// GetGatewayIPs get gateway ips
func GetGatewayIPs(w http.ResponseWriter, r *http.Request) {
ips := handler.GetGatewayHandler().GetGatewayIPs()
httputil.ReturnSuccess(r, w, ips)
}