1 viewer

rust 1,855,033 · typescript 234,882 · javascript 132,632 · python 19,643 · 6,389 files · digest d8586b9e8a33 · built in 1.5 s · crystals off

crates/cre8-app-messaging/src/thread.rs

cre8-app-messaging · module thread · src · 2,800 lines (2,423 code, 205 comment) · sha 35325edb348f1f03

Items

const KIND_MESSAGE const VID_KIND_MESSAGE const KIND_MODEL_TURN const VID_KIND_MODEL_TURN const EDGE_THREAD_MODEL_TURN const KIND_THREAD_CAPABILITY_POLICY const VID_KIND_THREAD_CAPABILITY_POLICY const EDGE_THREAD_CAPABILITY_POLICY const EDGE_MODEL_TURN_POLICY const KIND_THREAD_POLICY_MUTATION const VID_KIND_THREAD_POLICY_MUTATION const EDGE_THREAD_POLICY_MUTATION const EDGE_POLICY_MUTATION_POLICY const EDGE_POLICY_SUPERSEDES const KIND_CONTEXT_PACK const VID_KIND_CONTEXT_PACK const EDGE_POLICY_CONTEXT_PACK const EDGE_MODEL_TURN_CONTEXT_PACK const THREAD_CAPABILITY_POLICY_VERSION const DEFAULT_THREAD_TRANSCRIPT_MESSAGE_LIMIT const DEFAULT_THREAD_MAX_OUTPUT_TOKENS const APPROVED_PROVIDER_SELECTION_PREFIX const APPROVED_MODEL_SELECTION_PREFIX enum ThreadKind impl ThreadKind enum Role impl Role struct ThreadMember struct ThreadMessage struct ThreadSnapshot enum ThreadModelTarget impl ThreadModelTarget struct ThreadCapabilityPolicy impl ThreadCapabilityPolicy struct ModelTurnRecord impl ModelTurnRecord enum ModelTurnClaim struct ThreadPolicyMutationRecord enum ThreadPolicyRevisionResult struct PreparedThreadMessage impl PreparedThreadMessage struct ThreadHeader impl ThreadSnapshot struct ThreadMessagePage

Functions

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

