chore: fix go.mod replace

pancsta · pancsta · commit c97977b6e200 · 2025-06-21T14:10:06.000+02:00
diff --git a/go.mod b/go.mod
@@ -4,7 +4,7 @@ go 1.24
 
 toolchain go1.24.0
 
-replace github.com/pancsta/cview => ../cview
+//replace github.com/pancsta/cview => ../cview
 
 require (
 	code.rocketnine.space/tslocum/cbind v0.1.5
@@ -28,7 +28,7 @@ require (
 	github.com/nats-io/nats.go v1.41.2
 	github.com/nkall/compactnumber v1.1.1
 	github.com/orsinium-labs/enum v1.4.0
-	github.com/pancsta/cview v1.5.16
+	github.com/pancsta/cview v1.5.17
 	github.com/patrickmn/go-cache v2.1.0+incompatible
 	github.com/prometheus/client_golang v1.20.5
 	github.com/reeflective/console v0.1.22
diff --git a/go.sum b/go.sum
@@ -355,6 +355,8 @@ github.com/opencontainers/runtime-spec v1.2.0/go.mod h1:jwyrGlmzljRJv/Fgzds9SsS/
 github.com/openzipkin/zipkin-go v0.1.1/go.mod h1:NtoC/o8u3JlF1lSlyPNswIbeQH9bJTmOf0Erfk+hxe8=
 github.com/orsinium-labs/enum v1.4.0 h1:3NInlfV76kuAg0kq2FFUondmg3WO7gMEgrPPrlzLDUM=
 github.com/orsinium-labs/enum v1.4.0/go.mod h1:Qj5IK2pnElZtkZbGDxZMjpt7SUsn4tqE5vRelmWaBbc=
+github.com/pancsta/cview v1.5.17 h1:myzbupJQqqugwjB3CfhPB7Q4wu1D6u1leRK8HD6ORZM=
+github.com/pancsta/cview v1.5.17/go.mod h1:R6H3+/2zImmT9E1zXSJ2mZBulCfFw10NafJ5TugbjZE=
 github.com/patrickmn/go-cache v2.1.0+incompatible h1:HRMgzkcYKYpi3C8ajMPV8OFXaaRUnok+kx1WdO15EQc=
 github.com/patrickmn/go-cache v2.1.0+incompatible/go.mod h1:3Qf8kWWT7OJRJbdiICTKqZju1ZixQ/KpMGzzAfe6+WQ=
 github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58 h1:onHthvaw9LFnH4t2DcNVpwGmV9E1BkGknEliJkfwQj0=
diff --git a/pkg/pubsub/pubsub_test.go b/pkg/pubsub/pubsub_test.go
@@ -433,13 +433,15 @@ func newPsPeer(
 
 	// pick N random addrs
 	pickedAddrs := []ma.Multiaddr{}
+	pickedAddrsStr := []string{}
 	for range n {
 		if len(connAddrs) == 0 {
 			break
 		}
 		a := connAddrs[rand.Intn(len(connAddrs))]
-		if !slices.Contains(pickedAddrs, a) {
+		if !slices.Contains(pickedAddrsStr, a.String()) {
 			pickedAddrs = append(pickedAddrs, a)
+			pickedAddrsStr = append(pickedAddrsStr, a.String())
 		}
 	}
 
diff --git a/pkg/pubsub/topic.go b/pkg/pubsub/topic.go
@@ -1274,7 +1274,11 @@ func (t *Topic) ListMachinesState(e *am.Event) {
 		}
 	}
 
-	retCh <- ret
+	select {
+	case retCh <- ret:
+	default:
+		t.log("ListMachines: closed chan, dropping")
+	}
 }
 
 func (t *Topic) HeartbeatState(e *am.Event) {

Original file line number	Diff line number	Diff line change
`@@ -433,13 +433,15 @@ func newPsPeer(`
`433`	`433`
`434`	`434`	`// pick N random addrs`
`435`	`435`	`pickedAddrs := []ma.Multiaddr{}`
	`436`	`+ pickedAddrsStr := []string{}`
`436`	`437`	`for range n {`
`437`	`438`	`if len(connAddrs) == 0 {`
`438`	`439`	`break`
`439`	`440`	`}`
`440`	`441`	`a := connAddrs[rand.Intn(len(connAddrs))]`
`441`		`- if !slices.Contains(pickedAddrs, a) {`
	`442`	`+ if !slices.Contains(pickedAddrsStr, a.String()) {`
`442`	`443`	`pickedAddrs = append(pickedAddrs, a)`
	`444`	`+ pickedAddrsStr = append(pickedAddrsStr, a.String())`
`443`	`445`	`}`
`444`	`446`	`}`
`445`	`447`
Original file line number	Diff line number	Diff line change
`@@ -1274,7 +1274,11 @@ func (t Topic) ListMachinesState(e am.Event) {`
`1274`	`1274`	`}`
`1275`	`1275`	`}`
`1276`	`1276`
`1277`		`- retCh <- ret`
	`1277`	`+ select {`
	`1278`	`+ case retCh <- ret:`
	`1279`	`+ default:`
	`1280`	`+ t.log("ListMachines: closed chan, dropping")`
	`1281`	`+ }`
`1278`	`1282`	`}`
`1279`	`1283`
`1280`	`1284`	`func (t Topic) HeartbeatState(e am.Event) {`