Functions — github.com/AppFlowy-IO/AppFlowy-Cloud

hub / github.com/AppFlowy-IO/AppFlowy-Cloud / functions

Functions3,042 in github.com/AppFlowy-IO/AppFlowy-Cloud

⨍ Functions 3,042◇ Types & classes 910

↓ 2 callersMethodget_template_categories

( &self, name_contains: Option<&str>, category_type: Option<TemplateCategoryType>, )

libs/client-api/src/http_template.rs:62

↓ 2 callersMethodget_template_category

( &self, category_id: Uuid, )

libs/client-api/src/http_template.rs:80

↓ 2 callersMethodget_template_creator

( &self, creator_id: Uuid, )

libs/client-api/src/http_template.rs:156

↓ 2 callersFunctionget_user_owned_workspaces

( access_token: &str, appflowy_cloud_base_url: &str, )

admin_frontend/src/ext/api.rs:14

↓ 2 callersMethodget_user_session

( &self, session_id: &str, )

admin_frontend/src/session.rs:37

↓ 2 callersMethodget_workspace_database_collab

(&self, workspace_id: Uuid)

libs/client-api-test/src/test_client.rs:345

↓ 2 callersFunctionget_workspace_member

( uid: i64, pg_pool: &PgPool, workspace_id: &Uuid, )

src/biz/workspace/ops.rs:585

↓ 2 callersMethodget_workspace_member

( &self, params: QueryWorkspaceMember, )

libs/client-api/src/http_member.rs:155

↓ 2 callersFunctionget_workspace_members

( workspace_id: &str, access_token: &str, appflowy_cloud_base_url: &str, )

admin_frontend/src/ext/api.rs:95

↓ 2 callersMethodget_workspace_updates

( &self, workspace_id: &WorkspaceId, since: MessageId, )

services/appflowy-collaborate/src/collab/collab_manager.rs:227

↓ 2 callersFunctiongetting_started_document_data

()

libs/workspace-template/src/document/getting_started.rs:346

↓ 2 callersMethodhandle_client_message

Handle the message sent from the client

services/appflowy-collaborate/src/group/group_init.rs:552

↓ 2 callersFunctionhandle_collab_message

( weak_collab_channels: &Weak<RwLock<ChannelByObjectId>>, collab_messages: Vec<ServerCollabMessage>, )

libs/client-api/src/ws/client.rs:419

↓ 2 callersFunctionhandle_failed_task

