fix test

Author: AlinsRan

internal/adc/translator/apisixroute.go

@@ -235,7 +235,7 @@ func (t *Translator) buildUpstream(tctx *provider.TranslateContext, service *adc
 			log.Debugw("failed to retrieve ApisixUpstream from tctx", zap.Any("ApisixUpstream", upsNN))
 			continue
 		}
-		upstream, err := t.translateApisixUpstream(tctx, au, 0)
+		upstream, err := t.translateApisixUpstream(tctx, au)
 		if err != nil {
 			t.Log.Error(err, "failed to translate ApisixUpstream", "ApisixUpstream", utils.NamespacedName(au))
 			continue
@@ -347,7 +347,7 @@ func (t *Translator) translateApisixRouteHTTPBackend(tctx *provider.TranslateCon
 		if err != nil {
 			return nil, err
 		}
-		upstream, err = t.translateApisixUpstream(tctx, au, port)
+		upstream, err = t.translateApisixUpstreamForPort(tctx, au, ptr.To(port))
 		if err != nil {
 			return nil, err
 		}
@@ -356,12 +356,12 @@ func (t *Translator) translateApisixRouteHTTPBackend(tctx *provider.TranslateCon
 	if backend.ResolveGranularity == apiv2.ResolveGranularityService {
 		upstream.Nodes, err = t.translateApisixRouteBackendResolveGranularityService(tctx, auNN, backend)
 		if err != nil {
-			t.Log.Error(err, "failed to translate backend resolve granularity service", "backend", backend)
+			return nil, err
 		}
 	} else {
 		upstream.Nodes, err = t.translateApisixRouteBackendResolveGranularityEndpoint(tctx, auNN, backend)
 		if err != nil {
-			t.Log.Error(err, "failed to translate backend resolve granularity endpoint", "backend", backend)
+			return nil, err
 		}
 	}
 
@@ -466,7 +466,7 @@ func (t *Translator) translateStreamRule(tctx *provider.TranslateContext, ar *ap
 		if err != nil {
 			return nil, err
 		}
-		upstream, _ = t.translateApisixUpstream(tctx, au, port)
+		upstream, _ = t.translateApisixUpstreamForPort(tctx, au, ptr.To(port))
 	}
 	nodes, err := t.translateApisixRouteStreamBackendResolveGranularity(tctx, utils.NamespacedName(ar), part.Backend)
 	if err != nil {

internal/adc/translator/apisixupstream.go

@@ -34,8 +34,12 @@ import (
 	"github.com/apache/apisix-ingress-controller/internal/utils"
 )
 
-func (t *Translator) translateApisixUpstream(tctx *provider.TranslateContext, au *apiv2.ApisixUpstream, port int32) (*adc.Upstream, error) {
-	log.Debugw("translating ApisixUpstream", zap.Any("apisixupstream", au), zap.Int32("port", port))
+func (t *Translator) translateApisixUpstream(tctx *provider.TranslateContext, au *apiv2.ApisixUpstream) (*adc.Upstream, error) {
+	return t.translateApisixUpstreamForPort(tctx, au, nil)
+}
+
+func (t *Translator) translateApisixUpstreamForPort(tctx *provider.TranslateContext, au *apiv2.ApisixUpstream, port *int32) (*adc.Upstream, error) {
+	log.Debugw("translating ApisixUpstream", zap.Any("apisixupstream", au), zap.Int32p("port", port))
 
 	ups := adc.NewDefaultUpstream()
 	ups.Name = composeExternalUpstreamName(au)
@@ -48,10 +52,11 @@ func (t *Translator) translateApisixUpstream(tctx *provider.TranslateContext, au
 		return nil, err
 	}
 
-	// If portLevelSettings is configured, we need to validate the ports in
-	if len(au.Spec.PortLevelSettings) > 0 && port != 0 {
+	// If PortLevelSettings is configured and a specific port is provided,
+	// apply the ApisixUpstreamConfig for the matching port to the upstream.
+	if len(au.Spec.PortLevelSettings) > 0 && port != nil {
 		for _, pls := range au.Spec.PortLevelSettings {
-			if pls.Port != port {
+			if pls.Port != *port {
 				continue
 			}
 			if err := translateApisixUpstreamConfig(tctx, &pls.ApisixUpstreamConfig, ups); err != nil {