server

type AnnounceJob struct {
	InfoHash      common.InfoHash
	ForwarderName string
	PeerID        common.PeerID
	Forwarder     CoreCommon.Forward
	Request       tracker.Request // template request
	ScheduledTime time.Time       // If set, job should execute at this time (zero means immediate)
}

type AnnounceResult struct {
	Success      bool
	Peers        []common.Peer
	Interval     int
	ResponseSize int
	Duration     time.Duration
	Error        error
	NonRetryable bool // If true, error is non-retryable (disable forwarder)
	Suspend      bool // If true, forwarder should be suspended (e.g., 429)
}

type Core struct {
	Config           *config.Config
	Storage          *Storage
	ForwarderStorage *ForwarderStorage
	ForwarderManager *ForwarderManager
	Receiver         *Receiver
}

type DisabledForwarder struct {
	Reason       string
	DisabledAt   int64
	FailureCount int
}

type ForwarderManager struct {
	Config      *config.Config
	Storage     *ForwarderStorage
	MainStorage *Storage
	Forwarders  []CoreCommon.Forward
	Workers     int

	Prometheus  *observability.Prometheus
	TempStorage *TempStorage
	// contains filtered or unexported fields
}

type ForwarderPeerEntry struct {
	Peers        []common.Peer
	Interval     int // Last reported interval in seconds from tracker response (per hash+forwarder)
	LastUpdate   time.Time
	NextAnnounce time.Time // Calculated as LastUpdate + Interval
}

type ForwarderStats struct {
	AvgResponseTime  time.Duration
	LastInterval     int
	LastAnnounceTime time.Time
	SampleCount      int
	// contains filtered or unexported fields
}

type ForwarderStorage struct {
	// map[InfoHash]map[ForwarderName]ForwarderPeerEntry
	Entries map[common.InfoHash]map[string]ForwarderPeerEntry
	// contains filtered or unexported fields
}

type Receiver struct {
	Announce *ReceiverAnnounce
	UDP      *ReceiverUDP
}

type ReceiverAnnounce struct {
	Config           *config.Config
	Storage          *Storage
	ForwarderStorage *ForwarderStorage
	ForwarderManager *ForwarderManager
	Prometheus       *observability.Prometheus
	TempStorage      *TempStorage
}

type ReceiverUDP struct {
	Config           *config.Config
	Storage          *Storage
	ForwarderStorage *ForwarderStorage
	ForwarderManager *ForwarderManager
	Prometheus       *observability.Prometheus
	TempStorage      *TempStorage
	// contains filtered or unexported fields
}

type ScrapeResponse struct {
	Files map[string]ScrapeResponseHash `bencode:"files"`
}

type ScrapeResponseHash struct {
	Complete   int `bencode:"complete"`
	Incomplete int `bencode:"incomplete"`
	Downloaded int `bencode:"downloaded"`
}

type ScrapeStats struct {
	Complete   int // Number of seeders
	Incomplete int // Number of leechers
	Downloaded int // Number of completed downloads (not accurately tracked)
}

type Storage struct {
	Config   *config.Config
	Requests map[common.InfoHash]map[common.PeerID]tracker.Request
	// contains filtered or unexported fields
}

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

type UDPAnnounceRequest struct {
	ConnectionID  uint64
	Action        uint32
	TransactionID uint32
	InfoHash      [20]byte
	PeerID        [20]byte
	Downloaded    uint64
	Left          uint64
	Uploaded      uint64
	Event         uint32
	IP            uint32
	Key           uint32
	NumWant       int32
	Port          uint16
}

type UDPAnnounceResponse struct {
	Action        uint32
	TransactionID uint32
	Interval      uint32
	Leechers      uint32
	Seeders       uint32
	Peers         []UDPPeer
}

type UDPConnectRequest struct {
	Magic         uint64
	Action        uint32
	TransactionID uint32
}

type UDPConnectResponse struct {
	Action        uint32
	TransactionID uint32
	ConnectionID  uint64
}

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

type UDPPeer struct {
	IP   [4]byte
	Port uint16
}

type UDPScrapeData struct {
	Seeders   uint32
	Completed uint32
	Leechers  uint32
}

type UDPScrapeRequest struct {
	ConnectionID  uint64
	Action        uint32
	TransactionID uint32
	InfoHashes    [][20]byte
}

type UDPScrapeResponse struct {
	Action        uint32
	TransactionID uint32
	ScrapeData    []UDPScrapeData
}