From 4addc898c14d6edd22cf168e1284114a7066b6a3 Mon Sep 17 00:00:00 2001 From: vyzo Date: Mon, 27 Aug 2018 11:11:41 +0300 Subject: [PATCH] test floodsub with message signing --- floodsub_test.go | 36 ++++++++++++++++++++++++++++++++++++ 1 file changed, 36 insertions(+) diff --git a/floodsub_test.go b/floodsub_test.go index b0196ca..9af2cac 100644 --- a/floodsub_test.go +++ b/floodsub_test.go @@ -899,3 +899,39 @@ func assertPeerList(t *testing.T, peers []peer.ID, expected ...peer.ID) { } } } + +func TestWithSigning(t *testing.T) { + ctx, cancel := context.WithCancel(context.Background()) + defer cancel() + + hosts := getNetHosts(t, ctx, 2) + psubs := getPubsubs(ctx, hosts, WithMessageSigning()) + + connect(t, hosts[0], hosts[1]) + + topic := "foobar" + data := []byte("this is a message") + + sub, err := psubs[1].Subscribe(topic) + if err != nil { + t.Fatal(err) + } + + time.Sleep(time.Millisecond * 10) + + err = psubs[0].Publish(topic, data) + if err != nil { + t.Fatal(err) + } + + msg, err := sub.Next(ctx) + if err != nil { + t.Fatal(err) + } + if msg.Signature == nil { + t.Fatal("no signature in message") + } + if string(msg.Data) != string(data) { + t.Fatalf("unexpected data: %s", string(msg.Data)) + } +}