mirror of
https://github.com/AppFlowy-IO/AppFlowy.git
synced 2024-08-30 18:12:39 +00:00
23997e977c
* chore: upload chat file to local ai * chore: async func * chore: individual file progress * chore: fix test * chore: fix file upload
260 lines
6.5 KiB
Rust
260 lines
6.5 KiB
Rust
use std::ops::Deref;
|
|
use std::sync::Arc;
|
|
|
|
use anyhow::Error;
|
|
use collab::preclude::CollabPlugin;
|
|
use collab_document::blocks::DocumentData;
|
|
use collab_document::document_data::default_document_data;
|
|
use nanoid::nanoid;
|
|
use parking_lot::Once;
|
|
use tempfile::TempDir;
|
|
use tracing_subscriber::{fmt::Subscriber, util::SubscriberInitExt, EnvFilter};
|
|
|
|
use collab_integrate::collab_builder::{
|
|
AppFlowyCollabBuilder, CollabCloudPluginProvider, CollabPluginProviderContext,
|
|
CollabPluginProviderType, WorkspaceCollabIntegrate,
|
|
};
|
|
use collab_integrate::CollabKVDB;
|
|
use flowy_document::document::MutexDocument;
|
|
use flowy_document::entities::{DocumentSnapshotData, DocumentSnapshotMeta};
|
|
use flowy_document::manager::{DocumentManager, DocumentSnapshotService, DocumentUserService};
|
|
use flowy_document_pub::cloud::*;
|
|
use flowy_error::{ErrorCode, FlowyError, FlowyResult};
|
|
use flowy_storage_pub::chunked_byte::ChunkedBytes;
|
|
use flowy_storage_pub::storage::{CreatedUpload, FileProgressReceiver, StorageService};
|
|
use lib_infra::async_trait::async_trait;
|
|
use lib_infra::box_any::BoxAny;
|
|
use lib_infra::future::FutureResult;
|
|
|
|
pub struct DocumentTest {
|
|
inner: DocumentManager,
|
|
}
|
|
|
|
impl DocumentTest {
|
|
pub fn new() -> Self {
|
|
let user = FakeUser::new();
|
|
let cloud_service = Arc::new(LocalTestDocumentCloudServiceImpl());
|
|
let file_storage = Arc::new(DocumentTestFileStorageService) as Arc<dyn StorageService>;
|
|
let document_snapshot = Arc::new(DocumentTestSnapshot);
|
|
|
|
let builder = Arc::new(AppFlowyCollabBuilder::new(
|
|
DefaultCollabStorageProvider(),
|
|
WorkspaceCollabIntegrateImpl {
|
|
workspace_id: user.workspace_id.clone(),
|
|
},
|
|
));
|
|
|
|
let manager = DocumentManager::new(
|
|
Arc::new(user),
|
|
builder,
|
|
cloud_service,
|
|
Arc::downgrade(&file_storage),
|
|
document_snapshot,
|
|
);
|
|
Self { inner: manager }
|
|
}
|
|
}
|
|
|
|
impl Deref for DocumentTest {
|
|
type Target = DocumentManager;
|
|
|
|
fn deref(&self) -> &Self::Target {
|
|
&self.inner
|
|
}
|
|
}
|
|
|
|
pub struct FakeUser {
|
|
workspace_id: String,
|
|
collab_db: Arc<CollabKVDB>,
|
|
}
|
|
|
|
impl FakeUser {
|
|
pub fn new() -> Self {
|
|
setup_log();
|
|
|
|
let tempdir = TempDir::new().unwrap();
|
|
let path = tempdir.into_path();
|
|
let collab_db = Arc::new(CollabKVDB::open(path).unwrap());
|
|
let workspace_id = uuid::Uuid::new_v4().to_string();
|
|
|
|
Self {
|
|
collab_db,
|
|
workspace_id,
|
|
}
|
|
}
|
|
}
|
|
|
|
impl DocumentUserService for FakeUser {
|
|
fn user_id(&self) -> Result<i64, FlowyError> {
|
|
Ok(1)
|
|
}
|
|
|
|
fn workspace_id(&self) -> Result<String, FlowyError> {
|
|
Ok(self.workspace_id.clone())
|
|
}
|
|
|
|
fn collab_db(&self, _uid: i64) -> Result<std::sync::Weak<CollabKVDB>, FlowyError> {
|
|
Ok(Arc::downgrade(&self.collab_db))
|
|
}
|
|
|
|
fn device_id(&self) -> Result<String, FlowyError> {
|
|
Ok("".to_string())
|
|
}
|
|
}
|
|
|
|
pub fn setup_log() {
|
|
static START: Once = Once::new();
|
|
START.call_once(|| {
|
|
std::env::set_var("RUST_LOG", "collab_persistence=trace");
|
|
let subscriber = Subscriber::builder()
|
|
.with_env_filter(EnvFilter::from_default_env())
|
|
.with_ansi(true)
|
|
.finish();
|
|
subscriber.try_init().unwrap();
|
|
});
|
|
}
|
|
|
|
pub async fn create_and_open_empty_document() -> (DocumentTest, Arc<MutexDocument>, String) {
|
|
let test = DocumentTest::new();
|
|
let doc_id: String = gen_document_id();
|
|
let data = default_document_data(&doc_id);
|
|
let uid = test.user_service.user_id().unwrap();
|
|
// create a document
|
|
test
|
|
.create_document(uid, &doc_id, Some(data.clone()))
|
|
.await
|
|
.unwrap();
|
|
|
|
test.open_document(&doc_id).await.unwrap();
|
|
let document = test.get_opened_document(&doc_id).await.unwrap();
|
|
|
|
(test, document, data.page_id)
|
|
}
|
|
|
|
pub fn gen_document_id() -> String {
|
|
let uuid = uuid::Uuid::new_v4();
|
|
uuid.to_string()
|
|
}
|
|
|
|
pub fn gen_id() -> String {
|
|
nanoid!(10)
|
|
}
|
|
|
|
pub struct LocalTestDocumentCloudServiceImpl();
|
|
impl DocumentCloudService for LocalTestDocumentCloudServiceImpl {
|
|
fn get_document_doc_state(
|
|
&self,
|
|
document_id: &str,
|
|
_workspace_id: &str,
|
|
) -> FutureResult<Vec<u8>, FlowyError> {
|
|
let document_id = document_id.to_string();
|
|
FutureResult::new(async move {
|
|
Err(FlowyError::new(
|
|
ErrorCode::RecordNotFound,
|
|
format!("Document {} not found", document_id),
|
|
))
|
|
})
|
|
}
|
|
|
|
fn get_document_snapshots(
|
|
&self,
|
|
_document_id: &str,
|
|
_limit: usize,
|
|
_workspace_id: &str,
|
|
) -> FutureResult<Vec<DocumentSnapshot>, Error> {
|
|
FutureResult::new(async move { Ok(vec![]) })
|
|
}
|
|
|
|
fn get_document_data(
|
|
&self,
|
|
_document_id: &str,
|
|
_workspace_id: &str,
|
|
) -> FutureResult<Option<DocumentData>, Error> {
|
|
FutureResult::new(async move { Ok(None) })
|
|
}
|
|
}
|
|
|
|
pub struct DocumentTestFileStorageService;
|
|
|
|
#[async_trait]
|
|
impl StorageService for DocumentTestFileStorageService {
|
|
fn delete_object(&self, _url: String, _local_file_path: String) -> FlowyResult<()> {
|
|
todo!()
|
|
}
|
|
|
|
fn download_object(&self, _url: String, _local_file_path: String) -> FlowyResult<()> {
|
|
todo!()
|
|
}
|
|
|
|
async fn create_upload(
|
|
&self,
|
|
_workspace_id: &str,
|
|
_parent_dir: &str,
|
|
_local_file_path: &str,
|
|
_upload_immediately: bool,
|
|
) -> Result<(CreatedUpload, Option<FileProgressReceiver>), flowy_error::FlowyError> {
|
|
todo!()
|
|
}
|
|
|
|
async fn start_upload(&self, _chunks: &ChunkedBytes, _record: &BoxAny) -> Result<(), FlowyError> {
|
|
todo!()
|
|
}
|
|
|
|
async fn resume_upload(
|
|
&self,
|
|
_workspace_id: &str,
|
|
_parent_dir: &str,
|
|
_file_id: &str,
|
|
) -> Result<(), FlowyError> {
|
|
todo!()
|
|
}
|
|
|
|
async fn subscribe_file_progress(&self, _url: &str) -> Result<FileProgressReceiver, FlowyError> {
|
|
todo!()
|
|
}
|
|
}
|
|
|
|
struct DefaultCollabStorageProvider();
|
|
|
|
#[async_trait]
|
|
impl CollabCloudPluginProvider for DefaultCollabStorageProvider {
|
|
fn provider_type(&self) -> CollabPluginProviderType {
|
|
CollabPluginProviderType::Local
|
|
}
|
|
|
|
fn get_plugins(&self, _context: CollabPluginProviderContext) -> Vec<Box<dyn CollabPlugin>> {
|
|
vec![]
|
|
}
|
|
|
|
fn is_sync_enabled(&self) -> bool {
|
|
false
|
|
}
|
|
}
|
|
|
|
struct DocumentTestSnapshot;
|
|
impl DocumentSnapshotService for DocumentTestSnapshot {
|
|
fn get_document_snapshot_metas(
|
|
&self,
|
|
_document_id: &str,
|
|
) -> FlowyResult<Vec<DocumentSnapshotMeta>> {
|
|
todo!()
|
|
}
|
|
|
|
fn get_document_snapshot(&self, _snapshot_id: &str) -> FlowyResult<DocumentSnapshotData> {
|
|
todo!()
|
|
}
|
|
}
|
|
|
|
struct WorkspaceCollabIntegrateImpl {
|
|
workspace_id: String,
|
|
}
|
|
impl WorkspaceCollabIntegrate for WorkspaceCollabIntegrateImpl {
|
|
fn workspace_id(&self) -> Result<String, Error> {
|
|
Ok(self.workspace_id.clone())
|
|
}
|
|
|
|
fn device_id(&self) -> Result<String, Error> {
|
|
Ok("fake_device_id".to_string())
|
|
}
|
|
}
|