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 }