mirror of
https://github.com/logos-messaging/logos-messaging-go-bindings.git
synced 2026-08-25 09:51:16 +00:00
Igor Sirotin
8f6210f599
The Kernel API and the Messaging API each built their own node and kept the FFI handle private, so a MessagingClient had no way to reach store queries, peers or metrics. The C library has one context serving both tiers, so this was only a Go ownership problem. kernel.Node now owns that context, and the kernel protocols hang off it as facades: Relay(), Store(), Peers(), Discovery(), plus Messaging() for the stable tier. MessagingClient drives a Node and hands it over with Node(), mirroring the Nim MessagingClient's public waku field.
56 lines
1.6 KiB
Go
56 lines
1.6 KiB
Go
package kernel
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/libp2p/go-libp2p/core/peer"
|
|
"github.com/multiformats/go-multiaddr"
|
|
)
|
|
|
|
// The library parses its peer argument as a single multiaddress, so a peer
|
|
// advertising several addresses must still yield one dialable string.
|
|
func TestPeerAddrSendsOneMultiaddress(t *testing.T) {
|
|
id, err := peer.Decode("16Uiu2HAmVGHwfEi4kiNvuK6xVwGB2WeHoZNU1FgTUgZ8QvxiMqQw")
|
|
if err != nil {
|
|
t.Fatalf("Decode: %v", err)
|
|
}
|
|
|
|
peerInfo := peer.AddrInfo{ID: id, Addrs: []multiaddr.Multiaddr{
|
|
multiaddr.StringCast("/ip4/127.0.0.1/tcp/60000"),
|
|
multiaddr.StringCast("/ip4/10.0.0.1/tcp/60001"),
|
|
}}
|
|
|
|
got, err := peerAddr(peerInfo)
|
|
if err != nil {
|
|
t.Fatalf("peerAddr: %v", err)
|
|
}
|
|
|
|
want := "/ip4/127.0.0.1/tcp/60000/p2p/" + id.String()
|
|
if got != want {
|
|
t.Errorf("peerAddr() = %q, want %q", got, want)
|
|
}
|
|
}
|
|
|
|
func TestPeerAddrRejectsAddresslessPeer(t *testing.T) {
|
|
if _, err := peerAddr(peer.AddrInfo{}); err == nil {
|
|
t.Error("peerAddr() on a peer with no addresses returned no error")
|
|
}
|
|
}
|
|
|
|
// Zero milliseconds is not "no timeout": chronos expires immediately on it, so
|
|
// a context without a deadline has to fall back to the request timeout.
|
|
func TestTimeoutMillisFallsBackToRequestTimeout(t *testing.T) {
|
|
if got, want := timeoutMillis(context.Background(), requestTimeout),
|
|
int(requestTimeout.Milliseconds()); got != want {
|
|
t.Errorf("timeoutMillis(Background) = %d, want %d", got, want)
|
|
}
|
|
|
|
ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
|
|
defer cancel()
|
|
if got := timeoutMillis(ctx, requestTimeout); got <= 0 || got > 60_000 {
|
|
t.Errorf("timeoutMillis(1m) = %d, want (0, 60000]", got)
|
|
}
|
|
}
|