mirror of
https://github.com/luxfi/node.git
synced 2026-07-27 03:39:39 +00:00
94 lines
2.0 KiB
Go
94 lines
2.0 KiB
Go
//go:build nattraversal
|
|
|
|
// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package nat
|
|
|
|
import (
|
|
"errors"
|
|
"math"
|
|
"net/netip"
|
|
"time"
|
|
|
|
"github.com/jackpal/gateway"
|
|
|
|
natpmp "github.com/jackpal/go-nat-pmp"
|
|
)
|
|
|
|
const (
|
|
// pmpProtocol is intentionally lowercase and should not be confused with
|
|
// upnpProtocol.
|
|
// See:
|
|
// - https://github.com/jackpal/go-nat-pmp/blob/v1.0.2/natpmp.go#L82
|
|
pmpProtocol = "tcp"
|
|
pmpClientTimeout = 500 * time.Millisecond
|
|
)
|
|
|
|
var (
|
|
_ Router = (*pmpRouter)(nil)
|
|
|
|
errInvalidLifetime = errors.New("invalid mapping duration range")
|
|
)
|
|
|
|
// pmpRouter adapts the NAT-PMP protocol implementation so it conforms to the
|
|
// common interface.
|
|
type pmpRouter struct {
|
|
client *natpmp.Client
|
|
}
|
|
|
|
func (*pmpRouter) SupportsNAT() bool {
|
|
return true
|
|
}
|
|
|
|
func (r *pmpRouter) MapPort(
|
|
newInternalPort uint16,
|
|
newExternalPort uint16,
|
|
_ string,
|
|
mappingDuration time.Duration,
|
|
) error {
|
|
internalPort := int(newInternalPort)
|
|
externalPort := int(newExternalPort)
|
|
|
|
// go-nat-pmp uses seconds to denote their lifetime
|
|
lifetime := mappingDuration.Seconds()
|
|
// Assumes the architecture is at least 32-bit
|
|
if lifetime < 0 || lifetime > math.MaxInt32 {
|
|
return errInvalidLifetime
|
|
}
|
|
|
|
_, err := r.client.AddPortMapping(pmpProtocol, internalPort, externalPort, int(lifetime))
|
|
return err
|
|
}
|
|
|
|
func (r *pmpRouter) UnmapPort(internalPort uint16, _ uint16) error {
|
|
internalPortInt := int(internalPort)
|
|
|
|
_, err := r.client.AddPortMapping(pmpProtocol, internalPortInt, 0, 0)
|
|
return err
|
|
}
|
|
|
|
func (r *pmpRouter) ExternalIP() (netip.Addr, error) {
|
|
response, err := r.client.GetExternalAddress()
|
|
if err != nil {
|
|
return netip.Addr{}, err
|
|
}
|
|
return netip.AddrFrom4(response.ExternalIPAddress), nil
|
|
}
|
|
|
|
func getPMPRouter() *pmpRouter {
|
|
gatewayIP, err := gateway.DiscoverGateway()
|
|
if err != nil {
|
|
return nil
|
|
}
|
|
|
|
pmp := &pmpRouter{
|
|
client: natpmp.NewClientWithTimeout(gatewayIP, pmpClientTimeout),
|
|
}
|
|
if _, err := pmp.ExternalIP(); err != nil {
|
|
return nil
|
|
}
|
|
|
|
return pmp
|
|
}
|