Check if user can update node

lib/Helper/IProcessingFileAccessor.php

@@ -25,15 +25,15 @@
 
 interface IProcessingFileAccessor {
 	/**
-	 * Returns the id of the file which is currently
+	 * Returns the path of the file which is currently
 	 * processed via OCR
-	 * @return ?int
+	 * @return ?string
 	 */
-	public function getCurrentlyProcessedFileId() : ?int;
+	public function getCurrentlyProcessedFilePath() : ?string;
 
 	/**
-	 * Sets the id of the file which is currently
+	 * Sets the path of the file which is currently
 	 * processed via OCR
 	 */
-	public function setCurrentlyProcessedFileId(?int $fileId) : void;
+	public function setCurrentlyProcessedFilePath(?string $filePath) : void;
 }

lib/Helper/ProcessingFileAccessor.php

@@ -24,15 +24,15 @@
 namespace OCA\WorkflowOcr\Helper;
 
 /**
- * This class is a singleton which holds the id
+ * This class is a singleton which holds the path
  * of the currently OCR processed file. This ensures
  * that a files is not added to the processing queue
  * if the 'postWrite' hook was triggered by a new
  * version created by the OCR process.
  */
 class ProcessingFileAccessor implements IProcessingFileAccessor {
-	/** @var ?int */
-	private $currentlyProcessedFileId;
+	/** @var ?string */
+	private $currentlyProcessedFilePath;
 
 	/** @var ProcessingFileAccessor */
 	private static $instance;
@@ -50,14 +50,14 @@ private function __construct() {
 	/**
 	 * @inheritdoc
 	 */
-	public function getCurrentlyProcessedFileId() : ?int {
-		return $this->currentlyProcessedFileId;
+	public function getCurrentlyProcessedFilePath() : ?string {
+		return $this->currentlyProcessedFilePath;
 	}
 
 	/**
 	 * @inheritdoc
 	 */
-	public function setCurrentlyProcessedFileId(?int $fileId) : void {
-		$this->currentlyProcessedFileId = $fileId;
+	public function setCurrentlyProcessedFilePath(?string $filePath) : void {
+		$this->currentlyProcessedFilePath = $filePath;
 	}
 }

lib/Operation.php

@@ -226,7 +226,7 @@ private function tryGetJobArgs(Node $node, $operation, & $argsArray) : bool {
 
 	private function eventTriggeredByOcrProcess(Node $node) : bool {
 		// Check if the event was triggered by OCR rewrite of the file
-		if ($node->getId() === $this->processingFileAccessor->getCurrentlyProcessedFileId()) {
+		if ($node->getPath() === $this->processingFileAccessor->getCurrentlyProcessedFilePath()) {
 			$this->logger->debug('Not processing event because file with path \'{path}\' was written by OCR process.',
 				['path' => $node->getPath()]);
 			return true;

lib/Service/OcrService.php

@@ -252,7 +252,7 @@ private function createNewFileVersion(string $filePath, string $ocrContent, int
 		$dirPath = dirname($filePath);
 		$filename = basename($filePath);
 
-		$this->processingFileAccessor->setCurrentlyProcessedFileId($fileId);
+		$this->processingFileAccessor->setCurrentlyProcessedFilePath($filePath);
 
 		try {
 			$view = $this->viewFactory->create($dirPath);
@@ -267,7 +267,7 @@ private function createNewFileVersion(string $filePath, string $ocrContent, int
 				$view->touch($filename, $fileMtime);
 			}
 		} finally {
-			$this->processingFileAccessor->setCurrentlyProcessedFileId(null);
+			$this->processingFileAccessor->setCurrentlyProcessedFilePath(null);
 		}
 	}
 
@@ -315,14 +315,23 @@ private function doPostProcessing(Node $file, string $uid, WorkflowSettings $set
 
 		// Only create a new file version if the file OCR result was not empty #130
 		if ($result->getRecognizedText() !== '') {
-			if ($settings->getKeepOriginalFileVersion()) {
+			if ($settings->getKeepOriginalFileVersion() && $file->isUpdateable()) {
 				// Add label to original file to prevent its expiry
 				$this->setFileVersionsLabel($file, $uid, self::FILE_VERSION_LABEL_VALUE);
 			}
 
-			$newFilePath = $originalFileExtension === $newFileExtension ?
-				$filePath :
-				$filePath . '.pdf';
+			if ($originalFileExtension === $newFileExtension) {
+				if (!$file->isUpdateable()) {
+					// Add suffix '_OCR' if original file cannot be updated
+					$fileInfo = pathinfo($filePath);
+					$newFilePath = $fileInfo['dirname'] . '/' . $fileInfo['filename'] . '_OCR.' . $originalFileExtension;
+				} else {
+					$newFilePath = $filePath;
+				}
+			} else {
+				$newFilePath = $filePath . '.pdf';
+			}
+
 
 			$this->createNewFileVersion($newFilePath, $fileContent, $fileId, $fileMtime);
 		}

tests/Unit/Helper/ProcessingFIleAccessorTest.php

@@ -36,8 +36,8 @@ public function testSingleton() {
 
 	public function testGetSet() {
 		$o = ProcessingFileAccessor::getInstance();
-		$o ->setCurrentlyProcessedFileId(42);
-		$this->assertEquals(42, $o->getCurrentlyProcessedFileId());
-		$o->setCurrentlyProcessedFileId(null);
+		$o ->setCurrentlyProcessedFilePath('/someuser/files/somefile.pdf');
+		$this->assertEquals('/someuser/files/somefile.pdf', $o->getCurrentlyProcessedFilePath());
+		$o->setCurrentlyProcessedFilePath(null);
 	}
 }