Skip to content

Commit 709d4db

Browse files
authored
chore: remove double p2p setting (#3041)
remove next info
1 parent 0189cd5 commit 709d4db

File tree

5 files changed

+29
-24
lines changed

5 files changed

+29
-24
lines changed

pkg/cmd/p2p.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,9 +96,7 @@ var NetInfoCmd = &cobra.Command{
9696
// Iterate through all listen addresses
9797
fmt.Fprintf(w, "📡 Listen Addrs:")
9898
for i, addr := range netInfo.ListenAddresses {
99-
fullAddress := fmt.Sprintf("%s/p2p/%s", addr, nodeID)
10099
fmt.Fprintf(w, " [%d] Addr: \033[1;36m%s\033[0m\n", i+1, addr)
101-
fmt.Fprintf(w, " Full: \033[1;32m%s\033[0m\n", fullAddress)
102100
}
103101

104102
fmt.Fprintf(w, "%s\n", strings.Repeat("-", 50))

pkg/cmd/p2p_test.go

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,9 @@ func TestNetInfoCmd_Success(t *testing.T) {
4646
mockP2P := new(testmocks.MockP2PRPC)
4747

4848
mockNodeID := "12D3KooWExampleNodeID1234567890"
49-
mockListenAddr1 := "/ip4/127.0.0.1/tcp/7676"
50-
mockListenAddr2 := "/ip6/::1/tcp/7677"
49+
// Listen addresses include peer ID (as returned by the P2P layer)
50+
mockListenAddr1 := "/ip4/127.0.0.1/tcp/7676/p2p/" + mockNodeID
51+
mockListenAddr2 := "/ip6/::1/tcp/7677/p2p/" + mockNodeID
5152
mockPeerID1Str := "12D3KooWJHLDoXhmgYe6FEbujPzMQJvJ9JyGwRR2VjRM4f7Udvte"
5253
mockPeerAddr1Str := "/ip4/192.168.1.100/tcp/7676"
5354
mockPeerID2Str := "12D3KooWJHLDoXhmgYe6FEbujPzMQJvJ9JyGwRR2VjRM4f7Udvte"
@@ -114,9 +115,7 @@ func TestNetInfoCmd_Success(t *testing.T) {
114115
assert.Contains(output, fmt.Sprintf("Node ID: \033[1;36m%s\033[0m", mockNodeID))
115116
assert.Contains(output, "Listen Addrs:")
116117
assert.Contains(output, fmt.Sprintf("Addr: \033[1;36m%s\033[0m", mockListenAddr1))
117-
assert.Contains(output, fmt.Sprintf("Full: \033[1;32m%s/p2p/%s\033[0m", mockListenAddr1, mockNodeID))
118118
assert.Contains(output, fmt.Sprintf("Addr: \033[1;36m%s\033[0m", mockListenAddr2))
119-
assert.Contains(output, fmt.Sprintf("Full: \033[1;32m%s/p2p/%s\033[0m", mockListenAddr2, mockNodeID))
120119

121120
assert.Contains(output, "CONNECTED PEERS: \033[1;33m2\033[0m")
122121
assert.Contains(output, "PEER ID")
@@ -140,8 +139,9 @@ func TestNetInfoCmd_NoPeers(t *testing.T) {
140139
mockP2P := new(testmocks.MockP2PRPC)
141140

142141
mockNodeID := "12D3KooWExampleNodeID1234567890"
143-
mockListenAddr1 := "/ip4/127.0.0.1/tcp/7676"
144-
mockListenAddr2 := "/ip6/::1/tcp/7677"
142+
// Listen addresses include peer ID (as returned by the P2P layer)
143+
mockListenAddr1 := "/ip4/127.0.0.1/tcp/7676/p2p/" + mockNodeID
144+
mockListenAddr2 := "/ip6/::1/tcp/7677/p2p/" + mockNodeID
145145

146146
mockNetInfo := p2p.NetworkInfo{
147147
ID: mockNodeID,
@@ -192,9 +192,7 @@ func TestNetInfoCmd_NoPeers(t *testing.T) {
192192
assert.Contains(output, fmt.Sprintf("Node ID: \033[1;36m%s\033[0m", mockNodeID))
193193
assert.Contains(output, "Listen Addrs:")
194194
assert.Contains(output, fmt.Sprintf("Addr: \033[1;36m%s\033[0m", mockListenAddr1))
195-
assert.Contains(output, fmt.Sprintf("Full: \033[1;32m%s/p2p/%s\033[0m", mockListenAddr1, mockNodeID))
196195
assert.Contains(output, fmt.Sprintf("Addr: \033[1;36m%s\033[0m", mockListenAddr2))
197-
assert.Contains(output, fmt.Sprintf("Full: \033[1;32m%s/p2p/%s\033[0m", mockListenAddr2, mockNodeID))
198196

199197
assert.Contains(output, "CONNECTED PEERS: \033[1;33m0\033[0m")
200198
assert.Contains(output, "No peers connected")

pkg/p2p/client.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -410,8 +410,13 @@ func (c *Client) GetPeers() ([]peer.AddrInfo, error) {
410410

411411
func (c *Client) GetNetworkInfo() (NetworkInfo, error) {
412412
var addrs []string
413+
peerIDSuffix := "/p2p/" + c.host.ID().String()
413414
for _, a := range c.host.Addrs() {
414-
addr := fmt.Sprintf("%s/p2p/%s", a, c.host.ID())
415+
addr := a.String()
416+
// Only append peer ID if not already present
417+
if !strings.HasSuffix(addr, peerIDSuffix) {
418+
addr = addr + peerIDSuffix
419+
}
415420
addrs = append(addrs, addr)
416421
}
417422

scripts/run-evm-nodes.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -608,7 +608,7 @@ func isProjectRoot(dir string) bool {
608608
markers := []string{
609609
"apps/evm",
610610
"execution/evm",
611-
"da",
611+
"block",
612612
"scripts",
613613
"go.mod",
614614
}

scripts/run.go

Lines changed: 16 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ import (
1212
"os/exec"
1313
"os/signal"
1414
"path/filepath"
15+
"regexp"
1516
"strings"
1617
"syscall"
1718
"time"
@@ -275,17 +276,14 @@ func main() {
275276
lines := strings.Split(nodeInfoStr, "\n")
276277

277278
for _, line := range lines {
278-
if strings.Contains(line, "Full:") {
279-
// Extract the address part (after the color code)
280-
parts := strings.Split(line, "Full:")
281-
if len(parts) >= 2 {
282-
// Clean up ANSI color codes and whitespace
283-
cleanAddr := strings.TrimSpace(parts[1])
284-
// Remove potential ANSI color codes
285-
cleanAddr = strings.TrimPrefix(cleanAddr, "\033[1;32m")
286-
cleanAddr = strings.TrimSuffix(cleanAddr, "\033[0m")
287-
cleanAddr = strings.TrimSpace(cleanAddr)
288-
aggregatorAddress = cleanAddr
279+
if strings.Contains(line, "Addr:") && strings.Contains(line, "/p2p/") {
280+
addrIdx := strings.Index(line, "Addr:")
281+
if addrIdx == -1 {
282+
continue
283+
}
284+
addrPart := strings.TrimSpace(line[addrIdx+5:])
285+
if strings.Contains(addrPart, "/ip4/") && strings.Contains(addrPart, "/tcp/") {
286+
aggregatorAddress = stripANSI(addrPart)
289287
break
290288
}
291289
}
@@ -366,7 +364,7 @@ func findProjectRoot() (string, error) {
366364
func isProjectRoot(dir string) bool {
367365
// Check for key directories/files that would indicate the project root
368366
markers := []string{
369-
"da",
367+
"block",
370368
"apps",
371369
"scripts",
372370
"go.mod",
@@ -379,3 +377,9 @@ func isProjectRoot(dir string) bool {
379377
}
380378
return true
381379
}
380+
381+
// stripANSI removes ANSI escape sequences from a string.
382+
func stripANSI(str string) string {
383+
ansiRegex := regexp.MustCompile(`\x1b\[[0-9;]*m`)
384+
return ansiRegex.ReplaceAllString(str, "")
385+
}

0 commit comments

Comments
 (0)