From ec46f1e6e4b6375bb098e33dc7cb779a143705f8 Mon Sep 17 00:00:00 2001
From: Marten Seemann <martenseemann@gmail.com>
Date: Fri, 25 Feb 2022 11:44:47 +0400
Subject: [PATCH 1/2] fix prioritization of stream muxers

---
 core/node/libp2p/libp2p.go | 4 ++--
 core/node/libp2p/sec.go    | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/core/node/libp2p/libp2p.go b/core/node/libp2p/libp2p.go
index 3659b3c61..309490bdc 100644
--- a/core/node/libp2p/libp2p.go
+++ b/core/node/libp2p/libp2p.go
@@ -58,7 +58,7 @@ type priorityOption struct {
 
 func prioritizeOptions(opts []priorityOption) libp2p.Option {
 	type popt struct {
-		priority int64
+		priority int64 // lower priority values mean higher priority
 		opt      libp2p.Option
 	}
 	enabledOptions := make([]popt, 0, len(opts))
@@ -71,7 +71,7 @@ func prioritizeOptions(opts []priorityOption) libp2p.Option {
 		}
 	}
 	sort.Slice(enabledOptions, func(i, j int) bool {
-		return enabledOptions[i].priority > enabledOptions[j].priority
+		return enabledOptions[i].priority < enabledOptions[j].priority
 	})
 	p2pOpts := make([]libp2p.Option, len(enabledOptions))
 	for i, opt := range enabledOptions {
diff --git a/core/node/libp2p/sec.go b/core/node/libp2p/sec.go
index 65b440ec4..bef2efe47 100644
--- a/core/node/libp2p/sec.go
+++ b/core/node/libp2p/sec.go
@@ -30,11 +30,11 @@ func Security(enabled bool, tptConfig config.Transports) interface{} {
 	return func() (opts Libp2pOpts) {
 		opts.Opts = append(opts.Opts, prioritizeOptions([]priorityOption{{
 			priority:        tptConfig.Security.TLS,
-			defaultPriority: 100,
+			defaultPriority: 200,
 			opt:             libp2p.Security(tls.ID, tls.New),
 		}, {
 			priority:        tptConfig.Security.Noise,
-			defaultPriority: 300,
+			defaultPriority: 100,
 			opt:             libp2p.Security(noise.ID, noise.New),
 		}}))
 		return opts

From 3674b662db89a6820b4adfea1ccddec37b8ffe17 Mon Sep 17 00:00:00 2001
From: Marten Seemann <martenseemann@gmail.com>
Date: Mon, 28 Feb 2022 15:26:06 +0400
Subject: [PATCH 2/2] add a test case for libp2p option prioritization

---
 core/node/libp2p/libp2p_test.go | 58 +++++++++++++++++++++++++++++++++
 1 file changed, 58 insertions(+)
 create mode 100644 core/node/libp2p/libp2p_test.go

diff --git a/core/node/libp2p/libp2p_test.go b/core/node/libp2p/libp2p_test.go
new file mode 100644
index 000000000..fa9491303
--- /dev/null
+++ b/core/node/libp2p/libp2p_test.go
@@ -0,0 +1,58 @@
+package libp2p
+
+import (
+	"fmt"
+	"strconv"
+	"testing"
+
+	"github.com/libp2p/go-libp2p"
+	ma "github.com/multiformats/go-multiaddr"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestPrioritize(t *testing.T) {
+	// The option is encoded into the port number of a TCP multiaddr.
+	// By extracting the port numbers obtained from the applied option, we can make sure that
+	// prioritization sorted the options correctly.
+	newOption := func(num int) libp2p.Option {
+		return func(cfg *libp2p.Config) error {
+			cfg.ListenAddrs = append(cfg.ListenAddrs, ma.StringCast(fmt.Sprintf("/ip4/127.0.0.1/tcp/%d", num)))
+			return nil
+		}
+	}
+
+	extractNums := func(cfg *libp2p.Config) []int {
+		addrs := cfg.ListenAddrs
+		nums := make([]int, 0, len(addrs))
+		for _, addr := range addrs {
+			_, comp := ma.SplitLast(addr)
+			num, err := strconv.Atoi(comp.Value())
+			require.NoError(t, err)
+			nums = append(nums, num)
+		}
+		return nums
+	}
+
+	t.Run("using default priorities", func(t *testing.T) {
+		opts := []priorityOption{
+			{defaultPriority: 200, opt: newOption(200)},
+			{defaultPriority: 1, opt: newOption(1)},
+			{defaultPriority: 300, opt: newOption(300)},
+		}
+		var cfg libp2p.Config
+		require.NoError(t, prioritizeOptions(opts)(&cfg))
+		require.Equal(t, extractNums(&cfg), []int{1, 200, 300})
+	})
+
+	t.Run("using custom priorities", func(t *testing.T) {
+		opts := []priorityOption{
+			{defaultPriority: 200, priority: 1, opt: newOption(1)},
+			{defaultPriority: 1, priority: 300, opt: newOption(300)},
+			{defaultPriority: 300, priority: 20, opt: newOption(20)},
+		}
+		var cfg libp2p.Config
+		require.NoError(t, prioritizeOptions(opts)(&cfg))
+		require.Equal(t, extractNums(&cfg), []int{1, 20, 300})
+	})
+}