feat: add ability to parse addr infos from strings (#143)

cmd/qgb/helpers/parse.go

@@ -0,0 +1,20 @@
+package helpers
+
+import (
+	"github.com/libp2p/go-libp2p/core/peer"
+	tmlog "github.com/tendermint/tendermint/libs/log"
+)
+
+// ParseAddrInfos converts strings to AddrInfos
+func ParseAddrInfos(logger tmlog.Logger, addrs []string) ([]peer.AddrInfo, error) {
+	infos := make([]peer.AddrInfo, 0, len(addrs))
+	for _, addr := range addrs {
+		info, err := peer.AddrInfoFromString(addr)
+		if err != nil {
+			logger.Error("parsing info from multiaddr", "addr", addr, "err", err)
+			return nil, err
+		}
+		infos = append(infos, *info)
+	}
+	return infos, nil
+}

cmd/qgb/helpers/parse_test.go

@@ -0,0 +1,65 @@
+package helpers
+
+import (
+	"testing"
+
+	"github.com/libp2p/go-libp2p/core/peer"
+	"github.com/stretchr/testify/assert"
+	tmlog "github.com/tendermint/tendermint/libs/log"
+)
+
+func TestParseAddrInfos(t *testing.T) {
+	testCases := []struct {
+		name      string
+		addrs     []string
+		want      []peer.AddrInfo
+		shouldErr bool
+	}{
+		{
+			name:  "empty input",
+			addrs: []string{},
+			want:  []peer.AddrInfo{},
+		},
+		{
+			name: "valid input",
+			addrs: []string{
+				"/ip4/127.0.0.1/tcp/8080/p2p/12D3KooWHr2wqFAsMXnPzpFsgxmePgXb8BqpkePebwUgLyZc95bd",
+				"/dns4/limani.celestia-devops.dev/tcp/2121/p2p/12D3KooWDgG69kXfmSiHjUErN2ahpUC1SXpSfB2urrqMZ6aWC8NS",
+			},
+			want: []peer.AddrInfo{
+				func() peer.AddrInfo {
+					info, _ := peer.AddrInfoFromString("/ip4/127.0.0.1/tcp/8080/p2p/12D3KooWHr2wqFAsMXnPzpFsgxmePgXb8BqpkePebwUgLyZc95bd")
+					return *info
+				}(),
+				func() peer.AddrInfo {
+					info, _ := peer.AddrInfoFromString("/dns4/limani.celestia-devops.dev/tcp/2121/p2p/12D3KooWDgG69kXfmSiHjUErN2ahpUC1SXpSfB2urrqMZ6aWC8NS")
+					return *info
+				}(),
+			},
+		},
+		{
+			name: "invalid multiaddr",
+			addrs: []string{
+				"/ip4/127.0.0.1/tcp/8080",
+				"invalid-multiaddr",
+			},
+			shouldErr: true,
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			got, err := ParseAddrInfos(tmlog.NewNopLogger(), tc.addrs)
+			if tc.shouldErr {
+				assert.Error(t, err)
+				assert.Nil(t, got)
+			} else {
+				assert.NoError(t, err)
+				for i, info := range tc.want {
+					assert.Equal(t, info.ID.String(), got[i].ID.String())
+					assert.Equal(t, info.Addrs, got[i].Addrs)
+				}
+			}
+		})
+	}
+}