1 viewer
rust 1,859,989 · typescript 235,537 · javascript 132,952 · python 20,426 · 6,407 files · digest 4f42637fac12 · built in 1.2 s · crystals off
crates/cre8-app-messaging/src/connection.rs
Items
enum MessagingActionKind struct CallScriptInput struct MessagingInput struct PreparedSendInput impl PreparedSendInput const DEFAULT_GET_THREAD_LIMIT const MAX_GET_THREAD_LIMIT enum ModelTurnRound const TURN_PRICING_ENABLED_ENV enum OriginPolicy const DEFAULT_COMMENT_LIST_LIMIT static SPECS const TEST_BASE_URL struct TestSessionAccount impl AuthenticatedSessionAccountOrigin for TestSessionAccount struct FakeThreadProvider impl LlmProvider for FakeThreadProvider struct ToolCallingThreadProvider impl LlmProvider for ToolCallingThreadProvider const SENDGRID_ENV
Functions
By call-graph weight (PageRank; 1.0 is the average function). 168 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| connectsrc/connection.rs:192 | fn | 23 | 5 | 59 | 5 | 10.6 | |
| as_accountsrc/connection.rs:3090 | fn | 5 | 1 | 36 | 2 | 3.8 | |
| ctx_with_graphsrc/connection.rs:3065 | fn | 8 | 1 | 20 | 3 | 3.6 | |
| dispatch_actionsrc/connection.rs:279 | fn | 13 | 4 | 1 | 5 | 2.3 | |
| pick_providersrc/connection.rs:2484 | fn | 23 | 6 | 5 | 1 | 2.2 | |
| prepare_send_inputsrc/connection.rs:573 | fn | 16 | 1 | 6 | 3 | 2.2 | |
| sendsrc/connection.rs:2767 | fn | 14 | 2 | 7 | 1 | 2.1 | |
| fresh_protocol_graphsrc/connection.rs:3053 | fn | 5 | 1 | 2 | 2 | 1.6 | |
| authenticated_participantsrc/connection.rs:2241 | fn | 19 | 9 | 6 | 3 | 1.5 | |
| library_voice_scriptsrc/connection.rs:863 | fn | 17 | 1 | 1 | 1 | 1.4 | |
| protocol_graph_atsrc/connection.rs:3059 | fn | 5 | 1 | 2 | 0 | 1.4 | |
| normalized_optionalsrc/connection.rs:2341 | fn | 3 | 1 | 3 | 0 | 1.4 | |
| require_thread_membersrc/connection.rs:2273 | fn | 7 | 2 | 6 | 0 | 1.3 | |
| configuredsrc/connection.rs:2758 | fn | 8 | 1 | 8 | 1 | 1.3 | |
| build_payloadsrc/connection.rs:2560 | fn | 12 | 4 | 2 | 0 | 1.2 | |
| ctx_with_graph_and_providersrc/connection.rs:3176 | fn | 15 | 1 | 9 | 4 | 1.2 | |
| persist_terminal_model_turnsrc/connection.rs:2163 | fn | 35 | 1 | 2 | 4 | 1.1 | |
| require_body_for_channelsrc/connection.rs:590 | fn | 12 | 4 | 1 | 0 | 1.1 | |
| ensure_voice_scriptsrc/connection.rs:828 | fn | 32 | 7 | 1 | 1 | 1.1 | |
| fund_quotasrc/connection.rs:3100 | fn | 14 | 1 | 10 | 1 | 1 | |
| ctx_with_message_storesrc/connection.rs:3235 | fn | 3 | 1 | 3 | 1 | 1 | |
| prepare_model_turn_requestsrc/connection.rs:1888 | fn | 67 | 14 | 3 | 16 | 1 | |
| require_private_context_threadsrc/connection.rs:2298 | fn | 13 | 3 | 2 | 0 | 1 | |
| parse_participantssrc/connection.rs:2461 | fn | 16 | 3 | 1 | 1 | 1 | |
| suppresssrc/connection.rs:2782 | fn | 4 | 1 | 5 | 1 | 1 | |
| agent_threadsrc/connection.rs:3125 | fn | 12 | 1 | 8 | 2 | 0.9 | |
| FakeThreadProvider::idsrc/connection.rs:3146 | trait impl | 3 | 1 | 1 | 0 | 0.9 | |
| prepare_provider_sendsrc/connection.rs:615 | fn | 38 | 3 | 5 | 4 | 0.9 | |
| parse_actionsrc/connection.rs:216 | fn | 8 | 1 | 1 | 4 | 0.9 | |
| dispatch_core_actionsrc/connection.rs:293 | fn | 19 | 4 | 1 | 3 | 0.9 | |
| dispatch_thread_actionsrc/connection.rs:330 | fn | 19 | 10 | 1 | 9 | 0.9 | |
| dispatch_comment_actionsrc/connection.rs:350 | fn | 12 | 3 | 1 | 2 | 0.9 | |
| dispatch_payload_actionsrc/connection.rs:363 | fn | 7 | 3 | 1 | 3 | 0.9 | |
| ctx_with_graph_atsrc/connection.rs:3074 | fn | 7 | 1 | 7 | 3 | 0.9 | |
| run_comment_postsrc/connection.rs:2383 | fn | 41 | 1 | 1 | 6 | 0.9 | |
| run_comment_listsrc/connection.rs:2425 | fn | 35 | 2 | 1 | 4 | 0.9 | |
| quota_balancesrc/connection.rs:3115 | fn | 9 | 1 | 7 | 1 | 0.9 | |
| reject_mismatched_claimsrc/connection.rs:2324 | fn | 16 | 2 | 6 | 3 | 0.8 | |
| unknown_action_responsesrc/connection.rs:405 | fn | 6 | 1 | 2 | 0 | 0.8 | |
| prepared_callsrc/connection.rs:2796 | fn | 7 | 1 | 2 | 1 | 0.8 | |
| required_subject_fieldsrc/connection.rs:2359 | fn | 3 | 1 | 2 | 0 | 0.8 | |
| commit_sent_receiptsrc/connection.rs:2515 | fn | 44 | 4 | 1 | 3 | 0.8 | |
| model_turn_spend_summarysrc/connection.rs:2068 | fn | 9 | 1 | 3 | 0 | 0.8 | |
| settle_model_turn_spendsrc/connection.rs:2095 | fn | 21 | 1 | 3 | 1 | 0.8 | |
| authenticated_accountsrc/connection.rs:2261 | fn | 3 | 1 | 6 | 1 | 0.8 | |
| witness_model_turn_responsesrc/connection.rs:1958 | fn | 16 | 3 | 2 | 2 | 0.8 | |
| suppression_channelsrc/connection.rs:963 | fn | 6 | 2 | 2 | 1 | 0.8 | |
| suppression_addresssrc/connection.rs:970 | fn | 9 | 1 | 2 | 0 | 0.8 | |
| resolve_thread_model_targetsrc/connection.rs:2022 | fn | 17 | 2 | 2 | 3 | 0.8 | |
| dispatch_message_actionsrc/connection.rs:313 | fn | 16 | 8 | 1 | 8 | 0.7 | |
| status_responsesrc/connection.rs:371 | fn | 10 | 1 | 1 | 0 | 0.7 | |
| providers_responsesrc/connection.rs:397 | fn | 7 | 1 | 1 | 0 | 0.7 | |
| persist_suppressed_sendsrc/connection.rs:528 | fn | 44 | 1 | 1 | 4 | 0.7 | |
| persist_successful_sendsrc/connection.rs:738 | fn | 43 | 1 | 1 | 2 | 0.7 | |
| persist_failed_sendsrc/connection.rs:783 | fn | 44 | 1 | 1 | 1 | 0.7 | |
| required_trimmedsrc/connection.rs:2345 | fn | 3 | 1 | 5 | 1 | 0.7 | |
| has_headersrc/connection.rs:690 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| voice_call_idsrc/connection.rs:944 | fn | 8 | 4 | 1 | 1 | 0.7 | |
| apply_unsubscribe_headerssrc/connection.rs:663 | fn | 25 | 4 | 1 | 3 | 0.7 | |
| send_payload_with_call_idsrc/connection.rs:694 | fn | 10 | 3 | 1 | 1 | 0.7 | |
| prepare_voice_callsrc/connection.rs:915 | fn | 28 | 3 | 1 | 3 | 0.7 | |
| parse_core_actionsrc/connection.rs:225 | fn | 16 | 11 | 1 | 0 | 0.7 | |
| parse_thread_actionsrc/connection.rs:242 | fn | 19 | 10 | 1 | 0 | 0.7 | |
| parse_comment_actionsrc/connection.rs:262 | fn | 8 | 3 | 1 | 0 | 0.7 | |
| parse_view_actionsrc/connection.rs:271 | fn | 7 | 2 | 1 | 0 | 0.7 | |
| prepared_emailsrc/connection.rs:2787 | fn | 8 | 2 | 2 | 1 | 0.7 | |
| require_sales_call_consentsrc/connection.rs:884 | fn | 12 | 3 | 2 | 1 | 0.6 | |
| comment_authorsrc/connection.rs:2369 | fn | 13 | 2 | 1 | 2 | 0.6 | |
| persist_failed_model_turnsrc/connection.rs:2137 | fn | 8 | 1 | 2 | 1 | 0.6 | |
| preflight_model_turn_spendsrc/connection.rs:2081 | fn | 10 | 1 | 2 | 3 | 0.6 | |
| message_recordsrc/connection.rs:3239 | fn | 24 | 1 | 1 | 0 | 0.6 | |
| ctx_with_truth_graph_and_providersrc/connection.rs:3192 | fn | 42 | 1 | 2 | 7 | 0.6 | |
| run_create_threadsrc/connection.rs:1110 | fn | 13 | 1 | 1 | 8 | 0.6 | |
| run_send_thread_messagesrc/connection.rs:1190 | fn | 42 | 4 | 1 | 10 | 0.6 | |
| run_list_inboxsrc/connection.rs:1233 | fn | 18 | 1 | 1 | 4 | 0.6 | |
| run_get_threadsrc/connection.rs:1258 | fn | 47 | 1 | 1 | 10 | 0.6 | |
| run_model_turnsrc/connection.rs:1306 | fn | 254 | 29 | 1 | 37 | 0.6 | |
| run_stop_model_turnsrc/connection.rs:1561 | fn | 21 | 1 | 1 | 8 | 0.6 | |
| run_review_workspace_changesrc/connection.rs:1583 | fn | 11 | 1 | 1 | 7 | 0.6 | |
| run_update_thread_policysrc/connection.rs:1595 | fn | 174 | 34 | 1 | 25 | 0.6 | |
| run_remember_context_memorysrc/connection.rs:1770 | fn | 41 | 2 | 1 | 8 | 0.6 | |
| run_sendsrc/connection.rs:419 | fn | 45 | 3 | 1 | 12 | 0.6 | |
| run_suppresssrc/connection.rs:980 | fn | 24 | 3 | 1 | 4 | 0.6 | |
| run_unsuppresssrc/connection.rs:1005 | fn | 14 | 1 | 1 | 3 | 0.6 | |
| run_suppressionssrc/connection.rs:1020 | fn | 14 | 2 | 1 | 2 | 0.6 | |
| run_listsrc/connection.rs:1035 | fn | 16 | 1 | 1 | 1 | 0.6 | |
| run_getsrc/connection.rs:1052 | fn | 19 | 2 | 1 | 1 | 0.6 | |
| run_update_statussrc/connection.rs:1072 | fn | 31 | 3 | 1 | 4 | 0.6 | |
| require_thread_ownersrc/connection.rs:2292 | fn | 5 | 3 | 2 | 0 | 0.6 | |
| required_group_thread_idsrc/connection.rs:1172 | fn | 8 | 1 | 1 | 0 | 0.6 | |
| resolve_validated_context_packsrc/connection.rs:1996 | fn | 16 | 3 | 2 | 3 | 0.6 | |
| resolve_policy_model_providersrc/connection.rs:2013 | fn | 8 | 1 | 2 | 2 | 0.6 | |
| require_model_threadsrc/connection.rs:2281 | fn | 10 | 3 | 2 | 1 | 0.6 | |
| require_context_pack_audiencesrc/connection.rs:2312 | fn | 11 | 3 | 2 | 1 | 0.6 | |
| parse_create_thread_kindsrc/connection.rs:1124 | fn | 5 | 1 | 1 | 1 | 0.6 | |
| parse_create_thread_participantssrc/connection.rs:1130 | fn | 7 | 2 | 1 | 1 | 0.6 | |
| create_thread_in_graphsrc/connection.rs:1138 | fn | 33 | 4 | 1 | 7 | 0.6 | |
| create_thread_responsesrc/connection.rs:1181 | fn | 8 | 1 | 1 | 0 | 0.6 | |
| require_participantsrc/connection.rs:2265 | fn | 7 | 2 | 1 | 0 | 0.6 | |
| suppressed_recipientsrc/connection.rs:488 | fn | 3 | 1 | 1 | 1 | 0.5 | |
| refuse_suppressed_sendsrc/connection.rs:499 | fn | 21 | 4 | 1 | 2 | 0.5 | |
| available_send_providersrc/connection.rs:603 | fn | 11 | 2 | 1 | 1 | 0.5 | |
| persist_send_resultsrc/connection.rs:706 | fn | 30 | 2 | 1 | 2 | 0.5 | |
| idempotent_send_replaysrc/connection.rs:897 | fn | 17 | 3 | 1 | 1 | 0.5 | |
| thread_policy_revision_responsesrc/connection.rs:1812 | fn | 32 | 3 | 1 | 0 | 0.5 | |
| complete_model_turnsrc/connection.rs:1865 | fn | 19 | 3 | 1 | 2 | 0.5 | |
| reject_client_model_policysrc/connection.rs:1975 | fn | 20 | 13 | 1 | 0 | 0.5 | |
| turn_pricing_enabledsrc/connection.rs:2052 | fn | 3 | 1 | 1 | 1 | 0.5 | |
| model_turn_payersrc/connection.rs:2058 | fn | 6 | 1 | 1 | 1 | 0.5 | |
| settle_answered_roundsrc/connection.rs:2122 | fn | 14 | 2 | 1 | 2 | 0.5 | |
| persist_model_turn_errorsrc/connection.rs:2146 | fn | 16 | 3 | 1 | 4 | 0.5 | |
| model_turn_replay_responsesrc/connection.rs:2199 | fn | 27 | 2 | 1 | 0 | 0.5 | |
| compliance_statussrc/connection.rs:386 | fn | 10 | 1 | 0 | 1 | 0.5 | |
| PreparedSendInput::scopesrc/connection.rs:478 | method | 3 | 1 | 0 | 1 | 0.5 | |
| a_library_call_script_binds_into_the_voice_script_and_refuses_missing_valuessrc/connection.rs:2805 | fn | 23 | 1 | 0 | 2 | 0.5 | |
| a_sales_call_needs_recorded_consent_but_a_reminder_does_notsrc/connection.rs:2830 | fn | 24 | 1 | 0 | 4 | 0.5 | |
| a_send_to_a_suppressed_address_is_refused_and_never_reaches_a_providersrc/connection.rs:2856 | fn | 17 | 1 | 0 | 5 | 0.5 | |
| a_suppression_outranks_an_idempotency_key_that_already_succeededsrc/connection.rs:2875 | fn | 17 | 1 | 0 | 4 | 0.5 | |
| a_retried_refused_send_replays_the_first_refusal_instead_of_adding_a_rowsrc/connection.rs:2894 | fn | 14 | 1 | 0 | 5 | 0.5 | |
| a_scoped_suppression_stops_one_sender_and_an_unattributed_send_but_not_a_second_sendersrc/connection.rs:2910 | fn | 13 | 1 | 0 | 4 | 0.5 | |
| list_unsubscribe_headers_reach_the_provider_requestsrc/connection.rs:2925 | fn | 20 | 1 | 0 | 5 | 0.5 | |
| an_unconfigured_runtime_omits_the_headers_and_records_whysrc/connection.rs:2947 | fn | 18 | 1 | 0 | 5 | 0.5 | |
| a_caller_that_mints_its_own_unsubscribe_header_is_not_overriddensrc/connection.rs:2967 | fn | 17 | 1 | 0 | 4 | 0.5 | |
| a_non_email_channel_carries_no_unsubscribe_headerssrc/connection.rs:2986 | fn | 13 | 1 | 0 | 4 | 0.5 | |
| the_operator_surface_adds_lists_and_releases_suppressionssrc/connection.rs:3001 | fn | 23 | 1 | 0 | 5 | 0.5 | |
| TestSessionAccount::authenticated_session_account_idsrc/connection.rs:3085 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| FakeThreadProvider::default_modelsrc/connection.rs:3150 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| FakeThreadProvider::completesrc/connection.rs:3154 | trait impl | 20 | 2 | 0 | 1 | 0.5 | |
| create_dm_thread_is_deterministicsrc/connection.rs:3265 | fn | 25 | 1 | 0 | 3 | 0.5 | |
| create_group_thread_requires_thread_idsrc/connection.rs:3292 | fn | 15 | 1 | 0 | 3 | 0.5 | |
| rich_message_round_trip_preserves_parts_and_membershipsrc/connection.rs:3309 | fn | 22 | 1 | 0 | 3 | 0.5 | |
| rich_model_turn_replays_exact_parts_and_rejects_changed_mediasrc/connection.rs:3333 | fn | 15 | 1 | 0 | 5 | 0.5 | |
| dm_round_trip_appends_and_loads_messagessrc/connection.rs:3350 | fn | 45 | 1 | 0 | 3 | 0.5 | |
| list_inbox_returns_threads_for_identitysrc/connection.rs:3397 | fn | 51 | 1 | 0 | 3 | 0.5 | |
| send_thread_message_rejects_unknown_threadsrc/connection.rs:3450 | fn | 15 | 1 | 0 | 3 | 0.5 | |
| get_thread_errors_on_unknown_idsrc/connection.rs:3467 | fn | 6 | 1 | 0 | 3 | 0.5 | |
| private_thread_operations_require_membership_and_reject_spoofed_identitysrc/connection.rs:3475 | fn | 33 | 1 | 0 | 3 | 0.5 | |
| model_turn_persists_completion_and_replays_without_a_second_provider_callsrc/connection.rs:3510 | fn | 75 | 1 | 0 | 8 | 0.5 | |
| signed_context_pack_is_inert_immutable_provider_context_and_replays_oncesrc/connection.rs:3587 | fn | 101 | 2 | 0 | 16 | 0.5 | |
| context_pack_attachment_is_denied_for_shared_human_audiences_before_signingsrc/connection.rs:3690 | fn | 50 | 1 | 0 | 7 | 0.5 | |
| model_turn_rejects_client_provider_model_and_budget_policysrc/connection.rs:3742 | fn | 34 | 2 | 0 | 3 | 0.5 | |
| owner_policy_revision_drives_new_turns_while_old_turn_replay_stays_boundsrc/connection.rs:3778 | fn | 111 | 2 | 0 | 5 | 0.5 | |
| owner_selected_provider_is_exact_and_stale_targets_fail_before_claimsrc/connection.rs:3891 | fn | 121 | 1 | 0 | 8 | 0.5 | |
| model_turn_and_transcript_survive_protocol_store_reopensrc/connection.rs:4014 | fn | 74 | 1 | 0 | 10 | 0.5 | |
| agent_session_origin_may_participate_but_never_creates_or_pays_for_a_threadsrc/connection.rs:4090 | fn | 44 | 2 | 0 | 4 | 0.5 | |
| model_turn_debits_the_agent_payer_and_publishes_a_spend_receiptsrc/connection.rs:4136 | fn | 37 | 1 | 0 | 8 | 0.5 | |
| unaffordable_agent_payer_fails_the_turn_closed_without_a_provider_callsrc/connection.rs:4175 | fn | 33 | 1 | 0 | 6 | 0.5 | |
| turn_pricing_disarmed_meters_the_spend_without_moving_valuesrc/connection.rs:4210 | fn | 27 | 1 | 0 | 7 | 0.5 | |
| ToolCallingThreadProvider::idsrc/connection.rs:4246 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| ToolCallingThreadProvider::default_modelsrc/connection.rs:4250 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| ToolCallingThreadProvider::completesrc/connection.rs:4254 | trait impl | 15 | 1 | 0 | 0 | 0.5 | |
| a_round_the_provider_answered_is_charged_even_when_the_turn_failssrc/connection.rs:4272 | fn | 41 | 1 | 0 | 11 | 0.5 | |
| get_thread_pages_newest_first_and_the_cursor_walks_backwardssrc/connection.rs:4315 | fn | 64 | 2 | 0 | 7 | 0.5 | |
| invalid_participant_ref_is_a_clean_errorsrc/connection.rs:4381 | fn | 14 | 1 | 0 | 3 | 0.5 | |
| update_status_resolves_by_id_and_provider_message_idsrc/connection.rs:4397 | fn | 45 | 1 | 0 | 4 | 0.5 | |
| update_status_validates_required_lookup_and_statussrc/connection.rs:4444 | fn | 12 | 1 | 0 | 2 | 0.5 | |
| send_with_mock_provider_persists_and_replays_idempotent_successsrc/connection.rs:4458 | fn | 25 | 1 | 0 | 2 | 0.5 | |
| auto_select_never_returns_a_placeholder_providersrc/connection.rs:4489 | fn | 12 | 3 | 0 | 1 | 0.5 | |
| auto_select_email_prefers_the_configured_real_providersrc/connection.rs:4503 | fn | 8 | 1 | 0 | 2 | 0.5 | |
| auto_select_email_errors_when_no_real_provider_is_availablesrc/connection.rs:4513 | fn | 16 | 1 | 0 | 2 | 0.5 | |
| explicit_mock_provider_still_resolvessrc/connection.rs:4531 | fn | 7 | 2 | 0 | 1 | 0.5 | |
| comment_list_before_any_post_is_empty_oksrc/connection.rs:4542 | fn | 10 | 1 | 0 | 2 | 0.5 | |
| comment_post_then_list_round_trips_nested_parent_chainsrc/connection.rs:4554 | fn | 66 | 1 | 0 | 2 | 0.5 | |
| comment_thread_id_is_deterministic_across_postssrc/connection.rs:4622 | fn | 20 | 1 | 0 | 2 | 0.5 | |
| comment_subject_ids_with_slashes_are_slug_safesrc/connection.rs:4644 | fn | 24 | 1 | 0 | 2 | 0.5 | |
| comment_author_prefers_verified_caller_then_actor_then_anonsrc/connection.rs:4670 | fn | 26 | 1 | 0 | 2 | 0.5 | |
| comment_post_validates_required_fieldssrc/connection.rs:4698 | fn | 18 | 1 | 0 | 2 | 0.5 | |
| comment_list_honours_limit_but_reports_full_countsrc/connection.rs:4718 | fn | 25 | 2 | 0 | 2 | 0.5 |
Source not readable from this process.