nntp

type ArticleProcessor interface {
	ProcessIncomingArticle(article *models.Article) (int, error)
	Lookup(msgIdItem *history.MessageIdItem) (int, error)
}

type ArticleRetrievalResult struct {
	Article    *models.Article
	Overview   *models.Overview
	ArticleNum int64
	MsgIdItem  *history.MessageIdItem
	GroupDBs   *database.GroupDBs
}

type ArticleRetrievalType int

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

type BackendConfig struct {
	Host           string        // hostname or IP address of the NNTP server
	Port           int           // port number for the NNTP server
	SSL            bool          // whether to use SSL/TLS
	Username       string        // username for authentication
	Password       string        // password for authentication
	ConnectTimeout time.Duration // timeout for establishing a connection
	//ReadTimeout    time.Duration    // timeout for reading from the connection
	//WriteTimeout   time.Duration    // timeout for writing to the connection
	MaxConns int              // maximum number of connections to this backend
	Provider *config.Provider // link to provider config
	Mux      sync.Mutex
}

type BackendConn struct {
	Backend *BackendConfig

	Pool *Pool // link to parent pool
	// contains filtered or unexported fields
}

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

type GroupInfo struct {
	Name      string
	Count     int64
	First     int64
	Last      int64
	PostingOK bool
}

type HeaderLine struct {
	ArticleNum int64
	Value      string
}

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

type NNTPServer struct {
	Config      *config.ServerConfig
	DB          *database.Database
	Listener    net.Listener
	TLSListener net.Listener
	AuthManager *AuthManager
	Stats       *ServerStats
	Processor   ArticleProcessor // For handling incoming articles (POST/IHAVE/TAKETHIS)
	// contains filtered or unexported fields
}

type OverviewLine struct {
	ArticleNum int64
	Subject    string
	From       string
	Date       string
	MessageID  string
	References string
	Bytes      int64
	Lines      int64
}

type PatternMatchResult struct {
	Matched     bool   // Whether any pattern matched
	Action      string // "send", "exclude", "reject"
	Pattern     string // The specific pattern that matched
	Explanation string // Human-readable explanation
}

