mirror of
https://github.com/luxfi/node.git
synced 2026-10-30 15:24:05 +00:00
zeekay
7cf87b230b
The module already called itself github.com/luxfi/node while containing no node in Go: cmd/luxd was twenty-one lines that printed the size of a few types, and the Go column of the matrix measured a VM plugin. A repo that fetches the thing it claims to be has not replaced it, so the Go sources move in — 1515 files, the daemon and everything under it — and the build reaches outside this module for nothing. Rust and C++ sit beside it unchanged and are still measured against it by the differential. That is the point of one repo: the reference implementation and the two ports are the same checkout, so parity is a thing you can run rather than a thing you assert. Verified: builds, and the closure carries no lux-private — checked at build time rather than believed. The daemon starts twelve chains on a local network (P X C Q Z A B G K M F, plus D through its plugin) and reports healthy.
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
|
|
}
|