feat: migrate UpdatePolicy API to Connect RPC

Author: rohilsurana

internal/api/v1beta1connect/policy.go

@@ -87,6 +87,10 @@ func (h *ConnectHandler) GetPolicy(ctx context.Context, request *connect.Request
 	return connect.NewResponse(&frontierv1beta1.GetPolicyResponse{Policy: policyPB}), nil
 }
 
+func (h *ConnectHandler) UpdatePolicy(ctx context.Context, request *connect.Request[frontierv1beta1.UpdatePolicyRequest]) (*connect.Response[frontierv1beta1.UpdatePolicyResponse], error) {
+	return nil, connect.NewError(connect.CodeUnimplemented, errors.New("unsupported at the moment"))
+}
+
 func (h *ConnectHandler) ListPolicies(ctx context.Context, request *connect.Request[frontierv1beta1.ListPoliciesRequest]) (*connect.Response[frontierv1beta1.ListPoliciesResponse], error) {
 	var policies []*frontierv1beta1.Policy
 

internal/api/v1beta1connect/policy_test.go

@@ -597,3 +597,31 @@ func TestConnectHandler_ListPolicies(t *testing.T) {
 		})
 	}
 }
+
+func TestConnectHandler_UpdatePolicy(t *testing.T) {
+	tests := []struct {
+		name    string
+		request *connect.Request[frontierv1beta1.UpdatePolicyRequest]
+		wantErr error
+		errCode connect.Code
+	}{
+		{
+			name:    "should return unimplemented error",
+			request: connect.NewRequest(&frontierv1beta1.UpdatePolicyRequest{Id: "test-id"}),
+			wantErr: errors.New("unsupported at the moment"),
+			errCode: connect.CodeUnimplemented,
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			handler := &ConnectHandler{}
+
+			got, err := handler.UpdatePolicy(context.Background(), tt.request)
+			assert.Error(t, err)
+			assert.Equal(t, tt.errCode, connect.CodeOf(err))
+			assert.Contains(t, err.Error(), tt.wantErr.Error())
+			assert.Nil(t, got)
+		})
+	}
+}