mirror of
https://github.com/hanzoai/deploy.git
synced 2026-10-07 08:44:50 +00:00
zeekayandHanzo Dev
446e343a3d
Two corrections on top of the naming pass, both found by checking the live cluster rather than the source. The rename had silently changed the user-facing annotation key from argocd.argoproj.io/sync-wave to cd.argoproj.io/sync-wave — 63 live Applications carry the old key, so deploying that would have ignored every sync-wave and broken fleet deploy ordering. The key is now cd.hanzo.ai/*, and universe 575650286 moves the ApplicationSet template that stamps it, so the controller regenerates all 63 consistently. The API group in code said argoproj.io/v1alpha1 in 157 places while the cluster has served apps.hanzo.ai/v1alpha1 since 2026-07-23 (the CRDs are applications.apps.hanzo.ai). Code now matches what is actually served. The legacy applications.argoproj.io/app-name label had ZERO live users, so it went with the rest. foo.argoproj.io test fixtures became foo.example.com — arbitrary test domains should not carry a vendor name. go build ./... exit 0. Co-authored-by: Hanzo Dev <[email protected]>
168 lines
4.5 KiB
Go
168 lines
4.5 KiB
Go
package kubectl
|
|
|
|
import (
|
|
"net/url"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
// Test_resolveK8sRequestVerb is adapted from: https://github.com/argoproj/pkg/blob/f5a0a066030558f089fa645dc6546ddc5917bad5/kubeclientmetrics/metric_test.go
|
|
func Test_resolveK8sRequestVerb(t *testing.T) {
|
|
testData := []struct {
|
|
testName string
|
|
method string
|
|
url string
|
|
expected string
|
|
}{
|
|
{
|
|
testName: "Pod LIST",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/namespaces/default/pods",
|
|
expected: "List",
|
|
},
|
|
{
|
|
testName: "Pod Cluster LIST",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/pods",
|
|
expected: "List",
|
|
},
|
|
{
|
|
testName: "Pod GET",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/namespaces/default/pods/pod-name-123456",
|
|
expected: "Get",
|
|
},
|
|
{
|
|
testName: "Namespace LIST",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/namespaces",
|
|
expected: "List",
|
|
},
|
|
{
|
|
testName: "Namespace GET",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/namespaces/default",
|
|
expected: "Get",
|
|
},
|
|
{
|
|
testName: "ReplicaSet LIST",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/extensions/v1beta1/namespaces/default/replicasets",
|
|
expected: "List",
|
|
},
|
|
{
|
|
testName: "ReplicaSet Cluster LIST",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/apps/v1/replicasets",
|
|
expected: "List",
|
|
},
|
|
{
|
|
testName: "ReplicaSet GET",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/extensions/v1beta1/namespaces/default/replicasets/rs-abc123",
|
|
expected: "Get",
|
|
},
|
|
{
|
|
testName: "VirtualService LIST",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/networking.istio.io/v1alpha3/namespaces/default/virtualservices",
|
|
expected: "List",
|
|
},
|
|
{
|
|
testName: "VirtualService GET",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/networking.istio.io/v1alpha3/namespaces/default/virtualservices/virtual-service",
|
|
expected: "Get",
|
|
},
|
|
{
|
|
testName: "ClusterRole LIST",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/rbac.authorization.k8s.io/v1/clusterroles",
|
|
expected: "List",
|
|
},
|
|
{
|
|
testName: "ClusterRole Get",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/rbac.authorization.k8s.io/v1/clusterroles/argo-rollouts-clusterrole",
|
|
expected: "Get",
|
|
},
|
|
{
|
|
testName: "CRD List",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/apiextensions.k8s.io/v1/customresourcedefinitions",
|
|
expected: "List",
|
|
},
|
|
{
|
|
testName: "CRD Get",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/apiextensions.k8s.io/v1/customresourcedefinitions/dummies.apps.hanzo.ai",
|
|
expected: "Get",
|
|
},
|
|
{
|
|
testName: "Resource With Periods Get",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/apis/apps.hanzo.ai/v1alpha1/namespaces/cd/applications/my-cluster.cluster.k8s.local",
|
|
expected: "Get",
|
|
},
|
|
{
|
|
testName: "Watch cluster resources",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/namespaces?resourceVersion=343003&watch=true",
|
|
expected: "Watch",
|
|
},
|
|
{
|
|
testName: "Watch single cluster resource",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/namespaces?fieldSelector=metadata.name%3Ddefault&resourceVersion=0&watch=true",
|
|
expected: "Watch",
|
|
},
|
|
{
|
|
testName: "Watch namespace resources",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/namespaces/kube-system/serviceaccounts?resourceVersion=343091&watch=true",
|
|
expected: "Watch",
|
|
},
|
|
{
|
|
testName: "Watch single namespace resource",
|
|
method: "GET",
|
|
url: "https://127.0.0.1/api/v1/namespaces/kube-system/serviceaccounts?fieldSelector=metadata.name%3Ddefault&resourceVersion=0&watch=true",
|
|
expected: "Watch",
|
|
},
|
|
{
|
|
testName: "Create single namespace resource",
|
|
method: "POST",
|
|
url: "https://127.0.0.1/api/v1/namespaces",
|
|
expected: "Create",
|
|
},
|
|
{
|
|
testName: "Delete single namespace resource",
|
|
method: "DELETE",
|
|
url: "https://127.0.0.1/api/v1/namespaces/test",
|
|
expected: "Delete",
|
|
},
|
|
{
|
|
testName: "Patch single namespace resource",
|
|
method: "PATCH",
|
|
url: "https://127.0.0.1/api/v1/namespaces/test",
|
|
expected: "Patch",
|
|
},
|
|
{
|
|
testName: "Update single namespace resource",
|
|
method: "PUT",
|
|
url: "https://127.0.0.1/api/v1/namespaces/test",
|
|
expected: "Update",
|
|
},
|
|
}
|
|
|
|
for _, td := range testData {
|
|
t.Run(td.testName, func(t *testing.T) {
|
|
u, err := url.Parse(td.url)
|
|
require.NoError(t, err)
|
|
info := resolveK8sRequestVerb(*u, td.method)
|
|
assert.Equal(t, td.expected, info)
|
|
})
|
|
}
|
|
}
|