chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: panic when apply invalid update (#745)

This commit is contained in:
Nathan.fooo 2024-08-24 14:55:49 +08:00 committed by GitHub
parent 1122031735
commit d111282f7e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
services/appflowy-collaborate/src/indexer/document_indexer.rs
View File

@ -53,14 +53,20 @@ impl Indexer for DocumentIndexer {
object_id: &str, object_id: &str,
doc_state: Vec<u8>, doc_state: Vec<u8>,
) -> Result<Option<AFCollabEmbeddings>, AppError> { ) -> Result<Option<AFCollabEmbeddings>, AppError> {
let collab = Collab::new_with_source( let cloned_object_id = object_id.to_string();
CollabOrigin::Server, let collab = tokio::spawn(async move {
object_id, Collab::new_with_source(
DataSource::DocStateV1(doc_state), CollabOrigin::Server,
vec![], &cloned_object_id,
false, DataSource::DocStateV1(doc_state),
) vec![],
.map_err(|e| AppError::Internal(e.into()))?; false,
)
.map_err(|e| AppError::Internal(e.into()))
})
.await
.map_err(|e| AppError::Internal(e.into()))??;
let document = Document::open(collab).map_err(|e| AppError::Internal(e.into()))?; let document = Document::open(collab).map_err(|e| AppError::Internal(e.into()))?;
let mut params = match Self::get_document_contents(&document) { let mut params = match Self::get_document_contents(&document) {
Ok(result) => result, Ok(result) => result,