MCPcopy Create free account

hub / github.com/Desiders/ytdl_tg_bot / functions

Functions727 in github.com/Desiders/ytdl_tg_bot

⨍ Functions 727◇ Types & classes 375
↓ 2 callersMethodchat_config_reader
(&self)
bot/src/database/tx_manager.rs:52
↓ 2 callersFunctionclassify_retryable_error
(stderr: &str)
downloader/src/services/ytdl.rs:102
↓ 2 callersMethodcookie_count
(&self, worker_id: &str)
cookie_assignment/src/service.rs:352
↓ 2 callersFunctioncreate_gallery_dl_command
(gallery_dl_cfg: &GalleryDlConfig)
downloader/src/services/gallery_dl.rs:363
↓ 2 callersFunctiondefault_extractor_args
()
downloader/src/config.rs:53
↓ 2 callersMethoddomain_count
(&self, worker_id: &str)
cookie_assignment/src/service.rs:356
↓ 2 callersFunctiondone_key
(job_id: Uuid)
bot/src/services/queue.rs:206
↓ 2 callersMethoddownload
(&self, file_id: &str)
bot/src/services/file_download.rs:42
↓ 2 callersFunctiondownload_and_convert
(url: &str, output_file_path: &Path, executable_path: &str, timeout: u64)
downloader/src/services/ffmpeg.rs:86
↓ 2 callersMethodexecute
(self, input: DownloadInput<'_>)
bot/src/interactors/video.rs:93
↓ 2 callersMethodexecute
(self, input: ShazamInput<'_>)
bot/src/interactors/shazam.rs:79
↓ 2 callersMethodfetch_status
Fetches the node active-download and capacity counters. # Errors Returns an error if auth metadata cannot be built or the RPC fails.
downloader_client/src/handle.rs:104
↓ 2 callersMethodfetch_supported_domains
Fetches domains for which the node currently has assigned cookies. # Errors Returns an error if auth metadata cannot be built or the RPC fails.
downloader_client/src/handle.rs:93
↓ 2 callersMethodfrom
(raw: &str)
bot/src/locale.rs:40
↓ 2 callersFunctionget_host_from_text
(text: &str)
bot/src/filters/text_url.rs:22
↓ 2 callersMethodget_path_by_optional_host
(&self, host: Option<&Host<&str>>)
downloader/src/entities/cookies.rs:76
↓ 2 callersMethodget_random
( &self, limit: u64, media_type: MediaType, domains: &[String], )
bot/src/database/readers/downloaded_media.rs:79
↓ 2 callersMethodget_stats
(&self)
bot/src/database/readers/chat.rs:26
↓ 2 callersMethodinsert_or_update
( &self, Chat { tg_id, username, kind, created
bot/src/database/repos/chat.rs:23
↓ 2 callersFunctionis_errors_in_chosen_inline
( messenger: &(impl MessengerPort + ?Sized), inline_message_id: &str, format_errs: &[String],
bot/src/handlers_utils/progress.rs:236
↓ 2 callersMethodmark_unavailable
(&self)
downloader_client/src/handle.rs:84
↓ 2 callersMethodnormalize
(&mut self)
downloader/src/entities/range.rs:28
↓ 2 callersFunctionnormalize_domain
(domain: &str)
downloader/src/entities/cookies.rs:98
↓ 2 callersFunctionparse_entry
(entry_id: String, map: &std::collections::HashMap<String, Value>)
bot/src/services/queue.rs:210
↓ 2 callersFunctionparse_format_strategy
(media_type: &str, audio_ext: &str)
downloader/src/grpc/downloader.rs:1122
↓ 2 callersFunctionparse_url
(raw: &str)
downloader/src/grpc/downloader.rs:1133
↓ 2 callersFunctionprobe_audio
( get_audio: &get_media::GetAudioByURL, url: &Url, range: &Range, sections: Option<&Sections>,
bot/src/interactors/auto.rs:475
↓ 2 callersFunctionprobe_video
(file_path: &Path, executable_path: &str, timeout: u64)
downloader/src/services/ffmpeg.rs:44
↓ 2 callersFunctionprobe_video
( get_video: &get_media::GetVideoByURL, url: &Url, range: &Range, sections: Option<&Sections>,
bot/src/interactors/auto.rs:448
↓ 2 callersMethodrefresh_capabilities
(&self)
downloader_client/src/router.rs:97
↓ 2 callersMethodrefresh_nodes
(&self)
downloader_client/src/router.rs:119
↓ 2 callersMethodrefresh_status
(&self)
downloader_client/src/router.rs:71
↓ 2 callersFunctionreject_active_livestreams
(playlist: &Playlist)
downloader/src/grpc/downloader.rs:959
↓ 2 callersMethodremove_cookie
(&self, cookie_id: &str)
downloader/src/entities/cookies.rs:57
↓ 2 callersMethodreply
(&self, chat_id: i64, reply_to_message_id: i64, text: &str)
bot/src/interactors/shazam.rs:241
↓ 2 callersMethodresolve
Resolves `raw_url` to a DRM-free downloadable source via `spotdl url`.
downloader/src/services/spotdl.rs:53
↓ 2 callersFunctionresolve_max_file_size
(request_max_file_size: u64, node_max_file_size: u64)
downloader/src/grpc/downloader.rs:1137
↓ 2 callersMethodresolve_nodes
Resolves the headless downloader service DNS into active node socket addresses. # Errors Returns an I/O error if DNS resolution fails.
downloader_client/src/client.rs:46
↓ 2 callersFunctionsend_media_group
( bot: &Bot, chat_id: &ChatIdKind, media_group: Vec<InputMedia>, reply_to_message_id: Option<i
bot/src/services/messenger/telegram.rs:672
↓ 2 callersFunctionsend_status
(tx: &UnboundedSender<Result<DownloadChunk, Status>>, status: Status)
downloader/src/grpc/downloader.rs:1288
↓ 2 callersFunctionshorten_response_body
(body: &str)
bot/src/services/yt_toolkit.rs:9
↓ 2 callersFunctionsynthesize_direct
Builds a `direct_fetch`-marked entry from a snapsave CDN URL so the download path fetches it with ffmpeg (remux for video, audio extract for m4a) inst
downloader/src/grpc/downloader.rs:969
↓ 2 callersMethodupdate_remote_status
(&self, active_downloads: u32, max_concurrent: u32)
downloader_client/src/handle.rs:73
↓ 2 callersMethodusername
(&self)
bot/src/services/messenger/telegram.rs:58
↓ 2 callersMethodxadd
(&self, key: &str, job: &DownloadJob)
bot/src/services/queue.rs:78
↓ 1 callersMethodanswer_inline_error
(&self, request: AnswerInlineErrorRequest<'_>)
bot/src/services/messenger/telegram.rs:110
↓ 1 callersMethodassign_free_cookies
( &mut self, cookies: &[CookieRecord], available_workers: &HashMap<String, AssignmentN
cookie_assignment/src/service.rs:154
↓ 1 callersMethodauthority
(&self)
downloader_client/src/client.rs:37
↓ 1 callersFunctionbuild_downloaded_media
( session: DownloadSession, output_dir: &Path, base_format: &MediaFormat, progress_sender: Opt
bot/src/services/download/media.rs:681
↓ 1 callersMethodbuild_handle
Builds a cookie-assignment RPC handle for one downloader node address. # Errors Returns a transport error if the gRPC channel cannot be built.
downloader_client/src/cookie_assignment.rs:34
↓ 1 callersMethodbuild_worker_assignments
(&self, cookie_domains: &HashMap<&'a str, &'a str>)
cookie_assignment/src/service.rs:288
↓ 1 callersMethodcfg
(&self)
bot/src/services/queue.rs:201
↓ 1 callersFunctioncfg_registry
(cfg: Config)
bot/src/di_container.rs:34
↓ 1 callersMethodchat_reader
(&self)
bot/src/database/tx_manager.rs:48
↓ 1 callersMethodchat_repo
(&self)
bot/src/database/tx_manager.rs:73
↓ 1 callersMethodclassify
( &self, url: &Url, range: &Range, sections: Option<&Sections>, audio_
bot/src/interactors/auto.rs:577
↓ 1 callersMethodclear_on_startup
(&self)
downloader/src/entities/cookies.rs:29
↓ 1 callersFunctionclear_reaction
Removes the acknowledgment reaction the middleware set on the user's message. The middleware sets it on receipt; the worker clears it here once the jo
bot/src/worker.rs:279
↓ 1 callersFunctioncookie_file_name
(domain: &str)
downloader/src/entities/cookies.rs:102
↓ 1 callersFunctiondatabase_registry
(cfg_registry: Registry)
bot/src/di_container.rs:88
↓ 1 callersMethoddead_letter
Moves a job to the dead-letter stream and acks the original.
bot/src/services/queue.rs:151
↓ 1 callersFunctiondecode_cookie_entry_name
(encoded_cookie_name: &str)
cookie_assignment/src/cookies.rs:49
↓ 1 callersFunctiondefault_job_timeout
()
bot/src/config.rs:30
↓ 1 callersFunctiondefault_max_audio_size
()
downloader/src/config.rs:146
↓ 1 callersFunctiondefault_queue_block_ms
()
bot/src/config.rs:238
↓ 1 callersFunctiondefault_queue_claim_min_idle_ms
()
bot/src/config.rs:242
↓ 1 callersFunctiondefault_queue_dead_letter_key
()
bot/src/config.rs:230
↓ 1 callersFunctiondefault_queue_dedup_ttl_secs
()
bot/src/config.rs:246
↓ 1 callersFunctiondefault_queue_group
()
bot/src/config.rs:226
↓ 1 callersFunctiondefault_queue_max_attempts
()
bot/src/config.rs:234
↓ 1 callersFunctiondefault_queue_stream_key
()
bot/src/config.rs:222
↓ 1 callersFunctiondefault_queue_workers
()
bot/src/config.rs:218
↓ 1 callersMethoddelete_exclude_domain
( &self, ChatConfigExcludeDomain { tg_id, domain }: ChatConfigExcludeDomain, )
bot/src/database/repos/chat_config.rs:108
↓ 1 callersMethoddelete_message
(&self, request: DeleteMessageRequest)
bot/src/services/messenger/telegram.rs:105
↓ 1 callersMethoddownload_media
(&self, request: Request<DownloadRequest>)
downloader/src/grpc/downloader.rs:230
↓ 1 callersMethoddownload_song
Best-effort: searches YouTube for the recognized track and enqueues a normal audio download so the song is sent (with the usual download progress). Si
bot/src/interactors/shazam.rs:170
↓ 1 callersMethoddownloaded_media_repo
(&self)
bot/src/database/tx_manager.rs:81
↓ 1 callersMethodedit_audio_by_id
(&self, request: EditMediaByIdRequest<'_>)
bot/src/services/messenger/telegram.rs:391
↓ 1 callersMethodedit_photo_by_id
(&self, request: EditMediaByIdRequest<'_>)
bot/src/services/messenger/telegram.rs:412
↓ 1 callersMethodedit_video_by_id
(&self, request: EditMediaByIdRequest<'_>)
bot/src/services/messenger/telegram.rs:369
↓ 1 callersFunctionembed
(media_path: &Path, thumbnail: Vec<u8>)
downloader/src/services/thumbnail.rs:37
↓ 1 callersFunctionembed_thumbnail
(media_path: &Path, thumbnail_path: &Path)
downloader/src/services/thumbnail.rs:26
↓ 1 callersMethodensure_group
Creates the consumer group (and the stream) if it does not exist yet. Idempotent.
bot/src/services/queue.rs:56
↓ 1 callersFunctionexecute_audio
(interactor: &DownloadAudio<Messenger>, input: DownloadInput<'_>)
bot/src/interactors/chosen_inline.rs:472
↓ 1 callersFunctionexecute_photo
(interactor: &DownloadPhoto<Messenger>, input: DownloadInput<'_>)
bot/src/interactors/chosen_inline.rs:758
↓ 1 callersFunctionexecute_video
(interactor: &DownloadVideo<Messenger>, input: DownloadInput<'_>)
bot/src/interactors/chosen_inline.rs:186
↓ 1 callersFunctionextract_audio
(url: &str, output_file_path: &Path, executable_path: &str, timeout: u64)
downloader/src/services/ffmpeg.rs:112
↓ 1 callersMethodextract_author
(&self)
downloader/src/entities/gallery_dl.rs:76
↓ 1 callersMethodextract_dimensions
(&self)
downloader/src/entities/gallery_dl.rs:87
↓ 1 callersMethodextract_display_id
(&self)
downloader/src/entities/gallery_dl.rs:145
↓ 1 callersMethodextract_extension
(&self)
downloader/src/entities/gallery_dl.rs:149
↓ 1 callersMethodextract_filesize
(&self)
downloader/src/entities/gallery_dl.rs:157
↓ 1 callersMethodextract_id
(&self)
downloader/src/entities/gallery_dl.rs:71
↓ 1 callersFunctionextract_logged_error
Extracts a gallery-dl `[category][error] <message>` line from stderr, returning the message. gallery-dl logs extraction failures this way even when it
downloader/src/services/gallery_dl.rs:233
↓ 1 callersMethodextract_title
(&self)
downloader/src/entities/gallery_dl.rs:153
↓ 1 callersMethodextract_webpage_url
(&self)
downloader/src/entities/gallery_dl.rs:161
↓ 1 callersMethodfallbacks
(&self)
downloader/src/services/ytdl.rs:40
↓ 1 callersFunctionfinish_ytdlp
(status: std::process::ExitStatus, stdout_res: Result<(), io::Error>, stderr_text: &str)
downloader/src/services/ytdl.rs:591
↓ 1 callersFunctionformat_song
(song: &RecognizedSong, locale: &str)
bot/src/interactors/shazam.rs:256
↓ 1 callersFunctionforward_download_stream
( mut session: DownloadSession, progress_sender: Option<mpsc::UnboundedSender<DownloadProgressEvent>>,
bot/src/services/download/media.rs:747
← previousnext →101–200 of 727, ranked by callers