(camel-k) 04/06: chore(e2e): Improve Integration logs waiting for container created

[cdeppisch]

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

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

commit e1da60771dfe6e826e96a12d21aa1fe31cad56e1
Author: Christoph Deppisch <cdeppi...@redhat.com>
AuthorDate: Wed Mar 13 12:52:07 2024 +0100

    chore(e2e): Improve Integration logs waiting for container created
    
    - Avoid logs watch errors when container is still creating
---
 e2e/support/test_support.go | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git a/e2e/support/test_support.go b/e2e/support/test_support.go
index 03cb2094f..ddda64af5 100644
--- a/e2e/support/test_support.go
+++ b/e2e/support/test_support.go
@@ -485,6 +485,13 @@ func IntegrationLogs(t *testing.T, ctx context.Context, 
ns, name string) func()
                        TailLines: pointer.Int64(100),
                }
 
+               for _, container := range pod.Status.ContainerStatuses {
+                       if !container.Ready || container.State.Waiting != nil {
+                               // avoid logs watch fail due to container 
creating state
+                               return ""
+                       }
+               }
+
                if len(pod.Spec.Containers) > 1 {
                        options.Container = pod.Spec.Containers[0].Name
                }
@@ -493,7 +500,7 @@ func IntegrationLogs(t *testing.T, ctx context.Context, ns, 
name string) func()
        }
 }
 
-// Retrieve the Logs from the Pod defined by its name in the given namespace 
ns. The number of lines numLines from the end of the logs to show.
+// TailedLogs Retrieve the Logs from the Pod defined by its name in the given 
namespace ns. The number of lines numLines from the end of the logs to show.
 func TailedLogs(t *testing.T, ctx context.Context, ns, name string, numLines 
int64) func() string {
        return func() string {
                options := corev1.PodLogOptions{
@@ -517,12 +524,12 @@ func Logs(t *testing.T, ctx context.Context, ns, podName 
string, options corev1.
                        }
                }()
 
-               bytes, err := io.ReadAll(byteReader)
+               logBytes, err := io.ReadAll(byteReader)
                if err != nil {
                        log.Error(err, "Error while reading container logs")
                        return ""
                }
-               return string(bytes)
+               return string(logBytes)
        }
 }
 
@@ -760,7 +767,7 @@ func HealthCheckData(r *v1.HealthCheckResponse) 
(map[string]interface{}, error)
        }
 
        var data map[string]interface{}
-       if err := json.Unmarshal(r.Data, data); err != nil {
+       if err := json.Unmarshal(r.Data, &data); err != nil {
                return nil, err
        }
 
@@ -873,7 +880,7 @@ func ServiceType(t *testing.T, ctx context.Context, ns 
string, name string) func
        }
 }
 
-// Find the service in the given namespace with the given type
+// ServicesByType Find the service in the given namespace with the given type
 func ServicesByType(t *testing.T, ctx context.Context, ns string, svcType 
corev1.ServiceType) func() []corev1.Service {
        return func() []corev1.Service {
                svcs := []corev1.Service{}