From 21725055ebb617be23f167c04adb92be152228a7 Mon Sep 17 00:00:00 2001
From: Andrea Cosentino <ancosen@gmail.com>
Date: Fri, 21 Oct 2022 10:41:51 +0200
Subject: [PATCH] Added a getKameletScheme method

Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
---
 .../kamelets/catalog/KameletsCatalog.java     | 22 ++++++++++++++-----
 1 file changed, 17 insertions(+), 5 deletions(-)

diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
index 0797c68a4..31a688ec5 100644
--- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
+++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
@@ -18,7 +18,13 @@
 
 import java.io.IOException;
 import java.io.InputStream;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.TreeMap;
 import java.util.stream.Collectors;
 
 import com.fasterxml.jackson.databind.DeserializationFeature;
@@ -193,10 +199,12 @@ public List<ComponentModel.EndpointHeaderModel> getKameletSupportedHeaders(Strin
             String prefixName = local.getMetadata().getName().substring(0, lastIndex);
             String schemeName = enumValue(prefixName);
             if (schemeName != null) {
-                List<ComponentModel.EndpointHeaderModel> headers = cc.componentModel(schemeName).getEndpointHeaders();
-                for (ComponentModel.EndpointHeaderModel e : headers) {
-                    if (ObjectHelper.isEmpty(e.getLabel()) || e.getLabel().equalsIgnoreCase(camelType)) {
-                        resultingHeaders.add(e);
+                if (ObjectHelper.isNotEmpty(cc.componentModel(schemeName).getEndpointHeaders())) {
+                    List<ComponentModel.EndpointHeaderModel> headers = cc.componentModel(schemeName).getEndpointHeaders();
+                    for (ComponentModel.EndpointHeaderModel e : headers) {
+                        if (ObjectHelper.isEmpty(e.getLabel()) || e.getLabel().equalsIgnoreCase(camelType)) {
+                            resultingHeaders.add(e);
+                        }
                     }
                 }
             }
@@ -204,6 +212,10 @@ public List<ComponentModel.EndpointHeaderModel> getKameletSupportedHeaders(Strin
         return resultingHeaders;
     }
 
+    public String getKameletScheme(String prefix) {
+        return enumValue(prefix);
+    }
+
     private String enumValue(String prefix) {
         for (KameletPrefixSchemeEnum c : KameletPrefixSchemeEnum.values()) {
             if (c.name.equals(prefix)) return c.scheme;