Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Desiders/ytdl_tg_bot
/ functions
Functions
727 in github.com/Desiders/ytdl_tg_bot
⨍
Functions
727
◇
Types & classes
375
↓ 1 callers
Method
fulfill
Silent video download+send for an already-resolved result (shared with the auto path).
bot/src/interactors/video.rs:539
↓ 1 callers
Method
get_cookie_ids
(&self)
downloader/src/entities/cookies.rs:90
↓ 1 callers
Method
get_domains
(&self)
downloader/src/entities/cookies.rs:80
↓ 1 callers
Method
get_element_count
(&self)
downloader/src/entities/range.rs:35
↓ 1 callers
Method
get_element_count
(self)
bot/src/entities/range.rs:35
↓ 1 callers
Method
get_exclude_domains
(&self, tg_id: i64)
bot/src/database/readers/chat_config.rs:36
↓ 1 callers
Method
get_media_info
(&self, request: Request<MediaInfoRequest>)
downloader/src/grpc/downloader.rs:70
↓ 1 callers
Function
get_path
()
downloader/src/config.rs:221
↓ 1 callers
Function
get_path
()
cookie_assignment/src/config.rs:63
↓ 1 callers
Function
get_path
()
bot/src/config.rs:287
↓ 1 callers
Method
get_path_by_host
(&self, host: &Host<&str>)
downloader/src/entities/cookies.rs:67
↓ 1 callers
Function
get_playlist_entries
( search: &str, request_url: &Url, gallery_dl_cfg: &GalleryDlConfig, playlist_range: &Range,
downloader/src/services/gallery_dl.rs:173
↓ 1 callers
Method
get_supported_domains
(&self, _request: Request<Empty>)
downloader/src/grpc/capabilities.rs:29
↓ 1 callers
Method
get_thumb_url_jpg
(&self)
bot/src/entities/media.rs:148
↓ 1 callers
Function
get_video_id
(input: &str)
bot/src/utils/url.rs:15
↓ 1 callers
Function
get_video_info
(client: &Client, api_url: &str, url: &str)
bot/src/services/yt_toolkit.rs:35
↓ 1 callers
Function
handle_download_event
( event: DownloadEvent, progress_sender: Option<&mpsc::UnboundedSender<DownloadProgressEvent>>, me
bot/src/services/download/media.rs:775
↓ 1 callers
Method
has_capacity
(&self)
downloader_client/src/handle.rs:54
↓ 1 callers
Method
has_domain
(&self, worker_id: &str, domain: &str)
cookie_assignment/src/service.rs:348
↓ 1 callers
Function
has_video_stream
(cached: &[MediaInPlaylist], uncached: &[(Media, Vec<(MediaFormat, RawMediaWithFormat)>)])
bot/src/interactors/auto.rs:526
↓ 1 callers
Function
init
( interactors_registry: RegistryWithSync, database_registry: RegistryWithSync, queue_registry: Reg
bot/src/di_container.rs:529
↓ 1 callers
Method
insert_exclude_domain_or_update
( &self, ChatConfigExcludeDomain { tg_id, domain }: ChatConfigExcludeDomain, )
bot/src/database/repos/chat_config.rs:85
↓ 1 callers
Method
insert_or_ignore
( &self, DownloadedMedia { file_id, id, domain,
bot/src/database/repos/downloaded_media.rs:23
↓ 1 callers
Method
insert_or_replace
( &self, DownloadedMedia { file_id, id, domain,
bot/src/database/repos/downloaded_media.rs:67
↓ 1 callers
Method
into_playlist_entry
(self)
downloader/src/entities/gallery_dl.rs:27
↓ 1 callers
Function
invisible_link
(webpage_url: Option<&Url>)
bot/src/utils/text.rs:4
↓ 1 callers
Method
is_active_livestream
(&self)
downloader/src/entities/media.rs:97
↓ 1 callers
Method
is_available
(&self)
downloader_client/src/handle.rs:80
↓ 1 callers
Method
is_default
(self)
bot/src/entities/range.rs:48
↓ 1 callers
Method
is_done
True if this `job_id` was already completed (used to suppress duplicate sends on replay).
bot/src/services/queue.rs:164
↓ 1 callers
Function
is_instagram_or_facebook
(url: &Url)
downloader/src/services/snapsave.rs:94
↓ 1 callers
Method
is_no_match
(&self)
downloader_client/src/errors.rs:69
↓ 1 callers
Function
is_photo_extension
(ext: &str)
downloader/src/entities/gallery_dl.rs:169
↓ 1 callers
Function
is_preparing
( messenger: &(impl MessengerPort + ?Sized), chat_id: i64, message_id: i64, locale: &str,
bot/src/handlers_utils/progress.rs:32
↓ 1 callers
Method
is_progressive_streamable
Streamable only when it's a single pre-muxed HTTP(S) file that yt-dlp can write to stdout as-is. Such formats (e.g. YouTube progressive) are already f
downloader/src/entities/media.rs:202
↓ 1 callers
Function
is_selected_by_range
(index: i16, range: &Range)
downloader/src/services/gallery_dl.rs:133
↓ 1 callers
Function
is_sending
( messenger: &(impl MessengerPort + ?Sized), chat_id: i64, message_id: i64, locale: &str,
bot/src/handlers_utils/progress.rs:51
↓ 1 callers
Method
is_single_element
(&self)
downloader/src/entities/range.rs:39
↓ 1 callers
Method
is_single_element
(self)
bot/src/entities/range.rs:39
↓ 1 callers
Function
is_spotify_platform
(domain: Option<&str>)
downloader_client/src/resolve.rs:11
↓ 1 callers
Method
is_supported
(&self, url: &Url)
downloader/src/services/snapsave.rs:34
↓ 1 callers
Function
is_valid_token
(header: &MetadataValue<Ascii>, token: &str)
downloader/src/grpc/auth.rs:46
↓ 1 callers
Function
is_video_ext
Container extensions that imply a video stream. `webm` is excluded: it is also a common audio-only container, and real video webm carries a width to c
bot/src/interactors/auto.rs:695
↓ 1 callers
Method
list_node_cookies
Lists cookie identifiers currently stored on the worker. # Errors Returns an error if auth metadata cannot be built or the RPC fails.
downloader_client/src/cookie_assignment.rs:72
↓ 1 callers
Function
load_cookies_from_directory
(root: &Path)
cookie_assignment/src/cookies.rs:13
↓ 1 callers
Method
load_server_tls_cfg
(&self)
downloader/src/config.rs:190
↓ 1 callers
Method
load_worker_cookie_ids
(&self, available_workers: &HashMap<String, AssignmentNodeHandle>)
cookie_assignment/src/service.rs:90
↓ 1 callers
Method
load_workers
(&self)
cookie_assignment/src/service.rs:57
↓ 1 callers
Function
map_playlist_response
(playlist: Playlist, max_file_size: u64)
downloader/src/grpc/downloader.rs:910
↓ 1 callers
Method
mark_done
Marks a `job_id` as completed, with a TTL so the marker set does not grow unbounded.
bot/src/services/queue.rs:171
↓ 1 callers
Function
merge_metadata
(base: Option<&Value>, item: Value)
downloader/src/services/gallery_dl.rs:119
↓ 1 callers
Method
meta
(&self)
downloader_client/src/download.rs:20
↓ 1 callers
Method
next_event
Reads the next event from the downloader stream. # Errors Returns an error if the stream RPC fails or the downloader sends an invalid chunk sequence
downloader_client/src/download.rs:30
↓ 1 callers
Function
node_router_registry
(cfg_registry: Registry)
bot/src/di_container.rs:72
↓ 1 callers
Method
normalize
(&mut self)
bot/src/entities/range.rs:28
↓ 1 callers
Method
output_ext
Output file extension: for video this is the chosen container, for audio this is the requested audio codec extension (e.g. `m4a`).
downloader/src/services/ytdl.rs:49
↓ 1 callers
Function
parse_from_fs
Loads downloader configuration from a TOML file. # Errors Returns an error if the file cannot be read or the TOML cannot be parsed.
downloader/src/config.rs:238
↓ 1 callers
Function
parse_from_fs
Loads cookie-assignment configuration from a TOML file. # Errors Returns an error if the file cannot be read or the TOML cannot be parsed.
cookie_assignment/src/config.rs:80
↓ 1 callers
Function
parse_from_fs
Loads bot configuration from a TOML file. # Errors Returns an error if the file cannot be read or the TOML cannot be parsed.
bot/src/config.rs:304
↓ 1 callers
Function
parse_language
(audio_language: &str)
downloader/src/grpc/downloader.rs:1111
↓ 1 callers
Function
parse_ndjson
(input: &[u8])
downloader/src/services/ytdl.rs:136
↓ 1 callers
Function
parse_probe
(stdout: &[u8])
downloader/src/services/ffmpeg.rs:73
↓ 1 callers
Function
parse_urls
`spotdl url` prints matched URLs to stdout, one per line (several for an album/playlist). Ignores progress/noise lines.
downloader/src/services/spotdl.rs:112
↓ 1 callers
Function
patch_info_json
Sets the top-level `ext` (so yt-dlp names the output with a real container) and, when given, the `thumbnail` in a `--load-info-json` blob. Returns the
downloader/src/grpc/downloader.rs:1043
↓ 1 callers
Function
photo_ext
Image extension from a URL's last path segment, defaulting to `jpg`.
downloader/src/grpc/downloader.rs:1025
↓ 1 callers
Method
pick_node
(&self, domain: Option<&str>, excluded: &HashSet<String>)
downloader_client/src/router.rs:57
↓ 1 callers
Function
playlist_from_response
(response: proto::downloader::MediaInfoResponse)
bot/src/services/get_media.rs:442
↓ 1 callers
Method
poll_bytes
(&mut self, cx: &mut Context<'_>)
bot/src/services/download/media.rs:722
↓ 1 callers
Function
probe_photo
( get_photo: &get_media::GetPhotoByURL, url: &Url, range: &Range, overwrite_cache: bool, )
bot/src/interactors/auto.rs:498
↓ 1 callers
Function
process
(container: Container, queue: &RedisJobQueue, QueuedJob { entry_id, job }: QueuedJob)
bot/src/worker.rs:110
↓ 1 callers
Method
push_cookie
Pushes cookie data to the worker. # Errors Returns an error if auth metadata cannot be built or the RPC fails.
downloader_client/src/cookie_assignment.rs:85
↓ 1 callers
Function
queue_registry
(cfg_registry: Registry)
bot/src/di_container.rs:133
↓ 1 callers
Method
reclaim_stale
Reclaims jobs whose owning consumer has been idle longer than `claim_min_idle_ms` (i.e. a crashed worker's in-flight jobs). Returns the batch claimed
bot/src/services/queue.rs:115
↓ 1 callers
Method
recognize
(&self, audio: &[u8])
downloader/src/services/songrec.rs:63
↓ 1 callers
Method
recognize
Downloads the clip and recognizes it, returning the message text to show the user and, on a successful match, the recognized song so the caller can al
bot/src/interactors/shazam.rs:145
↓ 1 callers
Function
recognize_error_status
(err: RecognizeErrorKind)
downloader/src/grpc/song_recognizer.rs:33
↓ 1 callers
Function
recognize_song
(router: &NodeRouter, audio: Vec<u8>)
downloader_client/src/recognize.rs:26
↓ 1 callers
Method
recognize_song
(&self, request: Request<RecognizeSongRequest>)
downloader/src/grpc/song_recognizer.rs:15
↓ 1 callers
Method
reconcile_assignments
( &mut self, available_workers: &HashMap<String, AssignmentNodeHandle>, worker_cookie_
cookie_assignment/src/service.rs:112
↓ 1 callers
Method
release_download_slot
(&self)
downloader_client/src/handle.rs:62
↓ 1 callers
Function
remove_tmp_media_files
()
bot/src/utils/startup.rs:47
↓ 1 callers
Method
remove_url_tracking_params
(&mut self, cfg: &TrackingParamsConfig)
bot/src/entities/media.rs:109
↓ 1 callers
Function
remux_copy
(url: &str, output_file_path: &Path, executable_path: &str, timeout: u64)
downloader/src/services/ffmpeg.rs:93
↓ 1 callers
Method
replace_nodes
(&self, nodes: Vec<Arc<NodeHandle>>, domain_cookie_map: HashMap<String, Vec<usize>>)
downloader_client/src/router.rs:193
↓ 1 callers
Method
requeue
Re-enqueues a job (e.g. after a transient failure) with an incremented attempt count, and acks the original entry so it leaves this consumer's pending
bot/src/services/queue.rs:158
↓ 1 callers
Method
reserve_download_slot
(&self)
downloader_client/src/handle.rs:58
↓ 1 callers
Function
resolve_drm_free_source
Resolves a DRM-platform track link to a DRM-free downloadable source via a routed node. # Errors Returns an error if no node is available, authentic
downloader_client/src/resolve.rs:52
↓ 1 callers
Method
resolve_drm_free_source
(&self, request: Request<ResolveSourceRequest>)
downloader/src/grpc/music_resolver.rs:15
↓ 1 callers
Function
resolve_error_status
(err: ResolveErrorKind)
downloader/src/grpc/music_resolver.rs:35
↓ 1 callers
Function
resolve_to_drm_free
(router: &NodeRouter, url: &Url)
downloader_client/src/resolve.rs:23
↓ 1 callers
Method
revoke_removed_source_cookies
( &mut self, cookies: &[CookieRecord], available_workers: &HashMap<String, AssignmentN
cookie_assignment/src/service.rs:218
↓ 1 callers
Function
run_gallery_dl_json
( search: &str, gallery_dl_cfg: &GalleryDlConfig, timeout: u64, cookie_path: Option<&Path>,
downloader/src/services/gallery_dl.rs:240
↓ 1 callers
Function
run_in_scope
(child: &Container, job: &DownloadJob)
bot/src/worker.rs:159
↓ 1 callers
Function
run_job
(container: Container, job: &DownloadJob)
bot/src/worker.rs:143
↓ 1 callers
Method
run_songrec
(&self, wav: &Path)
downloader/src/services/songrec.rs:114
↓ 1 callers
Function
search_video
(client: &Client, api_url: &str, text: &str)
bot/src/services/yt_toolkit.rs:86
↓ 1 callers
Function
select_by_range
Selects snapsave carousel URLs by the `items` range (1-based start:count:step), mirroring playlist range selection on the node.
downloader/src/grpc/downloader.rs:1059
↓ 1 callers
Function
select_by_range
Applies the `items` range (1-based `start:count:step`) to the resolved URL list, mirroring how the node applies it to a regular playlist's entries.
bot/src/services/get_media.rs:428
↓ 1 callers
Method
select_worker_for_cookie
( &self, workers: &[&'a AssignmentNodeHandle], worker_assignments: &WorkerAssignments<
cookie_assignment/src/service.rs:301
↓ 1 callers
Method
send_audio_by_id
(&self, request: SendMediaByIdRequest<'_>)
bot/src/services/messenger/telegram.rs:323
← previous
next →
201–300 of 727, ranked by callers