dht

type Config struct {
	// in mainline dht, k = 8
	K int
	// for crawling mode, we put all nodes in one bucket, so KBucketSize may
	// not be K
	KBucketSize int
	// candidates are udp, udp4, udp6
	Network string
	// format is `ip:port`
	Address string
	// the prime nodes through which we can join in dht network
	PrimeNodes []string
	// the kbucket expired duration
	KBucketExpiredAfter time.Duration
	// the node expired duration
	NodeExpriedAfter time.Duration
	// how long it checks whether the bucket is expired
	CheckKBucketPeriod time.Duration
	// peer token expired duration
	TokenExpiredAfter time.Duration
	// the max transaction id
	MaxTransactionCursor uint64
	// how many nodes routing table can hold
	MaxNodes int
	// callback when got get_peers request
	OnGetPeers func(string, string, int)
	// callback when receive get_peers response
	OnGetPeersResponse func(string, Peer)
	// callback when got announce_peer request
	OnAnnouncePeer func(string, string, int)
	// blcoked ips
	BlockedIPs []string
	// blacklist size
	BlackListMaxSize int
	// StandardMode or CrawlMode
	Mode int
	// the times it tries when send fails
	Try int
	// the size of packet need to be dealt with
	PacketJobLimit int
	// the size of packet handler
	PacketWorkerLimit int
	// the nodes num to be fresh in a kbucket
	RefreshNodeNum int
}

type DHT struct {
	*Config

	Ready bool
	// contains filtered or unexported fields
}

type DHTErrorResponse struct {
	TransactionID string
	ErrorCode     int
	ErrorMessage  string
}

type DHTPayload interface {
	ToPayload() map[string]interface{}
}

type DHTQuery struct {
	TransactionID string
	QueryType     DHTQueryType
	Arguments     map[string]interface{}
}

type DHTQueryResponse struct {
	TransactionID string
	Arguments     map[string]interface{}
}

type DHTQueryType string

type Node interface {
	ID() *bitmap
	IDRawString() string
	Address() *net.UDPAddr
	LastActiveTime() time.Time
	CompactIPPortInfo() string
	CompactNodeInfo() string
}

type Peer interface {
	IP() net.IP
	Port() int
	Token() string
	CompactIPPortInfo() string
}

type Query struct {
	Node Node
	Data *DHTQuery
}

type Request struct {
	InfoHash []byte
	IP       string
	Port     int
}

type Response struct {
	Request
	MetadataInfo []byte
}

type Transaction struct {
	*Query
	ID       string
	Response chan struct{}
}

type TransactionMap struct {
	*sync.Map
}

type Wire struct {
	// contains filtered or unexported fields
}