1 viewer

rust 1,863,570 · typescript 235,774 · javascript 133,179 · python 20,426 · 6,416 files · digest 72c4f5c61f73 · built in 1.7 s · crystals off

crates/cre8-app-room/src/connection.rs

cre8-app-room · module connection · src · 5,452 lines (4,714 code, 320 comment) · sha ba371eecf474b774

Items

const ROOM_RECIPE_ENGINE const ROOM_MESSAGE_WINDOW const SPECS const ROOM_FLOOD_MAX_POSTS const ROOM_FLOOD_WINDOW_MS const ROOM_SLOW_MODE_MAX_MS const ROOM_TIMEOUT_MAX_SECONDS const ROLE_OWNER const ROLE_MOD const ROLE_VIEWER const SERVER_OWNED_METADATA_KEYS struct RoomInput struct RoomState struct GenericRoomMessage struct RoomThrottleState struct GenericRoomState struct RoomReactiveBridgeState static ROOM_REGISTRY static GENERIC_ROOM_REGISTRY static ROOM_REACTIVE_REGISTRY enum PublishRefusal impl PublishRefusal const W_MODE const W_SEED const W_TAGS const W_SKILL const W_WARM const SKILL_SPAN struct MatchCriteria impl MatchCriteria const DEFAULT_GOVERN_ALLOW static ROOM_GOVERNANCE_OWNERS struct RoomRecipeRun struct RoomReactiveConfig struct AudioEnvelope struct ReactiveVideoControl struct ReactiveBridgeRuntime impl ReactiveBridgeRuntime enum ReactiveBridgeStep enum ReactiveAudioPoll struct AudioRecipeSettings struct AudioRecipeTexture struct NormalizedRoomRecipeParts struct NormalizedRoomMediaRecipe struct RoomMessageWindow static LOCK

Functions

By call-graph weight (PageRank; 1.0 is the average function). 228 functions in all.

