Switch to ChipTestSink

Author: dhaidashenko

core/scripts/go.mod

@@ -56,7 +56,7 @@ require (
 	github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20251124151448-0448aefdaab9
 	github.com/smartcontractkit/chainlink-protos/job-distributor v0.17.0
 	github.com/smartcontractkit/chainlink-testing-framework/framework v0.13.14-0.20260202230832-eb33f42188d1
-	github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose v0.1.18
+	github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose v0.1.19
 	github.com/smartcontractkit/chainlink-testing-framework/lib v1.54.5
 	github.com/smartcontractkit/chainlink-testing-framework/seth v1.51.2
 	github.com/smartcontractkit/chainlink/core/scripts/cre/environment/examples/workflows/v1/proof-of-reserve/cron-based v0.0.0-20251020210257-0a6ec41648b4

core/scripts/go.sum

@@ -1691,8 +1691,8 @@ github.com/smartcontractkit/chainlink-sui/deployment v0.0.0-20260124000807-bff5e
 github.com/smartcontractkit/chainlink-sui/deployment v0.0.0-20260124000807-bff5e296dfb7/go.mod h1:FbqbTFP9aBvE/2GDmfcFr/03HEWkzjP7OMmxdib26aY=
 github.com/smartcontractkit/chainlink-testing-framework/framework v0.13.14-0.20260202230832-eb33f42188d1 h1:JijOMT/94w/mt2q69vBQodliDlVfe+jqeaSTQJP3uxo=
 github.com/smartcontractkit/chainlink-testing-framework/framework v0.13.14-0.20260202230832-eb33f42188d1/go.mod h1:IQC7fXKDsFjD1vb0Jh83WWY4BCFhN1fkcn+z3oSuFIA=
-github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose v0.1.18 h1:1ng+p/+85zcVLHB050PiWUAjOcxyd4KjwkUlJy34rgE=
-github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose v0.1.18/go.mod h1:2+OrSz56pdgtY0Oc20nCS9LH/bEksFDBQjoR82De5PI=
+github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose v0.1.19 h1:LFZkB/pc8SE+U13vsuCapnYqf1LPzeBsiWPUIQYiUkg=
+github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose v0.1.19/go.mod h1:98jNYBOPuKWJw9a8x0LgQuudp5enrHhQQP5Hq0YwRB8=
 github.com/smartcontractkit/chainlink-testing-framework/framework/components/fake v0.10.0 h1:PWAMYu0WaAMBfbpxCpFJGRIDHmcgmYin6a+UQC0OdtY=
 github.com/smartcontractkit/chainlink-testing-framework/framework/components/fake v0.10.0/go.mod h1:YEQbZRHFojvlQKeuckG/70t0WkAqOBmArSbkacgHSbc=
 github.com/smartcontractkit/chainlink-testing-framework/lib v1.54.5 h1:jARz/SWbmWoGJJGVcAnWwGMb8JuHRTQQsM3m6ZwrAGk=

system-tests/tests/smoke/cre/v2_evm_capability_test.go

@@ -39,8 +39,16 @@ func ExecuteEVMReadTest(t *testing.T, testEnv *ttypes.TestEnvironment) {
 	const workflowFileLocation = "./evm/evmread/main.go"
 	enabledChains := t_helpers.GetEVMEnabledChains(t, testEnv)
 
-	listenerCtx, messageChan, _ := t_helpers.StartBeholder(t, lggr, testEnv)
-	go t_helpers.LogBeholderMessages(listenerCtx, lggr, messageChan)
+	userLogsCh := makeSinkCh[*workflowevents.UserLogs]()
+	baseMessageCh := makeSinkCh[*commonevents.BaseMessage]()
+
+	// `./logs` folder inside `smoke/cre` is uploaded as artifact in GH
+	server := t_helpers.StartChipTestSink(t, t_helpers.GetLoggingPublishFn(lggr, userLogsCh, baseMessageCh, "./logs/evm_read_workflow_test.log"))
+	t.Cleanup(func() {
+		server.Shutdown(t.Context())
+		close(userLogsCh)
+		close(baseMessageCh)
+	})
 
 	chainLock := sync.Mutex{}
 	for _, bcOutput := range testEnv.CreEnvironment.Blockchains {
@@ -73,6 +81,17 @@ func ExecuteEVMReadTest(t *testing.T, testEnv *ttypes.TestEnvironment) {
 	}
 }
 
+func makeSinkCh[T any]() chan T {
+	c := make(chan T, 1)
+	go func() {
+		for range c {
+
+		}
+	}()
+
+	return c
+}
+
 func configureEVMReadWorkflow(t *testing.T, lggr zerolog.Logger, chain *evm.Blockchain, testCase evm_config.TestCase, workflowName string) evm_config.Config {
 	t.Helper()
 

system-tests/tests/test-helpers/t_helpers.go

@@ -242,34 +242,6 @@ func AssertBeholderMessage(ctx context.Context, t *testing.T, expectedLog string
 	return nil
 }
 
-func LogBeholderMessages(ctx context.Context, testLogger zerolog.Logger, messageChan <-chan proto.Message) {
-	for {
-		select {
-		case <-ctx.Done():
-			return
-		case msg := <-messageChan:
-			// Process received messages
-			switch typedMsg := msg.(type) {
-			case *commonevents.BaseMessage:
-				l := testLogger.Info()
-				for labelKey, labelValue := range typedMsg.Labels {
-					l = l.Str(labelKey, labelValue)
-				}
-				l.Msg("➡️ Beholder Msg: " + typedMsg.Msg)
-			case *workflowevents.UserLogs:
-				l := testLogger.Info().
-					Str("execution_id", typedMsg.M.WorkflowExecutionID).
-					Str("workflow_name", typedMsg.M.WorkflowName)
-				for _, logLine := range typedMsg.LogLines {
-					l.Msg("➡️ Beholder user msg: " + logLine.Message)
-				}
-			default:
-				// ignore other message types
-			}
-		}
-	}
-}
-
 //////////////////////////////
 //      CRYPTO HELPERS      //
 //////////////////////////////