From 3d5e8e550beb7d93d42fdaeee7be0baa6f074d26 Mon Sep 17 00:00:00 2001 From: Ivan Folgueira Bande Date: Fri, 12 Dec 2025 22:48:53 +0100 Subject: [PATCH] chore: waku-go-bindings -> logos-messaging-go-bindings --- README.md | 2 +- tools/memory_record.go | 2 +- waku/nodes_basic_test.go | 4 ++-- waku/nwaku.go | 2 +- waku/nwaku_test.go | 2 +- waku/nwaku_test_utils.go | 8 ++++---- waku/peer_connections_test.go | 2 +- waku/relay_test.go | 2 +- waku/store_test.go | 2 +- waku/stress_test.go | 22 ++++++++++------------ waku/test_data.go | 2 +- 11 files changed, 24 insertions(+), 26 deletions(-) diff --git a/README.md b/README.md index 77b812d..4496047 100644 --- a/README.md +++ b/README.md @@ -5,7 +5,7 @@ Go bindings for the Waku library. ## Install ``` -go get -u github.com/waku-org/waku-go-bindings +go get -u github.com/logos-messaging/logos-messaging-go-bindings ``` ## Dependencies diff --git a/tools/memory_record.go b/tools/memory_record.go index 6ad63af..540a72a 100644 --- a/tools/memory_record.go +++ b/tools/memory_record.go @@ -6,7 +6,7 @@ import ( "os" "runtime" - "github.com/waku-org/waku-go-bindings/utils" + "github.com/logos-messaging/logos-messaging-go-bindings/utils" ) var ( diff --git a/waku/nodes_basic_test.go b/waku/nodes_basic_test.go index f486945..93cba02 100644 --- a/waku/nodes_basic_test.go +++ b/waku/nodes_basic_test.go @@ -4,8 +4,8 @@ import ( "testing" "time" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" "github.com/stretchr/testify/require" - "github.com/waku-org/waku-go-bindings/waku/common" ) func TestBasicWakuNodes(t *testing.T) { @@ -29,7 +29,7 @@ func TestBasicWakuNodes(t *testing.T) { Debug("TestBasicWakuNodes completed successfully") } -/* artifact https://github.com/waku-org/waku-go-bindings/issues/40 */ +/* artifact https://github.com/logos-messaging/logos-messaging-go-bindings/issues/40 */ func TestNodeRestart(t *testing.T) { t.Skip("Skipping test for open artifact ") Debug("Starting TestNodeRestart") diff --git a/waku/nwaku.go b/waku/nwaku.go index fe7f315..28e2bd9 100644 --- a/waku/nwaku.go +++ b/waku/nwaku.go @@ -360,7 +360,7 @@ import ( "github.com/waku-org/go-waku/waku/v2/protocol/pb" "github.com/waku-org/go-waku/waku/v2/utils" - "github.com/waku-org/waku-go-bindings/waku/common" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" ) const requestTimeout = 30 * time.Second diff --git a/waku/nwaku_test.go b/waku/nwaku_test.go index 61a7fcd..59ccb09 100644 --- a/waku/nwaku_test.go +++ b/waku/nwaku_test.go @@ -13,11 +13,11 @@ import ( "github.com/cenkalti/backoff/v3" "github.com/libp2p/go-libp2p/core/peer" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" ma "github.com/multiformats/go-multiaddr" "github.com/stretchr/testify/require" "github.com/waku-org/go-waku/waku/v2/protocol/pb" "github.com/waku-org/go-waku/waku/v2/protocol/store" - "github.com/waku-org/waku-go-bindings/waku/common" ) // In order to run this test, you must run an nwaku node diff --git a/waku/nwaku_test_utils.go b/waku/nwaku_test_utils.go index 4da8272..75c07c0 100644 --- a/waku/nwaku_test_utils.go +++ b/waku/nwaku_test_utils.go @@ -16,9 +16,9 @@ import ( "github.com/cenkalti/backoff/v3" "github.com/libp2p/go-libp2p/core/peer" + "github.com/logos-messaging/logos-messaging-go-bindings/utils" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" "github.com/waku-org/go-waku/waku/v2/protocol/pb" - "github.com/waku-org/waku-go-bindings/utils" - "github.com/waku-org/waku-go-bindings/waku/common" "google.golang.org/protobuf/proto" ) @@ -296,9 +296,9 @@ func captureMemory(testName, phase string) { runtime.ReadMemStats(&ms) heapKB := ms.HeapAlloc / 1024 - rssKB, _ := utils.GetRSSKB() + rssKB, _ := utils.GetRSSKB() Debug("[%s] Memory usage (%s): %d KB (RSS %d KB)", testName, phase, heapKB, rssKB) _ = recordMemoryMetricsPX(testName, phase, heapKB, rssKB) -} \ No newline at end of file +} diff --git a/waku/peer_connections_test.go b/waku/peer_connections_test.go index c18bcea..fad825c 100644 --- a/waku/peer_connections_test.go +++ b/waku/peer_connections_test.go @@ -5,8 +5,8 @@ import ( "testing" "time" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" "github.com/stretchr/testify/require" - "github.com/waku-org/waku-go-bindings/waku/common" ) // Test node connect & disconnect peers diff --git a/waku/relay_test.go b/waku/relay_test.go index 4c4f5f9..414bbbe 100644 --- a/waku/relay_test.go +++ b/waku/relay_test.go @@ -7,9 +7,9 @@ import ( "time" "github.com/cenkalti/backoff/v3" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" "github.com/stretchr/testify/require" "github.com/waku-org/go-waku/waku/v2/protocol/pb" - "github.com/waku-org/waku-go-bindings/waku/common" "google.golang.org/protobuf/proto" ) diff --git a/waku/store_test.go b/waku/store_test.go index 2609c8b..befedc4 100644 --- a/waku/store_test.go +++ b/waku/store_test.go @@ -9,7 +9,7 @@ import ( "github.com/stretchr/testify/require" "github.com/waku-org/go-waku/waku/v2/protocol/pb" - "github.com/waku-org/waku-go-bindings/waku/common" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" "google.golang.org/protobuf/proto" ) diff --git a/waku/stress_test.go b/waku/stress_test.go index ceea537..142df92 100644 --- a/waku/stress_test.go +++ b/waku/stress_test.go @@ -10,8 +10,8 @@ import ( "testing" "time" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" "github.com/stretchr/testify/require" - "github.com/waku-org/waku-go-bindings/waku/common" // "go.uber.org/zap/zapcore" "google.golang.org/protobuf/proto" @@ -107,9 +107,9 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { if i%10 == 0 { storeQueryRequest := &common.StoreQueryRequest{ - TimeStart: queryTimestamp, - IncludeData: true, - PaginationLimit: proto.Uint64(50), + TimeStart: queryTimestamp, + IncludeData: true, + PaginationLimit: proto.Uint64(50), PaginationForward: false, } @@ -117,7 +117,7 @@ func TestStressStoreQuery5kMessagesWithPagination(t *testing.T) { require.NoError(t, err, "Failed to query store messages") require.Greater(t, len(*storedmsgs.Messages), 0, "Expected at least one stored message") } - Debug("##Iteration #%d",i) + Debug("##Iteration #%d", i) } captureMemory(t.Name(), "at end") @@ -144,8 +144,8 @@ func TestStressHighThroughput10kPublish(t *testing.T) { captureMemory(t.Name(), "at start") - const totalMessages = 1000 - var pubsubTopic = DefaultPubsubTopic + const totalMessages = 1000 + var pubsubTopic = DefaultPubsubTopic for i := 0; i < totalMessages; i++ { msg := node1.CreateMessage() @@ -153,17 +153,15 @@ func TestStressHighThroughput10kPublish(t *testing.T) { hash, err := node1.RelayPublishNoCTX(pubsubTopic, msg) require.NoError(t, err, "publish failed @%d", i) - Debug("Iteration-10kpublish #%d",i) - err = node2.VerifyMessageReceived(msg, hash ) + Debug("Iteration-10kpublish #%d", i) + err = node2.VerifyMessageReceived(msg, hash) require.NoError(t, err, "verification failed @%d", i) - } captureMemory(t.Name(), "at end") } - func TestStressConnectDisconnect1kIteration(t *testing.T) { captureMemory(t.Name(), "at start") @@ -342,7 +340,7 @@ func TestStressLargePayloadEphemeralMessagesEndurance(t *testing.T) { func TestStress2Nodes2kIterationTearDown(t *testing.T) { captureMemory(t.Name(), "at start") - var err error + var err error totalIterations := 2000 for i := 1; i <= totalIterations; i++ { var nodes []*WakuNode diff --git a/waku/test_data.go b/waku/test_data.go index 920713c..463e17e 100644 --- a/waku/test_data.go +++ b/waku/test_data.go @@ -4,7 +4,7 @@ import ( "fmt" "time" - "github.com/waku-org/waku-go-bindings/waku/common" + "github.com/logos-messaging/logos-messaging-go-bindings/waku/common" "google.golang.org/protobuf/proto" )