MCPcopy Create free account

hub / github.com/ShukeBta/MediaStationGo / functions

Functions5,617 in github.com/ShukeBta/MediaStationGo

⨍ Functions 5,617◇ Types & classes 739
↓ 21 callersMethodFindByUsername
FindByUsername returns the user matching username, or (nil, nil) when absent.
internal/repository/user_repository.go:45
↓ 21 callersMethodStop
Stop terminates the hub goroutine and disconnects every subscriber.
internal/service/ws_hub.go:59
↓ 21 callersFunctionimageURL
(remote?: string, version?: string, options: ImageURLOptions = false)
web/src/api/client.ts:161
↓ 21 callersFunctionnormalizeCloudDAVPath
(p string)
internal/service/cloud/clouddrive2.go:211
↓ 21 callersFunctiontelegramFirstValue
(data map[string]interface{}, keys ...string)
internal/service/notify_telegram_fields.go:9
↓ 20 callersMethodCreate
Create inserts a new STRM record.
internal/repository/strm_repo.go:17
↓ 20 callersFunctionNewSessionTrackerService
(log *zap.Logger)
internal/service/session_tracker.go:75
↓ 20 callersFunctionclose
(value: string | null)
web/src/components/requestPIN.tsx:10
↓ 19 callersFunctionReadLocalMetadata
ReadLocalMetadata reads sidecar NFO files for a media path. For TV/anime it merges show-level tvshow.nfo with episode-level sidecar metadata.
internal/service/local_metadata_read.go:13
↓ 19 callersFunctionconfigureTestDefaultQB
(t *testing.T, repos *repository.Container, baseURL string)
internal/service/download_add_test.go:23
↓ 19 callersFunctionembyUserID
embyUserID 从中间件中获取 user id。Emby auth middleware 写入 CtxUserID。
internal/handler/emby_auth.go:20
↓ 19 callersFunctionloadBotConfig
loadBotConfig reads the device-management configuration from settings, falling back to safe defaults for any missing/invalid key.
internal/service/bot_settings.go:93
↓ 18 callersMethodResolve
Resolve turns a provider-native file reference (id or pickcode) into a short-lived direct download link suitable for 302 playback.
internal/service/cloud/cloud.go:70
↓ 18 callersFunctiondoRequest
doRequest 执行 HTTP 请求并返回响应体。 当 cfg.FlareSolverrURL 已配置且方法为 GET 时，通过 FlareSolverr 代理请求 以绕过 Cloudflare/WAF 挑战验证。
internal/service/site_adapter.go:166
↓ 18 callersFunctionmustAtoi
(s string)
internal/service/episode_parser.go:197
↓ 18 callersFunctionsetIfChanged
(updates map[string]any, key string, current, next T)
internal/repository/media_repository_upsert.go:258
↓ 17 callersFunctionFilterDisplayCloudLibraries
(ctx context.Context, repo *repository.Container, libs []model.Library)
internal/service/cloud_mount_filter.go:10
↓ 17 callersFunctionmatchesSubscriptionRules
(sub *model.Subscription, title string)
internal/service/subscription_rules.go:9
↓ 17 callersFunctionrefresh
()
web/src/pages/StorageForm.tsx:33
↓ 16 callersMethodDecrypt
Decrypt returns the plaintext for an encrypted value. Plaintext rows (no prefix) are returned unchanged.
internal/service/crypto.go:79
↓ 16 callersMethodDelete
Delete 删除通知渠道。
internal/handler/notify_handler.go:161
↓ 16 callersMethodListRoots
(ctx context.Context, libraryID string)
internal/repository/library_repository.go:88
↓ 16 callersFunctionNewSchedulerService
NewSchedulerService is the constructor.
internal/service/scheduler.go:84
↓ 16 callersFunctioncontainsItemType
(types []string, want string)
internal/service/emby_items_helpers.go:5
↓ 16 callersFunctionnewStorageUploadTestService
(t *testing.T)
internal/service/storage_upload_test.go:227
↓ 16 callersFunctiontoInt64
toInt64 安全地将 interface{} 转为 int64。
internal/service/transmission_parse.go:33
↓ 15 callersFunctionNewDeviceService
NewDeviceService constructs a DeviceService.
internal/service/device_service.go:40
↓ 15 callersFunctionNewStreamService
NewStreamService is the constructor.
internal/service/stream_service.go:39
↓ 15 callersMethodReloadConfig
ReloadConfig rebuilds the qBittorrent client from the configured download clients (preferred) or the legacy Setting table (fallback). 配置来源优先级： 1. do
internal/service/downloads_config_runtime.go:28
↓ 15 callersMethodSearchMediaVisible
(ctx context.Context, query string, limit int, visibility MediaVisibility)
internal/service/media_search.go:15
↓ 15 callersFunctioncountMedia
(t *testing.T, repos *repository.Container)
internal/service/scanner_incremental_test.go:26
↓ 15 callersFunctionfingerprint
fingerprint derives a stable terminal hash from the device name. Client/app names are deliberately ignored so one phone/TV/PC using multiple apps is s
internal/service/device_service.go:56
↓ 15 callersFunctionnewDownloadClientHTTPRequest
(ctx context.Context, method, endpoint string, body io.Reader)
internal/service/download_client_endpoint.go:109
↓ 15 callersFunctionnormalizeCloudMountDir
(provider, value string)
internal/service/cloud_mount_label.go:122
↓ 15 callersMethodprocessDownloadSnapshot
(ctx context.Context, live []QBitTorrent, taskByKey map[string]model.DownloadTask)
internal/service/download_polling.go:44
↓ 15 callersFunctionwithSQLiteBusyRetry
(ctx context.Context, op func() error)
internal/repository/sqlite_busy_retry.go:11
↓ 14 callersMethodEncrypt
Encrypt returns the base64-encoded ciphertext (with prefix) for plain. Empty inputs round-trip unchanged.
internal/service/crypto.go:62
↓ 14 callersMethodListByUser
ListByUser returns the profiles owned by the user.
internal/service/play_profile.go:60
↓ 14 callersMethodListMediaVisible
(ctx context.Context, libraryID string, page, pageSize int, visibility MediaVisibility)
internal/service/media_listing.go:18
↓ 14 callersMethodRecordActivity
(ctx context.Context, userID, userName, deviceID, deviceName, client, remoteEndPoint string)
internal/service/session_tracker.go:88
↓ 14 callersMethodRename
(ctx context.Context, ref, name string)
internal/service/cloud/cloud.go:78
↓ 14 callersMethodSearch
Search 搜索种子。
internal/service/site_adapter.go:88
↓ 14 callersMethodServeCloudCached
ServeCloudCached serves an already-local cloud sidecar image without asking the cloud provider for a fresh direct link. It returns true when it wrote
internal/service/image_proxy_cloud.go:39
↓ 14 callersMethodUpsert
Upsert atomically inserts/updates the resume position.
internal/repository/history_repository.go:17
↓ 14 callersFunctionappendUniqueLibraryIDs
(ids []string, values ...string)
internal/service/cloud_mount_scope.go:134
↓ 14 callersFunctionassertFileContains
(t *testing.T, path, want string)
internal/service/strm_svc_test.go:490
↓ 14 callersFunctionenvOrDefault
(key, fallback string)
internal/service/media_path_normalize.go:46
↓ 14 callersFunctionfinishHTTPTask
(task *service.TaskHandle, err error, stage, message string, metrics map[string]int64, details []string)
internal/handler/task_helpers.go:5
↓ 14 callersFunctionpathBaseSlash
(value string)
internal/service/cloud_metadata_merge.go:140
↓ 14 callersFunctionsanitizeTelegramError
(err error)
internal/service/telegram_api_client.go:111
↓ 13 callersFunctionAutoMigrate
AutoMigrate creates tables for every model registered in the model package.
internal/database/schema_migration.go:10
↓ 13 callersMethodCreateWithRoots
(ctx context.Context, l *model.Library, roots []model.LibraryRoot)
internal/repository/library_repository.go:21
↓ 13 callersMethodGetJSON
(ctx context.Context, key string, out any)
internal/service/runtime_cache.go:79
↓ 13 callersMethodLogin
Login validates credentials and returns the user + a fresh JWT token pair.
internal/service/auth.go:141
↓ 13 callersFunctionNewExternalHTTPClient
NewExternalHTTPClient builds an HTTP client for third-party APIs. It uses environment proxies first, then the local OS proxy configuration.
internal/service/proxy.go:22
↓ 13 callersFunctionNewTelegramBotService
NewTelegramBotService 创建 Telegram Bot 服务。
internal/service/telegram_bot.go:126
↓ 13 callersMethodSetImageProxy
SetImageProxy lets cloud scans warm sidecar poster/backdrop files into the local image cache. This keeps library opening fast without forcing the UI o
internal/service/scanner.go:148
↓ 13 callersFunctioncleanPathForVolumeMapping
(path string)
internal/service/media_path_normalize.go:9
↓ 13 callersFunctionhasAny
(values map[string]struct{}, needles ...string)
internal/service/media_classifier_helpers.go:20
↓ 13 callersFunctionnewScannerTestEnv
(t *testing.T)
internal/service/scanner_incremental_test.go:18
↓ 13 callersFunctionorganizeMetadataMatchTrusted
(query string, sourceYear int, match *Match)
internal/service/organizer_metadata_match.go:12
↓ 13 callersMethodpendingDownloadAvailability
(ctx context.Context, sub *model.Subscription)
internal/service/subscription_availability.go:11
↓ 13 callersFunctionselectSiteSearchCandidatesWithStats
(results []SearchResult, sub *model.Subscription, seenSet map[string]struct{}, local LocalAvailability)
internal/service/subscription_planner.go:65
↓ 13 callersFunctiontransferFile
transferFile 按指定方式把 src 转移到 dst。 dst 已存在时一律报错，绝不覆盖（防止不同 release 改名后互相覆盖）。
internal/service/transfer.go:59
↓ 12 callersFunctionCloudLibraryMergeKey
(lib model.Library)
internal/service/cloud_mount_merge.go:26
↓ 12 callersMethodGenerateForLibrary
(ctx context.Context, opts GenerateSTRMOptions)
internal/service/strm_generate.go:56
↓ 12 callersFunctionNewTokenService
NewTokenService 创建令牌服务实例。
internal/service/token_svc.go:54
↓ 12 callersMethodRecordLogin
RecordLogin records (or refreshes) a login channel at authentication time and runs the terminal-device + fingerprint anti-share checks. It is safe to
internal/service/device_service.go:74
↓ 12 callersMethodServe
Serve writes the requested image to w. Caller is expected to validate the JWT before invoking it.
internal/service/image_proxy_remote.go:57
↓ 12 callersMethodSetJSON
(ctx context.Context, key string, value any, ttl time.Duration)
internal/service/runtime_cache.go:100
↓ 12 callersMethodUpdate
Update 更新通知渠道。
internal/handler/notify_handler.go:110
↓ 12 callersMethodUpdateFields
UpdateFields applies a narrow set of user field updates.
internal/repository/user_repository.go:117
↓ 12 callersMethodboundUser
boundUser resolves the local user bound to a Telegram account, or nil.
internal/service/telegram_menu.go:36
↓ 12 callersFunctionepisodeRefsFromTitle
(path string)
internal/service/episode_parser.go:98
↓ 12 callersFunctionnewOpenListAPIServer
(t *testing.T, list func(path string, page, perPage int) ([]openListTestEntry, int))
internal/service/scanner_cloud_test_helpers_test.go:16
↓ 12 callersFunctionnewPlaybackScopeTestRouter
(t *testing.T)
internal/handler/playback_extra_test.go:389
↓ 12 callersFunctionnormalizeAvailabilityComparable
(value string)
internal/service/subscription_availability_scan.go:85
↓ 12 callersFunctionsameLibraryPath
(a, b string)
internal/service/media_path_normalize.go:42
↓ 12 callersFunctionsetNonEmptyUpdate
(updates map[string]any, key, value string)
internal/service/organizer_media_metadata.go:114
↓ 12 callersFunctionsplitNFOList
(value string)
internal/service/nfo.go:180
↓ 12 callersFunctionsubscriptionRequestUserID
(c *gin.Context)
internal/handler/subscription_logging.go:14
↓ 12 callersFunctiontasksByTorrentIdentity
(rows []model.DownloadTask)
internal/service/download_completion_state.go:194
↓ 11 callersFunctionApplyRuntimeSetting
(cfg *config.Config, key, value string)
internal/service/runtime_settings.go:30
↓ 11 callersFunctionIsAdminCloudConfigurable
(typ string)
internal/service/storage_types.go:20
↓ 11 callersFunctionLibraryVisibleForUser
LibraryVisibleForUser applies profile library limits and adult-directory hiding to a library card/folder.
internal/service/visibility.go:92
↓ 11 callersMethodList
(ctx context.Context)
internal/service/session_tracker.go:151
↓ 11 callersFunctionNewAuthService
NewAuthService is the constructor.
internal/service/auth.go:30
↓ 11 callersMethodReclassifyMisclassifiedMedia
ReclassifyMisclassifiedMedia corrects already-scanned local media whose stored metadata clearly disagrees with the current library/category.
internal/service/organizer_reclassify_scanned.go:26
↓ 11 callersFunctionSuccess
Success 返回成功响应。
internal/handler/response.go:45
↓ 11 callersMethodUpdate
Update updates a STRM record.
internal/repository/strm_repo.go:68
↓ 11 callersFunctiondownloadTaskIdentityKey
(name string)
internal/service/download_identity.go:63
↓ 11 callersFunctionisSubscriptionSeriesType
(mediaType string)
internal/service/subscription_rules.go:76
↓ 11 callersFunctionmediaIsEpisodic
(m *model.Media, lib *model.Library)
internal/service/scraper_query.go:108
↓ 11 callersFunctionnormalizeRemotePath
(p string)
internal/service/storage_upload.go:258
↓ 11 callersFunctionsubscriptionSiteSearchLogFields
(sub *model.Subscription, keyword string)
internal/service/subscription_site_search_helpers.go:13
↓ 11 callersFunctionupdate
(patch: Partial<PlayProfileInput>)
web/src/pages/ProfileFormModal.tsx:44
↓ 10 callersMethodAllows
(media *model.Media)
internal/service/media.go:29
↓ 10 callersFunctionCleanQueryWithRecognition
(ctx context.Context, repo *repository.Container, raw string)
internal/service/recognition_words.go:131
↓ 10 callersMethodCloudResolve
(ctx context.Context, typ, fileRef, clientUA string)
internal/service/emby_compat.go:67
↓ 10 callersMethodEnrichLibraryDetailedWithOptions
(ctx context.Context, libraryID string, options ScrapeOptions)
internal/service/scraper_library.go:92
← previousnext →101–200 of 5,617, ranked by callers