[BUGFIX] Always catch StopRecordOperationException (#68)

* [BUGFIX] Always catch StopRecordOperationException

When calling `interest:create --update` on a remote ID that exists or `interest:update --create` on a remote ID that doesn't exist, `StopRecordOperationException` will now be caught as it should.

`StopRecordOperationException` is always caught in REST requests and will not be reported as an exception in the response.

Resolves: #67

Author: mabolek

Classes/Command/CreateCommandController.php

@@ -64,14 +64,20 @@ protected function execute(InputInterface $input, OutputInterface $output)
                     throw $exception;
                 }
 
-                (new UpdateRecordOperation(
-                    $data,
-                    $input->getArgument('endpoint'),
-                    $remoteId,
-                    $input->getArgument('language'),
-                    $input->getArgument('workspace'),
-                    $input->getOption('metaData')
-                ))();
+                try {
+                    (new UpdateRecordOperation(
+                        $data,
+                        $input->getArgument('endpoint'),
+                        $remoteId,
+                        $input->getArgument('language'),
+                        $input->getArgument('workspace'),
+                        $input->getOption('metaData')
+                    ))();
+                } catch (StopRecordOperationException $exception) {
+                    $output->writeln($exception->getMessage(), OutputInterface::VERBOSITY_VERY_VERBOSE);
+
+                    continue;
+                }
             } catch (\Throwable $exception) {
                 $exceptions[] = $exception;
             }

Classes/Command/UpdateCommandController.php

@@ -64,14 +64,20 @@ protected function execute(InputInterface $input, OutputInterface $output)
                     throw $exception;
                 }
 
-                (new CreateRecordOperation(
-                    $data,
-                    $input->getArgument('endpoint'),
-                    $remoteId,
-                    $input->getArgument('language'),
-                    $input->getArgument('workspace'),
-                    $input->getOption('metaData')
-                ))();
+                try {
+                    (new CreateRecordOperation(
+                        $data,
+                        $input->getArgument('endpoint'),
+                        $remoteId,
+                        $input->getArgument('language'),
+                        $input->getArgument('workspace'),
+                        $input->getOption('metaData')
+                    ))();
+                } catch (StopRecordOperationException $exception) {
+                    $output->writeln($exception->getMessage(), OutputInterface::VERBOSITY_VERY_VERBOSE);
+
+                    continue;
+                }
             } catch (\Throwable $exception) {
                 $exceptions[] = $exception;
             }

Classes/RequestHandler/AbstractRecordRequestHandler.php

@@ -6,6 +6,7 @@
 
 use Pixelant\Interest\Context;
 use Pixelant\Interest\Database\RelationHandlerWithoutReferenceIndex;
+use Pixelant\Interest\DataHandling\Operation\Event\Exception\StopRecordOperationException;
 use Pixelant\Interest\DataHandling\Operation\Exception\AbstractException;
 use Pixelant\Interest\RequestHandler\ExceptionConverter\OperationToRequestHandlerExceptionConverter;
 use Psr\Http\Message\ResponseInterface;
@@ -335,6 +336,8 @@ protected function handleOperations(&$operationCount = 0): array
 
                         try {
                             $this->handleSingleOperation($table, $remoteId, $language, $workspace, $data);
+                        } catch (StopRecordOperationException $exception) {
+                            continue;
                         } catch (AbstractException $exception) {
                             $exceptions[$table][$remoteId][$language][$workspace] = $exception;
                         }