mirror of
https://github.com/AppFlowy-IO/AppFlowy.git
synced 2025-12-30 00:38:39 +00:00
chore: clippy
This commit is contained in:
parent
8cf31b8afc
commit
7456c65799
@ -284,7 +284,7 @@ impl AppFlowyCollabBuilder {
|
||||
object.uid,
|
||||
object.workspace_id.clone(),
|
||||
object.object_id.to_string(),
|
||||
object.collab_type.clone(),
|
||||
object.collab_type,
|
||||
collab_db,
|
||||
persistence_config,
|
||||
);
|
||||
|
||||
@ -390,7 +390,7 @@ impl AIManager {
|
||||
.get_server_available_models()
|
||||
.await?
|
||||
.into_iter()
|
||||
.map(|m| AIModel::from(m))
|
||||
.map(AIModel::from)
|
||||
.collect();
|
||||
|
||||
trace!("[Model Selection]: Available models: {:?}", models);
|
||||
@ -428,7 +428,7 @@ impl AIManager {
|
||||
None => {
|
||||
// when there is selected model and current local ai is active, then use local ai
|
||||
if let Some(local_ai_model) = models.iter().find(|m| m.is_local) {
|
||||
user_selected_model = AIModel::from(local_ai_model.clone());
|
||||
user_selected_model = local_ai_model.clone();
|
||||
}
|
||||
},
|
||||
Some(model) => {
|
||||
@ -442,14 +442,14 @@ impl AIManager {
|
||||
.iter()
|
||||
.find(|m| m.name == user_selected_model.name)
|
||||
.cloned()
|
||||
.or_else(|| Some(AIModel::from(server_active_model)));
|
||||
.or(Some(server_active_model));
|
||||
|
||||
// Update the stored preference if a different model is used.
|
||||
if let Some(ref active_model) = active_model {
|
||||
if active_model.name != user_selected_model.name {
|
||||
self
|
||||
.store_preferences
|
||||
.set_object::<AIModel>(&source_key, &AIModel::from(active_model.clone()))?;
|
||||
.set_object::<AIModel>(&source_key, &active_model.clone())?;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -24,7 +24,7 @@ impl SnapshotPersistence for SnapshotDBImpl {
|
||||
collab_type: &CollabType,
|
||||
encoded_v1: Vec<u8>,
|
||||
) -> Result<(), PersistenceError> {
|
||||
let collab_type = collab_type.clone();
|
||||
let collab_type = *collab_type;
|
||||
let object_id = object_id.to_string();
|
||||
let weak_user = self.0.clone();
|
||||
tokio::task::spawn_blocking(move || {
|
||||
|
||||
@ -197,7 +197,7 @@ impl FolderQueryService for FolderServiceImpl {
|
||||
}
|
||||
|
||||
async fn get_collab(&self, object_id: &str, collab_type: CollabType) -> Option<QueryCollab> {
|
||||
let encode_collab = get_encoded_collab_v1_from_disk(&self.user, object_id, collab_type.clone())
|
||||
let encode_collab = get_encoded_collab_v1_from_disk(&self.user, object_id, collab_type)
|
||||
.await
|
||||
.ok();
|
||||
|
||||
|
||||
@ -776,7 +776,7 @@ impl DatabaseCollabService for WorkspaceDatabaseCollabServiceImpl {
|
||||
collab_type: CollabType,
|
||||
encoded_collab: Option<(EncodedCollab, bool)>,
|
||||
) -> Result<Collab, DatabaseError> {
|
||||
let object = self.build_collab_object(object_id, collab_type.clone())?;
|
||||
let object = self.build_collab_object(object_id, collab_type)?;
|
||||
let data_source = if self.persistence.is_collab_exist(object_id) {
|
||||
trace!(
|
||||
"build collab: {}:{} from local encode collab",
|
||||
@ -796,7 +796,7 @@ impl DatabaseCollabService for WorkspaceDatabaseCollabServiceImpl {
|
||||
object_id,
|
||||
encoded_collab.is_none(),
|
||||
);
|
||||
match self.get_encode_collab(object_id, collab_type.clone()).await {
|
||||
match self.get_encode_collab(object_id, collab_type).await {
|
||||
Ok(Some(encode_collab)) => {
|
||||
info!(
|
||||
"build collab: {}:{} with remote encode collab, {} bytes",
|
||||
@ -885,7 +885,7 @@ impl DatabaseCollabService for WorkspaceDatabaseCollabServiceImpl {
|
||||
.filter_map(|object_id| {
|
||||
self
|
||||
.persistence
|
||||
.get_encoded_collab(object_id.as_str(), collab_type.clone())
|
||||
.get_encoded_collab(object_id.as_str(), collab_type)
|
||||
.map(|encoded_collab| (object_id.clone(), encoded_collab))
|
||||
})
|
||||
.collect();
|
||||
|
||||
@ -45,7 +45,7 @@ where
|
||||
let cloned_user = self.user.clone();
|
||||
let params = QueryCollabParams {
|
||||
workspace_id: workspace_id.clone(),
|
||||
inner: QueryCollab::new(object_id.clone(), collab_type.clone()),
|
||||
inner: QueryCollab::new(object_id.clone(), collab_type),
|
||||
};
|
||||
let result = try_get_client?.get_collab(params).await;
|
||||
match result {
|
||||
@ -102,7 +102,7 @@ where
|
||||
let client = try_get_client?;
|
||||
let params = object_ids
|
||||
.into_iter()
|
||||
.map(|object_id| QueryCollab::new(object_id, object_ty.clone()))
|
||||
.map(|object_id| QueryCollab::new(object_id, object_ty))
|
||||
.collect();
|
||||
let results = client.batch_get_collab(&workspace_id, params).await?;
|
||||
check_request_workspace_id_is_match(&workspace_id, &cloned_user, "batch get database object")?;
|
||||
|
||||
@ -1248,7 +1248,7 @@ pub async fn upload_collab_objects_data(
|
||||
objects.push(UserCollabParams {
|
||||
object_id: oid,
|
||||
encoded_collab,
|
||||
collab_type: collab_type.clone(),
|
||||
collab_type,
|
||||
});
|
||||
size_counter += obj_size;
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user