chore: Init sync when missing updates (#5001)

* chore: bump client api

* chore: update

* chore: update

* chore: bump client api

* chore: bump client api
This commit is contained in:
Nathan.fooo
2024-03-29 19:34:51 +08:00
committed by GitHub
parent 0e7b3c7db2
commit c2c84a5812
10 changed files with 94 additions and 93 deletions

View File

@ -3,7 +3,7 @@ use std::sync::Arc;
use std::time::Duration;
use anyhow::Error;
use client_api::collab_sync::collab_msg::ServerCollabMessage;
use client_api::collab_sync::ServerCollabMessage;
use client_api::entity::UserMessage;
use client_api::notify::{TokenState, TokenStateReceiver};
use client_api::ws::{

View File

@ -5,7 +5,7 @@ use flowy_storage::ObjectStorageService;
use std::sync::Arc;
use anyhow::Error;
use client_api::collab_sync::collab_msg::ServerCollabMessage;
use client_api::collab_sync::ServerCollabMessage;
use parking_lot::RwLock;
use tokio_stream::wrappers::WatchStream;
#[cfg(feature = "enable_supabase")]

View File

@ -3,7 +3,7 @@ use std::sync::{Arc, Weak};
use anyhow::Error;
use chrono::{DateTime, Utc};
use client_api::collab_sync::collab_msg::MsgId;
use client_api::collab_sync::MsgId;
use collab::core::collab::DocStateSource;
use collab::preclude::merge_updates_v1;
use collab_entity::CollabObject;

View File

@ -28,7 +28,7 @@ pub(crate) const CREATED_AT: &str = "created_at";
pub fn table_name(ty: &CollabType) -> String {
match ty {
CollabType::DatabaseRow => format!("{}_database_row", AF_COLLAB_UPDATE_TABLE),
CollabType::Document => format!("{}_document", AF_COLLAB_UPDATE_TABLE),
CollabType::Document | CollabType::Empty => format!("{}_document", AF_COLLAB_UPDATE_TABLE),
CollabType::Database => format!("{}_database", AF_COLLAB_UPDATE_TABLE),
CollabType::WorkspaceDatabase => format!("{}_w_database", AF_COLLAB_UPDATE_TABLE),
CollabType::Folder => format!("{}_folder", AF_COLLAB_UPDATE_TABLE),
@ -36,6 +36,14 @@ pub fn table_name(ty: &CollabType) -> String {
}
}
pub fn partition_key(ty: &CollabType) -> i32 {
ty.value()
pub fn partition_key(collab_type: &CollabType) -> i32 {
match collab_type {
CollabType::Document => 0,
CollabType::Database => 1,
CollabType::WorkspaceDatabase => 2,
CollabType::Folder => 3,
CollabType::DatabaseRow => 4,
CollabType::UserAwareness => 5,
CollabType::Empty => 0,
}
}