From e10950dfe48c2528825937deda2bfacdb0378668 Mon Sep 17 00:00:00 2001
From: Black Swan <3999712+blacks1ne@users.noreply.github.com>
Date: Tue, 16 Dec 2025 00:19:46 +0200
Subject: [PATCH] force TCP for stream multiaddr (#487)

---
 node/main.go           | 7 +++++++
 node/worker/manager.go | 3 +++
 2 files changed, 10 insertions(+)

diff --git a/node/main.go b/node/main.go
index 1194f7f..e957a96 100644
--- a/node/main.go
+++ b/node/main.go
@@ -521,6 +521,13 @@ func main() {
 			rpcMultiaddr = nodeConfig.Engine.DataWorkerStreamMultiaddrs[*core-1]
 		}
 
+		rpcMultiaddr = strings.Replace(rpcMultiaddr, "/0.0.0.0/", "/127.0.0.1/", 1)
+		rpcMultiaddr = strings.Replace(rpcMultiaddr, "/0:0:0:0:0:0:0:0/", "/::1/", 1)
+		rpcMultiaddr = strings.Replace(rpcMultiaddr, "/::/", "/::1/", 1)
+		// force TCP as stream is not supported over UDP/QUIC
+		rpcMultiaddr = strings.Replace(rpcMultiaddr, "/quic-v1", "", 1)
+		rpcMultiaddr = strings.Replace(rpcMultiaddr, "udp", "tcp", 1)
+
 		dataWorkerNode, err := app.NewDataWorkerNode(
 			logger,
 			nodeConfig,
diff --git a/node/worker/manager.go b/node/worker/manager.go
index 5151594..11b6fda 100644
--- a/node/worker/manager.go
+++ b/node/worker/manager.go
@@ -817,6 +817,9 @@ func (w *WorkerManager) getMultiaddrOfWorker(coreId uint) (
 	rpcMultiaddr = strings.Replace(rpcMultiaddr, "/0.0.0.0/", "/127.0.0.1/", 1)
 	rpcMultiaddr = strings.Replace(rpcMultiaddr, "/0:0:0:0:0:0:0:0/", "/::1/", 1)
 	rpcMultiaddr = strings.Replace(rpcMultiaddr, "/::/", "/::1/", 1)
+	// force TCP as stream is not supported over UDP/QUIC
+	rpcMultiaddr = strings.Replace(rpcMultiaddr, "/quic-v1", "", 1)
+	rpcMultiaddr = strings.Replace(rpcMultiaddr, "udp", "tcp", 1)
 
 	ma, err := multiaddr.StringCast(rpcMultiaddr)
 	return ma, errors.Wrap(err, "get multiaddr of worker")