removed some retried functions and cleanup

cmd/apps/skychat/chat.go

@@ -128,10 +128,7 @@ func messageHandler(w http.ResponseWriter, req *http.Request) {
 		go handleConn(conn)
 	}
 
-	err := r.Do(func() error {
-		_, err := conn.Write([]byte(data["message"]))
-		return err
-	})
+	_, err := conn.Write([]byte(data["message"]))
 	if err != nil {
 		http.Error(w, err.Error(), http.StatusBadRequest)
 		connsMu.Lock()

internal/netutil/retrier.go

@@ -33,7 +33,8 @@ func NewRetrier(exponentialBackoff time.Duration, times, factor uint32) *Retrier
 	}
 }
 
-// WithErrWhitelist sets a list of errors into the retrier, if the RetryFunc provided to Do() fails with one of them it will return inmediatelly with such error
+// WithErrWhitelist sets a list of errors into the retrier, if the RetryFunc provided to Do() fails with one of them it will return inmediatelly with such error. Calling
+// this function is not thread-safe, and is advised to only use it when initializing the Retrier
 func (r *Retrier) WithErrWhitelist(errors ...error) *Retrier {
 	m := make(map[error]struct{})
 	for _, err := range errors {

internal/therealproxy/client.go

@@ -5,15 +5,10 @@ import (
 	"io"
 	"log"
 	"net"
-	"time"
-
-	"github.com/skycoin/skywire/internal/netutil"
 
 	"github.com/hashicorp/yamux"
 )
 
-var r = netutil.NewRetrier(50*time.Millisecond, 3, 2)
-
 // Client implement multiplexing proxy client using yamux.
 type Client struct {
 	session  *yamux.Session
@@ -48,10 +43,7 @@ func (c *Client) ListenAndServe(addr string) error {
 			return fmt.Errorf("accept: %s", err)
 		}
 
-		err = r.Do(func() error {
-			stream, err = c.session.Open()
-			return err
-		})
+		stream, err = c.session.Open()
 		if err != nil {
 			return fmt.Errorf("yamux: %s", err)
 		}

pkg/app/app.go

@@ -130,14 +130,11 @@ func (app *App) Dial(raddr *Addr) (net.Conn, error) {
 	if err != nil {
 		return nil, err
 	}
-	fmt.Println("loop created")
 	addr := &LoopAddr{laddr.Port, *raddr}
 	conn, out := net.Pipe()
-	fmt.Println("locking mux...")
 	app.mu.Lock()
 	app.conns[*addr] = conn
 	app.mu.Unlock()
-	fmt.Println("serving conn...")
 	go app.serveConn(addr, conn)
 	return newAppConn(out, laddr, raddr), nil
 }