Merge pull request #56 from Escape-Technologies/fix/k8s-asset

fix: k8s asset

Author: kaanescape

pkg/api/escape/assets.go

@@ -132,13 +132,22 @@ func UpdateAsset(
 	return nil
 }
 
+// normalizeAssetType normalizes asset type tokens to match generated method names
+// e.g. KUBERNETES_CLUSTER -> KUBERNETESCLUSTER, http-endpoint -> HTTPENDPOINT
+func normalizeAssetType(s string) string {
+    upper := strings.ToUpper(s)
+    upper = strings.ReplaceAll(upper, "_", "")
+    upper = strings.ReplaceAll(upper, "-", "")
+    return upper
+}
+
 // CreateAsset creates an asset
 func CreateAsset(ctx context.Context, data []byte, assetType string) (interface{}, error) {
 	typ := reflect.TypeOf((*v3.AssetsAPIService)(nil))
 	for i := 0; i < typ.NumMethod(); i++ {
 		method := typ.Method(i)
-		if strings.HasPrefix(method.Name, "Create") && !strings.HasSuffix(method.Name, "Execute") {
-			if strings.Contains(method.Name, strings.ToUpper(assetType)) {
+    	if strings.HasPrefix(method.Name, "Create") && !strings.HasSuffix(method.Name, "Execute") {
+            if strings.Contains(method.Name, normalizeAssetType(assetType)) {
 				client, err := newAPIV3Client()
 				if err != nil {
 					return nil, fmt.Errorf("unable to init client: %w", err)

pkg/api/v3/model_create_asset_github_organization_request.go

@@ -77,8 +77,11 @@ func connectAndRun(ctx context.Context, cfg *rest.Config, isConnected *atomic.Bo
 		}
 		log.Info("Connected to K8s API")
 		log.Trace("Upserting K8s integration")
-		asset := v3.NewCreateAssetKUBERNETESCLUSTERRequestWithDefaults()
-		asset.PrivateLocationId = locationID
+		asset := v3.NewCreateAssetKUBERNETESCLUSTERRequest(
+			v3.ENUMCLOUDHOSTING_CLOUD_HOSTING,
+			v3.ENUMKUBERNETESCLUSTER_KUBERNETES_CLUSTER,
+			locationID,
+		)
 		asset.Name = &locationName
 		data, err := asset.MarshalJSON()
 		if err != nil {