1 viewer
rust 1,961,941 · typescript 233,850 · javascript 141,145 · python 22,871 · 6,801 files · digest 6d882eacc8db · built in 12.5 s · crystals off
crates/cre8-app-channel/src/connection.rs
Items
const VIEWER_TTL_MS const DIRECTOR_CLIP_COOLDOWN_MS type ActionHandler const ACTION_HANDLERS const SPECS const ATTENTION_WINDOW_MS struct ViewerPresence type ViewerRegistry static VIEWERS static OWNERS static INTENTS static CLIPS static METADATA const MAX_CHANNEL_METADATA_BYTES const DIRECTOR_SPEECH_POSTS_PER_TICK const SWEEP_CAP const MAX_DURATION_MS const MAX_DIMENSION const INGEST_MARKERS const BROWSER_CAM_MARKERS const VIRTUAL_CAM_MARKERS const RADIO_MARKERS
Functions
By call-graph weight (PageRank; 1.0 is the average function). 99 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| lock_clipssrc/connection.rs:741 | fn | 6 | 2 | 8 | 1 | 8.1 | |
| clipssrc/connection.rs:735 | fn | 3 | 1 | 1 | 0 | 7.4 | |
| viewerssrc/connection.rs:655 | fn | 3 | 1 | 3 | 0 | 3.5 | |
| clip_by_idsrc/connection.rs:768 | fn | 3 | 1 | 22 | 1 | 3.5 | |
| lock_viewerssrc/connection.rs:659 | fn | 6 | 2 | 5 | 1 | 3.4 | |
| connectsrc/connection.rs:860 | fn | 8 | 2 | 16 | 3 | 3.2 | |
| resolve_channel_idsrc/connection.rs:3142 | fn | 11 | 4 | 15 | 0 | 2.6 | |
| ownerssrc/connection.rs:799 | fn | 3 | 1 | 1 | 0 | 2.5 | |
| dispatch_payloadsrc/connection.rs:1136 | fn | 7 | 1 | 11 | 0 | 2.4 | |
| lock_ownerssrc/connection.rs:803 | fn | 6 | 2 | 5 | 1 | 2.4 | |
| caller_identitysrc/connection.rs:840 | fn | 3 | 1 | 27 | 1 | 2.2 | |
| contextsrc/connection.rs:3159 | fn | 3 | 1 | 16 | 1 | 2 | |
| clip_records_for_channelsrc/connection.rs:750 | fn | 16 | 2 | 7 | 1 | 1.8 | |
| intentssrc/connection.rs:711 | fn | 3 | 1 | 1 | 0 | 1.8 | |
| tv_channel_has_live_mediasrc/connection.rs:2710 | fn | 10 | 3 | 2 | 0 | 1.8 | |
| commit_clip_recordsrc/connection.rs:774 | fn | 11 | 1 | 14 | 2 | 1.6 | |
| lock_intentssrc/connection.rs:715 | fn | 6 | 2 | 3 | 1 | 1.6 | |
| find_action_handlersrc/connection.rs:869 | fn | 6 | 1 | 2 | 0 | 1.6 | |
| channel_owner_gatesrc/connection.rs:847 | fn | 12 | 3 | 18 | 1 | 1.5 | |
| unknown_action_payloadsrc/connection.rs:2602 | fn | 3 | 1 | 1 | 0 | 1.4 | |
| handle_listsrc/connection.rs:2665 | fn | 7 | 1 | 6 | 4 | 1.3 | |
| contains_markersrc/connection.rs:2656 | fn | 3 | 1 | 2 | 0 | 1.3 | |
| annotated_tv_channelsrc/connection.rs:2685 | fn | 14 | 3 | 2 | 6 | 1.3 | |
| metadata_storesrc/connection.rs:820 | fn | 3 | 1 | 1 | 0 | 1.3 | |
| viewer_countsrc/connection.rs:691 | fn | 8 | 1 | 5 | 1 | 1.2 | |
| add_channel_list_metadatasrc/connection.rs:2738 | fn | 88 | 9 | 2 | 6 | 1.1 | |
| intent_snapshotsrc/connection.rs:722 | fn | 3 | 1 | 3 | 1 | 1 | |
| bounded_textsrc/connection.rs:2560 | fn | 7 | 2 | 2 | 0 | 1 | |
| economics_snapshotsrc/connection.rs:940 | fn | 118 | 9 | 3 | 4 | 1 | |
| handle_stopsrc/connection.rs:3039 | fn | 79 | 7 | 7 | 9 | 1 | |
| lock_metadatasrc/connection.rs:824 | fn | 6 | 2 | 4 | 1 | 1 | |
| status_payloadsrc/connection.rs:2606 | fn | 9 | 1 | 1 | 0 | 0.9 | |
| tv_channels_payloadsrc/connection.rs:2673 | fn | 4 | 1 | 2 | 1 | 0.9 | |
| annotated_tv_channelssrc/connection.rs:2678 | fn | 6 | 1 | 2 | 1 | 0.9 | |
| handle_startsrc/connection.rs:2858 | fn | 180 | 17 | 5 | 7 | 0.9 | |
| channel_status_is_livesrc/connection.rs:2734 | fn | 3 | 1 | 2 | 0 | 0.8 | |
| handle_intent_publishsrc/connection.rs:1078 | fn | 57 | 5 | 3 | 9 | 0.8 | |
| mock_dispatchsrc/connection.rs:3163 | fn | 26 | 6 | 5 | 0 | 0.8 | |
| infer_sourcesrc/connection.rs:2626 | fn | 17 | 5 | 2 | 1 | 0.8 | |
| record_viewersrc/connection.rs:666 | fn | 8 | 1 | 3 | 1 | 0.8 | |
| handle_heartbeatsrc/connection.rs:3119 | fn | 22 | 1 | 2 | 4 | 0.8 | |
| handle_director_ticksrc/connection.rs:1230 | fn | 100 | 8 | 1 | 12 | 0.7 | |
| maybe_mint_watch_attentionsrc/connection.rs:896 | fn | 38 | 4 | 1 | 3 | 0.7 | |
| take_elapsed_attention_windowsrc/connection.rs:679 | fn | 11 | 2 | 1 | 1 | 0.7 | |
| channel_id_from_tv_recordsrc/connection.rs:2700 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| radio_stream_from_muxsrc/connection.rs:2647 | fn | 8 | 2 | 1 | 0 | 0.6 | |
| advertised_channel_statussrc/connection.rs:2721 | fn | 12 | 3 | 1 | 1 | 0.6 | |
| handle_getsrc/connection.rs:2827 | fn | 30 | 6 | 2 | 5 | 0.6 | |
| handle_clip_createsrc/connection.rs:1493 | fn | 61 | 3 | 2 | 4 | 0.6 | |
| attention_recording_dispatchsrc/connection.rs:3310 | fn | 6 | 2 | 2 | 0 | 0.6 | |
| drain_recorded_attentionsrc/connection.rs:3317 | fn | 3 | 1 | 2 | 0 | 0.6 | |
| backdate_attention_windowsrc/connection.rs:3323 | fn | 8 | 1 | 2 | 1 | 0.6 | |
| handle_spectate_targetssrc/connection.rs:1144 | fn | 21 | 1 | 1 | 3 | 0.6 | |
| checkbox_enabledsrc/connection.rs:2462 | fn | 12 | 6 | 1 | 0 | 0.6 | |
| spectate_dispatchsrc/connection.rs:3208 | fn | 38 | 5 | 1 | 0 | 0.6 | |
| no_channels_dispatchsrc/connection.rs:3247 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| accepted_channel_metadatasrc/connection.rs:833 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| nested_dispatchsrc/connection.rs:3190 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| novelty_clip_dispatchsrc/connection.rs:3194 | fn | 13 | 2 | 1 | 0 | 0.6 | |
| sanitize_public_intentsrc/connection.rs:2515 | fn | 44 | 1 | 1 | 1 | 0.6 | |
| restore_clip_recordssrc/connection.rs:787 | fn | 11 | 3 | 1 | 2 | 0.6 | |
| director_chatter_exchangesrc/connection.rs:1348 | fn | 82 | 8 | 1 | 4 | 0.5 | |
| director_sweepsrc/connection.rs:1435 | fn | 32 | 3 | 1 | 2 | 0.5 | |
| director_config_from_inputsrc/connection.rs:1470 | fn | 16 | 5 | 1 | 1 | 0.5 | |
| connect_statussrc/connection.rs:876 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| connect_heartbeatsrc/connection.rs:880 | fn | 5 | 1 | 0 | 2 | 0.5 | |
| handle_economicssrc/connection.rs:1059 | fn | 6 | 1 | 0 | 2 | 0.5 | |
| handle_intentsrc/connection.rs:1066 | fn | 11 | 1 | 0 | 1 | 0.5 | |
| handle_spectate_selectsrc/connection.rs:1166 | fn | 54 | 3 | 0 | 6 | 0.5 | |
| handle_clip_importsrc/connection.rs:1565 | fn | 99 | 6 | 0 | 8 | 0.5 | |
| handle_clip_trimsrc/connection.rs:1677 | fn | 101 | 6 | 0 | 5 | 0.5 | |
| handle_clip_bedsrc/connection.rs:1790 | fn | 105 | 8 | 0 | 3 | 0.5 | |
| handle_clip_retimesrc/connection.rs:1906 | fn | 103 | 9 | 0 | 5 | 0.5 | |
| handle_clip_holdsrc/connection.rs:2018 | fn | 104 | 6 | 0 | 5 | 0.5 | |
| handle_clip_shapesrc/connection.rs:2132 | fn | 125 | 14 | 0 | 3 | 0.5 | |
| handle_clip_concatsrc/connection.rs:2271 | fn | 174 | 11 | 0 | 5 | 0.5 | |
| handle_clip_publishsrc/connection.rs:2448 | fn | 11 | 2 | 0 | 2 | 0.5 | |
| handle_clip_search_setsrc/connection.rs:2477 | fn | 13 | 2 | 0 | 4 | 0.5 | |
| handle_clip_listsrc/connection.rs:2491 | fn | 6 | 1 | 0 | 2 | 0.5 | |
| handle_clip_getsrc/connection.rs:2499 | fn | 15 | 2 | 0 | 1 | 0.5 | |
| handle_view_patchsrc/connection.rs:2572 | fn | 29 | 3 | 0 | 4 | 0.5 | |
| connect_covers_status_aliases_unknown_and_empty_actionsrc/connection.rs:3252 | fn | 26 | 1 | 0 | 3 | 0.5 | |
| viewer_registry_records_expires_counts_and_clears_on_stopsrc/connection.rs:3280 | fn | 25 | 1 | 0 | 6 | 0.5 | |
| sustained_watching_mints_attention_once_per_windowsrc/connection.rs:3333 | fn | 31 | 1 | 0 | 7 | 0.5 | |
| anonymous_viewers_count_but_never_mint_attentionsrc/connection.rs:3366 | fn | 14 | 1 | 0 | 7 | 0.5 | |
| source_inference_and_channel_id_resolution_cover_aliasessrc/connection.rs:3382 | fn | 22 | 2 | 0 | 3 | 0.5 | |
| spectate_targets_select_and_get_share_the_native_world_directorysrc/connection.rs:3406 | fn | 29 | 1 | 0 | 4 | 0.5 | |
| public_intent_publish_is_allow_listed_and_latest_winssrc/connection.rs:3437 | fn | 51 | 1 | 0 | 3 | 0.5 | |
| public_intent_rejects_incomplete_snapshotssrc/connection.rs:3490 | fn | 9 | 1 | 0 | 2 | 0.5 | |
| high_novelty_public_intent_retroactively_creates_a_shareable_clipsrc/connection.rs:3501 | fn | 54 | 1 | 0 | 5 | 0.5 | |
| list_get_start_and_stop_cover_dispatch_fallbacks_and_source_branchessrc/connection.rs:3557 | fn | 40 | 2 | 0 | 5 | 0.5 | |
| list_get_start_and_stop_cover_successful_dispatch_branchessrc/connection.rs:3599 | fn | 48 | 4 | 0 | 8 | 0.5 | |
| channel_metadata_is_capped_echoed_and_surfacedsrc/connection.rs:3649 | fn | 29 | 1 | 0 | 5 | 0.5 | |
| list_metadata_annotates_poster_only_when_mux_knownsrc/connection.rs:3680 | fn | 32 | 1 | 0 | 1 | 0.5 | |
| list_handles_dispatch_payload_without_channels_arraysrc/connection.rs:3714 | fn | 7 | 1 | 0 | 4 | 0.5 | |
| test_dispatch_restores_nested_handler_and_covers_default_mock_branchsrc/connection.rs:3723 | fn | 19 | 1 | 0 | 5 | 0.5 | |
| owner_gate_blocks_non_owner_start_over_and_stopsrc/connection.rs:3744 | fn | 36 | 1 | 0 | 6 | 0.5 | |
| ownerless_dev_channel_stays_ungatedsrc/connection.rs:3782 | fn | 9 | 1 | 0 | 6 | 0.5 | |
| viewer_registry_recovers_from_poisoned_locksrc/connection.rs:3793 | fn | 18 | 1 | 0 | 8 | 0.5 |
Source not readable from this process.