type Peer struct {
	// Basic identification
	Enabled      bool   `json:"enabled" yaml:"enabled"`
	Hostname     string `json:"hostname" yaml:"hostname"`           // FQDN/RDNS for network connections (used as map key)
	PathHostname string `json:"path_hostname" yaml:"path_hostname"` // Hostname used in Path headers (can differ from network hostname)
	DisplayName  string `json:"display_name" yaml:"display_name"`   // Human-readable name
	Description  string `json:"description" yaml:"description"`     // Optional description

	// Network configuration
	Port        int    `json:"port" yaml:"port"`                 // Default: 119
	IPv4Address string `json:"ipv4_address" yaml:"ipv4_address"` // Static IPv4 for outgoing
	IPv6Address string `json:"ipv6_address" yaml:"ipv6_address"` // Static IPv6 for outgoing
	IPv4CIDR    string `json:"ipv4_cidr" yaml:"ipv4_cidr"`       // CIDR for incoming validation
	IPv6CIDR    string `json:"ipv6_cidr" yaml:"ipv6_cidr"`       // CIDR for incoming validation

	// Connection limits and performance
	MaxIncomingConns int   `json:"max_incoming_conns" yaml:"max_incoming_conns"` // Limit incoming from this peer
	MaxOutgoingConns int   `json:"max_outgoing_conns" yaml:"max_outgoing_conns"` // Limit outgoing to this peer
	SpeedLimitKBps   int64 `json:"speed_limit_kbps" yaml:"speed_limit_kbps"`     // Speed limit per connection

	// Authentication
	LocalUsername  string `json:"local_username" yaml:"local_username"`   // Username this peer must use to auth
	LocalPassword  string `json:"local_password" yaml:"local_password"`   // Password this peer must use to auth
	RemoteUsername string `json:"remote_username" yaml:"remote_username"` // Username we use when connecting
	RemotePassword string `json:"remote_password" yaml:"remote_password"` // Password we use when connecting

	// TLS/SSL configuration
	UseSSL      bool `json:"use_ssl" yaml:"use_ssl"`           // Connect using SSL/TLS
	SSLInsecure bool `json:"ssl_insecure" yaml:"ssl_insecure"` // Allow self-signed certs
	RequireSSL  bool `json:"require_ssl" yaml:"require_ssl"`   // Require SSL for incoming

	// Feed configuration (similar to INN2 newsfeeds patterns)
	SendPatterns    []string `json:"send_patterns" yaml:"send_patterns"`       // Newsgroup patterns to send
	AcceptPatterns  []string `json:"accept_patterns" yaml:"accept_patterns"`   // Newsgroup patterns to accept
	ExcludePatterns []string `json:"exclude_patterns" yaml:"exclude_patterns"` // !patterns - exclude specific groups from send
	RejectPatterns  []string `json:"reject_patterns" yaml:"reject_patterns"`   // @patterns - reject entire article if any group matches

	// Feed behavior
	ReadOnlyAccess bool   `json:"read_only_access" yaml:"read_only_access"` // Peer can only read, not post
	Streaming      bool   `json:"streaming" yaml:"streaming"`               // Use streaming mode (CHECK/TAKETHIS)
	MaxArticleSize int64  `json:"max_article_size" yaml:"max_article_size"` // Maximum article size
	FeedMode       string `json:"feed_mode" yaml:"feed_mode"`               // "realtime", "batch", "pull"

	// Statistics and monitoring
	ArticlesSent     int64     `json:"articles_sent" yaml:"-"`
	ArticlesReceived int64     `json:"articles_received" yaml:"-"`
	BytesSent        int64     `json:"bytes_sent" yaml:"-"`
	BytesReceived    int64     `json:"bytes_received" yaml:"-"`
	LastConnected    time.Time `json:"last_connected" yaml:"-"`
	LastError        string    `json:"last_error" yaml:"-"`
	ErrorCount       int64     `json:"error_count" yaml:"-"`

	// Internal state
	ActiveIncoming   int       `json:"-" yaml:"-"` // Current incoming connections
	ActiveOutgoing   int       `json:"-" yaml:"-"` // Current outgoing connections
	LastConfigReload time.Time `json:"-" yaml:"-"` // When config was last reloaded
}

type PeeringConfig struct {
	// Server identification
	Hostname string `json:"hostname" yaml:"hostname"`

	// Connection management
	AcceptAllGroups  bool          `json:"accept_all_groups" yaml:"accept_all_groups"`
	AcceptMaxGroups  int           `json:"accept_max_groups" yaml:"accept_max_groups"`
	ConnectionDelay  time.Duration `json:"connection_delay" yaml:"connection_delay"`
	ReloadInterval   time.Duration `json:"reload_interval" yaml:"reload_interval"`
	MaxOutgoingFeeds int           `json:"max_outgoing_feeds" yaml:"max_outgoing_feeds"`
	MaxIncomingFeeds int           `json:"max_incoming_feeds" yaml:"max_incoming_feeds"`

	// Authentication settings
	AuthRequired      bool `json:"auth_required" yaml:"auth_required"`
	MinPasswordLength int  `json:"min_password_length" yaml:"min_password_length"`
	ListRequiresAuth  bool `json:"list_requires_auth" yaml:"list_requires_auth"`

	// DNS and network settings
	DNSQueryLimit      int           `json:"dns_query_limit" yaml:"dns_query_limit"`
	DNSQueryTimeout    time.Duration `json:"dns_query_timeout" yaml:"dns_query_timeout"`
	ForceConnectionACL bool          `json:"force_connection_acl" yaml:"force_connection_acl"`
}

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

type PeeringStats struct {
	TotalPeers         int
	EnabledPeers       int
	ActiveConnections  int
	TotalArticlesSent  int64
	TotalArticlesRecvd int64
	TotalBytesSent     int64
	TotalBytesRecvd    int64
	LastReload         time.Time
}

type Pool struct {
	Backend *BackendConfig
	// contains filtered or unexported fields
}

type PoolStats struct {
	MaxConnections    int
	ActiveConnections int
	IdleConnections   int
	TotalCreated      int64
	TotalClosed       int64
	Closed            bool
}

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