add status

Author: AlinsRan

api/adc/types.go

@@ -521,7 +521,7 @@ func ComposeGRPCServiceNameWithRule(namespace, name string, rule string) string
 
 func ComposeServicesNameWithScheme(namespace, name string, rule string, scheme string) string {
 	var p []byte
-	plen := len(namespace) + len(name) + len(scheme) + 3
+	plen := len(namespace) + len(name) + len(rule) + len(scheme) + 3
 
 	p = make([]byte, 0, plen)
 	buf := bytes.NewBuffer(p)

internal/adc/translator/grpcroute.go

@@ -329,7 +329,7 @@ func (t *Translator) translateGatewayGRPCRouteMatch(match *gatewayv1.GRPCRouteMa
 		matchType := ptr.Deref(match.Method.Type, gatewayv1.GRPCMethodMatchExact)
 		if matchType == gatewayv1.GRPCMethodMatchExact &&
 			service == "" && method == "" {
-			return nil, fmt.Errorf("service and method cannot both be empty")
+			return nil, fmt.Errorf("service and method cannot both be empty for exact match type")
 		}
 	}
 

internal/provider/apisix/status.go

@@ -144,6 +144,41 @@ func (d *apisixProvider) updateStatus(nnk types.NamespacedNameKind, condition me
 				return cp
 			}),
 		})
+	case types.KindGRPCRoute:
+		parentRefs := d.client.ConfigManager.GetConfigRefsByResourceKey(nnk)
+		log.Debugw("updating GRPCRoute status", zap.Any("parentRefs", parentRefs))
+		gatewayRefs := map[types.NamespacedNameKind]struct{}{}
+		for _, parentRef := range parentRefs {
+			if parentRef.Kind == types.KindGateway {
+				gatewayRefs[parentRef] = struct{}{}
+			}
+		}
+		d.updater.Update(status.Update{
+			NamespacedName: nnk.NamespacedName(),
+			Resource:       &gatewayv1.GRPCRoute{},
+			Mutator: status.MutatorFunc(func(obj client.Object) client.Object {
+				cp := obj.(*gatewayv1.GRPCRoute).DeepCopy()
+				gatewayNs := cp.GetNamespace()
+				for i, ref := range cp.Status.Parents {
+					ns := gatewayNs
+					if ref.ParentRef.Namespace != nil {
+						ns = string(*ref.ParentRef.Namespace)
+					}
+					if ref.ParentRef.Kind == nil || *ref.ParentRef.Kind == types.KindGateway {
+						nnk := types.NamespacedNameKind{
+							Name:      string(ref.ParentRef.Name),
+							Namespace: ns,
+							Kind:      types.KindGateway,
+						}
+						if _, ok := gatewayRefs[nnk]; ok {
+							ref.Conditions = cutils.MergeCondition(ref.Conditions, condition)
+							cp.Status.Parents[i] = ref
+						}
+					}
+				}
+				return cp
+			}),
+		})
 	}
 }