internal

type DiskBudget ¶ added in v0.18.0

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

DiskBudget 跟踪已预留但尚未落盘的磁盘空间。

多个并发 RSS worker 推送前先 Reserve，防止它们同时观察到相同的 OS 空闲空间 而并发越界（Issue #299 根因之一）。Reserve/Release 使用原子计数 + 修正循环 保证不会下溢到负数。

典型用法:

budget := internal.GetDiskBudget()
if budget.EffectiveFreeGB(rawFreeBytes)-torrentSizeGB < threshold {
    return ErrInsufficientSpace
}
budget.Reserve(torrentSize)
if pushErr != nil {
    budget.Release(torrentSize) // 推送失败时归还配额
}
// 推送成功的预留由 cleanup_monitor 周期 Reset，或上层在 qBit 已可见后调
// Release（避免与 GetIncompletePendingBytes 双重计数）。

func GetDiskBudget() *DiskBudget

func (b *DiskBudget) EffectiveFreeBytes(actualFreeBytes int64) int64

func (b *DiskBudget) EffectiveFreeGB(actualFreeBytes int64) float64

func (b *DiskBudget) Release(bytes int64)

func (b *DiskBudget) Reserve(bytes int64) int64

func (b *DiskBudget) Reserved() int64

func (b *DiskBudget) Reset()

type DownloaderInfo ¶ added in v0.3.0

type DownloaderInfo struct {
	ID        uint
	Name      string
	AutoStart bool
	NeedClose bool
}

GetDownloaderForRSS 根据 RSS 配置获取下载器 DownloaderInfo 下载器附加信息，用于记录推送来源

func GetDownloaderForRSSWithInfo(rssCfg models.RSSConfig) (downloader.Downloader, *DownloaderInfo, error)

type PTSiteInter ¶

type PTSiteInter[T models.ResType] interface {
	GetTorrentDetails(item *gofeed.Item) (*models.APIResponse[T], error)
	IsEnabled() bool
	DownloadTorrent(url, title, downloadDir string) (string, error)
	MaxRetries() int
	RetryDelay() time.Duration
	SendTorrentToDownloader(ctx context.Context, rssCfg models.RSSConfig) error
	Context() context.Context
}

PTSiteInter 旧的泛型接口（已废弃，请使用 UnifiedPTSite） Deprecated: Use UnifiedPTSite instead for new implementations

type PushTorrentRequest ¶ added in v0.2.0

type PushTorrentRequest struct {
	SiteID       string // 站点ID (如 hdsky, mteam)
	TorrentID    string // 种子ID
	TorrentData  []byte // 种子文件数据
	Title        string // 种子标题
	Category     string // 分类
	Tags         string // 标签
	SavePath     string // 保存路径（可选）
	DownloaderID uint   // 下载器ID
}

PushTorrentRequest 推送种子请求参数

type PushTorrentResult ¶ added in v0.2.0

type PushTorrentResult struct {
	Success     bool
	Skipped     bool // 是否跳过（如已存在）
	TorrentHash string
	Message     string
}

PushTorrentResult 推送种子结果

func PushTorrentToDownloader(ctx context.Context, req PushTorrentRequest) (*PushTorrentResult, error)

type RSSFilteredNotice ¶ added in v0.31.0

type RSSFilteredNotice struct {
	RSS       *models.RSSConfig
	Torrent   *v2.TorrentItem
	Rule      *models.FilterRule
	SiteName  string
	TorrentID string
}

RSSFilteredNotice is the payload for the 'filtered' RSS notification path. Mirror of app.RSSFilteredEvent but defined here to avoid the internal → internal/app import cycle. Bridged by rssNotifierAdapter in cmd/web.go.

type RSSItemNotice ¶ added in v0.31.0

type RSSItemNotice struct {
	RSS       *models.RSSConfig
	FeedItem  *gofeed.Item
	SiteName  string
	TorrentID string
}

RSSItemNotice is the minimal payload the RSS pipeline needs to fire an "all" notification — purposely dependency-light so internal does not import internal/app (which would create a cycle via scheduler).

type RSSNotifier ¶ added in v0.31.0

type RSSNotifier interface {
	NotifyNewItem(ctx context.Context, ev RSSItemNotice) error
	NotifyFilteredItem(ctx context.Context, ev RSSFilteredNotice) error
}

RSSNotifier is the structural contract internal/app/rssNotifier satisfies. The concrete adapter lives in cmd/web.go and bridges this minimal type to app.RSSItemEvent before delegating to the real app.RSSNotifier.

type TorrentDetailForTest ¶ added in v0.2.0

type TorrentDetailForTest struct {
	Title  string // 种子标题（优先使用中文名）
	Tag    string // 种子标签/副标题
	IsFree bool   // 是否免费
}

TorrentDetailForTest 用于测试的种子详情

func GetTorrentDetailForTest(ctx context.Context, siteName models.SiteGroup, item *gofeed.Item) (*TorrentDetailForTest, error)

type TorrentScheduleFunc ¶ added in v0.3.0

type TorrentScheduleFunc func(torrent models.TorrentInfo)

type UnifiedPTSite ¶ added in v0.2.0

type UnifiedPTSite interface {
	// GetTorrentDetails 获取种子详情，返回统一的 TorrentItem
	GetTorrentDetails(item *gofeed.Item) (*v2.TorrentItem, error)
	// IsEnabled 检查站点是否启用
	IsEnabled() bool
	// DownloadTorrent 下载种子文件，返回 torrent hash
	DownloadTorrent(url, title, downloadDir string) (string, error)
	// MaxRetries 返回最大重试次数
	MaxRetries() int
	// RetryDelay 返回重试间隔
	RetryDelay() time.Duration
	// SendTorrentToDownloader 发送种子到下载器
	SendTorrentToDownloader(ctx context.Context, rssCfg models.RSSConfig) error
	// Context 返回上下文
	Context() context.Context
	// SiteGroup 返回站点分组标识
	SiteGroup() models.SiteGroup
}

UnifiedPTSite 统一的 PT 站点接口（非泛型） 新增站点应使用此接口，无需创建新的实现类

type UnifiedSiteImpl ¶ added in v0.2.0

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

UnifiedSiteImpl 统一站点实现 使用 site/v2 的 Driver 模式，无需为每个站点创建单独的实现

func NewUnifiedSiteImpl(ctx context.Context, siteGroup models.SiteGroup) (*UnifiedSiteImpl, error)

func (u *UnifiedSiteImpl) Context() context.Context

func (u *UnifiedSiteImpl) DownloadTorrent(url, title, downloadDir string) (string, error)

func (u *UnifiedSiteImpl) GetTorrentDetails(item *gofeed.Item) (*v2.TorrentItem, error)

func (u *UnifiedSiteImpl) IsEnabled() bool

func (u *UnifiedSiteImpl) MaxRetries() int

func (u *UnifiedSiteImpl) RetryDelay() time.Duration

func (u *UnifiedSiteImpl) SendTorrentToDownloader(ctx context.Context, rssCfg models.RSSConfig) error

func (u *UnifiedSiteImpl) SiteGroup() models.SiteGroup