node/mesh/dialer/endpoint_dialer.go

// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
// See the file LICENSE for licensing terms.

package dialer

import (
	"context"
	"errors"
	"fmt"
	"net"
	"net/netip"
	"sync"
	"time"

	"github.com/luxfi/log"
	"github.com/luxfi/net/endpoints"
	"github.com/luxfi/node/mesh/throttling"
)

var (
	// ErrRNSNotConfigured is returned when dialing an RNS endpoint without an RNS transport.
	ErrRNSNotConfigured = errors.New("RNS transport not configured")
	// ErrRNSDialFailed is returned when the RNS transport fails to establish a link.
	ErrRNSDialFailed = errors.New("RNS dial failed")
)

var _ EndpointDialer = (*endpointDialer)(nil)

// EndpointDialer attempts to create a connection with IP:port, hostname:port, or RNS destination.
type EndpointDialer interface {
	// DialEndpoint dials an endpoint (IP, hostname, or RNS).
	DialEndpoint(ctx context.Context, endpoint endpoints.Endpoint) (net.Conn, error)

	// Dial is the legacy IP-only dial method for backward compatibility.
	Dial(ctx context.Context, ip netip.AddrPort) (net.Conn, error)
}

// RNSTransport provides connectivity over Reticulum Network Stack.
// Implementations wrap RNS Links as net.Conn interfaces.
type RNSTransport interface {
	// Dial establishes a link to an RNS destination and returns it as net.Conn.
	Dial(ctx context.Context, destination [endpoints.RNSDestinationLen]byte) (net.Conn, error)

	// Available returns true if RNS transport is ready to use.
	Available() bool

	// Close shuts down the RNS transport.
	Close() error
}

// DNSCacheConfig configures the DNS resolution cache.
type DNSCacheConfig struct {
	// TTL is how long resolved IPs are cached.
	TTL time.Duration `json:"ttl"`
	// MaxEntries is the maximum number of cached resolutions.
	MaxEntries int `json:"maxEntries"`
	// ResolveTimeout is the timeout for DNS resolution.
	ResolveTimeout time.Duration `json:"resolveTimeout"`
}

// DefaultDNSCacheConfig returns sensible defaults for DNS caching.
func DefaultDNSCacheConfig() DNSCacheConfig {
	return DNSCacheConfig{
		TTL:            5 * time.Minute,
		MaxEntries:     1000,
		ResolveTimeout: 5 * time.Second,
	}
}

type dnsEntry struct {
	addrs     []netip.Addr
	expiresAt time.Time
}

type endpointDialer struct {
	dialer    net.Dialer
	log       log.Logger
	network   string
	throttler throttling.DialThrottler
	dnsConfig DNSCacheConfig

	// DNS resolution cache
	dnsMu    sync.RWMutex
	dnsCache map[string]*dnsEntry

	// RNS transport (optional, for mesh/LoRa/offline-first connectivity)
	rns RNSTransport
}

// EndpointDialerConfig extends Config with DNS and RNS settings.
type EndpointDialerConfig struct {
	Config
	DNSConfig    DNSCacheConfig `json:"dnsConfig"`
	RNSTransport RNSTransport   `json:"-"` // Optional RNS transport (not serialized)
}

// NewEndpointDialer creates a dialer that supports IP, hostname, and RNS endpoints.
func NewEndpointDialer(network string, config EndpointDialerConfig, logger log.Logger) EndpointDialer {
	var throttler throttling.DialThrottler
	if config.ThrottleRps <= 0 {
		throttler = throttling.NewNoDialThrottler()
	} else {
		throttler = throttling.NewDialThrottler(int(config.ThrottleRps))
	}

	dnsConfig := config.DNSConfig
	if dnsConfig.TTL == 0 {
		dnsConfig = DefaultDNSCacheConfig()
	}

	rnsAvailable := config.RNSTransport != nil && config.RNSTransport.Available()

	logger.Debug(
		"creating endpoint dialer",
		log.Uint32("throttleRPS", config.ThrottleRps),
		log.Duration("dialTimeout", config.ConnectionTimeout),
		log.Duration("dnsTTL", dnsConfig.TTL),
		log.Int("dnsMaxEntries", dnsConfig.MaxEntries),
		log.Bool("rnsAvailable", rnsAvailable),
	)

	return &endpointDialer{
		dialer:    net.Dialer{Timeout: config.ConnectionTimeout},
		log:       logger,
		network:   network,
		throttler: throttler,
		dnsConfig: dnsConfig,
		dnsCache:  make(map[string]*dnsEntry),
		rns:       config.RNSTransport,
	}
}

// DialEndpoint dials an endpoint, handling IP, hostname, and RNS targets seamlessly.
func (d *endpointDialer) DialEndpoint(ctx context.Context, endpoint endpoints.Endpoint) (net.Conn, error) {
	if err := d.throttler.Acquire(ctx); err != nil {
		return nil, err
	}

	// Handle RNS endpoints via Reticulum transport
	if endpoint.IsRNS() {
		return d.dialRNS(ctx, endpoint)
	}

	// Handle IP and hostname endpoints via TCP
	return d.dialTCP(ctx, endpoint)
}

