disable orphan remover (#2027)

core/src/api/locations.rs

@@ -393,7 +393,7 @@ pub(crate) fn mount() -> AlphaRouter<Ctx> {
 
 						debug!("Disconnected {count} file paths from objects");
 
-						library.orphan_remover.invoke().await;
+						// library.orphan_remover.invoke().await;
 					}
 
 					// rescan location

core/src/library/library.rs

@@ -43,7 +43,7 @@ pub struct Library {
 	// pub key_manager: Arc<KeyManager>,
 	/// p2p identity
 	pub identity: Arc<Identity>,
-	pub orphan_remover: OrphanRemoverActor,
+	// pub orphan_remover: OrphanRemoverActor,
 	// The UUID which matches `config.instance_id`'s primary key.
 	pub instance_uuid: Uuid,
 
@@ -86,7 +86,7 @@ impl Library {
 			db: db.clone(),
 			// key_manager,
 			identity,
-			orphan_remover: OrphanRemoverActor::spawn(db),
+			// orphan_remover: OrphanRemoverActor::spawn(db),
 			instance_uuid,
 			env: node.env.clone(),
 			event_bus_tx: node.event_bus.0.clone(),

core/src/library/manager/mod.rs

@@ -494,7 +494,7 @@ impl Libraries {
 			.insert(library.id, Arc::clone(&library));
 
 		if should_seed {
-			library.orphan_remover.invoke().await;
+			// library.orphan_remover.invoke().await;
 			indexer::rules::seed::new_or_existing_library(&library).await?;
 		}
 

core/src/location/indexer/indexer_job.rs

@@ -497,7 +497,7 @@ impl StatefulJob for IndexerJobInit {
 
 		if run_metadata.total_updated_paths > 0 {
 			// Invoking orphan remover here as we probably have some orphans objects due to updates
-			ctx.library.orphan_remover.invoke().await;
+			// ctx.library.orphan_remover.invoke().await;
 		}
 
 		if run_metadata.indexed_count > 0

core/src/location/indexer/shallow.rs

@@ -190,7 +190,7 @@ pub async fn shallow(
 		invalidate_query!(library, "search.objects");
 	}
 
-	library.orphan_remover.invoke().await;
+	// library.orphan_remover.invoke().await;
 
 	Ok(())
 }

core/src/location/mod.rs

@@ -852,7 +852,7 @@ pub async fn delete_directory(
 
 	db.file_path().delete_many(children_params).exec().await?;
 
-	library.orphan_remover.invoke().await;
+	// library.orphan_remover.invoke().await;
 
 	invalidate_query!(library, "search.paths");
 	invalidate_query!(library, "search.objects");

core/src/object/fs/delete.rs

@@ -105,7 +105,7 @@ impl StatefulJob for FileDeleterJobInit {
 		let init = self;
 		invalidate_query!(ctx.library, "search.paths");
 
-		ctx.library.orphan_remover.invoke().await;
+		// ctx.library.orphan_remover.invoke().await;
 
 		Ok(Some(json!({ "init": init })))
 	}