feat(kamelets): bundling from jar

This is required to simplify the release process and leverage to distributed catalog as dependency

build/Dockerfile

@@ -43,20 +43,17 @@ ENV MAVEN_USER_HOME="${MAVEN_HOME}"
 RUN ${MVNW_DIR}/mvnw --version | grep "Maven home:" | sed 's/Maven home: //' >> ${MVNW_DIR}default \
     && cp -r /usr/share/maven/lib/. $(cat ${MVNW_DIR}default)/lib \
     && rm $(cat ${MVNW_DIR}default)/lib/maven-slf4j-provider* \
-    && rm $(cat ${MVNW_DIR}default)/lib/slf4j-api-1.* 
+    && rm $(cat ${MVNW_DIR}default)/lib/slf4j-api-1.*
 
 ENV MAVEN_OPTS="${MAVEN_OPTS} -Dlogback.configurationFile=${MAVEN_HOME}/conf/logback.xml"
 
 ADD build/_maven_output ${MVN_REPO}
 # Fix https://github.com/moby/moby/issues/37965
 RUN true
-ADD build/_kamelets /kamelets
 
 RUN chgrp -R 0 ${MVN_REPO} \
     && chown -R 1001:0 ${MVN_REPO} \
     && chmod -R 775 ${MVN_REPO} \
-    && chgrp -R 0 /kamelets \
-    && chmod -R g=u /kamelets \
     && chgrp -R 0 ${MAVEN_HOME} \
     && chown -R 1001:0 ${MAVEN_HOME} \
     && chmod -R 775 ${MAVEN_HOME}

pkg/apis/camel/v1/integrationplatform_types.go

@@ -192,19 +192,20 @@ const (
 	// IntegrationPlatformPhaseError when the IntegrationPlatform had some error (see Conditions).
 	IntegrationPlatformPhaseError IntegrationPlatformPhase = "Error"
 	// IntegrationPlatformPhaseCreateCatalog when the IntegrationPlatform creates a new CamelCatalog.
+	// Deprecated no longer in use.
 	IntegrationPlatformPhaseCreateCatalog IntegrationPlatformPhase = "CreateCatalog"
 
 	// IntegrationPlatformConditionReady is the condition if the IntegrationPlatform is ready.
 	// Deprecated: use IntegrationPlatformConditionTypeCreated.
 	IntegrationPlatformConditionReady = "Ready"
 	// IntegrationPlatformConditionTypeCreated is the condition if the IntegrationPlatform has been created.
 	IntegrationPlatformConditionTypeCreated IntegrationPlatformConditionType = "Created"
-
 	// IntegrationPlatformConditionTypeRegistryAvailable is the condition for the availability of a container registry.
 	IntegrationPlatformConditionTypeRegistryAvailable IntegrationPlatformConditionType = "RegistryAvailable"
-
-	// IntegrationPlatformConditionCamelCatalogAvailable is the condition for the availability of a container registry.
+	// IntegrationPlatformConditionCamelCatalogAvailable is the condition for the availability of a the CamelCatalog.
 	IntegrationPlatformConditionCamelCatalogAvailable IntegrationPlatformConditionType = "CamelCatalogAvailable"
+	// IntegrationPlatformConditionKameletCatalogAvailable is the condition for the availability of a Kamelet catalog.
+	IntegrationPlatformConditionKameletCatalogAvailable IntegrationPlatformConditionType = "KameletCatalogAvailable"
 
 	// IntegrationPlatformConditionCreatedReason represents the reason that the IntegrationPlatform is created.
 	IntegrationPlatformConditionCreatedReason = "IntegrationPlatformCreated"

pkg/apis/camel/v1/kamelet_types_support.go

@@ -178,6 +178,11 @@ func (k *Kamelet) SortedTypesKeys() []TypeSlot {
 	return res
 }
 
+// IsBundled returns true if the Kamelet is coming from a pre-bundled installation.
+func (k *Kamelet) IsBundled() bool {
+	return k.Labels != nil && k.Labels[KameletBundledLabel] == "true"
+}
+
 func ValidKameletName(name string) bool {
 	return !reservedKameletNames[name]
 }

pkg/cmd/reset.go

@@ -18,7 +18,6 @@ limitations under the License.
 package cmd
 
 import (
-	"errors"
 	"fmt"
 
 	v1 "github.com/apache/camel-k/v2/pkg/apis/camel/v1"
@@ -93,13 +92,6 @@ func (o *resetCmdOptions) reset(cmd *cobra.Command, _ []string) {
 		}
 		fmt.Fprintln(cmd.OutOrStdout(), n, "integration kits deleted from namespace", o.Namespace)
 	}
-
-	if err = o.resetIntegrationPlatform(c); err != nil {
-		fmt.Fprintln(cmd.ErrOrStderr(), err)
-		return
-	}
-
-	fmt.Fprintln(cmd.OutOrStdout(), "Camel K platform has been reset successfully!")
 }
 
 func (o *resetCmdOptions) deleteAllIntegrations(c client.Client) (int, error) {
@@ -163,22 +155,6 @@ func (o *resetCmdOptions) deleteAllKameletBindings(c client.Client) (int, error)
 	return len(list.Items), nil
 }
 
-func (o *resetCmdOptions) resetIntegrationPlatform(c client.Client) error {
-	list := v1.NewIntegrationPlatformList()
-	if err := c.List(o.Context, &list, k8sclient.InNamespace(o.Namespace)); err != nil {
-		return fmt.Errorf("could not retrieve integration platform from namespace %s: %w", o.Namespace, err)
-	}
-	if len(list.Items) > 1 {
-		return fmt.Errorf("expected 1 integration platform in the namespace, found: %d", len(list.Items))
-	} else if len(list.Items) == 0 {
-		return errors.New("no integration platforms found in the namespace")
-	}
-	platform := list.Items[0]
-	// Let's reset the status
-	platform.Status = v1.IntegrationPlatformStatus{}
-	return c.Status().Update(o.Context, &platform)
-}
-
 func isIntegrationOwned(it v1.Integration) bool {
 	for _, ref := range it.OwnerReferences {
 		gv, err := schema.ParseGroupVersion(ref.APIVersion)

pkg/controller/catalog/initialize.go

@@ -45,7 +45,6 @@ func (action *initializeAction) CanHandle(catalog *v1.CamelCatalog) bool {
 
 func (action *initializeAction) Handle(ctx context.Context, catalog *v1.CamelCatalog) (*v1.CamelCatalog, error) {
 	action.L.Info("Initializing CamelCatalog")
-
 	platform, err := platformutil.GetForName(ctx, action.client, catalog.Namespace, defaults.OperatorID())
 
 	if err != nil {