mirror of
https://github.com/hanzoai/base.git
synced 2026-10-21 03:41:50 +00:00
zeekay
23121474a8
ZAP binary protocol duplex RPC standardizes on :9999 across every service. Lux validator staking/RPC ports (9630/9631 mainnet, 9650/9651 devnet) are unchanged — those are luxd network protocol ports, not ZAP. One ZAP port everywhere (was a mix of 9651/9652/9653/9633/9900).
50 lines
1.4 KiB
Go
50 lines
1.4 KiB
Go
// Copyright (c) 2025, Hanzo Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package network
|
|
|
|
import "testing"
|
|
|
|
// TestIsSelfPeer verifies that BASE_PEERS entries are correctly matched
|
|
// against the local NodeID even when the peer entry carries the full
|
|
// headless-Service FQDN + :port (which the operator emits).
|
|
//
|
|
// Regression: operator emits
|
|
//
|
|
// BASE_PEERS=-0.-network.liquidity.svc.cluster.local:9999,...
|
|
// BASE_NODE_ID=-0
|
|
//
|
|
// Plain equality failed to skip self → transport dialed its own pod →
|
|
// luxfi/zap detected dup NodeID and closed → 3s reconnect loop burned
|
|
// CPU and logs without ever replicating a frame.
|
|
func TestIsSelfPeer(t *testing.T) {
|
|
z := &zapTransport{self: "-0"}
|
|
|
|
cases := []struct {
|
|
peer string
|
|
self bool
|
|
}{
|
|
// Empty / exact match — trivially self.
|
|
{"", true},
|
|
{"-0", true},
|
|
|
|
// FQDN + port — the operator-emitted shape.
|
|
{"-0.-network.liquidity.svc.cluster.local:9999", true},
|
|
|
|
// Short hostname + port, no domain — also self.
|
|
{"-0:9999", true},
|
|
|
|
// Different ordinal — not self.
|
|
{"-1.-network.liquidity.svc.cluster.local:9999", false},
|
|
{"-2:9999", false},
|
|
|
|
// Completely different name — not self.
|
|
{"some-other-pod.some-other.svc:9999", false},
|
|
}
|
|
for _, tc := range cases {
|
|
if got := z.isSelfPeer(tc.peer); got != tc.self {
|
|
t.Errorf("isSelfPeer(%q) = %v, want %v", tc.peer, got, tc.self)
|
|
}
|
|
}
|
|
}
|