function	kind	lines	cyclomatic	callers	callees	weight
ThreadSnapshot::loadsrc/thread.rs:1714	method	10	1	34	4	2.7
prepare_thread_message_with_partssrc/thread.rs:1455	fn	44	3	3	4	2.5
create_thread_internalsrc/thread.rs:1315	fn	50	9	2	4	2.3
alicesrc/thread.rs:1937	fn	3	1	24	1	2.2
ThreadKind::parsesrc/thread.rs:85	method	8	4	3	0	2.1
validate_model_target_idsrc/thread.rs:207	fn	12	6	1	0	2
ThreadCapabilityPolicy::validate_for_executionsrc/thread.rs:375	method	63	23	8	4	1.8
ThreadCapabilityPolicy::next_revision_with_workspacesrc/thread.rs:336	method	36	5	3	4	1.7
ThreadModelTarget::approvedsrc/thread.rs:175	method	5	1	4	1	1.7
append_thread_message_with_partssrc/thread.rs:1427	fn	16	1	2	1	1.7
ThreadCapabilityPolicy::authority_hashsrc/thread.rs:479	method	61	4	4	1	1.6
thread_member_from_edgesrc/thread.rs:1787	fn	20	1	1	2	1.4
thread_message_from_edgesrc/thread.rs:1818	fn	18	1	1	0	1.4
update_model_turnsrc/thread.rs:1665	fn	10	1	7	2	1.4
revise_thread_capability_policy_with_workspacesrc/thread.rs:1009	fn	98	8	2	12	1.4
ThreadCapabilityPolicy::model_targetsrc/thread.rs:541	method	11	4	5	1	1.3
add_participantsrc/thread.rs:1376	fn	30	3	4	4	1.3
append_thread_messagesrc/thread.rs:1416	fn	10	1	11	1	1.3
create_threadsrc/thread.rs:1282	fn	10	1	12	1	1.3
ThreadCapabilityPolicy::next_revision_with_contextsrc/thread.rs:324	method	11	1	1	1	1.3
load_thread_capability_policysrc/thread.rs:762	fn	44	8	7	2	1.3
resolve_thread_capability_policysrc/thread.rs:738	fn	23	4	16	3	1.2
bobsrc/thread.rs:1940	fn	3	1	11	1	1.2
load_thread_capability_policy_by_idsrc/thread.rs:807	fn	37	7	2	4	1.2
default_rolesrc/thread.rs:1925	fn	6	2	2	0	1.2
claim_model_turn_with_partssrc/thread.rs:1521	fn	115	7	2	9	1.1
Role::parsesrc/thread.rs:112	method	8	4	1	0	1.1
load_thread_headersrc/thread.rs:1769	fn	10	1	1	1	1.1
load_thread_memberssrc/thread.rs:1780	fn	6	1	1	1	1.1
load_thread_messagessrc/thread.rs:1808	fn	9	1	1	1	1.1
load_context_pack_for_policysrc/thread.rs:913	fn	29	6	4	4	1
revise_thread_capability_policy_with_contextsrc/thread.rs:992	fn	16	1	3	1	1
zoe_agentsrc/thread.rs:2005	fn	3	1	11	1	1
next_message_seqsrc/thread.rs:1880	fn	4	1	1	1	1
find_or_create_dmsrc/thread.rs:1241	fn	38	4	8	5	1
ensure_inboxsrc/thread.rs:1211	fn	23	2	3	2	1
ThreadCapabilityPolicy::next_revisionsrc/thread.rs:306	method	17	1	1	1	0.9
ThreadCapabilityPolicy::runtime_defaultsrc/thread.rs:262	method	33	2	2	3	0.9
ThreadModelTarget::selection_fieldssrc/thread.rs:181	method	9	2	1	0	0.9
create_thread_ownedsrc/thread.rs:1297	fn	17	3	7	1	0.8
page_thread_messagessrc/thread.rs:1746	fn	22	6	3	0	0.8
list_inbox_threadssrc/thread.rs:1839	fn	38	6	4	4	0.8
ModelTurnRecord::receipt_summarysrc/thread.rs:639	method	31	1	3	0	0.8
policy_vertex_write_opssrc/thread.rs:863	fn	49	4	2	3	0.8
require_workspace_audiencesrc/thread.rs:158	fn	9	7	5	0	0.8
model_turn_idsrc/thread.rs:1885	fn	5	1	2	1	0.8
paged_messagesrc/thread.rs:2692	fn	10	1	2	0	0.8
page_timestampssrc/thread.rs:2703	fn	3	1	2	0	0.8
list_model_turnssrc/thread.rs:1681	fn	29	4	5	1	0.8
claim_model_turnsrc/thread.rs:1505	fn	15	1	6	1	0.7
validate_policy_revision_requestsrc/thread.rs:1143	fn	29	6	2	1	0.7
thread_policy_mutation_idsrc/thread.rs:1173	fn	3	1	2	1	0.7
capability_policy_write_opssrc/thread.rs:845	fn	17	5	2	3	0.7
thread_message_statssrc/thread.rs:1897	fn	27	5	1	0	0.7
find_model_turnsrc/thread.rs:699	fn	34	8	3	3	0.7
thread_existssrc/thread.rs:1637	fn	3	1	2	1	0.6
commit_model_turn_messagesrc/thread.rs:1643	fn	19	1	3	2	0.6
replay_thread_capability_policy_revisionsrc/thread.rs:1108	fn	34	7	2	4	0.6
context_pack_vertex_write_opssrc/thread.rs:943	fn	21	3	1	2	0.6
revise_thread_capability_policysrc/thread.rs:965	fn	26	1	2	1	0.6
prepare_thread_messagesrc/thread.rs:1444	fn	10	1	2	1	0.6
signed_packsrc/thread.rs:2009	fn	25	1	1	3	0.5
ThreadKind::as_strsrc/thread.rs:77	method	7	3	0	0	0.5
Role::as_strsrc/thread.rs:104	method	7	3	0	0	0.5
ThreadModelTarget::summarysrc/thread.rs:191	method	14	2	0	0	0.5
ThreadCapabilityPolicy::next_budget_revisionsrc/thread.rs:296	method	9	1	0	1	0.5
ThreadCapabilityPolicy::summarysrc/thread.rs:439	method	39	2	0	0	0.5
ModelTurnRecord::harness_summarysrc/thread.rs:621	method	16	7	0	0	0.5
PreparedThreadMessage::idsrc/thread.rs:1187	method	3	1	0	0	0.5
workspace_policy_preserves_legacy_commitment_and_binds_every_grant_fieldsrc/thread.rs:1945	fn	25	5	0	6	0.5
workspace_audience_rejects_peers_other_accounts_and_extra_agentssrc/thread.rs:1972	fn	12	2	0	5	0.5
stop_and_terminal_commit_have_a_single_graph_lock_ordersrc/thread.rs:1986	fn	19	1	0	5	0.5
ensure_inbox_is_idempotentsrc/thread.rs:2036	fn	7	1	0	3	0.5
find_or_create_dm_dedups_threadsrc/thread.rs:2045	fn	14	1	0	6	0.5
create_thread_rejects_dm_kindsrc/thread.rs:2061	fn	5	1	0	3	0.5
create_thread_writes_group_with_title_and_memberssrc/thread.rs:2068	fn	14	1	0	6	0.5
owned_thread_creation_records_exact_creator_without_electing_legacy_ownerssrc/thread.rs:2084	fn	27	1	0	8	0.5
owner_policy_revision_is_append_only_idempotent_and_conflict_safesrc/thread.rs:2113	fn	112	1	0	10	0.5
signed_context_pack_is_policy_and_model_turn_hash_boundsrc/thread.rs:2227	fn	64	1	0	12	0.5
approved_model_target_is_hash_bound_and_replays_exactlysrc/thread.rs:2293	fn	55	1	0	10	0.5
append_thread_message_assigns_monotonic_idssrc/thread.rs:2350	fn	8	1	0	5	0.5
append_thread_message_rejects_unknown_threadsrc/thread.rs:2360	fn	5	1	0	3	0.5
snapshot_roundtrips_messages_sorted_by_tssrc/thread.rs:2367	fn	15	1	0	6	0.5
list_inbox_threads_returns_threads_for_identitysrc/thread.rs:2384	fn	25	1	0	9	0.5
add_participant_is_idempotentsrc/thread.rs:2411	fn	8	1	0	6	0.5
snapshot_load_unknown_thread_errorssrc/thread.rs:2421	fn	5	1	0	2	0.5
terminal_model_turn_batch_rolls_back_assistant_message_when_turn_update_failssrc/thread.rs:2428	fn	31	1	0	9	0.5
model_turn_ledger_orders_receipts_and_hides_replay_materialsrc/thread.rs:2461	fn	56	1	0	10	0.5
initial_model_turn_batch_rolls_back_claim_when_user_message_conflictssrc/thread.rs:2519	fn	37	1	0	10	0.5
model_turn_claim_materializes_and_links_default_deny_policysrc/thread.rs:2558	fn	39	1	0	9	0.5
imperative_writers_emit_lowercase_vid_prefixessrc/thread.rs:2607	fn	18	1	0	7	0.5
imperative_thread_inbox_vids_match_declarative_resolver_outputsrc/thread.rs:2627	fn	29	1	0	6	0.5
messaging_case_skew_unifiedsrc/thread.rs:2658	fn	33	1	0	8	0.5
page_thread_messages_windows_the_newest_page_and_reports_the_cursorsrc/thread.rs:2708	fn	32	1	0	3	0.5
page_thread_messages_never_splits_a_shared_millisecondsrc/thread.rs:2742	fn	23	1	0	3	0.5
inbox_headers_carry_the_last_authorsrc/thread.rs:2767	fn	33	1	0	6	0.5

Source not readable from this process.