( context: &mut TaskContext, import_record: &AFImportTask, task: &NotionImportTask, stream_name: &str,

services/appflowy-worker/src/import_worker/worker.rs:366

↓ 2 callersMethodhandle_protocol

(&mut self, bytes: Bytes, ctx: &mut ws::WebsocketContext<Self>)

services/appflowy-collaborate/src/ws2/actors/session.rs:106

↓ 2 callersMethodhandle_receive

(&self, msg: ServerMessage)

libs/client-api/src/v2/actor.rs:623

↓ 2 callersMethodhandle_sync_step2

Handle reply for a sync-step-1 send from this replica previously. By default just apply an update to current `awareness` document instance.

libs/collab-rt-protocol/src/protocol.rs:31

↓ 2 callersMethodhandle_user_disconnect

Handles the disconnection of a user from the system. remove a user based on their device and session ID. If the session ID of the disconnecting user

services/appflowy-collaborate/src/connect_state.rs:92

↓ 2 callersFunctionhome_handler

( State(state): State<AppState>, session: Option<UserSession>, jar: CookieJar, )

admin_frontend/src/web_app.rs:440

↓ 2 callersMethodimport_file

Sends a POST request to import a file to the server. This function streams the contents of a file located at the provided `file_path` as part of a mu

libs/client-api/src/http_file.rs:126

↓ 2 callersFunctionimport_notion_zip_until_complete

upload_after_secs: simulate the delay of uploading the file

tests/workspace/import_test.rs:216

↓ 2 callersMethodincr_failure_write_count

(&self, count: i64)

src/api/metrics.rs:215

↓ 2 callersMethodincr_fallback_read_count

(&self, count: i64)

src/api/metrics.rs:223

↓ 2 callersMethodincr_success_write_count

(&self, count: i64)

src/api/metrics.rs:207

↓ 2 callersMethodindex_pending_collabs

Index all pending collabs in the background

libs/indexer/src/scheduler.rs:207

↓ 2 callersFunctioninitialize_workspace_for_user

( uid: i64, user_uuid: &Uuid, row: &AFWorkspaceRow, txn: &mut Transaction<'_, sqlx::Postgres>, templ

src/biz/user/user_init.rs:21

↓ 2 callersFunctioninsert_answer_message

( pg_pool: &PgPool, author: ChatAuthor, chat_id: &str, content: String, metadata: Option<serde_json:

libs/database/src/chat/chat_ops.rs:303

↓ 2 callersFunctioninsert_answer_message_with_transaction

( transaction: &mut Transaction<'_, Postgres>, author: ChatAuthor, chat_id: &str, content: String, m

libs/database/src/chat/chat_ops.rs:196

↓ 2 callersFunctioninsert_blob_metadata

( pg_pool: &PgPool, file_id: &str, workspace_id: &Uuid, file_type: &str, file_size: usize, )

libs/database/src/resource_usage.rs:36

↓ 2 callersMethodinsert_data_with_timestamp

( &self, object_id: &Uuid, data: &[u8], millis_secs: MillisSeconds, expiration_seconds: Op

services/appflowy-collaborate/src/collab/cache/mem_cache.rs:408

↓ 2 callersFunctioninsert_database_row

( state: &AppState, workspace_uuid: Uuid, database_uuid: Uuid, uid: i64, new_db_row_id: Option<Uuid>

src/biz/collab/ops.rs:428

↓ 2 callersMethodinsert_encode_collab_data

( &self, workspace_id: &Uuid, uid: &i64, params: CollabParams, transaction: &mut Transacti

services/appflowy-collaborate/src/collab/cache/collab_cache.rs:592

↓ 2 callersFunctioninsert_or_replace_publish_collabs

( pg_pool: &PgPool, workspace_id: &Uuid, publisher_uuid: &Uuid, publish_items: Vec<PublishCollabItem<s

libs/database/src/publish.rs:245

↓ 2 callersFunctioninsert_question_message

( executor: E, author: ChatAuthorWithUuid, chat_id: &str, content: String, )

libs/database/src/chat/chat_ops.rs:330

↓ 2 callersFunctioninsert_related_templates

( executor: E, view_id: Uuid, category_ids: &[Uuid], )

libs/database/src/template.rs:443

↓ 2 callersFunctioninsert_template_view_template_category

( executor: E, view_id: Uuid, category_ids: &[Uuid], )

libs/database/src/template.rs:401

↓ 2 callersFunctioninsert_user_workspace

( pg_pool: &PgPool, user_uuid: &Uuid, workspace_name: &str, workspace_icon: &str, is_initialized: bo

libs/database/src/workspace.rs:44

↓ 2 callersMethodinsert_view_to_general_space

( &self, workspace_id: &Uuid, view_id: &str, view_name: &str, view_layout: ViewLayout,

libs/client-api-test/src/test_client.rs:161

↓ 2 callersFunctionis_blob_metadata_exists

( pool: &PgPool, workspace_id: &Uuid, file_id: &str, )

libs/database/src/resource_usage.rs:13

↓ 2 callersMethodis_collab_deleted

(&self, object_id: &Uuid)

services/appflowy-collaborate/src/collab/cache/disk_cache.rs:523

↓ 2 callersMethodis_compressed

(&self)

libs/collab-stream/src/model.rs:436

↓ 2 callersMethodis_dirty_since

(&self, object_id: &Uuid, millis_seconds: MillisSeconds)

services/appflowy-collaborate/src/collab/cache/collab_cache.rs:110

↓ 2 callersFunctionis_empty_update

(update: &[u8], flag: &UpdateFlags)

services/appflowy-collaborate/src/ws2/actors/workspace.rs:923

↓ 2 callersMethodis_init_sync

(&self)

libs/collab-rt-entity/src/client_message.rs:109

↓ 2 callersMethodis_v2_encoded

(&self)

libs/collab-stream/src/model.rs:426

↓ 2 callersMethodlayout

(&self)

libs/workspace-template/src/document/vault_template.rs:46

↓ 2 callersMethodlease

( &self, workspace_id: &str, object_id: &str, )

libs/collab-stream/src/client.rs:65

↓ 2 callersMethodleave_workspace

(&self, workspace_id: &Uuid)

libs/client-api/src/http_member.rs:15

↓ 2 callersFunctionlist_database_row_ids

( collab_storage: &Arc<dyn CollabStore>, workspace_uuid: Uuid, database_uuid: Uuid, )

src/biz/collab/ops.rs:401

↓ 2 callersMethodlist_database_row_ids

( &self, workspace_id: &Uuid, database_id: &str, )

libs/client-api/src/http_collab.rs:178

↓ 2 callersMethodlist_published_views

( &self, workspace_id: &Uuid, )

libs/client-api/src/http_publish.rs:19

↓ 2 callersMethodload_collab_full

(&self)

services/appflowy-collaborate/src/group/group_init.rs:1258

↓ 2 callersMethodload_compact

Loads collab without its history. Used for handling y-sync protocol messages.

services/appflowy-collaborate/src/group/group_init.rs:1018

↓ 2 callersFunctionload_group_policies

(enforcer: &mut CachedEnforcer)

libs/access-control/src/casbin/access.rs:279

↓ 2 callersFunctionmail_box_size

()

services/appflowy-collaborate/src/actix_ws/server/rt_actor.rs:49

↓ 2 callersFunctionmake_clients

Create two clients and the first client makes an edit to the collaborative document. The second client did do init sync but disable receive message, s

tests/collab/missing_update_test.rs:48

↓ 2 callersFunctionmake_last_message_id_key

(workspace_id: &Uuid)

libs/client-api/src/v2/db.rs:402

↓ 2 callersMethodmark_as_duplicate

(&mut self)

libs/database-entity/src/dto.rs:814

↓ 2 callersMethodmergeable

(&self)

libs/client-api/src/collab_sync/collab_sink.rs:652

↓ 2 callersMethodmetrics

(&self)

services/appflowy-collaborate/src/collab/collab_store.rs:99

↓ 2 callersMethodmsg_id

(&self)

libs/collab-rt-entity/src/message.rs:167

↓ 2 callersMethodname

(&self)

libs/appflowy-ai-client/src/dto.rs:273

↓ 2 callersFunctionnew_session_cookie

(id: uuid::Uuid)

admin_frontend/src/session.rs:297

↓ 2 callersMethodnotify_next

Notify the sink to process the next message.

libs/client-api/src/collab_sync/collab_sink.rs:401

↓ 2 callersMethodnotify_progress

(&self, progress: ImportProgress)

services/appflowy-worker/src/import_worker/email_notifier.rs:15

↓ 2 callersMethodnumber_of_connected_users

(&self)

services/appflowy-collaborate/src/connect_state.rs:115

↓ 2 callersMethodparse_blob_url_v1

Returns the workspace_id, parent_dir, and file_id from the given blob url.

libs/client-api/src/http_blob.rs:106

↓ 2 callersMethodpartial_cmp

(&self, other: &Self)

libs/access-control/src/act.rs:82

↓ 2 callersFunctionpatch_collabs

( pg_pool: &PgPool, workspace_id: &Uuid, user_uuid: &Uuid, patches: &[PatchPublishedCollab], )

src/biz/workspace/publish.rs:612

↓ 2 callersMethodping

(&self)

libs/client-api/src/v2/actor.rs:257

↓ 2 callersFunctionpolicies_for_subject_with_given_object

( subject: SubjectType, object_type: ObjectType, enforcer: &CachedEnforcer, )

libs/access-control/src/casbin/util.rs:6

↓ 2 callersFunctionpool

()

tests/collab/storage_test.rs:515

↓ 2 callersMethodport

(&self)

src/application.rs:100

↓ 2 callersMethodpost_realtime_binary

(&self, message: Vec<u8>)

libs/client-api-test/src/test_client.rs:951

↓ 2 callersMethodprocess_next_msg

(&self)

libs/client-api/src/collab_sync/collab_sink.rs:275

↓ 2 callersMethodprocess_query_batch

( &self, workspace_id: &Uuid, queries: Vec<QueryCollab>, )

services/appflowy-collaborate/src/collab/cache/collab_cache.rs:438

↓ 2 callersFunctionprocess_response_data

(resp: reqwest::Response)

libs/client-api/src/http.rs:1283

↓ 2 callersMethodpublish_awareness

( &self, object_id: ObjectId, collab_type: CollabType, update: AwarenessUpdate, )

libs/client-api/src/v2/actor.rs:1091

↓ 2 callersMethodpublish_collabs

( &self, publish_items: Vec<PublishCollabItem<serde_json::Value, Vec<u8>>>, workspace_id: &Uuid,

src/biz/workspace/publish.rs:314

↓ 2 callersMethodpublish_manifest

(&self, object_id: ObjectId, collab: &Collab, collab_type: CollabType)

libs/client-api/src/v2/actor.rs:1053

↓ 2 callersMethodpush_msg

(&mut self, msg_id: MsgId, msg: Msg)

libs/client-api/src/collab_sync/collab_sink.rs:592

↓ 2 callersMethodqueue_init_sync

When queue the init message, the sink will clear all the pending messages and send the init message immediately.

libs/client-api/src/collab_sync/collab_sink.rs:144

↓ 2 callersFunctionquick_note_resource_url

(base_url: &str, workspace_id: Uuid, quick_note_id: Uuid)

libs/client-api/src/http_quick_note.rs:14

↓ 2 callersFunctionread_bytes_from_file

(file_name: &str)

tests/yrs_version/util.rs:4

↓ 2 callersMethodread_u32_little_endian

(&mut self)

src/api/util.rs:160

↓ 2 callersMethodrecord_embed_count

(&self, count: u64)

libs/indexer/src/metrics.rs:59

↓ 2 callersMethodrecord_prompt_usage_count

(&self, prompt_id: &str, count: u64)

src/biz/chat/metrics.rs:86

↓ 2 callersMethodrecord_total_completion_count

(&self, count: u64)

src/biz/chat/metrics.rs:74

↓ 2 callersMethodrecord_update_size_bytes

(&self, size: usize)

src/api/metrics.rs:277

↓ 2 callersMethodrecord_write_embedding_time

(&self, millis: u128)

libs/indexer/src/metrics.rs:71

↓ 2 callersFunctionredis_connection_manager

()

tests/collab/util.rs:169

↓ 2 callersMethodrefresh_if_expired

Refresh token if given timestamp is close to the token expiration time

libs/client-api/src/http.rs:1110

↓ 2 callersMethodregister_template

( &mut self, name: &str, template: &str, )

libs/mailer/src/sender.rs:49

↓ 2 callersMethodrelease

(&mut self)

libs/collab-stream/src/lease.rs:22

↓ 2 callersMethodremove_policies

( &mut self, _sec: &str, _ptype: &str, _rules: Vec<Vec<String>>, )

libs/access-control/src/casbin/adapter.rs:162

↓ 2 callersMethodremove_policy

(&self, sub: SubjectType, obj: ObjectType)

libs/access-control/src/casbin/access.rs:90

↓ 2 callersMethodremove_user

(&self, user: &RealtimeUser)

services/appflowy-collaborate/src/group/state.rs:156

↓ 2 callersFunctionremove_workspace_members

( pg_pool: &PgPool, workspace_id: &Uuid, member_emails: &[String], workspace_access_control: Arc<dyn W

src/biz/workspace/ops.rs:531

↓ 2 callersMethodremove_workspace_members

( &self, workspace_id: &Uuid, member_emails: Vec<String>, )

libs/client-api/src/http_member.rs:138

↓ 2 callersFunctionreplace_json_placeholders

Replace the placeholders in the JSON value with the given replacements. The placeholders are in the format of "<key>", for example "<name>". The valu

libs/workspace-template/src/document/getting_started.rs:370

← previous next →601–700 of 3,042, ranked by callers