PR comments

lib/Service/EndpointService.php

@@ -714,6 +714,10 @@ private function processFilePartRule(Rule $rule, array $data, Endpoint $endpoint
             throw new Exception('Filepart rules can only be applied after the object has been created');
         }
 
+        if (isset($rule->getConfiguration()['fileparts_create']) === false) {
+            throw new Exception('No configuration found for fileparts_create');
+        }
+
         $config = $rule->getConfiguration()['fileparts_create'];
 
         $targetId = explode('/', $endpoint->getTargetId());
@@ -782,7 +786,7 @@ private function processFilePartRule(Rule $rule, array $data, Endpoint $endpoint
      * @param string|null $objectId The id of the object.
      *
      * @return array The updated object data.
-     * 
+     *
      * @throws DoesNotExistException
      * @throws LoaderError
      * @throws MultipleObjectsReturnedException
@@ -792,6 +796,10 @@ private function processFilePartRule(Rule $rule, array $data, Endpoint $endpoint
      */
     private function processFilePartUploadRule(Rule $rule, array $data, ?string $objectId = null): array
     {
+        if (isset($rule->getConfiguration()['filepart_upload']) === false) {
+            throw new Exception('No configuration found for filepart_upload');
+        }
+
         $config = $rule->getConfiguration()['filepart_upload'];
 
         $mappedData = $data;

lib/Service/SynchronizationService.php

@@ -309,9 +309,9 @@ public function getObjectFromSource(Synchronization $synchronization, string $en
 	 * @throws Exception If both dynamic and static endpoint configurations are missing or the endpoint cannot be determined.
 	 */
 	private function fetchExtraDataForObject(
-		Synchronization $synchronization, 
-		array $extraDataConfig, 
-		array $object, ?string 
+		Synchronization $synchronization,
+		array $extraDataConfig,
+		array $object, ?string
 		$originId = null
 	)
 	{
@@ -1444,6 +1444,10 @@ private function getRuleById(string $id): ?Rule
      */
     private function processFetchFileRule(Rule $rule, array $data): array
     {
+        if (isset($rule->getConfiguration()['fetch_file'])) {
+            throw new Exception('No configuration found for fetch_file');
+        }
+
         $config = $rule->getConfiguration()['fetch_file'];
 
         $source = $this->sourceMapper->find($config['source']);
@@ -1477,6 +1481,11 @@ private function processFetchFileRule(Rule $rule, array $data): array
      */
     private function processWriteFileRule(Rule $rule, array $data, string $objectId, int $registerId, int $schemaId): array
     {
+
+        if (isset($rule->getConfiguration()['write_file'])) {
+            throw new Exception('No configuration found for write_file');
+        }
+
         $config  = $rule->getConfiguration()['write_file'];
         $dataDot = new Dot($data);
         $content = base64_decode($dataDot[$config['filePath']]);