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.
101 lines
2.1 KiB
Go
101 lines
2.1 KiB
Go
// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package ips
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"net"
|
|
"strconv"
|
|
|
|
"github.com/luxfi/node/utils/wrappers"
|
|
)
|
|
|
|
const nullStr = "null"
|
|
|
|
var (
|
|
errMissingQuotes = errors.New("first and last characters should be quotes")
|
|
errBadIP = errors.New("bad ip format")
|
|
)
|
|
|
|
type IPDesc IPPort
|
|
|
|
func (ipDesc IPDesc) String() string {
|
|
return IPPort(ipDesc).String()
|
|
}
|
|
|
|
func (ipDesc IPDesc) MarshalJSON() ([]byte, error) {
|
|
return []byte(`"` + ipDesc.String() + `"`), nil
|
|
}
|
|
|
|
func (ipDesc *IPDesc) UnmarshalJSON(b []byte) error {
|
|
str := string(b)
|
|
if str == nullStr { // If "null", do nothing
|
|
return nil
|
|
} else if len(str) < 2 {
|
|
return errMissingQuotes
|
|
}
|
|
|
|
lastIndex := len(str) - 1
|
|
if str[0] != '"' || str[lastIndex] != '"' {
|
|
return errMissingQuotes
|
|
}
|
|
|
|
ipPort, err := ToIPPort(str[1:lastIndex])
|
|
if err != nil {
|
|
return fmt.Errorf("couldn't decode to IPPort: %w", err)
|
|
}
|
|
*ipDesc = IPDesc(ipPort)
|
|
|
|
return nil
|
|
}
|
|
|
|
// An IP and a port.
|
|
type IPPort struct {
|
|
IP net.IP `json:"ip"`
|
|
Port uint16 `json:"port"`
|
|
}
|
|
|
|
func (ipPort IPPort) Equal(other IPPort) bool {
|
|
return ipPort.Port == other.Port && ipPort.IP.Equal(other.IP)
|
|
}
|
|
|
|
func (ipPort IPPort) String() string {
|
|
return net.JoinHostPort(ipPort.IP.String(), strconv.FormatUint(uint64(ipPort.Port), 10))
|
|
}
|
|
|
|
// IsZero returns if the IP or port is zeroed out
|
|
func (ipPort IPPort) IsZero() bool {
|
|
ip := ipPort.IP
|
|
return ipPort.Port == 0 ||
|
|
len(ip) == 0 ||
|
|
ip.Equal(net.IPv4zero) ||
|
|
ip.Equal(net.IPv6zero)
|
|
}
|
|
|
|
func ToIPPort(str string) (IPPort, error) {
|
|
host, portStr, err := net.SplitHostPort(str)
|
|
if err != nil {
|
|
return IPPort{}, errBadIP
|
|
}
|
|
port, err := strconv.ParseUint(portStr, 10 /*=base*/, 16 /*=size*/)
|
|
if err != nil {
|
|
return IPPort{}, err
|
|
}
|
|
ip := net.ParseIP(host)
|
|
if ip == nil {
|
|
return IPPort{}, errBadIP
|
|
}
|
|
return IPPort{
|
|
IP: ip,
|
|
Port: uint16(port),
|
|
}, nil
|
|
}
|
|
|
|
// PackIP packs an ip port pair to the byte array
|
|
func PackIP(p *wrappers.Packer, ip IPPort) {
|
|
p.PackFixedBytes(ip.IP.To16())
|
|
p.PackShort(ip.Port)
|
|
}
|