[camel-k] 01/02: Fix #2724: assign an ID to the binding main route

[nferraro]

This is an automated email from the ASF dual-hosted git repository.

nferraro pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git

commit 2888b0a166ab931ae2c6ef7deea811108555f490
Author: nicolaferraro <ni.ferr...@gmail.com>
AuthorDate: Tue Nov 2 12:19:12 2021 +0100

    Fix #2724: assign an ID to the binding main route
---
 pkg/controller/kameletbinding/common.go | 15 ++++++++++-----
 1 file changed, 10 insertions(+), 5 deletions(-)

diff --git a/pkg/controller/kameletbinding/common.go 
b/pkg/controller/kameletbinding/common.go
index 5fd8edb..ea7e3d0 100644
--- a/pkg/controller/kameletbinding/common.go
+++ b/pkg/controller/kameletbinding/common.go
@@ -185,17 +185,22 @@ func createIntegrationFor(ctx context.Context, c 
client.Client, kameletbinding *
 
        dslSteps = append(dslSteps, s)
 
-       flowFrom := map[string]interface{}{
-               "from": map[string]interface{}{
-                       "uri":   from.URI,
+       fromWrapper := map[string]interface{}{
+               "uri": from.URI,
+       }
+
+       flowRoute := map[string]interface{}{
+               "route": map[string]interface{}{
+                       "id":    "binding",
+                       "from":  fromWrapper,
                        "steps": dslSteps,
                },
        }
-       encodedFrom, err := json.Marshal(flowFrom)
+       encodedRoute, err := json.Marshal(flowRoute)
        if err != nil {
                return nil, err
        }
-       it.Spec.Flows = append(it.Spec.Flows, v1.Flow{RawMessage: encodedFrom})
+       it.Spec.Flows = append(it.Spec.Flows, v1.Flow{RawMessage: encodedRoute})
 
        return &it, nil
 }