[camel-k] 03/33: fix(kamelets): optional error handler

[astefanutti]

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

astefanutti pushed a commit to branch release-1.4.x
in repository https://gitbox.apache.org/repos/asf/camel-k.git

commit 2292a3434bad3ea35f7a25b4bfd29d742e2764ef
Author: Pasquale Congiusti <pasquale.congiu...@gmail.com>
AuthorDate: Tue Mar 16 17:38:14 2021 +0100

    fix(kamelets): optional error handler
---
 pkg/controller/kameletbinding/common.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/pkg/controller/kameletbinding/common.go 
b/pkg/controller/kameletbinding/common.go
index 354dfa2..32d7182 100644
--- a/pkg/controller/kameletbinding/common.go
+++ b/pkg/controller/kameletbinding/common.go
@@ -79,9 +79,12 @@ func createIntegrationFor(ctx context.Context, c 
client.Client, kameletbinding *
        if err != nil {
                return nil, errors.Wrap(err, "could not determine sink URI")
        }
-       onError, err := bindings.Translate(bindingContext, 
bindings.EndpointContext{Type: v1alpha1.EndpointTypeErrorHandler}, 
kameletbinding.Spec.ErrorHandler)
-       if err != nil {
-               return nil, errors.Wrap(err, "could not determine error handler 
URI")
+       var onError *bindings.Binding
+       if kameletbinding.Spec.ErrorHandler.Ref != nil || 
kameletbinding.Spec.ErrorHandler.URI != nil {
+               onError, err = bindings.Translate(bindingContext, 
bindings.EndpointContext{Type: v1alpha1.EndpointTypeErrorHandler}, 
kameletbinding.Spec.ErrorHandler)
+               if err != nil {
+                       return nil, errors.Wrap(err, "could not determine error 
handler URI")
+               }
        }
 
        steps := make([]*bindings.Binding, 0, len(kameletbinding.Spec.Steps))