fix status updater

Signed-off-by: zirain <zirain2009@gmail.com>

Author: zirain

internal/provider/kubernetes/status.go

@@ -175,19 +175,20 @@ func (r *gatewayAPIReconciler) updateStatusFromSubscriptions(ctx context.Context
 				}
 				key := update.Key
 				val := update.Value
+				// For status updater, need to use storage version.
 				r.statusUpdater.Send(Update{
 					NamespacedName: key,
-					Resource:       new(gwapiv1a2.TLSRoute),
+					Resource:       new(gwapiv1a3.TLSRoute),
 					Mutator: MutatorFunc(func(obj client.Object) client.Object {
-						t, ok := obj.(*gwapiv1a2.TLSRoute)
+						t, ok := obj.(*gwapiv1a3.TLSRoute)
 						if !ok {
 							err := fmt.Errorf("unsupported object type %T", obj)
 							errChan <- err
 							panic(err)
 						}
 						valCopy := val.DeepCopy()
 						setLastTransitionTimeInConditionsForRouteStatus(&valCopy.RouteStatus, metav1.Now())
-						tCopy := &gwapiv1a2.TLSRoute{
+						tCopy := &gwapiv1a3.TLSRoute{
 							TypeMeta:   t.TypeMeta,
 							ObjectMeta: t.ObjectMeta,
 							Spec:       t.Spec,
@@ -451,19 +452,20 @@ func (r *gatewayAPIReconciler) updateStatusFromSubscriptions(ctx context.Context
 				}
 				key := update.Key
 				val := update.Value
+				// For status updater, need to use storage version.
 				r.statusUpdater.Send(Update{
 					NamespacedName: key,
-					Resource:       new(gwapiv1a3.BackendTLSPolicy),
+					Resource:       new(gwapiv1.BackendTLSPolicy),
 					Mutator: MutatorFunc(func(obj client.Object) client.Object {
-						t, ok := obj.(*gwapiv1a3.BackendTLSPolicy)
+						t, ok := obj.(*gwapiv1.BackendTLSPolicy)
 						if !ok {
 							err := fmt.Errorf("unsupported object type %T", obj)
 							errChan <- err
 							panic(err)
 						}
 						valCopy := val.DeepCopy()
 						setLastTransitionTimeInConditionsForPolicyStatus(valCopy, metav1.Now())
-						tCopy := &gwapiv1a3.BackendTLSPolicy{
+						tCopy := &gwapiv1.BackendTLSPolicy{
 							TypeMeta:   t.TypeMeta,
 							ObjectMeta: t.ObjectMeta,
 							Spec:       t.Spec,

internal/provider/kubernetes/status_updater.go

@@ -7,6 +7,7 @@ package kubernetes
 
 import (
 	"context"
+	"fmt"
 	"sync"
 	"time"
 
@@ -99,7 +100,7 @@ func (u *UpdateHandler) apply(update Update) {
 			if kerrors.IsNotFound(err) {
 				return nil
 			}
-			return err
+			return fmt.Errorf("failed to get resource for status update: %w", err)
 		}
 
 		newObj := update.Mutator.Mutate(obj)
@@ -113,7 +114,11 @@ func (u *UpdateHandler) apply(update Update) {
 
 		newObj.SetUID(obj.GetUID())
 
-		return u.client.Status().Update(context.Background(), newObj)
+		err := u.client.Status().Update(context.Background(), newObj)
+		if err != nil {
+			return fmt.Errorf("failed to update status: %w", err)
+		}
+		return nil
 	}); err != nil {
 		log.Error(err, "unable to update status")