engine

type BatchEngine struct {
	Workers   int
	Timeout   time.Duration
	Providers []abuse.Provider
	Abuse     bool
	Checker   CheckFunc
	SortBy    string
	Filter    string
	Progress  ProgressFunc
}

type BatchItem struct {
	Endpoint     endpoint.Endpoint `json:"endpoint"`
	Reachable    bool              `json:"reachable"`
	LatencyMs    int64             `json:"latency_ms"`
	AbuseScore   int               `json:"abuse_score"`
	Purity       string            `json:"purity"`
	ProviderErrs []string          `json:"provider_errors,omitempty"`
}

type BatchResult struct {
	Items   []BatchItem  `json:"items"`
	Summary BatchSummary `json:"summary"`
}

type BatchSummary struct {
	Total       int   `json:"total"`
	Processed   int   `json:"processed"`
	Reachable   int   `json:"reachable"`
	Unreachable int   `json:"unreachable"`
	Abusive     int   `json:"abusive"`
	Suspicious  int   `json:"suspicious"`
	Clean       int   `json:"clean"`
	AvgLatency  int64 `json:"avg_latency_ms"`
	Errors      int   `json:"errors"`
}

type CheckFunc func(context.Context, endpoint.Endpoint, checker.Options) checker.CheckResult

type CollisionSource struct {
	File string `json:"file"`
	Line int    `json:"line"`
}

type DedupeResult struct {
	Unique      []endpoint.Endpoint          `json:"unique"`
	Collisions  map[string][]CollisionSource `json:"collisions,omitempty"`
	UniqueCount int                          `json:"unique_count"`
	TotalCount  int                          `json:"total_count"`
}

type ProgressFunc func(processed, total int)

type SourceEndpoint struct {
	Endpoint endpoint.Endpoint
	Source   CollisionSource
}