feat: support global rules for Manager API

api/filter/schema.go

@@ -36,11 +36,12 @@ import (
 )
 
 var resources = map[string]string{
-	"routes":    "route",
-	"upstreams": "upstream",
-	"services":  "service",
-	"consumers": "consumer",
-	"ssl":       "ssl",
+	"routes":       "route",
+	"upstreams":    "upstream",
+	"services":     "service",
+	"consumers":    "consumer",
+	"ssl":          "ssl",
+	"global_rules": "global_rule",
 }
 
 func parseCert(crt, key string) ([]string, error) {

api/internal/core/entity/entity.go

@@ -226,6 +226,12 @@ type Script struct {
 	Script interface{} `json:"script,omitempty"`
 }
 
+// swagger:model GlobalPlugins
+type GlobalPlugins struct {
+	ID      interface{}            `json:"id"`
+	Plugins map[string]interface{} `json:"plugins,omitempty"`
+}
+
 type ServerInfo struct {
 	BaseInfo
 	LastReportTime int64  `json:"last_report_time,omitempty"`

api/internal/core/store/storehub.go

@@ -34,6 +34,7 @@ const (
 	HubKeySsl        HubKey = "ssl"
 	HubKeyUpstream   HubKey = "upstream"
 	HubKeyScript     HubKey = "script"
+	HubKeyGlobalRule HubKey = "global_rule"
 	HubKeyServerInfo HubKey = `server_info`
 )
 
@@ -42,8 +43,15 @@ var (
 )
 
 func InitStore(key HubKey, opt GenericStoreOption) error {
-	if key == HubKeyConsumer || key == HubKeyRoute ||
-		key == HubKeyService || key == HubKeySsl || key == HubKeyUpstream {
+	hubsNeedCheck := map[HubKey]bool{
+		HubKeyConsumer:   true,
+		HubKeyRoute:      true,
+		HubKeySsl:        true,
+		HubKeyService:    true,
+		HubKeyUpstream:   true,
+		HubKeyGlobalRule: true,
+	}
+	if _, ok := hubsNeedCheck[key]; ok {
 		validator, err := NewAPISIXJsonSchemaValidator("main." + string(key))
 		if err != nil {
 			return err
@@ -145,6 +153,18 @@ func InitStores() error {
 		return err
 	}
 
+	err = InitStore(HubKeyGlobalRule, GenericStoreOption{
+		BasePath: "/apisix/global_rules",
+		ObjType:  reflect.TypeOf(entity.GlobalPlugins{}),
+		KeyFunc: func(obj interface{}) string {
+			r := obj.(*entity.GlobalPlugins)
+			return utils.InterfaceToString(r.ID)
+		},
+	})
+	if err != nil {
+		return err
+	}
+
 	err = InitStore(HubKeyServerInfo, GenericStoreOption{
 		BasePath: "/apisix/data_plane/server_info",
 		ObjType:  reflect.TypeOf(entity.ServerInfo{}),

api/internal/handler/global_rule/global_rule.go

@@ -0,0 +1,140 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package global_rule
+
+import (
+	"reflect"
+	"strings"
+
+	"github.com/gin-gonic/gin"
+	"github.com/shiningrush/droplet"
+	"github.com/shiningrush/droplet/wrapper"
+	wgin "github.com/shiningrush/droplet/wrapper/gin"
+
+	"github.com/apisix/manager-api/internal/core/entity"
+	"github.com/apisix/manager-api/internal/core/store"
+	"github.com/apisix/manager-api/internal/handler"
+)
+
+type Handler struct {
+	globalRuleStore store.Interface
+}
+
+func NewHandler() (handler.RouteRegister, error) {
+	return &Handler{
+		globalRuleStore: store.GetStore(store.HubKeyGlobalRule),
+	}, nil
+}
+
+func (h *Handler) ApplyRoute(r *gin.Engine) {
+	// global plugins
+	r.GET("/apisix/admin/global_rules/:id", wgin.Wraps(h.Get,
+		wrapper.InputType(reflect.TypeOf(GetInput{}))))
+	r.GET("/apisix/admin/global_rules", wgin.Wraps(h.List,
+		wrapper.InputType(reflect.TypeOf(ListInput{}))))
+	r.PUT("/apisix/admin/global_rules/:id", wgin.Wraps(h.Set,
+		wrapper.InputType(reflect.TypeOf(entity.GlobalPlugins{}))))
+	r.PUT("/apisix/admin/global_rules", wgin.Wraps(h.Set,
+		wrapper.InputType(reflect.TypeOf(entity.GlobalPlugins{}))))
+	r.DELETE("/apisix/admin/global_rules/:ids", wgin.Wraps(h.BatchDelete,
+		wrapper.InputType(reflect.TypeOf(BatchDeleteInput{}))))
+}
+
+type GetInput struct {
+	ID string `auto_read:"id,path" validate:"required"`
+}
+
+func (h *Handler) Get(c droplet.Context) (interface{}, error) {
+	input := c.Input().(*GetInput)
+
+	r, err := h.globalRuleStore.Get(input.ID)
+	if err != nil {
+		return handler.SpecCodeResponse(err), err
+	}
+	return r, nil
+}
+
+type ListInput struct {
+	store.Pagination
+}
+
+// swagger:operation GET /apisix/admin/global_rules getGlobalRuleList
+//
+// Return the global rule list according to the specified page number and page size.
+//
+// ---
+// produces:
+// - application/json
+// parameters:
+// - name: page
+//   in: query
+//   description: page number
+//   required: false
+//   type: integer
+// - name: page_size
+//   in: query
+//   description: page size
+//   required: false
+//   type: integer
+// responses:
+//   '0':
+//     description: list response
+//     schema:
+//       type: array
+//       items:
+//         "$ref": "#/definitions/GlobalPlugins"
+//   default:
+//     description: unexpected error
+//     schema:
+//       "$ref": "#/definitions/ApiError"
+func (h *Handler) List(c droplet.Context) (interface{}, error) {
+	input := c.Input().(*ListInput)
+
+	ret, err := h.globalRuleStore.List(store.ListInput{
+		PageSize:   input.PageSize,
+		PageNumber: input.PageNumber,
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	return ret, nil
+}
+
+func (h *Handler) Set(c droplet.Context) (interface{}, error) {
+	input := c.Input().(*entity.GlobalPlugins)
+
+	if err := h.globalRuleStore.Create(c.Context(), input); err != nil {
+		return handler.SpecCodeResponse(err), err
+	}
+
+	return nil, nil
+}
+
+type BatchDeleteInput struct {
+	IDs string `auto_read:"ids,path"`
+}
+
+func (h *Handler) BatchDelete(c droplet.Context) (interface{}, error) {
+	input := c.Input().(*BatchDeleteInput)
+
+	if err := h.globalRuleStore.BatchDelete(c.Context(), strings.Split(input.IDs, ",")); err != nil {
+		return handler.SpecCodeResponse(err), err
+	}
+
+	return nil, nil
+}