Context is canceled when the service container is closing.

Create produces a new hot backup via "VACUUM INTO".

Close 释放 services 持有的任何资源（websocket hub, ffmpeg 转码, fsnotify, 后台轮询器）。

New 将每个 repository 连接到单个 *gorm.DB。

Get returns the public view for a single provider, or nil.

FindByID returns a single site or nil.

NewHub builds a Hub. Caller must invoke Run in its own goroutine.

Set upserts a setting value.

List returns the entries under dirID. An empty dirID means the root.

Get 返回指定通知渠道详情。

Find returns the device row for (user, device), or (nil, nil) when absent.

SetDefault sets a specific client as default and clears others.

Count returns the total number of non-deleted users.

Create 创建新的通知渠道。

NewOrganizerService is the constructor.

Status resolves live database-backed AI config for the UI.

NewDownloadService is the constructor.

executeCommand parses and dispatches Telegram commands through a registry so adding a command does not grow a monolithic switch.

OrganizeDirectory organizes every video file found under opts.SourcePath into the destination root, applying dedup + 洗版 (resolution replacement).

Upsert 创建或更新 API 配置，自动加密敏感字段。

ScanLibrary walks the library root and persists discovered media files.

NewScannerService is the constructor.

Delete removes a single backup file.

AdminRequired must run AFTER AuthRequired; it enforces role == "admin".

NewSTRMService 创建 STRM 服务。

sanitizeFilename removes characters not safe for filesystem names.

NewScraperService is the constructor.

Remove 移除指定下载任务，deleteFiles 控制是否同时删除文件。

Run is the blocking event loop. Publish events with Hub.Publish.

toString converts a gin context value to a string, returning an empty string when the value is missing or of the wrong type.

NewCryptoService derives a 256-bit key from the given secret via SHA-256 and constructs an AES-GCM AEAD. Empty secrets yield a service whose Encrypt/D

NewSubscriptionService is the constructor.

NewTMDbProvider is the constructor. APIBase / image CDN can be overridden via secrets.tmdb_api_proxy + tmdb_image_proxy for users behind GFW. apiConfi

registerEmbyRoutes 在 r 上挂双前缀（"" + "/emby"）的 Emby 兼容路由。

NewMediaService is the constructor.

Register creates a new user. The first registered user is auto-promoted to admin to support fresh installs that did not run SeedAdmin.

NewImageProxy is the constructor.

Items paginates media in Emby's hierarchy. Episodic libraries are exposed as Series -> Season -> Episode so Infuse/Vidhub/SenPlayer stop treating ever

Enabled reports whether the AI integration is configured.

Update 更新 STRM 记录。

Publish sends an event to every interested subscriber. Non-blocking: the event is dropped if the hub is full to avoid stalling the producer.

CleanQuery converts a filename like "Inception.2010.1080p.BluRay.x264.mkv" into a TMDb-friendly title plus an optional year hint.

Error 返回错误响应。

NewEmbyService is the constructor.

ParseEpisode tries to extract (season, episode) from an arbitrary filename. Returns (0, 0) when nothing recognisable is found.

strr is a tiny helper to avoid importing fmt.Sprint just to coerce interface{} → string. (Named "strr" so it doesn't collide with the notify channel's

SetScraper wires the scraper so directory organize can resolve TMDb/Bangumi metadata before it decides the final folder and filename.

New constructs a provider of the given type from a free-form config map (as persisted by StorageConfigService). The client is shared so callers can in

NewStorageConfigService is the constructor.

Save persists the user permission patch (admin only — caller checks).

SetStorageConfig wires cloud-disk storage access into the scanner. It is set after service construction because StorageConfigService depends on Crypto

Save inserts or updates the config row.

AllModels returns the slice consumed by gorm.AutoMigrate.

str coerces a config value to a trimmed string.