1 viewer
rust 1,860,549 · typescript 235,540 · javascript 132,956 · python 20,426 · 6,408 files · digest f04d4637f52b · built in 1.5 s · crystals off
crates/cre8-app-social/src/bot/bluesky/jetstream.rs
Items
const DEFAULT_JETSTREAM const READ_TIMEOUT const POST_COLLECTION const FOLLOW_COLLECTION const LIKE_COLLECTION const WANTED_COLLECTIONS const EVENT_NEW_POST const EVENT_FOLLOW const EVENT_LIKE struct JetstreamWatch impl JetstreamWatch enum JetstreamRead enum JetstreamMessageAction const OUR_DID
Functions
By call-graph weight (PageRank; 1.0 is the average function). 40 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| parse_framesrc/bot/bluesky/jetstream.rs:207 | fn | 11 | 4 | 10 | 4 | 3.3 | |
| frame_stampsrc/bot/bluesky/jetstream.rs:197 | fn | 6 | 2 | 3 | 0 | 1.6 | |
| jetstream_message_actionsrc/bot/bluesky/jetstream.rs:160 | fn | 9 | 5 | 2 | 0 | 1.5 | |
| emit_jetstream_textsrc/bot/bluesky/jetstream.rs:180 | fn | 5 | 2 | 2 | 1 | 1.5 | |
| create_commitsrc/bot/bluesky/jetstream.rs:319 | fn | 6 | 1 | 2 | 2 | 1.3 | |
| JetstreamWatch::is_selfsrc/bot/bluesky/jetstream.rs:53 | method | 3 | 2 | 3 | 0 | 1.2 | |
| parse_post_framesrc/bot/bluesky/jetstream.rs:219 | fn | 29 | 2 | 1 | 2 | 1.2 | |
| parse_follow_framesrc/bot/bluesky/jetstream.rs:251 | fn | 20 | 2 | 1 | 3 | 1.2 | |
| parse_like_framesrc/bot/bluesky/jetstream.rs:275 | fn | 21 | 2 | 1 | 4 | 1.2 | |
| frame_with_engagement_subjectsrc/bot/bluesky/jetstream.rs:303 | fn | 7 | 2 | 2 | 0 | 1.1 | |
| body_matches_keywordssrc/bot/bluesky/jetstream.rs:334 | fn | 7 | 2 | 2 | 0 | 1.1 | |
| self_watchsrc/bot/bluesky/jetstream.rs:355 | fn | 3 | 1 | 5 | 0 | 1.1 | |
| jetstream_urlsrc/bot/bluesky/jetstream.rs:58 | fn | 11 | 3 | 3 | 1 | 1.1 | |
| require_commit_framesrc/bot/bluesky/jetstream.rs:326 | fn | 3 | 1 | 1 | 0 | 1 | |
| require_create_operationsrc/bot/bluesky/jetstream.rs:330 | fn | 3 | 1 | 1 | 0 | 1 | |
| apply_read_timeoutsrc/bot/bluesky/jetstream.rs:170 | fn | 9 | 3 | 1 | 0 | 1 | |
| follow_framesrc/bot/bluesky/jetstream.rs:359 | fn | 8 | 1 | 4 | 0 | 1 | |
| like_framesrc/bot/bluesky/jetstream.rs:368 | fn | 9 | 1 | 4 | 0 | 1 | |
| emit_jetstream_binarysrc/bot/bluesky/jetstream.rs:186 | fn | 5 | 2 | 2 | 1 | 0.9 | |
| keyword_watchsrc/bot/bluesky/jetstream.rs:351 | fn | 3 | 1 | 2 | 0 | 0.9 | |
| at_uri_didsrc/bot/bluesky/jetstream.rs:313 | fn | 3 | 1 | 2 | 0 | 0.9 | |
| jetstream_timeoutsrc/bot/bluesky/jetstream.rs:192 | fn | 3 | 2 | 2 | 0 | 0.8 | |
| handle_jetstream_messagesrc/bot/bluesky/jetstream.rs:115 | fn | 16 | 3 | 1 | 3 | 0.8 | |
| handle_jetstream_control_messagesrc/bot/bluesky/jetstream.rs:132 | fn | 18 | 4 | 1 | 1 | 0.7 | |
| run_jetstreamsrc/bot/bluesky/jetstream.rs:70 | fn | 19 | 3 | 1 | 4 | 0.6 | |
| open_jetstream_socketsrc/bot/bluesky/jetstream.rs:90 | fn | 6 | 1 | 1 | 1 | 0.6 | |
| read_jetstream_messagesrc/bot/bluesky/jetstream.rs:103 | fn | 11 | 4 | 1 | 2 | 0.6 | |
| jetstream_url_subscribes_to_posts_follows_and_likessrc/bot/bluesky/jetstream.rs:379 | fn | 8 | 1 | 0 | 2 | 0.5 | |
| jetstream_url_keeps_an_operator_filter_verbatimsrc/bot/bluesky/jetstream.rs:389 | fn | 5 | 1 | 0 | 2 | 0.5 | |
| follow_frames_are_dropped_without_self_didssrc/bot/bluesky/jetstream.rs:396 | fn | 4 | 1 | 0 | 3 | 0.5 | |
| follow_of_us_becomes_a_follow_eventsrc/bot/bluesky/jetstream.rs:402 | fn | 8 | 1 | 0 | 3 | 0.5 | |
| like_on_our_post_becomes_a_like_event_carrying_the_postsrc/bot/bluesky/jetstream.rs:412 | fn | 7 | 1 | 0 | 3 | 0.5 | |
| engagement_frames_stamp_the_account_of_ours_they_landed_onsrc/bot/bluesky/jetstream.rs:421 | fn | 19 | 2 | 0 | 5 | 0.5 | |
| at_uri_did_reads_the_repositorysrc/bot/bluesky/jetstream.rs:442 | fn | 5 | 1 | 0 | 3 | 0.5 | |
| parse_frame_extracts_postsrc/bot/bluesky/jetstream.rs:449 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| parse_frame_keyword_filtersrc/bot/bluesky/jetstream.rs:459 | fn | 7 | 1 | 0 | 2 | 0.5 | |
| keywords_never_filter_engagement_framessrc/bot/bluesky/jetstream.rs:468 | fn | 5 | 1 | 0 | 3 | 0.5 | |
| message_action_classifies_socket_framessrc/bot/bluesky/jetstream.rs:475 | fn | 7 | 1 | 0 | 1 | 0.5 | |
| binary_frames_emit_valid_utf8_posts_onlysrc/bot/bluesky/jetstream.rs:484 | fn | 11 | 1 | 0 | 2 | 0.5 | |
| frame_guards_and_timeout_helpers_cover_negative_pathssrc/bot/bluesky/jetstream.rs:497 | fn | 14 | 1 | 0 | 5 | 0.5 |
Source not readable from this process.