Merge pull request #6550 from multiversx/update-mx-chain-communication-go

new version of mx-chain-comm-go

Author: miiu96

cmd/node/config/external.toml

@@ -51,7 +51,7 @@
 
     # URL for the WebSocket client/server connection
     # This value represents the IP address and port number that the WebSocket client or server will use to establish a connection.
-    URL = "127.0.0.1:22111"
+    URL = "ws://127.0.0.1:22111"
 
     # After a message will be sent it will wait for an ack message if this flag is enabled
     WithAcknowledge = true

go.mod

@@ -14,7 +14,7 @@ require (
 	github.com/gorilla/websocket v1.5.0
 	github.com/klauspost/cpuid/v2 v2.2.5
 	github.com/mitchellh/mapstructure v1.5.0
-	github.com/multiversx/mx-chain-communication-go v1.1.0
+	github.com/multiversx/mx-chain-communication-go v1.1.1-0.20241021133229-d0833256e3ec
 	github.com/multiversx/mx-chain-core-go v1.2.22
 	github.com/multiversx/mx-chain-crypto-go v1.2.12
 	github.com/multiversx/mx-chain-es-indexer-go v1.7.9

go.sum

@@ -385,8 +385,8 @@ github.com/multiformats/go-varint v0.0.7 h1:sWSGR+f/eu5ABZA2ZpYKBILXTTs9JWpdEM/n
 github.com/multiformats/go-varint v0.0.7/go.mod h1:r8PUYw/fD/SjBCiKOoDlGF6QawOELpZAu9eioSos/OU=
 github.com/multiversx/concurrent-map v0.1.4 h1:hdnbM8VE4b0KYJaGY5yJS2aNIW9TFFsUYwbO0993uPI=
 github.com/multiversx/concurrent-map v0.1.4/go.mod h1:8cWFRJDOrWHOTNSqgYCUvwT7c7eFQ4U2vKMOp4A/9+o=
-github.com/multiversx/mx-chain-communication-go v1.1.0 h1:J7bX6HoN3HiHY7cUeEjG8AJWgQDDPcY+OPDOsSUOkRE=
-github.com/multiversx/mx-chain-communication-go v1.1.0/go.mod h1:WK6bP4pGEHGDDna/AYRIMtl6G9OA0NByI1Lw8PmOnRM=
+github.com/multiversx/mx-chain-communication-go v1.1.1-0.20241021133229-d0833256e3ec h1:KwpeVZXSHzic8DV9zaJZmaBgDNIIpSdbGz4Q+9fZyiI=
+github.com/multiversx/mx-chain-communication-go v1.1.1-0.20241021133229-d0833256e3ec/go.mod h1:WK6bP4pGEHGDDna/AYRIMtl6G9OA0NByI1Lw8PmOnRM=
 github.com/multiversx/mx-chain-core-go v1.2.22 h1:yDYrvoQOBbsDerEp7L3+de5AfMy3pTF333gWPpd+FNk=
 github.com/multiversx/mx-chain-core-go v1.2.22/go.mod h1:B5zU4MFyJezmEzCsAHE9YNULmGCm2zbPHvl9hazNxmE=
 github.com/multiversx/mx-chain-crypto-go v1.2.12 h1:zWip7rpUS4CGthJxfKn5MZfMfYPjVjIiCID6uX5BSOk=

node/chainSimulator/components/memoryComponents.go

@@ -9,11 +9,11 @@ import (
 
 // CreateMemUnit creates a new in-memory storage unit
 func CreateMemUnit() storage.Storer {
-	capacity := uint32(10)
+	capacity := uint32(10_000_000)
 	shards := uint32(1)
 	sizeInBytes := uint64(0)
 	cache, _ := storageunit.NewCache(storageunit.CacheConfig{Type: storageunit.LRUCache, Capacity: capacity, Shards: shards, SizeInBytes: sizeInBytes})
-	persist, _ := database.NewlruDB(100000)
+	persist, _ := database.NewlruDB(10_000_000)
 	unit, _ := storageunit.NewStorageUnit(cache, persist)
 
 	return unit

outport/factory/hostDriverFactory_test.go

@@ -15,7 +15,7 @@ func TestCreateHostDriver(t *testing.T) {
 
 	args := ArgsHostDriverFactory{
 		HostConfig: config.HostDriversConfig{
-			URL:                "localhost",
+			URL:                "ws://localhost",
 			RetryDurationInSec: 1,
 			MarshallerType:     "json",
 			Mode:               data.ModeClient,

outport/factory/outportFactory_test.go

@@ -122,7 +122,7 @@ func TestCreateOutport_SubscribeMultipleHostDrivers(t *testing.T) {
 				Marshaller: &testscommon.MarshalizerMock{},
 				HostConfig: config.HostDriversConfig{
 					Enabled:            true,
-					URL:                "localhost",
+					URL:                "ws://localhost",
 					RetryDurationInSec: 1,
 					MarshallerType:     "json",
 					Mode:               data.ModeClient,
@@ -132,7 +132,7 @@ func TestCreateOutport_SubscribeMultipleHostDrivers(t *testing.T) {
 				Marshaller: &testscommon.MarshalizerMock{},
 				HostConfig: config.HostDriversConfig{
 					Enabled:            false,
-					URL:                "localhost",
+					URL:                "ws://localhost",
 					RetryDurationInSec: 1,
 					MarshallerType:     "json",
 					Mode:               data.ModeClient,
@@ -142,7 +142,7 @@ func TestCreateOutport_SubscribeMultipleHostDrivers(t *testing.T) {
 				Marshaller: &testscommon.MarshalizerMock{},
 				HostConfig: config.HostDriversConfig{
 					Enabled:            true,
-					URL:                "localhost",
+					URL:                "ws://localhost",
 					RetryDurationInSec: 1,
 					MarshallerType:     "json",
 					Mode:               data.ModeClient,

testscommon/components/components.go

@@ -687,7 +687,7 @@ func GetStatusComponentsFactoryArgsAndProcessComponents(shardCoordinator shardin
 				{
 					MarshallerType:     "json",
 					Mode:               "client",
-					URL:                "localhost:12345",
+					URL:                "ws://localhost:12345",
 					RetryDurationInSec: 1,
 				},
 			},