Merge pull request #4 from julien-nc/feat/deleteSources

add deleteSources function
nextcloud · Nov 9, 2023 · 84ce529 · 84ce529
2 parents 539b8ce + 2ed09fb
commit 84ce529
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 0 deletions.
diff --git a/lib/BackgroundJobs/IndexerJob.php b/lib/BackgroundJobs/IndexerJob.php
@@ -136,6 +136,11 @@ protected function index(array $files): void {
 				}
 				$this->langRopeService->indexSources($userId, [$source]);
 			}
+			try {
+				$this->queue->removeFromQueue($queueFile);
+			} catch (Exception $e) {
+				$this->logger->error('Could not remove file from queue', ['exception' => $e]);
+			}
 		}
 	}
 }
diff --git a/lib/Service/LangRopeService.php b/lib/Service/LangRopeService.php
@@ -46,6 +46,33 @@ private function getExApp() {
 		return $exApp;
 	}
 
+	/**
+	 * @param string $userId
+	 * @param Source[] $sourceNames
+	 * @return void
+	 */
+	public function deleteSources(string $userId, array $sourceNames): void {
+		if (count($sourceNames) === 0) {
+			return;
+	  }
+
+		$params = [
+			'userId' => $userId,
+			'sourceNames' => $sourceNames,
+		];
+
+		$exApp = $this->getExApp();
+		if ($exApp === null) {
+			return;
+		}
+		$this->requestToExApp($userId, $exApp, '/deleteSources', 'POST', $params);
+	}
+
+	/**
+	 * @param string $userId
+	 * @param Source[] $sources
+	 * @return void
+	 */
 	public function indexSources(string $userId, array $sources): void {
 		if (count($sources) === 0) {
 			return;