Hello,

How are generated peers address?

For example, with https://github.com/v-braun/go2p/blob/master/example_test.go If I run a server at 127.0.0.1:7071 and another one at 127.0.0.1:7072 for example and I connect it to the first one, the peer address change to something like 127.0.0.1:30002

Probably a stupid question, but I'm a Junior (especially in P2P ... ) Thanks :)

Hi :) I have an issue when I try to send a message from a server (Terminal 1) to more than one client (Terminal 2 and 3)

Problem Description:

panic: runtime error: slice bounds out of range [:535024639] with capacity 359

goroutine 36 [running]:
github.com/v-braun/go2p.middlewareHeadersImpl(0xc00040c000, 0xc00040c0a0, 0xc000050080, 0x1, 0x1, 0x0)
        C:/Users/argau/go/src/github.com/v-braun/go2p/middleware_headers.go:57 +0x45b
github.com/v-braun/go2p.(*Pipe).process(0xc00040c0a0, 0xc000050080, 0x4, 0x4)   
        C:/Users/argau/go/src/github.com/v-braun/go2p/pipe.go:63 +0x3b0
github.com/v-braun/go2p.(*Peer).processPipe(0xc00040c000, 0xc000050080, 0x1)    
        C:/Users/argau/go/src/github.com/v-braun/go2p/peer.go:71 +0x93
github.com/v-braun/go2p.(*Peer).start.func3()
        C:/Users/argau/go/src/github.com/v-braun/go2p/peer.go:48 +0x1a7
github.com/v-braun/awaiter.(*awaiter).Go.func1(0xc00040e0e0, 0xc00040e020)      
        C:/Users/argau/go/src/github.com/v-braun/awaiter/awaiter.go:51 +0x59    
created by github.com/v-braun/awaiter.(*awaiter).Go
        C:/Users/argau/go/src/github.com/v-braun/awaiter/awaiter.go:49 +0x6a    
exit status 2

package main

import (
	"bufio"
	"flag"
	"fmt"
	"os"
	"strings"

	"github.com/fatih/color"
	"github.com/sirupsen/logrus"
	"github.com/v-braun/go2p"
	prefixed "github.com/x-cray/logrus-prefixed-formatter"
)

func main() {
	logrus.SetFormatter(new(prefixed.TextFormatter))
	logrus.SetOutput(os.Stdout)
	logrus.SetLevel(logrus.DebugLevel)

	/* 	localHost := "localhost:7071"
	 */
	localAddr := flag.String("laddr", "localhost:7071", "local ip address")
	flag.Parse()

	cyan := color.New(color.FgCyan).SprintFunc()
	blue := color.New(color.FgHiBlue).SprintFunc()
	green := color.New(color.FgHiGreen).SprintFunc()
	white := color.New(color.FgHiWhite).SprintFunc()
	peerName := color.New(color.BgBlue, color.FgHiWhite).SprintFunc()

	/* 	if localHost == "localhost:7071" {
	   		peerName = color.New(color.BgHiMagenta, color.FgHiWhite).SprintFunc()
	   	} else if localHost == "localhost:7072" {
	   		peerName = color.New(color.BgHiYellow, color.FgHiWhite).SprintFunc()
	   	} */

	net := go2p.NewNetworkConnectionTCP(*localAddr, &map[string]func(peer *go2p.Peer, msg *go2p.Message){
		"msg": func(peer *go2p.Peer, msg *go2p.Message) {
			fmt.Println(fmt.Sprintf("%s %s", peerName(peer.RemoteAddress()+" > "), msg.PayloadGetString()))
		},
	})

	err := net.Start()
	if err != nil {
		panic(err)
	}

	net.OnPeer(func(p *go2p.Peer) {
		fmt.Printf("%s %s\n", cyan("new peer:"), green(p.RemoteAddress()))
	})

	defer net.Stop()

	fmt.Println(cyan(`
local server started!
press:
	`))

	fmt.Printf("%s %s\n", blue("[q][ENTER]"), white("to exit"))
	fmt.Printf("%s %s\n", blue("[c {ip address : port}][ENTER]"), white("to connect to another peer"))
	fmt.Printf("%s %s\n", blue("[any message][ENTER]"), white("to send a message to all peers"))

	reader := bufio.NewReader(os.Stdin)
	for {
		text, _ := reader.ReadString('\n')
		text = strings.TrimSpace(text)
		if text == "q" {
			return
		} else if strings.HasPrefix(text, "c ") {
			text = strings.TrimPrefix(text, "c ")
			net.ConnectTo("tcp", text)
		} else {
			net.SendBroadcast(go2p.NewMessageRoutedFromString("msg", text))
		}
	}
}

First Terminal go run main.go Second Terminal go run main.go -laddr=localhost:7072 c localhost:7071 Third Terminal go run main.go -laddr=localhost:7073 c localhost:7071

First Terminal Send A Message

Second or Third Terminal will panic

Environment:

• Windows 10
• Latest Verison of Go2p