fix: fix inconsistent tests

core/test/app_mock.go

@@ -3,6 +3,7 @@ package test
 import (
 	"context"
 	"fmt"
+	"io"
 	"io/ioutil"
 	"net"
 	"strings"
@@ -125,8 +126,13 @@ func (a *AppMock) InitEventStream() error {
 	go func() {
 		for {
 			data, err := stream.Recv()
+			if err == io.EOF {
+				logger().Warn("eventstream EOF", zap.Error(err))
+				return
+			}
 			if err != nil {
-				logger().Debug("failed to receive stream data", zap.Error(err))
+				logger().Warn("failed to receive stream data", zap.Error(err))
+				return
 			}
 			a.eventStream <- data
 		}

core/test/test_test.go

@@ -62,6 +62,19 @@ func nodeChansLens(apps ...*AppMock) []int {
 		app.node.AsyncWait()
 		out = append(out, len(app.networkDriver.(*mock.Enqueuer).Queue()))
 		out = append(out, len(app.eventStream))
+		if len(app.eventStream) > 99 {
+			log.Println("!! QUEUE SHOULD NOT BE AS MUCH FILLED !!")
+			log.Println("--- queue")
+			for len(app.networkDriver.(*mock.Enqueuer).Queue()) > 0 {
+				event := <-app.networkDriver.(*mock.Enqueuer).Queue()
+				jsonPrint(event)
+			}
+			log.Println("--- eventStream")
+			for len(app.eventStream) > 0 {
+				event := <-app.eventStream
+				jsonPrint(event)
+			}
+		}
 	}
 	return out
 }