fix: add translator

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

Author: ronething

internal/controller/gateway_controller.go

@@ -120,6 +120,8 @@ func (r *GatewayReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ct
 		Secrets: make(map[types.NamespacedName]*corev1.Secret),
 	}
 	r.processListenerConfig(tctx, gateway, ns)
+	r.processGatewayProxy(tctx, gateway, ns)
+
 	if err := r.Provider.Update(ctx, tctx, gateway); err != nil {
 		acceptStatus = status{
 			status: false,
@@ -265,6 +267,25 @@ func (r *GatewayReconciler) listGatewaysForHTTPRoute(_ context.Context, obj clie
 	return recs
 }
 
+func (r *GatewayReconciler) processGatewayProxy(tctx *provider.TranslateContext, gateway *gatewayv1.Gateway, ns string) {
+	infra := gateway.Spec.Infrastructure
+	if infra != nil && infra.ParametersRef != nil {
+		paramRef := infra.ParametersRef
+		if string(paramRef.Group) == v1alpha1.GroupVersion.Group && string(paramRef.Kind) == "GatewayProxy" {
+			gatewayProxy := &v1alpha1.GatewayProxy{}
+			if err := r.Get(context.Background(), client.ObjectKey{
+				Namespace: ns,
+				Name:      string(paramRef.Name),
+			}, gatewayProxy); err != nil {
+				log.Error(err, "failed to get GatewayProxy", "namespace", ns, "name", string(paramRef.Name))
+			} else {
+				log.Info("found GatewayProxy for Gateway", "gateway", gateway.Name, "gatewayproxy", gatewayProxy.Name)
+				tctx.GatewayProxy = gatewayProxy
+			}
+		}
+	}
+}
+
 func (r *GatewayReconciler) processListenerConfig(tctx *provider.TranslateContext, gateway *gatewayv1.Gateway, ns string) {
 	listeners := gateway.Spec.Listeners
 	for _, listener := range listeners {

internal/provider/adc/adc.go

@@ -49,6 +49,8 @@ func (d *adcClient) Update(ctx context.Context, tctx *provider.TranslateContext,
 	switch obj := obj.(type) {
 	case *gatewayv1.HTTPRoute:
 		result, err = d.translator.TranslateHTTPRoute(tctx, obj.DeepCopy())
+	case *gatewayv1.Gateway:
+		result, err = d.translator.TranslateGateway(tctx, obj.DeepCopy())
 	}
 	if err != nil {
 		return err
@@ -58,7 +60,8 @@ func (d *adcClient) Update(ctx context.Context, tctx *provider.TranslateContext,
 	}
 
 	resources := types.Resources{
-		Services: result.Services,
+		Services:    result.Services,
+		GlobalRules: result.GlobalRules,
 	}
 
 	return d.sync(Task{
@@ -101,6 +104,7 @@ func (d *adcClient) sync(task Task) error {
 		"sync",
 		"-f", tmpFile.Name(),
 		"--include-resource-type", "service",
+		"--include-resource-type", "global_rule",
 		"--tls-skip-verify",
 	}
 

internal/provider/adc/translator/gateway.go

@@ -1 +1,51 @@
 package translator
+
+import (
+	"encoding/json"
+
+	adctypes "github.com/api7/api7-ingress-controller/api/adc"
+	"github.com/api7/api7-ingress-controller/api/v1alpha1"
+	"github.com/api7/api7-ingress-controller/internal/provider"
+	"github.com/api7/gopkg/pkg/log"
+	"go.uber.org/zap"
+	gatewayv1 "sigs.k8s.io/gateway-api/apis/v1"
+)
+
+// FillPluginsFromGatewayProxy fill plugins from GatewayProxy to given plugins
+func (t *Translator) FillPluginsFromGatewayProxy(plugins adctypes.Plugins, gatewayProxy *v1alpha1.GatewayProxy) {
+	if gatewayProxy == nil {
+		return
+	}
+
+	for _, plugin := range gatewayProxy.Spec.Plugins {
+		// only apply enabled plugins
+		if !plugin.Enabled {
+			continue
+		}
+
+		pluginName := plugin.Name
+		var pluginConfig map[string]any
+		if err := json.Unmarshal(plugin.Config.Raw, &pluginConfig); err != nil {
+			log.Errorw("gateway proxy plugin config unmarshal failed", zap.Error(err), zap.String("plugin", pluginName))
+			continue
+		}
+
+		log.Debugw("fill plugin from gateway proxy", zap.String("plugin", pluginName), zap.Any("config", pluginConfig))
+		plugins[pluginName] = pluginConfig
+	}
+}
+
+// TranslateGateway translate gateway to adc resources
+func (t *Translator) TranslateGateway(tctx *provider.TranslateContext, gateway *gatewayv1.Gateway) (*TranslateResult, error) {
+	result := &TranslateResult{}
+
+	// if gateway has a GatewayProxy resource, create a global service and apply plugins
+	if tctx.GatewayProxy != nil {
+		globalRules := adctypes.Plugins{}
+		// apply plugins from GatewayProxy to global rules
+		t.FillPluginsFromGatewayProxy(globalRules, tctx.GatewayProxy)
+		result.GlobalRules = globalRules
+	}
+
+	return result, nil
+}

internal/provider/adc/translator/translator.go

@@ -10,7 +10,8 @@ type Translator struct {
 	Log logr.Logger
 }
 type TranslateResult struct {
-	Routes   []*adctypes.Route
-	Services []*adctypes.Service
-	SSL      []*adctypes.SSL
+	Routes      []*adctypes.Route
+	Services    []*adctypes.Service
+	SSL         []*adctypes.SSL
+	GlobalRules adctypes.Plugins
 }

internal/provider/provider.go

@@ -20,6 +20,7 @@ type Provider interface {
 type TranslateContext struct {
 	BackendRefs      []gatewayv1.BackendRef
 	GatewayTLSConfig []gatewayv1.GatewayTLSConfig
+	GatewayProxy     *v1alpha1.GatewayProxy
 	EndpointSlices   map[types.NamespacedName][]discoveryv1.EndpointSlice
 	Secrets          map[types.NamespacedName]*corev1.Secret
 	PluginConfigs    map[types.NamespacedName]*v1alpha1.PluginConfig