fix: support sync global rule in api7ee mode

Signed-off-by: ashing <[email protected]>

Author: ronething

internal/provider/adc/adc.go

@@ -21,6 +21,7 @@ import (
 	"context"
 	"encoding/json"
 	"os"
+	"slices"
 	"sync"
 	"time"
 
@@ -351,6 +352,18 @@ func (d *adcClient) sync(ctx context.Context, task Task) error {
 		return errors.New("no adc configs provided")
 	}
 
+	// for global rules, we need to list all global rules
+	if slices.Contains(task.ResourceTypes, "global_rule") {
+		for _, config := range task.configs {
+			globalRules, err := d.store.GetGlobalRules(config.Name)
+			if err != nil {
+				return err
+			}
+			task.Resources.GlobalRules = *globalRules
+			log.Debugw("syncing resources global rules", zap.Any("globalRules", task.Resources.GlobalRules))
+		}
+	}
+
 	syncFilePath, cleanup, err := prepareSyncFile(task.Resources)
 	if err != nil {
 		return err

internal/provider/adc/store.go

@@ -244,3 +244,28 @@ func (s *Store) GetResources(name string) (*adctypes.Resources, error) {
 		PluginMetadata: metadata,
 	}, nil
 }
+
+func (s *Store) GetGlobalRules(name string) (*adctypes.GlobalRule, error) {
+	s.Lock()
+	defer s.Unlock()
+
+	var globalrule adctypes.GlobalRule
+	targetCache, ok := s.cacheMap[name]
+	if !ok {
+		return &globalrule, nil
+	}
+	// Get all global rules from cache and merge them
+	globalRuleItems, _ := targetCache.ListGlobalRules()
+	if len(globalRuleItems) > 0 {
+		merged := make(adctypes.Plugins)
+		for _, item := range globalRuleItems {
+			for k, v := range item.Plugins {
+				merged[k] = v
+			}
+		}
+		globalrule = adctypes.GlobalRule(merged)
+	}
+	log.Debugw("get resources global rule items", zap.Any("globalRuleItems", globalRuleItems))
+
+	return &globalrule, nil
+}

test/e2e/crds/v2/globalrule.go

@@ -88,9 +88,9 @@ spec:
 
 	Context("ApisixGlobalRule Basic Operations", func() {
 		BeforeEach(func() {
-			if s.Deployer.Name() == "api7ee" {
-				Skip("GlobalRule is not supported in api7ee")
-			}
+			// if s.Deployer.Name() == "api7ee" {
+			// 	Skip("GlobalRule is not supported in api7ee")
+			// }
 			By("create GatewayProxy")
 			gatewayProxy := fmt.Sprintf(gatewayProxyYaml, s.Deployer.GetAdminEndpoint(), s.AdminKey())
 			err := s.CreateResourceFromStringWithNamespace(gatewayProxy, "default")