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

feat: duplicate database for relation

This commit is contained in:
Zack Fu Zi Xiang 2024-09-05 00:17:56 +08:00
parent fe65396f3e
commit 5a2cd05f3f
No known key found for this signature in database
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/biz/workspace/publish_dup.rs
View File

@ -20,12 +20,12 @@ use shared_entity::dto::publish_dto::{PublishDatabaseData, PublishViewInfo, Publ
use shared_entity::dto::workspace_dto; use shared_entity::dto::workspace_dto;
use shared_entity::dto::workspace_dto::ViewLayout; use shared_entity::dto::workspace_dto::ViewLayout;
use sqlx::PgPool; use sqlx::PgPool;
use yrs::any;
use yrs::Out;
use std::collections::HashSet; use std::collections::HashSet;
use std::{collections::HashMap, sync::Arc}; use std::{collections::HashMap, sync::Arc};
use workspace_template::gen_view_id; use workspace_template::gen_view_id;
use yrs::any;
use yrs::updates::encoder::Encode; use yrs::updates::encoder::Encode;
use yrs::Out;
use yrs::{Map, MapRef}; use yrs::{Map, MapRef};
use crate::biz::collab::ops::get_latest_collab_encoded; use crate::biz::collab::ops::get_latest_collab_encoded;
@ -696,10 +696,13 @@ impl PublishCollabDuplicator {
if let Some(db_id) = m.get(&txn, "database_id") { if let Some(db_id) = m.get(&txn, "database_id") {
if let Out::Any(a) = db_id { if let Out::Any(a) = db_id {
if let any::Any::String(s) = a { if let any::Any::String(s) = a {
if !s.is_empty() { if let Some(related_db_view) = published_db.database_relations.get(s.as_ref()) {
// TODO: duplicate database then update database_id if let Some(dup_view_id) =
// m.insert(&mut txn, "database_id", "new_db_id"); self.deep_copy_view(related_db_view, &new_view_id).await?
} {
m.insert(&mut txn, "database_id", dup_view_id);
};
};
} }
} }
} }