logos-messaging/logos-messaging-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-messaging/logos-messaging-go-bindings.git synced 2026-01-07 16:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: integrate async support (#5)

Browse Source
This commit is contained in:
gabrielmer 2024-12-04 17:41:28 +01:00 committed by GitHub
parent 22c28a243a
commit 59f8461895
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 269 additions and 533 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

792
waku/nwaku.go
View File

File diff suppressed because it is too large Load Diff

10
waku/nwaku_test.go
View File

@ -31,6 +31,8 @@ func TestBasicWaku(t *testing.T) {
storeNodeInfo, err := GetNwakuInfo(nil, &extNodeRestPort) storeNodeInfo, err := GetNwakuInfo(nil, &extNodeRestPort)
require.NoError(t, err) require.NoError(t, err)
// ctx := context.Background()
nwakuConfig := WakuConfig{ nwakuConfig := WakuConfig{
Port: 30303, Port: 30303,
NodeKey: "11d0dcea28e86f81937a3bd1163473c7fbc0a0db54fd72914849bc47bdf78710", NodeKey: "11d0dcea28e86f81937a3bd1163473c7fbc0a0db54fd72914849bc47bdf78710",
@ -77,11 +79,11 @@ func TestBasicWaku(t *testing.T) {
storeNode, err := peer.AddrInfoFromString(storeNodeInfo.ListenAddresses[0]) storeNode, err := peer.AddrInfoFromString(storeNodeInfo.ListenAddresses[0])
require.NoError(t, err) require.NoError(t, err)
/* for i := 0; i <= 100; i++ { /*
time.Sleep(2 * time.Second) w.node.DialPeer(ctx, storeNode.Addrs[0], "")
}
w.StorenodeCycle.SetStorenodeConfigProvider(newTestStorenodeConfigProvider(*storeNode)) */ w.StorenodeCycle.SetStorenodeConfigProvider(newTestStorenodeConfigProvider(*storeNode))
*/
// Check that we are indeed connected to the store node // Check that we are indeed connected to the store node
connectedStoreNodes, err := w.node.GetPeerIDsByProtocol(store.StoreQueryID_v300) connectedStoreNodes, err := w.node.GetPeerIDsByProtocol(store.StoreQueryID_v300)