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.
133 lines
2.5 KiB
Go
133 lines
2.5 KiB
Go
// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package beacon
|
|
|
|
import (
|
|
"errors"
|
|
"net/netip"
|
|
"strings"
|
|
|
|
"github.com/luxfi/ids"
|
|
)
|
|
|
|
var (
|
|
_ Set = (*set)(nil)
|
|
|
|
errDuplicateID = errors.New("duplicated ID")
|
|
errDuplicateIP = errors.New("duplicated IP")
|
|
|
|
errUnknownID = errors.New("unknown ID")
|
|
errUnknownIP = errors.New("unknown IP")
|
|
)
|
|
|
|
type Set interface {
|
|
Add(Beacon) error
|
|
|
|
RemoveByID(ids.NodeID) error
|
|
RemoveByIP(netip.AddrPort) error
|
|
|
|
Len() int
|
|
|
|
IDsArg() string
|
|
IPsArg() string
|
|
}
|
|
|
|
type set struct {
|
|
ids map[ids.NodeID]int
|
|
ips map[netip.AddrPort]int
|
|
beacons []Beacon
|
|
}
|
|
|
|
func NewSet() Set {
|
|
return &set{
|
|
ids: make(map[ids.NodeID]int),
|
|
ips: make(map[netip.AddrPort]int),
|
|
}
|
|
}
|
|
|
|
func (s *set) Add(b Beacon) error {
|
|
id := b.ID()
|
|
_, duplicateID := s.ids[id]
|
|
if duplicateID {
|
|
return errDuplicateID
|
|
}
|
|
|
|
ip := b.IP()
|
|
_, duplicateIP := s.ips[ip]
|
|
if duplicateIP {
|
|
return errDuplicateIP
|
|
}
|
|
|
|
s.ids[id] = len(s.beacons)
|
|
s.ips[ip] = len(s.beacons)
|
|
s.beacons = append(s.beacons, b)
|
|
return nil
|
|
}
|
|
|
|
func (s *set) RemoveByID(idToRemove ids.NodeID) error {
|
|
indexToRemove, exists := s.ids[idToRemove]
|
|
if !exists {
|
|
return errUnknownID
|
|
}
|
|
toRemove := s.beacons[indexToRemove]
|
|
ipToRemove := toRemove.IP()
|
|
|
|
indexToMove := len(s.beacons) - 1
|
|
toMove := s.beacons[indexToMove]
|
|
idToMove := toMove.ID()
|
|
ipToMove := toMove.IP()
|
|
|
|
s.ids[idToMove] = indexToRemove
|
|
s.ips[ipToMove] = indexToRemove
|
|
s.beacons[indexToRemove] = toMove
|
|
|
|
delete(s.ids, idToRemove)
|
|
delete(s.ips, ipToRemove)
|
|
s.beacons[indexToMove] = nil
|
|
s.beacons = s.beacons[:indexToMove]
|
|
return nil
|
|
}
|
|
|
|
func (s *set) RemoveByIP(ip netip.AddrPort) error {
|
|
indexToRemove, exists := s.ips[ip]
|
|
if !exists {
|
|
return errUnknownIP
|
|
}
|
|
toRemove := s.beacons[indexToRemove]
|
|
idToRemove := toRemove.ID()
|
|
return s.RemoveByID(idToRemove)
|
|
}
|
|
|
|
func (s *set) Len() int {
|
|
return len(s.beacons)
|
|
}
|
|
|
|
func (s *set) IDsArg() string {
|
|
sb := strings.Builder{}
|
|
if len(s.beacons) == 0 {
|
|
return ""
|
|
}
|
|
b := s.beacons[0]
|
|
_, _ = sb.WriteString(b.ID().String())
|
|
for _, b := range s.beacons[1:] {
|
|
_, _ = sb.WriteString(",")
|
|
_, _ = sb.WriteString(b.ID().String())
|
|
}
|
|
return sb.String()
|
|
}
|
|
|
|
func (s *set) IPsArg() string {
|
|
sb := strings.Builder{}
|
|
if len(s.beacons) == 0 {
|
|
return ""
|
|
}
|
|
b := s.beacons[0]
|
|
_, _ = sb.WriteString(b.IP().String())
|
|
for _, b := range s.beacons[1:] {
|
|
_, _ = sb.WriteString(",")
|
|
_, _ = sb.WriteString(b.IP().String())
|
|
}
|
|
return sb.String()
|
|
}
|