diff --git a/examples/datagram/main.go b/examples/datagram/main.go index 074be0d19ec0a2a8faffa9edf46ffb2d2dc74e82..465ea95eccc79c137f5cbaac2ef7580a410f4c68 100644 --- a/examples/datagram/main.go +++ b/examples/datagram/main.go @@ -5,6 +5,7 @@ import ( "fmt" "os" + peer "github.com/libp2p/go-libp2p-peer" swarm "github.com/libp2p/go-libp2p-swarm" udpt "github.com/libp2p/go-udp-transport" ma "github.com/multiformats/go-multiaddr" @@ -25,7 +26,16 @@ func main() { fatal(err) } - s := swarm.NewBlankSwarm(context.Background(), "Qmbob", nil, nil) + QmAlice, err := peer.IDFromString("QmAlice") + if err != nil { + fatal(err) + } + QmBob, err := peer.IDFromString("QmBob") + if err != nil { + fatal(err) + } + + s := swarm.NewBlankSwarm(context.Background(), QmAlice, nil, nil) s.AddPacketTransport(udpt.NewUDPTransport()) // Add an address to start listening on @@ -35,17 +45,17 @@ func main() { } // Conn as argument, for WriteMsg()? - s.SetMsgHandler(func(msg []byte, peerid string) { - fmt.Printf("got message from %s: %s\n", peerid, string(msg)) + s.SetMsgHandler(func(msg []byte, p peer.ID) { + fmt.Printf("got message from %s: %s\n", p, string(msg)) - _, err = s.WriteMsg(msg, peerid) + _, err = s.WriteMsg(msg, p) if err != nil { fmt.Println(err) return } }) - s.WriteMsg("hey bob", "Qmbob") + s.WriteMsg("hey bob", QmBob) // Wait forever <-make(chan bool)