package discovery import ( "fmt" "reflect" "strings" "testing" "github.com/harmony-one/bls/ffi/go/bls" "github.com/harmony-one/harmony/api/proto" "github.com/harmony-one/harmony/api/proto/node" "github.com/harmony-one/harmony/crypto/pki" "github.com/harmony-one/harmony/p2p" ) var ( pubKey1 = pki.GetBLSPrivateKeyFromInt(333).GetPublicKey() p1 = p2p.Peer{ IP: "127.0.0.1", Port: "9999", ConsensusPubKey: pubKey1, } e1 = "ping:Validator/1=>127.0.0.1:9999/[243 115 129 181 183 47 198 209 163 18 215 155 77 104 111 72 137 195 176 68 51 235 192 7 86 203 82 136 233 41 255 250 49 53 101 89 110 5 249 216 141 233 10 129 171 124 49 151]" e3 = "ping:Client/1=>127.0.0.1:9999/[243 115 129 181 183 47 198 209 163 18 215 155 77 104 111 72 137 195 176 68 51 235 192 7 86 203 82 136 233 41 255 250 49 53 101 89 110 5 249 216 141 233 10 129 171 124 49 151]" pubKey2 = pki.GetBLSPrivateKeyFromInt(999).GetPublicKey() p2 = []p2p.Peer{ { IP: "127.0.0.1", Port: "8888", ConsensusPubKey: pubKey1, }, { IP: "127.0.0.1", Port: "9999", ConsensusPubKey: pubKey2, }, } leaderPubKey = pki.GetBLSPrivateKeyFromInt(888).GetPublicKey() pubKeys = []*bls.PublicKey{pubKey1, pubKey2} buf1 []byte buf2 []byte ) func TestString(test *testing.T) { ping1 := NewPingMessage(p1, false) r1 := fmt.Sprintf("%v", *ping1) if strings.Compare(r1, e1) != 0 { test.Errorf("expect: %v, got: %v", e1, r1) } ping1.Node.Role = node.ClientRole r3 := fmt.Sprintf("%v", *ping1) if strings.Compare(r3, e3) != 0 { test.Errorf("expect: %v, got: %v", e3, r3) } } func TestSerialize(test *testing.T) { ping1 := NewPingMessage(p1, true) buf1 = ping1.ConstructPingMessage() msg1, err := proto.GetMessagePayload(buf1) if err != nil { test.Error("GetMessagePayload Failed!") } ping, err := GetPingMessage(msg1) if err != nil { test.Error("Ping failed!") } if !reflect.DeepEqual(ping, ping1) { test.Error("Serialize/Deserialze Ping Message Failed") } }