MCPcopy Create free account

hub / github.com/Mimir-IM/mimir / functions

Functions338 in github.com/Mimir-IM/mimir

Functionbuild_header_all_known_types_roundtrip
()
src/peer/protocol.rs:614
Functionbuild_header_encodes_type_and_size
()
src/peer/protocol.rs:591
Functionbuild_header_zero_size
()
src/peer/protocol.rs:607
Functionbuild_ping_frame
()
src/peer/connection.rs:957
Functionbuild_request_frame_empty_payload
()
src/mediator/protocol.rs:248
Functionbuild_request_frame_layout
()
src/mediator/protocol.rs:234
Functioncache_excludes_expired_entries
()
src/peer/resolver.rs:665
Functioncache_is_empty_initially
()
src/peer/resolver.rs:642
Functioncache_returns_inserted_key
()
src/peer/resolver.rs:648
Functioncache_sorted_by_priority_descending
()
src/peer/resolver.rs:692
Methodchange_member_status
(&self, mediator_pubkey: Vec<u8>, chat_id: i64, user_pubkey: Vec<u8>, new_permissions: u8)
src/mediator/mod.rs:166
Methodchange_member_status
(&self, chat_id: i64, user_pubkey: &[u8], new_permissions: u8)
src/mediator/client.rs:380
Methodcheck_connections
Probe all live mediator connections by sending a ping. Call this when Yggdrasil connectivity is restored (e.g. from `onConnectivityChanged(true)`) to
src/mediator/mod.rs:89
Methodcheck_connections
Probe all live mediator connections by sending a ping. Call this when Yggdrasil connectivity is restored after a drop. Dead sessions are detected qui
src/mediator/manager.rs:250
Methodconnect
Dial `mediator_pubkey` on `port`, authenticate, and spawn background tasks. Returns the ready-to-use client or an error.
src/mediator/client.rs:64
Methodconnect_to_mediator
Dial `mediator_pubkey` and authenticate. Returns immediately (the actual connection happens asynchronously); the `on_connected` callback fires when a
src/mediator/mod.rs:62
Methodconnect_to_peer
Open an outbound connection to `pubkey`. Returns immediately; `on_peer_connected` fires when mutual auth completes. No-op if the peer is already con
src/peer/mod.rs:564
Methodcreate_chat
Create a new group chat. Includes proof-of-work (~1–5 seconds CPU). Returns the new chat ID assigned by the mediator.
src/mediator/mod.rs:102
Methodcreate_chat
`CMD_CREATE_CHAT` — includes proof-of-work (may take a few seconds).
src/mediator/client.rs:172
Functiondata_recv_task
Runs in its own tokio task. Reads file frames from the remote peer's send-data stream indefinitely and fires callbacks for each one. For FILE_RESPON
src/peer/data_stream.rs:61
Functiondecrypt_truncated_ciphertext_fails
()
src/crypto.rs:272
Functiondecrypt_with_wrong_key_fails
()
src/crypto.rs:264
Methoddelete_chat
(&self, mediator_pubkey: Vec<u8>, chat_id: i64)
src/mediator/mod.rs:116
Methoddelete_chat
(&self, chat_id: i64)
src/mediator/client.rs:204
Methoddelete_message
(&self, mediator_pubkey: Vec<u8>, chat_id: i64, guid: i64)
src/mediator/mod.rs:202
Methoddelete_message
(&self, chat_id: i64, guid: i64)
src/mediator/client.rs:306
Methoddelete_user
(&self, mediator_pubkey: Vec<u8>, chat_id: i64, user_pubkey: Vec<u8>)
src/mediator/mod.rs:147
Methoddelete_user
(&self, chat_id: i64, user_pubkey: &[u8])
src/mediator/client.rs:232
Methoddisconnect_peer
Close the connection to `pubkey` (if any).
src/peer/mod.rs:682
Methoddownload_chunk
Download a chunk of file data. Returns `(chunk_bytes, offset, total_size)`.
src/files/client.rs:188
Methoddownload_file
Download a file from the server and decrypt it to `dest_path`.
src/files/mod.rs:103
Methoddrop
(&mut self)
src/files/client.rs:40
Functionecies_output_is_ephpub_nonce_ciphertext
()
src/crypto.rs:319
Functionecies_roundtrip
()
src/crypto.rs:293
Functionecies_wrong_seed_fails
()
src/crypto.rs:306
Functionencrypt_decrypt_roundtrip
()
src/crypto.rs:253
Functionencrypt_message_output_is_nonce_plus_ciphertext
()
src/crypto.rs:280
Methodephemeral_key
The 32-byte ephemeral seed used for the Yggdrasil node. The app can persist this and pass it back on next start to keep the same routing address acros
src/peer/mod.rs:484
Methoderror_string
Extract the error string from a STATUS_ERR payload (`[len:2 BE][utf8...]`).
src/mediator/protocol.rs:158
Functionerror_string_from_ok_status_is_empty
()
src/mediator/protocol.rs:257
Functionerror_string_parses_correctly
()
src/mediator/protocol.rs:269
Functionerror_string_short_payload_is_empty
()
src/mediator/protocol.rs:263
Methodfile_info
Query file metadata from the server.
src/files/mod.rs:134
Methodfile_info
Query file metadata. Returns `(total_size, message_guid)`.
src/files/client.rs:152
Functiongenerate_shared_key_is_32_bytes
()
src/crypto.rs:237
Functiongenerate_shared_key_produces_different_keys
()
src/crypto.rs:243
Methodget_last_message_id
(&self, mediator_pubkey: Vec<u8>, chat_id: i64)
src/mediator/mod.rs:210
Methodget_last_message_id
(&self, chat_id: i64)
src/mediator/client.rs:315
Methodget_members
(&self, mediator_pubkey: Vec<u8>, chat_id: i64)
src/mediator/mod.rs:263
Methodget_members
(&self, chat_id: i64)
src/mediator/client.rs:372
Methodget_members_info
(&self, mediator_pubkey: Vec<u8>, chat_id: i64, since_timestamp: i64)
src/mediator/mod.rs:255
Methodget_members_info
(&self, chat_id: i64, since_timestamp: i64)
src/mediator/client.rs:363
Methodget_messages_since
(&self, mediator_pubkey: Vec<u8>, chat_id: i64, since_id: i64, limit: u32)
src/mediator/mod.rs:218
Methodget_messages_since
(&self, chat_id: i64, since_id: i64, limit: u32)
src/mediator/client.rs:324
Methodget_paths_json
Yggdrasil routing-path diagnostics, JSON-encoded.
src/peer/mod.rs:718
Methodget_peers_json
Yggdrasil peer-connection diagnostics, JSON-encoded.
src/peer/mod.rs:713
Methodget_str
(&self, tag: u8)
src/tlv.rs:179
Methodget_tree_json
Yggdrasil spanning-tree diagnostics, JSON-encoded.
src/peer/mod.rs:723
Methodget_user_chats
(&self)
src/mediator/client.rs:244
Functionhandle_incoming
Dispatch a fully-parsed incoming frame. `peer_flags` is re-queried after contact request/response events so that permission changes take effect immed
src/peer/connection.rs:528
Functionhandle_outgoing
( cmd: OutgoingCmd, write_tx: &mpsc::UnboundedSender<Vec<u8>>, data_write_tx: &mpsc::UnboundedSend
src/peer/connection.rs:683
Methodhangup_call
Hang up an active or ringing call.
src/peer/mod.rs:701
Methodidle_timeout_loop
Closes the connection after [`IDLE_TIMEOUT`] of no activity.
src/files/client.rs:420
Methodleave_chat
(&self, mediator_pubkey: Vec<u8>, chat_id: i64)
src/mediator/mod.rs:155
Methodleave_chat
(&self, chat_id: i64)
src/mediator/client.rs:269
Functionmain
()
build.rs:1
Functionmain
()
uniffi-bindgen.rs:1
Methodnew
( peer_node: Arc<PeerNode>, files_port: u16, event_listener: Box<dyn FilesEventListene
src/files/mod.rs:44
Methodnew
Create and start the node. `signing_key` – 32-byte Ed25519 seed (private key). `ygg_peers` – Yggdrasil bootstrap peer URIs. `peer_port`
src/peer/mod.rs:239
Methodnew
Create a new Resolver. `tracker_strs` – Tracker addresses in `"<hex32_pubkey>:<port>"` format.
src/peer/resolver.rs:102
Methodnew
(uris: Vec<String>)
src/peer/ygg_selector.rs:69
Methodnew
Create a new `MediatorNode` that shares the Yggdrasil node from `peer_node`. `peer_node` – A running `PeerNode`; its Ygg node and runtime are
src/mediator/mod.rs:39
Methodnew
(node: Arc<AsyncNode>, sk: Arc<SigningKey>, port: u16, listener: Arc<dyn MediatorEventListener>)
src/mediator/manager.rs:41
Methodopt_u64
(&self, tag: u8)
src/tlv.rs:189
Functionparse_get_addrs_bad_signature_is_skipped
()
src/peer/resolver.rs:604
Functionparse_get_addrs_count_mismatch_is_error
()
src/peer/resolver.rs:618
Functionparse_get_addrs_empty_payload
()
src/peer/resolver.rs:558
Functionparse_get_addrs_multiple_records
()
src/peer/resolver.rs:590
Functionparse_get_addrs_valid_single_record
()
src/peer/resolver.rs:574
Functionparse_get_addrs_zero_count
()
src/peer/resolver.rs:565
Functionparse_tracker_bad_hex
()
src/peer/resolver.rs:537
Functionparse_tracker_bad_port
()
src/peer/resolver.rs:543
Functionparse_tracker_missing_colon
()
src/peer/resolver.rs:550
Functionparse_tracker_valid
()
src/peer/resolver.rs:521
Functionparse_tracker_wrong_key_length
()
src/peer/resolver.rs:530
Methodping_loop
(&self, listener: &dyn MediatorEventListener)
src/mediator/client.rs:667
Methodreader_loop
(&self)
src/files/client.rs:380
Methodreader_loop
(&self, listener: &dyn MediatorEventListener)
src/mediator/client.rs:515
Methodrequest_file
Request a file from a connected peer. `name` is the random filename from the message metadata. `hash` is the SHA-256 hex hash for verification. The p
src/peer/mod.rs:672
Methodrespond_to_invite
(&self, mediator_pubkey: Vec<u8>, chat_id: i64, invite_id: i64, accept: bool)
src/mediator/mod.rs:236
Methodrespond_to_invite
(&self, _chat_id: i64, invite_id: i64, accept: bool)
src/mediator/client.rs:344
Methodretry_peers_now
Retry to connect to peers
src/peer/mod.rs:728
Functionrun_inbound
Drive an **inbound** connection to completion. Returns the peer's pubkey and an outgoing-command sender on success.
src/peer/connection.rs:103
Methodsend_call_packet
Send a raw call-packet to `pubkey` during an active call.
src/peer/mod.rs:707
Methodsend_contact_request
Send a contact (friend) request to `pubkey` with an introductory message.
src/peer/mod.rs:655
Methodsend_contact_response
Send a contact response (accept/reject) to `pubkey`.
src/peer/mod.rs:661
Methodsend_group_message
Send an encrypted message blob. Returns the server-assigned message ID.
src/mediator/mod.rs:193
Methodsend_invite
(&self, mediator_pubkey: Vec<u8>, chat_id: i64, recipient_pubkey: Vec<u8>, encrypted_data: Vec<u8>)
src/mediator/mod.rs:228
Methodsend_invite
(&self, chat_id: i64, recipient: &[u8], encrypted_data: &[u8])
src/mediator/client.rs:334
Methodsend_message
Queue a message for delivery to the peer identified by `pubkey`. The connection must already be established (`on_peer_connected` fired).
src/peer/mod.rs:545
← previousnext →201–300 of 338, ranked by callers