From 6e59eae1efb14f7483262b1418c0cb4b7cd4a3e0 Mon Sep 17 00:00:00 2001 From: Abhishek Kondur Date: Sun, 12 Feb 2023 15:08:08 +0400 Subject: [PATCH] get right listen for ext conf file --- controllers/ext_client.go | 2 +- logic/peers.go | 18 +++++++++--------- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/controllers/ext_client.go b/controllers/ext_client.go index ab55a905..2c2ba184 100644 --- a/controllers/ext_client.go +++ b/controllers/ext_client.go @@ -214,7 +214,7 @@ func getExtClientConf(w http.ResponseWriter, r *http.Request) { if network.DefaultKeepalive != 0 { keepalive = "PersistentKeepalive = " + strconv.Itoa(int(network.DefaultKeepalive)) } - gwendpoint := host.EndpointIP.String() + ":" + strconv.Itoa(host.ListenPort) + gwendpoint := host.EndpointIP.String() + ":" + strconv.Itoa(logic.GetPeerListenPort(host)) newAllowedIPs := network.AddressRange if newAllowedIPs != "" && network.AddressRange6 != "" { newAllowedIPs += "," diff --git a/logic/peers.go b/logic/peers.go index 6ee93534..39fb14fa 100644 --- a/logic/peers.go +++ b/logic/peers.go @@ -201,7 +201,7 @@ func GetProxyUpdateForHost(host *models.Host) (models.ProxyManagerPayload, error if host.IsRelayed { relayHost, err := GetHost(host.RelayedBy) if err == nil { - relayEndpoint, err := net.ResolveUDPAddr("udp", fmt.Sprintf("%s:%d", relayHost.EndpointIP, getPeerListenPort(relayHost))) + relayEndpoint, err := net.ResolveUDPAddr("udp", fmt.Sprintf("%s:%d", relayHost.EndpointIP, GetPeerListenPort(relayHost))) if err != nil { logger.Log(1, "failed to resolve relay node endpoint: ", err.Error()) } @@ -219,7 +219,7 @@ func GetProxyUpdateForHost(host *models.Host) (models.ProxyManagerPayload, error relayedHost := relayedHost payload, err := GetPeerUpdateForHost(&relayedHost) if err == nil { - relayedEndpoint, udpErr := net.ResolveUDPAddr("udp", fmt.Sprintf("%s:%d", relayedHost.EndpointIP, getPeerListenPort(&relayedHost))) + relayedEndpoint, udpErr := net.ResolveUDPAddr("udp", fmt.Sprintf("%s:%d", relayedHost.EndpointIP, GetPeerListenPort(&relayedHost))) if udpErr == nil { relayPeersMap[relayedHost.PublicKey.String()] = models.RelayedConf{ RelayedPeerEndpoint: relayedEndpoint, @@ -259,14 +259,14 @@ func GetProxyUpdateForHost(host *models.Host) (models.ProxyManagerPayload, error if currPeerConf, found = peerConfMap[peerHost.PublicKey.String()]; !found { currPeerConf = models.PeerConf{ Proxy: peerHost.ProxyEnabled, - PublicListenPort: int32(getPeerListenPort(peerHost)), + PublicListenPort: int32(GetPeerListenPort(peerHost)), } } if peerHost.IsRelayed && peerHost.RelayedBy != host.ID.String() { relayHost, err := GetHost(peerHost.RelayedBy) if err == nil { - relayTo, err := net.ResolveUDPAddr("udp", fmt.Sprintf("%s:%d", relayHost.EndpointIP, getPeerListenPort(relayHost))) + relayTo, err := net.ResolveUDPAddr("udp", fmt.Sprintf("%s:%d", relayHost.EndpointIP, GetPeerListenPort(relayHost))) if err == nil { currPeerConf.IsRelayed = true currPeerConf.RelayedTo = relayTo @@ -375,7 +375,7 @@ func GetPeerUpdateForHost(host *models.Host) (models.HostPeerUpdate, error) { } peerConfig.Endpoint = &net.UDPAddr{ IP: peerHost.EndpointIP, - Port: getPeerListenPort(peerHost), + Port: GetPeerListenPort(peerHost), } if uselocal { @@ -490,7 +490,7 @@ func GetPeerUpdateForHost(host *models.Host) (models.HostPeerUpdate, error) { return hostPeerUpdate, nil } -func getPeerListenPort(host *models.Host) int { +func GetPeerListenPort(host *models.Host) int { peerPort := host.ListenPort if host.ProxyEnabled { if host.PublicListenPort != 0 { @@ -560,7 +560,7 @@ func GetPeerUpdate(node *models.Node, host *models.Host) (models.PeerUpdate, err Port: peerHost.ListenPort, } if peerHost.ProxyEnabled { - peerConfig.Endpoint.Port = getPeerListenPort(peerHost) + peerConfig.Endpoint.Port = GetPeerListenPort(peerHost) } if uselocal { peerConfig.Endpoint.IP = peer.LocalAddress.IP @@ -693,7 +693,7 @@ func GetPeerUpdateLegacy(node *models.Node) (models.PeerUpdate, error) { if node.LocalAddress.String() != peer.LocalAddress.String() && peer.LocalAddress.IP != nil { peerHost.EndpointIP = peer.LocalAddress.IP if peerHost.ListenPort != 0 { - peerHost.ListenPort = getPeerListenPort(peerHost) + peerHost.ListenPort = GetPeerListenPort(peerHost) } } else { continue @@ -726,7 +726,7 @@ func GetPeerUpdateLegacy(node *models.Node) (models.PeerUpdate, error) { // or, if port is for some reason zero use the LocalListenPort // but only do this if LocalListenPort is not zero if ((!setUDPPort) || peerHost.ListenPort == 0) && peerHost.ListenPort != 0 { - peerHost.ListenPort = getPeerListenPort(peerHost) + peerHost.ListenPort = GetPeerListenPort(peerHost) } endpoint := peerHost.EndpointIP.String() + ":" + strconv.FormatInt(int64(peerHost.ListenPort), 10)