cmd: alpha test peers tests self

cmd/testpeers.go

@@ -570,30 +570,39 @@
 	return testRes
 }
 
-func dialTCPIP(ctx context.Context, address string) error {
+func dialLibp2pTCPIP(ctx context.Context, address string) error {
 	d := net.Dialer{Timeout: time.Second}
 	conn, err := d.DialContext(ctx, "tcp", address)
 	if err != nil {
 		return errors.Wrap(err, "net dial")
 	}
+	buf := new(strings.Builder)
+	_, err = io.Copy(buf, conn)
+	if err != nil {
+		return errors.Wrap(err, "io copy")
+	}
+	if !strings.Contains(buf.String(), "/multistream/1.0.0") {
+		return errors.New("multistream not found", z.Any("found", buf.String()), z.Any("address", address))
+	}
+
 	err = conn.Close()
 	if err != nil {
 		return errors.Wrap(err, "close conn")
 	}
 
 	return nil
 }
 
 func libp2pTCPPortOpenTest(ctx context.Context, cfg *testPeersConfig) testResult {
 	testRes := testResult{Name: "Libp2pTCPPortOpen"}
 
 	group, _ := errgroup.WithContext(ctx)
 
 	for _, addr := range cfg.P2P.TCPAddrs {
 		addrVal := addr
-		group.Go(func() error { return dialTCPIP(ctx, addrVal) })
+		group.Go(func() error { return dialLibp2pTCPIP(ctx, addrVal) })
 	}
 
 	err := group.Wait()
 	if err != nil {
 		testRes.Verdict = testVerdictFail
@@ -602,7 +611,7 @@
 		return testRes
 	}
 
 	testRes.Verdict = testVerdictOk
 
 	return testRes
 }