// dialRNS establishes a connection over Reticulum Network Stack.
func (d *endpointDialer) dialRNS(ctx context.Context, endpoint endpoints.Endpoint) (net.Conn, error) {
	if d.rns == nil || !d.rns.Available() {
		return nil, fmt.Errorf("%w: cannot dial %s", ErrRNSNotConfigured, endpoint)
	}

	d.log.Debug("dialing RNS endpoint",
		log.String("destination", endpoint.DestinationHex()),
	)

	conn, err := d.rns.Dial(ctx, endpoint.Destination)
	if err != nil {
		return nil, fmt.Errorf("%w: %s: %v", ErrRNSDialFailed, endpoint, err)
	}

	d.log.Debug("RNS link established",
		log.String("destination", endpoint.DestinationHex()),
	)

	return conn, nil
}

// dialTCP establishes a connection over TCP (IP or hostname).
func (d *endpointDialer) dialTCP(ctx context.Context, endpoint endpoints.Endpoint) (net.Conn, error) {
	var target string
	if endpoint.IsIP() {
		target = endpoint.AddrPort.String()
	} else {
		// Hostname endpoint - try to use cached resolution first
		addr, err := d.resolveHostname(ctx, endpoint.Hostname)
		if err != nil {
			// Fall back to letting net.Dial resolve the hostname
			d.log.Debug("DNS cache miss, using system resolver",
				log.String("hostname", endpoint.Hostname),
				log.Err(err),
			)
			target = endpoint.String()
		} else {
			// Use cached IP
			target = netip.AddrPortFrom(addr, endpoint.Port).String()
		}
	}

	d.log.Debug("dialing TCP endpoint",
		log.String("original", endpoint.String()),
		log.String("target", target),
	)

	conn, err := d.dialer.DialContext(ctx, d.network, target)
	if err != nil {
		return nil, fmt.Errorf("error dialing %s: %w", endpoint, err)
	}
	return conn, nil
}

// Dial implements the legacy IP-only Dialer interface.
func (d *endpointDialer) Dial(ctx context.Context, ip netip.AddrPort) (net.Conn, error) {
	return d.DialEndpoint(ctx, endpoints.NewIPEndpoint(ip))
}

// resolveHostname resolves a hostname to an IP, using cache when possible.
func (d *endpointDialer) resolveHostname(ctx context.Context, hostname string) (netip.Addr, error) {
	// Check cache first
	d.dnsMu.RLock()
	entry, ok := d.dnsCache[hostname]
	d.dnsMu.RUnlock()

	if ok && time.Now().Before(entry.expiresAt) && len(entry.addrs) > 0 {
		// Return first cached address (could round-robin for load balancing)
		return entry.addrs[0], nil
	}

	// Resolve with timeout
	resolveCtx, cancel := context.WithTimeout(ctx, d.dnsConfig.ResolveTimeout)
	defer cancel()

	resolver := net.DefaultResolver
	ips, err := resolver.LookupNetIP(resolveCtx, "ip", hostname)
	if err != nil {
		return netip.Addr{}, fmt.Errorf("failed to resolve %s: %w", hostname, err)
	}
	if len(ips) == 0 {
		return netip.Addr{}, fmt.Errorf("no addresses found for %s", hostname)
	}

	// Update cache
	d.dnsMu.Lock()
	// Enforce max entries
	if len(d.dnsCache) >= d.dnsConfig.MaxEntries {
		d.evictOldestDNSEntry()
	}
	d.dnsCache[hostname] = &dnsEntry{
		addrs:     ips,
		expiresAt: time.Now().Add(d.dnsConfig.TTL),
	}
	d.dnsMu.Unlock()

	d.log.Debug("resolved hostname",
		log.String("hostname", hostname),
		log.Stringer("addr", ips[0]),
		log.Duration("ttl", d.dnsConfig.TTL),
	)

	return ips[0], nil
}

// evictOldestDNSEntry removes the oldest DNS cache entry.
// Caller must hold dnsMu write lock.
func (d *endpointDialer) evictOldestDNSEntry() {
	var oldestHost string
	oldestTime := time.Now().Add(24 * time.Hour) // Far future

	for host, entry := range d.dnsCache {
		if entry.expiresAt.Before(oldestTime) {
			oldestTime = entry.expiresAt
			oldestHost = host
		}
	}

	if oldestHost != "" {
		delete(d.dnsCache, oldestHost)
	}
}

// InvalidateDNS removes a hostname from the DNS cache, forcing re-resolution.
func (d *endpointDialer) InvalidateDNS(hostname string) {
	d.dnsMu.Lock()
	delete(d.dnsCache, hostname)
	d.dnsMu.Unlock()
}

// ClearDNSCache clears the entire DNS cache.
func (d *endpointDialer) ClearDNSCache() {
	d.dnsMu.Lock()
	d.dnsCache = make(map[string]*dnsEntry)
	d.dnsMu.Unlock()
}

// SetRNSTransport sets the RNS transport for mesh connectivity.
// This can be called after initialization to enable RNS support.
func (d *endpointDialer) SetRNSTransport(transport RNSTransport) {
	d.rns = transport
	if transport != nil && transport.Available() {
		d.log.Info("RNS transport enabled")
	}
}

// RNSAvailable returns true if RNS transport is configured and ready.
func (d *endpointDialer) RNSAvailable() bool {
	return d.rns != nil && d.rns.Available()
}

// Close releases resources held by the dialer.
func (d *endpointDialer) Close() error {
	if d.rns != nil {
		return d.rns.Close()
	}
	return nil
}