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
↓ 282 callersFunctionnew
( messenger: &(impl MessengerPort + ?Sized), text: &str, chat_id: i64, reply_to_message_id: Op
bot/src/handlers_utils/progress.rs:14
↓ 220 callersMethodas_ref
(&self)
bot/src/entities/domains.rs:9
↓ 70 callersMethodas_str
(self)
bot/src/locale.rs:9
↓ 67 callersMethodget
(&self, tg_id: i64)
bot/src/database/readers/chat_config.rs:26
↓ 26 callersMethodexecute
(self, SaveChatInput { chat, chat_config }: SaveChatInput)
bot/src/services/chat.rs:32
↓ 26 callersMethodparse
(raw: &str)
bot/src/locale.rs:16
↓ 26 callersMethodparse
(text: &str)
bot/src/entities/params.rs:9
↓ 24 callersMethodformat
(&self, err: &(impl FormatErrorToMessage + ?Sized))
bot/src/utils/error.rs:67
↓ 24 callersFunctionis_error_in_chosen_inline
( messenger: &(impl MessengerPort + ?Sized), inline_message_id: &str, text: &str, format: Opti
bot/src/handlers_utils/progress.rs:219
↓ 24 callersMethodregister
(&mut self, worker_id: &str, domain: &'a str)
cookie_assignment/src/service.rs:343
↓ 19 callersMethodinto_inner
(self)
bot/src/entities/media.rs:293
↓ 18 callersMethodexecute
(self, input: DownloadInput<'_>)
bot/src/interactors/chosen_inline.rs:155
↓ 17 callersFunctionis_error_in_progress
( messenger: &(impl MessengerPort + ?Sized), chat_id: i64, message_id: i64, text: &str, fo
bot/src/handlers_utils/progress.rs:201
↓ 16 callersMethodlocale
(&self)
bot/src/entities/chat_config.rs:32
↓ 15 callersMethoddefault
()
bot/src/config.rs:35
↓ 12 callersFunctionmedia_link
(webpage_url: Option<&Url>)
bot/src/utils/text.rs:15
↓ 11 callersFunctionauthenticated_request
Builds a tonic request with the downloader bearer token in metadata. # Errors Returns [`InvalidMetadataValue`] if the token cannot be encoded as an
downloader_client/src/auth.rs:12
↓ 10 callersMethodedit_text
(&self, request: EditTextRequest<'_>)
bot/src/services/messenger/telegram.rs:82
↓ 10 callersMethodeq
(&self, other: &Self)
bot/src/entities/media.rs:44
↓ 10 callersMethodget_bool
(&self, key: &str)
bot/src/entities/params.rs:53
↓ 10 callersFunctionparse_gallery_dl_json
Parses gallery-dl's `--dump-json` / `--resolve-json` output: a `DataJob` array of message tuples whose first element is the identifier. In gallery-dl
downloader/src/services/gallery_dl.rs:58
↓ 9 callersMethodexecute
(self, input: AutoQuietInput<'_>)
bot/src/interactors/auto.rs:349
↓ 8 callersMethodall
()
bot/src/entities/range.rs:52
↓ 8 callersFunctionbuild_formats_string
(strategy: &FormatStrategy, heights: &[u32], audio_language: &Language)
downloader/src/services/ytdl.rs:150
↓ 8 callersMethodcommand_parts
(&self)
downloader/src/config.rs:45
↓ 8 callersMethodmax_file_size
(&self)
downloader_client/src/router.rs:47
↓ 7 callersMethodload
(cfg: &DownloaderTlsConfig, server_name: &str)
downloader_client/src/client.rs:64
↓ 7 callersFunctionprefixed
(base: Option<&str>, body: &str)
bot/src/utils/text.rs:8
↓ 7 callersFunctionwith_retries
(bot: &Bot, method: T, max_retries: u8, request_timeout: Option<f32>)
bot/src/services/messenger/telegram.rs:584
↓ 6 callersMethodcreate
(&self, conn: &'a DatabaseConnection)
bot/src/database/factories.rs:79
↓ 6 callersFunctiondelete
(messenger: &(impl MessengerPort + ?Sized), chat_id: i64, message_id: i64)
bot/src/handlers_utils/progress.rs:265
↓ 6 callersFunctionprepare_download
( node_router: &NodeRouter, domain: Option<&str>, request: DownloadRequest, output_dir: &Path,
bot/src/services/download/media.rs:660
↓ 6 callersFunctionprocess_exit_error
Build an `io::Error` describing a subprocess that exited unsuccessfully. Shared by the yt-dlp and gallery-dl wrappers to keep the messages consistent.
downloader/src/utils/process.rs:5
↓ 6 callersMethodrollback
(self: Box<Self>)
bot/src/database/tx_manager.rs:68
↓ 6 callersFunctionsend_chunk
(tx: &UnboundedSender<Result<DownloadChunk, Status>>, chunk: DownloadChunk)
downloader/src/grpc/downloader.rs:1283
↓ 5 callersMethodack
Acknowledges and removes a processed entry from the stream.
bot/src/services/queue.rs:143
↓ 5 callersMethodbegin
(&self)
bot/src/database/tx_manager.rs:40
↓ 5 callersMethodcommit
(self: Box<Self>)
bot/src/database/tx_manager.rs:63
↓ 5 callersMethodextract_string
(&self, keys: &[&str])
downloader/src/entities/gallery_dl.rs:133
↓ 5 callersFunctionget_url_from_text
(text: &str)
bot/src/filters/text_url.rs:10
↓ 5 callersMethodinto_raw_photo_info
(self, request_url: &Url)
downloader/src/entities/gallery_dl.rs:93
↓ 5 callersMethodnodes
(&self)
downloader_client/src/router.rs:52
↓ 5 callersFunctiononce
(bot: &Bot, method: T, request_timeout: Option<f32>)
bot/src/services/messenger/telegram.rs:571
↓ 5 callersFunctionparse_range
(range: Option<proto::downloader::Range>)
downloader/src/grpc/downloader.rs:1072
↓ 5 callersFunctionparse_section
(section: Option<Section>)
downloader/src/grpc/downloader.rs:1097
↓ 5 callersFunctionredact_token
(message: impl Into<String>, token: &str)
bot/src/utils/error.rs:28
↓ 5 callersFunctionselect_best_index
(candidates: Vec<NodeSnapshot<'_>>)
downloader_client/src/selection.rs:11
↓ 4 callersMethodchat_config_repo
(&self)
bot/src/database/tx_manager.rs:77
↓ 4 callersFunctiondownload_thumbnail
(thumb_urls: &[Url], thumb_file_path: &std::path::Path)
downloader/src/grpc/downloader.rs:1144
↓ 4 callersMethoddownloaded_media_reader
(&self)
bot/src/database/tx_manager.rs:56
↓ 4 callersMethodextract_u64
(&self, keys: &[&str])
downloader/src/entities/gallery_dl.rs:140
↓ 4 callersFunctionget_media_info
( search: &str, strategy: &FormatStrategy, audio_language: &Language, yt_dlp_cfg: &YtDlpConfig
downloader/src/services/ytdl.rs:222
↓ 4 callersMethodget_thumb_urls
(&self, aspect_kind: Option<AspectKind>)
downloader/src/entities/media.rs:101
↓ 4 callersFunctionpush_if_some
(vec: &mut Vec<T>, value: Option<T>)
downloader/src/services/ytdl.rs:151
↓ 4 callersFunctionrender_args
(args: &[String])
downloader/src/services/ytdl.rs:157
↓ 4 callersMethodreplace_url
(&self, url: &Url, kind: MediaKind)
downloader/src/services/domain_replacer.rs:48
↓ 4 callersFunctionresolve_download_duration
(media_duration: Option<f32>, section: Option<&Sections>)
downloader/src/grpc/downloader.rs:1293
↓ 4 callersFunctionresolve_media_file_path
( output_dir_path: &std::path::Path, expected_media_file_path: &std::path::Path, )
downloader/src/grpc/downloader.rs:1223
↓ 4 callersFunctionresolve_url
(url: Option<&Url>, result_id: &str)
bot/src/interactors/chosen_inline.rs:958
↓ 4 callersFunctionrun_ffmpeg
(args: &[&str], executable_path: &str, timeout: u64)
downloader/src/services/ffmpeg.rs:148
↓ 4 callersMethodsend_text
(&self, request: SendTextRequest<'_>)
bot/src/services/messenger/telegram.rs:63
↓ 4 callersMethodspawn_delete_message
Best-effort fire-and-forget delete that logs failures via `error_formatter`. Used after every "send + auto-delete" upload (the receiver chat is just a
bot/src/services/messenger/telegram.rs:515
↓ 4 callersFunctionstream_media_to_client
Stream a validated media file to the gRPC client as `Data` chunks.
downloader/src/grpc/downloader.rs:891
↓ 4 callersFunctionvalidate_download_file
Validate the downloaded file before its `Meta` is sent: it must be non-empty (yt-dlp/gallery-dl can exit 0 yet leave an empty file) and fit the size b
downloader/src/grpc/downloader.rs:869
↓ 4 callersFunctionwith_node_failover
Executes an operation against downloader nodes with router-based failover. # Errors Returns [`NodeFailoverError`] if no suitable node is available,
downloader_client/src/retry.rs:28
↓ 3 callersFunctionadd_media
(tx_manager: &dyn TxManager, media: DownloadedMedia, overwrite_cache: bool)
bot/src/services/downloaded_media.rs:156
↓ 3 callersFunctionaspect_is_equal
(left: f32, right: f32)
downloader/src/utils/aspect.rs:28
↓ 3 callersFunctionaspect_is_equal
(a: f32, b: f32)
bot/src/utils/media.rs:30
↓ 3 callersMethodaspect_ratio_kind
(&self)
downloader/src/entities/media.rs:24
↓ 3 callersFunctionclassify
( get_video: &get_media::GetVideoByURL, get_audio: &get_media::GetAudioByURL, get_photo: &get_medi
bot/src/interactors/auto.rs:416
↓ 3 callersFunctioncompile_rules
(rules: &[ReplaceRule])
downloader/src/services/domain_replacer.rs:69
↓ 3 callersFunctioncreate_ytdlp_command
(yt_dlp_cfg: &YtDlpConfig)
downloader/src/services/ytdl.rs:607
↓ 3 callersFunctiondownload_media
( strategy: FormatStrategy, format_id: &str, sections: Option<&Sections>, max_filesize: u64,
downloader/src/services/ytdl.rs:322
↓ 3 callersMethodenqueue
(&self, job: &DownloadJob)
bot/src/services/queue.rs:74
↓ 3 callersMethodestimated_active_downloads
(&self)
downloader_client/src/handle.rs:47
↓ 3 callersFunctionfile_size
(path: &std::path::Path)
downloader/src/grpc/downloader.rs:1219
↓ 3 callersFunctionformat_error_report
(err: &(impl std::error::Error + ?Sized))
bot/src/utils/error.rs:10
↓ 3 callersMethodfrom
( Model { tg_id, username, chat_type, created_at,
bot/src/entities/chat.rs:39
↓ 3 callersMethodfulfill
(&self, result: GetMediaByURLKind, ctx: &FulfillCtx<'_>)
bot/src/interactors/auto.rs:74
↓ 3 callersFunctionget_media_by_url
( router: &NodeRouter, tracking_params_cfg: &TrackingParamsConfig, url: &Url, playlist_range:
bot/src/services/get_media.rs:283
↓ 3 callersMethodget_status
(&self, _request: Request<Empty>)
downloader/src/grpc/capabilities.rs:19
↓ 3 callersFunctionis_audio_first
Video when any uncached format has dimensions or a video container ext (generic/snapsave often omits width), or when every entry was already cached as
bot/src/interactors/auto.rs:521
↓ 3 callersFunctionis_error_in_inline_query
(messenger: &(impl MessengerPort + ?Sized), query_id: &str, text: &str)
bot/src/handlers_utils/progress.rs:261
↓ 3 callersFunctionis_errors_if_exist
( messenger: &(impl MessengerPort + ?Sized), chat_id: i64, message_id: i64, media_errs: &[Vec<
bot/src/handlers_utils/progress.rs:70
↓ 3 callersMethodmax_concurrent
(&self)
downloader_client/src/handle.rs:42
↓ 3 callersFunctionmedia_groups
Telegram media groups are limited to 10 items; this splits a longer list into 10-sized batches and tolerates per-batch failures.
bot/src/services/messenger/telegram.rs:616
↓ 3 callersFunctionparse_host
(raw: &str)
downloader_client/src/client.rs:95
↓ 3 callersFunctionparse_optional_positive
(part: &str, is_step: bool)
downloader/src/entities/range.rs:58
↓ 3 callersFunctionparse_optional_positive
(part: &str, is_step: bool)
bot/src/entities/range.rs:81
↓ 3 callersFunctionparse_recognized
`songrec audio-file-to-recognized-song` prints the raw Shazam response. A successful match has a `track` object; a no-match response omits it (only `m
downloader/src/services/songrec.rs:144
↓ 3 callersFunctionpositive_i16
(value: i32, field: &str)
downloader/src/grpc/downloader.rs:1089
↓ 3 callersFunctionsanitize_send_filename
(path: &Path, name: &str)
bot/src/utils/fs.rs:3
↓ 3 callersFunctionsnapsave_name
A media name from a post URL: its last non-empty path segment (the reel/post shortcode).
downloader/src/grpc/downloader.rs:1034
↓ 3 callersFunctionstream_thumbnail_file
( thumb_file_path: &std::path::Path, tx: &UnboundedSender<Result<DownloadChunk, Status>>, )
downloader/src/grpc/downloader.rs:1159
↓ 3 callersFunctiontry_embed_thumbnail
Embed `thumb_file_path` into `media_file_path`. Best-effort — failures are logged but not surfaced to the caller (the media file is still usable).
downloader/src/grpc/downloader.rs:830
↓ 2 callersMethodanswer_inline_query
(&self, request: AnswerInlineQueryRequest<'_>)
bot/src/services/messenger/telegram.rs:119
↓ 2 callersMethodas_auto
(mut self, quiet: bool)
bot/src/entities/download_job.rs:69
↓ 2 callersMethodbuild_channel
(&self, address: &str)
downloader_client/src/client.rs:77
↓ 2 callersFunctionbuild_commands
(locale: &str)
bot/src/utils/startup.rs:28
↓ 2 callersFunctioncaption_with_link
Builds a media caption: an optional custom caption (e.g. recognized-song metadata) followed by the source "Link" when visible. Either part may be abse
bot/src/services/messenger/telegram.rs:561
next →1–100 of 727, ranked by callers