function	kind	lines	cyclomatic	callers	callees	weight
connectsrc/connection.rs:376	fn	44	20	17	22	8.1
generic_room_registrysrc/connection.rs:368	fn	3	1	30	0	7.3
normalize_room_idsrc/connection.rs:3989	fn	15	6	12	0	7
canonical_tokensrc/connection.rs:3981	fn	7	3	10	0	5
room_rolessrc/connection.rs:1052	fn	22	1	8	0	3.9
generic_message_payloadsrc/connection.rs:3564	fn	6	1	4	2	2.8
resolve_room_idsrc/connection.rs:3849	fn	3	1	16	1	2.6
room_reactive_registrysrc/connection.rs:372	fn	3	1	3	0	2.5
room_test_locksrc/connection.rs:4026	fn	4	1	24	0	2.3
mark_reactive_bridge_stoppedsrc/connection.rs:2930	fn	7	1	6	2	2.1
handle_generic_createsrc/connection.rs:495	fn	84	5	6	13	2
reset_generic_roomssrc/connection.rs:4031	fn	3	1	20	1	1.9
room_max_playerssrc/connection.rs:3803	fn	7	3	3	0	1.8
update_reactive_bridge_statesrc/connection.rs:2920	fn	8	2	3	1	1.7
generic_message_envelopesrc/connection.rs:3571	fn	20	1	1	1	1.7
room_revision_cursorsrc/connection.rs:3660	fn	7	1	1	0	1.7
room_governance_ownerssrc/connection.rs:1863	fn	3	1	8	0	1.6
handle_generic_publishsrc/connection.rs:771	fn	135	12	4	12	1.6
contains_anysrc/connection.rs:3977	fn	3	1	2	0	1.6
normalize_room_recipesrc/connection.rs:3232	fn	13	1	4	2	1.6
generic_room_payloadsrc/connection.rs:3533	fn	30	2	6	2	1.5
message_payload_created_atsrc/connection.rs:3777	fn	3	1	2	0	1.5
video_scene_for_promptsrc/connection.rs:3966	fn	10	3	2	2	1.4
resolve_peer_idsrc/connection.rs:3853	fn	15	1	8	1	1.4
metadata_object_mutsrc/connection.rs:1091	fn	6	2	3	0	1.4
room_meta_modesrc/connection.rs:1627	fn	6	2	2	1	1.4
audio_preset_for_promptsrc/connection.rs:3953	fn	12	4	2	2	1.3
display_room_recipe_enginesrc/connection.rs:3328	fn	3	2	1	0	1.2
cursor_revisionsrc/connection.rs:3649	fn	10	1	1	0	1.2
join_capacity_refusalsrc/connection.rs:3813	fn	8	3	3	1	1.2
normalized_room_recipe_partssrc/connection.rs:3259	fn	28	1	1	3	1.2
normalized_room_recipe_payloadsrc/connection.rs:3362	fn	30	1	1	0	1.2
generic_room_payloadssrc/connection.rs:3617	fn	27	2	3	3	1.2
room_endpoints_from_partssrc/connection.rs:3452	fn	47	1	1	3	1.1
room_transition_envelopesrc/connection.rs:3592	fn	24	1	6	1	1.1
create_room_assrc/connection.rs:4747	fn	7	1	9	1	1
handle_generic_joinsrc/connection.rs:580	fn	124	7	4	11	1
room_reactive_config_from_recipesrc/connection.rs:3004	fn	20	1	2	0	1
run_room_recipesrc/connection.rs:2237	fn	17	2	2	3	1
handle_governsrc/connection.rs:1936	fn	124	9	4	14	1
MatchCriteria::from_inputsrc/connection.rs:1534	method	29	3	2	4	1
MatchCriteria::mint_room_idsrc/connection.rs:1593	method	13	1	2	4	1
handle_modsrc/connection.rs:1216	fn	66	8	4	11	1
start_room_conduit_live_sessionsrc/connection.rs:2462	fn	25	1	1	1	1
maybe_start_audio_reactive_bridgesrc/connection.rs:2537	fn	63	4	1	7	1
govern_allow_listsrc/connection.rs:1804	fn	16	2	2	0	1
governance_metadatasrc/connection.rs:1823	fn	12	1	2	0	1
charter_id_from_createsrc/connection.rs:1839	fn	14	3	2	0	1
handle_configuresrc/connection.rs:1286	fn	65	8	4	10	1
moderation_caller_identitysrc/connection.rs:1042	fn	9	1	5	0	1
room_recipe_validation_payloadsrc/connection.rs:3418	fn	26	5	2	0	1
handle_generic_messagessrc/connection.rs:2073	fn	31	1	3	9	0.9
room_registrysrc/connection.rs:364	fn	3	1	2	0	0.9
handle_timeoutsrc/connection.rs:1434	fn	69	3	3	8	0.9
mode_gate_passessrc/connection.rs:1645	fn	6	2	2	1	0.9
handle_generic_syncsrc/connection.rs:2149	fn	35	2	2	9	0.9
best_match_forsrc/connection.rs:1728	fn	13	1	4	4	0.9
insert_match_roomsrc/connection.rs:4236	fn	18	1	4	1	0.9
handle_deletesrc/connection.rs:1356	fn	76	4	2	8	0.9
handle_generic_statesrc/connection.rs:2124	fn	24	1	2	5	0.9
message_payload_revisionsrc/connection.rs:3773	fn	3	1	1	0	0.8
ensure_room_recipe_objectsrc/connection.rs:3309	fn	6	2	1	0	0.8
ensure_room_recipe_enginesrc/connection.rs:3316	fn	11	2	1	1	0.8
moderation_deniedsrc/connection.rs:1178	fn	10	1	4	0	0.8
audio_recipe_settingssrc/connection.rs:3139	fn	11	1	1	3	0.8
room_recipe_from_live_inputsrc/connection.rs:3029	fn	49	1	1	7	0.8
write_room_rolessrc/connection.rs:1098	fn	3	1	2	1	0.8
sort_message_payloads_ascendingsrc/connection.rs:3760	fn	12	1	2	2	0.8
room_scope_authoritysrc/connection.rs:1913	fn	21	3	3	3	0.8
publish_assrc/connection.rs:4755	fn	17	1	6	1	0.8
ensure_room_recipe_shapesrc/connection.rs:3288	fn	4	1	1	2	0.8
normalized_room_media_recipesrc/connection.rs:3293	fn	15	1	1	4	0.8
normalized_room_recipe_idsrc/connection.rs:3332	fn	8	1	1	1	0.8
resolve_since_revisionsrc/connection.rs:3645	fn	3	1	3	1	0.8
room_av_mux_idsrc/connection.rs:3500	fn	16	5	1	2	0.8
default_audio_recipesrc/connection.rs:3079	fn	50	1	2	2	0.8
with_room_runtime_scopesrc/connection.rs:422	fn	6	1	1	1	0.8
handle_statussrc/connection.rs:437	fn	57	3	1	4	0.8
handle_generic_leavesrc/connection.rs:705	fn	65	2	1	7	0.8
handle_matchsrc/connection.rs:1742	fn	45	4	1	9	0.8
handle_generic_memberssrc/connection.rs:2105	fn	18	1	1	2	0.8
handle_livesrc/connection.rs:2185	fn	4	1	1	2	0.8
handle_recipesrc/connection.rs:2190	fn	9	2	1	5	0.8
binaural_audio_texturesrc/connection.rs:3180	fn	3	1	1	0	0.8
default_audio_texturesrc/connection.rs:3184	fn	3	1	1	0	0.8
value_to_seed_stringsrc/connection.rs:1608	fn	10	3	2	0	0.8
json_as_f64src/connection.rs:1619	fn	7	3	2	1	0.8
room_governorssrc/connection.rs:1889	fn	18	4	2	3	0.8
require_room_charter_sanctionsrc/connection.rs:3875	fn	46	4	3	4	0.8
pinned_message_payloadsrc/connection.rs:1195	fn	10	1	2	1	0.8
append_messages_after_revisionsrc/connection.rs:3709	fn	4	1	1	1	0.8
room_recipe_native_media_requiredsrc/connection.rs:2256	fn	12	1	1	0	0.8
run_room_recipe_nativesrc/connection.rs:2279	fn	30	3	1	8	0.8
MatchCriteria::mode_or_defaultsrc/connection.rs:1564	method	3	1	2	0	0.8
reactive_audio_idle_stepsrc/connection.rs:2755	fn	8	3	1	2	0.8
room_moderator_gatesrc/connection.rs:1159	fn	18	6	3	1	0.8
add_room_membersrc/connection.rs:3822	fn	8	2	3	0	0.8
ReactiveBridgeRuntime::newsrc/connection.rs:2646	method	9	1	1	1	0.8
reactive_bridge_ticksrc/connection.rs:2658	fn	23	5	1	4	0.8
room_slow_mode_mssrc/connection.rs:1005	fn	8	3	2	0	0.8
sort_message_payloads_descending_createdsrc/connection.rs:3732	fn	3	1	1	1	0.7
room_endpoints_from_recipesrc/connection.rs:3445	fn	6	1	1	1	0.7
room_recipe_idsrc/connection.rs:4005	fn	3	1	1	1	0.7
audio_preset_journeysrc/connection.rs:3151	fn	7	3	1	0	0.7
audio_preset_base_freqsrc/connection.rs:3159	fn	9	5	1	0	0.7
audio_recipe_texturesrc/connection.rs:3176	fn	3	2	1	2	0.7
durable_contextsrc/connection.rs:5313	fn	3	1	3	1	0.7
room_with_metasrc/connection.rs:4220	fn	15	1	1	0	0.7
sanitize_client_metadatasrc/connection.rs:1117	fn	8	3	2	0	0.7
room_matches_requestsrc/connection.rs:3692	fn	3	1	1	0	0.7
record_room_window_entrysrc/connection.rs:3696	fn	12	2	1	2	0.7
affinity_scoresrc/connection.rs:1654	fn	42	11	1	6	0.7
unsupported_recipe_operation_payloadsrc/connection.rs:2226	fn	10	1	1	0	0.7
audio_envelope_payloadsrc/connection.rs:2904	fn	14	1	1	0	0.7
role_ofsrc/connection.rs:1077	fn	13	3	2	1	0.7
required_room_recipe_childsrc/connection.rs:3341	fn	3	1	1	0	0.7
resolved_recipe_stream_idsrc/connection.rs:3345	fn	12	1	1	0	0.7
normalized_recipe_stream_idsrc/connection.rs:3358	fn	3	1	1	1	0.7
pin_recipe_stream_idsrc/connection.rs:3393	fn	24	3	1	0	0.7
flood_retry_after_mssrc/connection.rs:985	fn	10	2	1	0	0.7
prune_expired_timeoutssrc/connection.rs:1001	fn	3	1	1	0	0.7
collect_room_message_windowsrc/connection.rs:3674	fn	17	3	2	3	0.7
room_message_limitsrc/connection.rs:3714	fn	3	1	2	0	0.7
truncate_room_messagessrc/connection.rs:3736	fn	7	2	2	0	0.7
latest_revision_from_message_payloadssrc/connection.rs:3744	fn	7	1	2	0	0.7
message_payload_envelopessrc/connection.rs:3756	fn	3	1	2	0	0.7
room_state_payloadsrc/connection.rs:3517	fn	15	1	1	0	0.7
generic_messagesrc/connection.rs:4035	fn	13	1	2	0	0.7
insert_generic_roomsrc/connection.rs:4049	fn	18	1	2	1	0.7
apply_reactive_audio_chunksrc/connection.rs:2683	fn	24	2	1	4	0.7
reactive_bridge_cycles_completesrc/connection.rs:2728	fn	7	3	1	1	0.7
reactive_video_stream_closedsrc/connection.rs:2737	fn	7	2	1	2	0.7
poll_reactive_audio_chunksrc/connection.rs:2746	fn	7	1	1	2	0.7
latest_revision_from_room_payloadssrc/connection.rs:3781	fn	7	1	1	0	0.6
room_payload_message_envelopessrc/connection.rs:3789	fn	13	1	1	0	0.6
stored_roomsrc/connection.rs:5317	fn	6	1	2	1	0.6
duplicate_reactive_audio_chunksrc/connection.rs:2709	fn	3	1	1	0	0.6
apply_reactive_video_controlsrc/connection.rs:2765	fn	21	4	1	4	0.6
audio_envelope_from_chunksrc/connection.rs:2848	fn	29	6	1	0	0.6
reactive_video_controlsrc/connection.rs:2879	fn	23	5	1	1	0.6
required_recipe_inputsrc/connection.rs:2200	fn	3	1	1	0	0.6
dispatch_recipe_operationsrc/connection.rs:2204	fn	11	3	1	3	0.6
recipe_error_payloadsrc/connection.rs:2216	fn	9	1	1	0	0.6
resolve_operationsrc/connection.rs:3831	fn	17	4	1	1	0.6
send_reactive_video_controlsrc/connection.rs:2788	fn	19	1	1	1	0.6
record_reactive_control_successsrc/connection.rs:2809	fn	18	1	1	3	0.6
handle_reactive_control_failuresrc/connection.rs:2829	fn	17	3	1	3	0.6
ensure_room_ownersrc/connection.rs:1103	fn	11	2	1	2	0.6
carry_server_owned_metadatasrc/connection.rs:1129	fn	13	4	1	0	0.6
run_audio_reactive_bridgesrc/connection.rs:2621	fn	13	2	1	2	0.6
reactive_bridge_state_payloadsrc/connection.rs:2938	fn	23	1	1	0	0.6
reactive_bridge_keysrc/connection.rs:3000	fn	3	1	1	0	0.6
PublishRefusal::into_responsesrc/connection.rs:917	method	25	3	1	0	0.6
publish_refusalsrc/connection.rs:949	fn	33	8	1	3	0.6
record_accepted_postsrc/connection.rs:996	fn	4	1	1	0	0.6
resolve_publish_sendersrc/connection.rs:1016	fn	13	3	1	1	0.6
flat_publish_fieldsrc/connection.rs:3870	fn	3	1	1	0	0.6
default_video_recipesrc/connection.rs:3188	fn	43	1	1	1	0.6
room_meta_tagssrc/connection.rs:1634	fn	7	1	1	1	0.6
round4src/connection.rs:4018	fn	3	1	1	0	0.6
sort_messages_for_listingsrc/connection.rs:3724	fn	7	2	1	2	0.6
next_message_revisionsrc/connection.rs:3752	fn	3	3	1	0	0.6
sort_room_payloads_by_idsrc/connection.rs:3718	fn	5	1	1	0	0.6
room_recipe_runsrc/connection.rs:2311	fn	22	1	1	2	0.6
start_room_av_recipessrc/connection.rs:2335	fn	12	1	1	2	0.6
response_oksrc/connection.rs:2349	fn	3	1	1	0	0.6
room_recipe_reactive_payloadsrc/connection.rs:2354	fn	12	2	1	1	0.6
room_recipe_conduit_live_payloadsrc/connection.rs:2368	fn	24	2	1	1	0.6
room_recipe_av_mux_payloadsrc/connection.rs:2394	fn	10	1	1	0	0.6
upsert_room_recipe_statesrc/connection.rs:2406	fn	23	1	1	2	0.6
room_recipe_run_responsesrc/connection.rs:2431	fn	29	1	1	0	0.6
room_owner_gatesrc/connection.rs:1145	fn	10	3	1	1	0.6
roles_payloadsrc/connection.rs:1189	fn	4	1	1	1	0.6
MatchCriteria::to_metadatasrc/connection.rs:1569	method	20	6	1	0	0.6
room_join_sanctionedsrc/connection.rs:1704	fn	6	3	1	1	0.6
govern_caller_identitysrc/connection.rs:1871	fn	10	1	1	2	0.6
with_room_runtime_scopesrc/connection.rs:430	fn	6	1	0	0	0.5
pinned_payload_forsrc/connection.rs:1207	fn	7	1	0	2	0.5
room_join_sanctionedsrc/connection.rs:1712	fn	3	1	0	0	0.5
handle_governsrc/connection.rs:2062	fn	10	1	0	0	0.5
start_room_conduit_live_sessionsrc/connection.rs:2492	fn	15	1	0	0	0.5
maybe_start_audio_reactive_bridgesrc/connection.rs:2605	fn	14	1	0	0	0.5
reactive_bridge_payload_for_roomsrc/connection.rs:2962	fn	32	1	0	1	0.5
reactive_config_from_statesrc/connection.rs:2995	fn	3	1	0	0	0.5
room_audio_reactive_enabledsrc/connection.rs:3025	fn	3	1	0	1	0.5
require_room_charter_sanctionsrc/connection.rs:3923	fn	21	1	0	0	0.5
audio_reactive_enabledsrc/connection.rs:3945	fn	3	1	0	0	0.5
reactive_interval_mssrc/connection.rs:3949	fn	3	1	0	0	0.5
specs_cover_every_documented_connectionsrc/connection.rs:4069	fn	33	3	0	0	0.5
canonical_token_lowercases_and_normalizes_separatorssrc/connection.rs:4104	fn	5	1	0	1	0.5
normalize_room_id_rejects_bad_chars_and_lowercasessrc/connection.rs:4111	fn	15	1	0	1	0.5
join_capacity_refuses_only_new_peers_past_max_playerssrc/connection.rs:4128	fn	30	1	0	1	0.5
require_existing_join_rejects_missing_without_mutation_and_default_still_createssrc/connection.rs:4160	fn	32	1	0	5	0.5
require_existing_join_accepts_camel_case_and_preserves_capacity_gatesrc/connection.rs:4194	fn	25	1	0	6	0.5
match_criteria_reads_top_level_and_metadatasrc/connection.rs:4256	fn	16	1	0	1	0.5
mode_gate_only_blocks_explicit_mismatchsrc/connection.rs:4274	fn	9	1	0	2	0.5
best_match_prefers_tag_overlap_skips_full_and_wrong_modesrc/connection.rs:4285	fn	36	1	0	4	0.5
best_match_skips_join_denied_room_and_falls_to_next_bestsrc/connection.rs:4323	fn	39	1	0	4	0.5
best_match_none_when_every_room_incompatiblesrc/connection.rs:4364	fn	11	1	0	4	0.5
mint_room_id_honors_namespace_and_modesrc/connection.rs:4377	fn	10	1	0	1	0.5
govern_allow_list_defaults_trims_and_dedupssrc/connection.rs:4389	fn	14	1	0	1	0.5
governance_metadata_stamps_founder_role_and_allowsrc/connection.rs:4405	fn	12	1	0	1	0.5
charter_id_from_create_probes_known_pathssrc/connection.rs:4419	fn	7	1	0	1	0.5
govern_establishes_active_charter_and_enforces_sanctionsrc/connection.rs:4432	fn	28	1	0	5	0.5
govern_rejects_takeover_of_populated_roomsrc/connection.rs:4463	fn	50	1	0	7	0.5
a_rooms_charter_scope_is_governed_by_its_owner_and_stewardsrc/connection.rs:4516	fn	37	1	0	7	0.5
govern_refuses_a_stranger_on_an_empty_room_someone_else_createdsrc/connection.rs:4556	fn	19	1	0	7	0.5
video_scene_for_prompt_picks_by_keywordsrc/connection.rs:4577	fn	6	1	0	1	0.5
audio_preset_for_prompt_matches_first_winning_bucketsrc/connection.rs:4585	fn	6	1	0	1	0.5
room_input_serde_default_keeps_optionals_absentsrc/connection.rs:4593	fn	6	1	0	0	0.5
generic_messages_pages_descending_then_since_cursor_ascendingsrc/connection.rs:4601	fn	34	1	0	5	0.5
generic_sync_sorts_rooms_and_reports_message_windowsrc/connection.rs:4637	fn	19	1	0	5	0.5
default_audio_recipe_uses_prompt_settings_and_transportsrc/connection.rs:4658	fn	23	1	0	2	0.5
normalize_room_recipe_pins_stream_ids_and_default_controlssrc/connection.rs:4683	fn	32	1	0	1	0.5
normalize_room_recipe_reports_expected_errorssrc/connection.rs:4717	fn	27	1	0	1	0.5
create_assigns_verified_caller_as_owner_and_strips_client_moderation_keyssrc/connection.rs:4774	fn	49	1	0	6	0.5
mod_grants_are_owner_gated_and_round_tripsrc/connection.rs:4825	fn	55	1	0	7	0.5
publish_stamps_server_truth_role_and_verifiedsrc/connection.rs:4882	fn	43	1	0	7	0.5
publish_folds_flat_shapes_into_payloadsrc/connection.rs:4927	fn	52	1	0	5	0.5
slow_mode_blocks_viewers_within_window_and_exempts_modssrc/connection.rs:4981	fn	64	2	0	7	0.5
timeout_blocks_publish_until_cleared_or_expiredsrc/connection.rs:5047	fn	70	1	0	8	0.5
delete_redacts_in_place_appends_tombstone_and_clears_pinsrc/connection.rs:5119	fn	62	1	0	8	0.5
pinned_message_round_trips_in_state_and_messagessrc/connection.rs:5183	fn	57	1	0	8	0.5
anti_flood_floor_caps_all_senders_regardless_of_rolesrc/connection.rs:5242	fn	68	3	0	8	0.5
a_room_and_its_chat_survive_a_restartsrc/connection.rs:5325	fn	59	1	0	5	0.5
a_stored_room_keeps_its_owner_for_charter_authoritysrc/connection.rs:5386	fn	24	1	0	7	0.5
messages_that_leave_the_window_leave_the_graphsrc/connection.rs:5412	fn	28	2	0	6	0.5
a_context_without_a_store_stays_in_memorysrc/connection.rs:5442	fn	10	1	0	4	0.5

Source not readable from this process.