MCPcopy Create free account

hub / github.com/casouri/collab-mode / functions

Functions852 in github.com/casouri/collab-mode

⨍ Functions 852◇ Types & classes 667
↓ 1 callersMethodhandle_send_ops_from_editor
( &mut self, next: &Next<'a>, params: SendOpsParams, )
collab_mode/src/server.rs:3746
↓ 1 callersMethodhandle_share_file_from_editor
( &mut self, params: ShareFileParams, )
collab_mode/src/server.rs:3976
↓ 1 callersMethodhandle_signaling_bound_msg
Handle SignalingMsg::Bound message.
collab_mode/src/server.rs:4793
↓ 1 callersMethodhandle_signaling_connect_msg
Handle SignalingMsg::Connect message.
collab_mode/src/server.rs:4825
↓ 1 callersMethodhandle_snapshot
( &mut self, next: &Next<'a>, snapshot: NewSnapshot, remote_host_id: ServerId,
collab_mode/src/server.rs:3227
↓ 1 callersMethodhandle_undo_from_editor
(&mut self, params: UndoParams)
collab_mode/src/server.rs:3850
↓ 1 callersMethodhandle_update_config_from_editor
( &mut self, params: UpdateConfigParams, )
collab_mode/src/server.rs:4653
↓ 1 callersFunctionhey
()
collab_mode/src/webchannel/ssh_remote.rs:188
↓ 1 callersFunctionice_connect_with_sock
( mut sock: crate::signaling::client::Sock, progress_tx: Option<mpsc::Sender<ConnectionState>>, is
collab_mode/src/ice.rs:33
↓ 1 callersFunctionice_exchange_candidates_with_sock
Exchange ICE candidates with peer using Sock.
collab_mode/src/ice.rs:113
↓ 1 callersFunctionice_monitor_progress
( agent: Arc<Agent>, progress_tx: Option<mpsc::Sender<ConnectionState>>, error_tx: mpsc::Sender<We
collab_mode/src/ice.rs:172
↓ 1 callersMethodid
Get peer's ID.
collab_mode/src/signaling/client.rs:369
↓ 1 callersMethodinit_for_envoy
Bootstrap server state for envoy mode from a parsed `Msg::EnvoyInit` payload. - Registers the projects to share. - Trusts the host. - Pre-populates `
collab_mode/src/server.rs:892
↓ 1 callersFunctioninit_test_tracing
Helper function to initialize tracing for tests
collab_mode/src/webchannel/e2e_tests.rs:16
↓ 1 callersFunctioninit_test_tracing
()
collab_mode/src/server/transcript_tests.rs:10
↓ 1 callersMethodinject_message
Synthesize a transport-layer message into `host`’s inbox. Test escape hatch for events the in-process transport doesn’t generate on its own (e.g. `Con
collab_mode/src/server/tests/mod.rs:76
↓ 1 callersMethodinverse
Create the inverse of this op.
collab_mode/src/op.rs:130
↓ 1 callersFunctionisBlacklisted
(db: D1Database, certHash: string)
worker/src/d1.ts:5
↓ 1 callersFunctionisBound
(db: D1Database, endpointId: EndpointId)
worker/src/d1.ts:67
↓ 1 callersMethodis_buffer
(&self)
collab_mode/src/server.rs:92
↓ 1 callersMethodis_cert_trusted
Check whether `cert_hash` is trusted.
collab_mode/src/server.rs:1199
↓ 1 callersMethodis_dead
A handle is “dead” once its actor has dropped the receiver (connection broke or shutdown).
collab_mode/src/webchannel.rs:270
↓ 1 callersMethodis_project
Check if this descriptor represents a project (directory)
collab_mode/src/types.rs:224
↓ 1 callersFunctionkey_cert
()
collab_mode/src/webchannel/ssh_remote.rs:184
↓ 1 callersFunctionkey_cert_from_pem
Reconstruct a [`KeyCert`] from PEM strings — the inverse of [`generate_temp_key_cert`]. Used by the envoy to load the identity it received in `Msg::En
collab_mode/src/config_man.rs:112
↓ 1 callersMethodkind
(&self)
collab_mode/src/types.rs:272
↓ 1 callersMethodlimit
* Rate limit a request based on the provided options. * @see https://developers.cloudflare.com/workers/runtime-apis/bindings/rate-limit/ * @
worker/worker-configuration.d.ts:11946
↓ 1 callersMethodlist_files_from_remote
( &mut self, next: &Next<'a>, dir: Option<FileDesc>, remote_host_id: ServerId,
collab_mode/src/server.rs:2623
↓ 1 callersMethodlive_len
Return the length of this range. If this range is dead, return 0.
collab_mode/src/engine.rs:75
↓ 1 callersMethodload
(code: WorkerLoaderWorkerCode)
worker/worker-configuration.d.ts:3436
↓ 1 callersMethodlocal_docs_not_in_any_project
Return all locally hosted docs whose absolute paths are not under any declared project. These correspond to the _files virtual project.
collab_mode/src/server.rs:1153
↓ 1 callersMethodlog
* The **`console.log()`** static method outputs a message to the console. * * [MDN Reference](https://developer.mozilla.org/docs/Web/API/con
worker/worker-configuration.d.ts:177
↓ 1 callersMethodmake_directory_from_editor
( &mut self, next: &Next<'a>, file_desc: EditorFileDesc, )
collab_mode/src/server.rs:3053
↓ 1 callersFunctionmake_ice_agent
Create an ICE agent for WebRTC connection.
collab_mode/src/ice.rs:204
↓ 1 callersFunctionmake_id
Compose a [`ServerId`] from an optional name and a cert hash.
collab_mode/src/types.rs:62
↓ 1 callersMethodmark_remote_connected
(&mut self, peer: &ServerId)
collab_mode/src/server.rs:391
↓ 1 callersMethodmark_signaling_bound
(&mut self, addr: &str)
collab_mode/src/server.rs:437
↓ 1 callersMethodmove_cursor
(&mut self, offset: i64)
collab_mode/src/server/transcript_tests.rs:40
↓ 1 callersMethodnext_request_id
(&self)
collab_mode/src/server/tests/mod.rs:213
↓ 1 callersFunctionnotification_to_string
Convert lsp_server::Notification to a human-readable string
collab_mode/src/server.rs:5221
↓ 1 callersMethodopen_file_from_editor
( &mut self, next: &Next<'a>, file_desc: EditorFileDesc, mode: OpenMode, )
collab_mode/src/server.rs:2906
↓ 1 callersMethodpackage_local_ops
Return pending local ops.
collab_mode/src/engine.rs:1414
↓ 1 callersFunctionparse_identity_header
Parse the `<timestamp>:<base64-cert>` form of an [`Identity`] from a header string. Matches `Identity`'s `Serialize`/`Deserialize` shape.
collab_mode/src/signaling.rs:74
↓ 1 callersFunctionparse_transcript
Parse transcript file
collab_mode/src/server/transcript_tests.rs:224
↓ 1 callersMethodpeer_connection_id
Live `connection_id` for `host`'s actor handling `peer`. Tests use this to synthesize `Msg::ConnectionBroke` / `Msg::FailedToConnect` whose id matches
collab_mode/src/server/tests/mod.rs:88
↓ 1 callersMethodpending_local_ops
Return the length of pending local ops that haven’t been acked.
collab_mode/src/engine.rs:1428
↓ 1 callersMethodprev_op_acked
Return whether the previous ops we sent to the server have been acked.
collab_mode/src/engine.rs:1404
↓ 1 callersMethodprint_history
(&self)
collab_mode/src/engine.rs:1203
↓ 1 callersMethodprint_history_debug
(&self)
collab_mode/src/engine.rs:1249
↓ 1 callersMethodprocess_opkind
Process a local op according to its kind, return a suitable OpKind for the op. `op_seq` is the inferred global seq for the local op.
collab_mode/src/engine.rs:1142
↓ 1 callersFunctionquatradic_transform
Transform ops1 against ops2, and transform ops2 against ops1. Return the transformed ops1 and ops2. Pass the shorter list as `ops1` because it's copie
collab_mode/src/op.rs:288
↓ 1 callersFunctionread_from_stream
( stream: Arc<stream::Stream>, msg_tx: mpsc::Sender<Message>, remote_hostid: ServerId, last_pi
collab_mode/src/webchannel.rs:1069
↓ 1 callersMethodrecord_command
(&mut self, idx: usize, cmd: TranscriptCommand)
collab_mode/src/server/transcript_tests.rs:457
↓ 1 callersMethodrecv_candidate
Receive ICE candidate from peer.
collab_mode/src/signaling/client.rs:364
↓ 1 callersMethodrecv_sdp
Receive SDP from peer.
collab_mode/src/signaling/client.rs:343
↓ 1 callersMethodremove_by_editor_desc
Remove a remote doc by EditorFileDesc.
collab_mode/src/server.rs:777
↓ 1 callersMethodremove_endpoint
Remove binding for endpoint with `id`.
collab_mode/src/signaling/server.rs:126
↓ 1 callersMethodremove_signaling
(&mut self, addr: &str)
collab_mode/src/server.rs:479
↓ 1 callersFunctionreplaceTrust
( db: D1Database, endpointId: EndpointId, trusted: EndpointId[], )
worker/src/d1.ts:49
↓ 1 callersFunctionreplace_whitespace_char
(string: String)
collab_mode/src/op.rs:157
↓ 1 callersFunctionrequest_to_string
Convert lsp_server::Request to a human-readable string
collab_mode/src/server.rs:5167
↓ 1 callersFunctionresign
Sign `id` directly with `key_cert`'s private key
collab_mode/src/signaling/auth.rs:94
↓ 1 callersFunctionresponse_to_string
Convert lsp_server::Response to a human-readable string
collab_mode/src/server.rs:5180
↓ 1 callersFunctionresult_to_string
(result: &Option<serde_json::Value>)
collab_mode/src/server.rs:5190
↓ 1 callersFunctionrun_envoy
Run as an envoy: read `Msg::EnvoyInit` from stdin, configure the server from it, then run `Server::run` with stdio as the only peer transport.
collab_mode/src/main.rs:178
↓ 1 callersMethodrun_inner
Single select loop over the four event sources. Returns the reason we’re exiting.
collab_mode/src/webchannel.rs:774
↓ 1 callersMethodrun_inner
Single select loop over outgoing commands and inbound frames. Returns the reason we’re exiting.
collab_mode/src/webchannel/io_remote.rs:71
↓ 1 callersFunctionrun_stdio
Run the editor receptor on stdio. Returns when fatal error occurs.
collab_mode/src/editor_receptor.rs:11
↓ 1 callersFunctionrun_transcript_test
Run a transcript test
collab_mode/src/server/transcript_tests.rs:517
↓ 1 callersMethodsave_config
Write the current configuration to disk
collab_mode/src/config_man.rs:398
↓ 1 callersFunctionsend_receive_stream
( mut stream: WebSocketStream<TcpStream>, req_tx: mpsc::Sender<Result<Message, tung::tungstenite::Erro
collab_mode/src/signaling/server.rs:348
↓ 1 callersFunctionsend_response
( editor_tx: &mpsc::Sender<lsp_server::Message>, id: lsp_server::RequestId, result: impl Serialize
collab_mode/src/server.rs:5091
↓ 1 callersMethodsetWebSocketAutoResponse
(maybeReqResp?: WebSocketRequestResponsePair)
worker/worker-configuration.d.ts:548
↓ 1 callersMethodset_remote_pending
(&mut self, peer: &ServerId, transport: webchannel::TransportConfig)
collab_mode/src/server.rs:373
↓ 1 callersMethodshutdown
Send `Bye` to connected peers, save owned docs to disk, and shutdown. Roughly bounded by [`SHUTDOWN_TIMEOUT`].
collab_mode/src/server.rs:1087
↓ 1 callersMethodsite_id_of
Get the site id assigned to host. Create one if not assigned yet.
collab_mode/src/server.rs:3293
↓ 1 callersFunctionstart_connect_1
Inner body of [`WebChannel::start_connect`]: await the future to get the transport, run `connect` with it, then send all the post-connect messages to
collab_mode/src/webchannel.rs:183
↓ 1 callersFunctionstream_id_init
Determine which side uses odd stream IDs based on host ID ordering. The host with lexicographically smaller ID uses odd stream IDs (1, 3, 5...) The h
collab_mode/src/webchannel.rs:69
↓ 1 callersMethodtext
()
worker/worker-configuration.d.ts:2055
↓ 1 callersMethodtoString
()
worker/worker-configuration.d.ts:512
↓ 1 callersMethodtoken
Clone a cancellation token out.
collab_mode/src/cancel.rs:59
↓ 1 callersFunctiontransform_di
( op: &(u64, String), base: &(u64, String), op_site: &SiteId, base_site: &SiteId, )
collab_mode/src/op.rs:90
↓ 1 callersFunctiontransform_ii
( op: &(u64, String), base: &(u64, String), op_site: &SiteId, base_site: &SiteId, )
collab_mode/src/op.rs:69
↓ 1 callersMethodtry_connect_remote
( &mut self, next: &Next<'a>, host_id: ServerId, transport_config: webchannel:
collab_mode/src/server.rs:2406
↓ 1 callersMethodtry_connect_remote_sctp
( &mut self, next: &Next<'a>, host_id: ServerId, transport_config: webchannel:
collab_mode/src/server.rs:2439
↓ 1 callersMethodtry_connect_remote_ssh
Connect to a remote envoy via ssh. Spawn `ssh ssh_host -- collab-mode --envoy`, send `Msg::EnvoyInit`, then `Msg::Hey`.
collab_mode/src/server.rs:2474
↓ 1 callersMethodupdate_trust
Override the trust list for `id`. No-op if `id` is not bound.
collab_mode/src/signaling/server.rs:118
↓ 1 callersFunctionupsertBindingAndTrust
( db: D1Database, endpointId: EndpointId, certHash: string, trusted: EndpointId[], )
worker/src/d1.ts:25
↓ 1 callersFunctionvalidate_bind
Validate the `X-Collab-*` bind headers from a WebSocket upgrade request. On success returns `(endpoint_id, trusted_set)` so the outer task can registe
collab_mode/src/signaling/server.rs:150
↓ 1 callersMethodwait
(delay: number, maybeOptions?: SchedulerWaitOptions)
worker/worker-configuration.d.ts:878
↓ 1 callersFunctionwait_for_bound
Wait for Bound message from signaling server
collab_mode/src/webchannel/e2e_tests.rs:119
↓ 1 callersFunctionwait_for_signaling_server
Wait for the signaling server to be ready by attempting to connect to it. Returns Ok(()) when connection succeeds, Err if timeout is reached.
collab_mode/src/server/tests/mod.rs:101
Method"assert"
(condition?: boolean, ...data: any[])
worker/worker-configuration.d.ts:105
Method[Symbol.asyncIterator]
(options?: ReadableStreamValuesOptions)
worker/worker-configuration.d.ts:2259
Methodabort
(reason?: string)
worker/worker-configuration.d.ts:554
Methodabort
(name: string, reason: any)
worker/worker-configuration.d.ts:623
Methodabort
(self)
collab_mode/src/server/tests/connection.rs:22
Methodack
()
worker/worker-configuration.d.ts:1978
MethodackAll
()
worker/worker-configuration.d.ts:1985
MethodackAll
()
worker/worker-configuration.d.ts:1992
← previousnext →301–400 of 852, ranked by callers