add action, make some variables more generic

Installation/Action/synczaken.action.json

@@ -0,0 +1,34 @@
+{
+  "title": "ZgwToVrijbrpBirthAction",
+  "$id": "https://vrijbrp.nl/action/vrijbrp.synczaken.action.json",
+  "$schema": "https://json-schema.org/draft/2020-12/action",
+  "version": "0.0.2",
+  "listens": [
+    "vrijbrp.zaken.sync"
+  ],
+  "throws": [],
+  "conditions": {
+    "==": [
+      1,
+      1
+    ]
+  },
+  "class": "CommonGateway\\VrijBRPToZGWBundle\\ActionHandler\\SynchronizeCollectionHandler",
+  "configuration": {
+    "source": "https://vrijbrp.nl/source/vrijbrp.dossiers.source.json",
+    "schema": "https://vng.opencatalogi.nl/schemas/zrc.zaak.schema.json",
+    "mapping": "https://commongateway.nl/mapping/vrijbrp.dossierToZaak.mapping.json",
+    "endpoint": "/api/v1/dossiers/search",
+    "idField": "dossierId",
+    "resultsPath": "result.content",
+    "method": "POST",
+    "body": {
+      "types": [
+        "intra_mun_relocation",
+        "inter_mun_relocation"
+      ]
+    }
+  },
+  "isLockable": false,
+  "isEnabled": true
+}

src/ActionHandler/SynchronizeCollectionHandler.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace CommonGateway\VrijBRPToZGWBundle\ActionHandler;
+
+use App\ActionHandler\ActionHandlerInterface;
+use CommonGateway\VrijBRPToZGWBundle\Service\NewSynchronizationService;
+use CommonGateway\VrijBRPToZGWBundle\Service\VrijBrpService;
+
+class SynchronizeCollectionHandler implements ActionHandlerInterface
+{
+
+    /**
+     * @param NewSynchronizationService $synchronizationService
+     */
+    public function __construct(
+        private readonly NewSynchronizationService $synchronizationService,
+        private readonly VrijBrpService            $vrijBrpService,
+    )
+    {
+    }
+
+    /**
+     *  This function returns the requered configuration as a [json-schema](https://json-schema.org/) array.
+     *
+     * @throws array a [json-schema](https://json-schema.org/) that this  action should comply to
+     */
+    public function getConfiguration(): array
+    {
+        return [
+            '$id'         => 'https://commongateway.nl/ActionHandler/SynchronizationCollectionHandler.ActionHandler.json',
+            '$schema'     => 'https://docs.commongateway.nl/schemas/ActionHandler.schema.json',
+            'title'       => 'SynchronizationCollectionHandler',
+            'description' => '',
+            'required'    => [],
+            'properties'  => [
+            ],
+        ];
+    }
+
+    /**
+     * Run the actual business logic in the appropriate server.
+     *
+     * @param array $data          The data from the call
+     * @param array $configuration The configuration of the action
+     *
+     * @return array
+     */
+    public function run(array $data, array $configuration): array
+    {
+        $configuration = $this->vrijBrpService->setVrijBRPDefaults($configuration);
+
+        return $this->synchronizationService->synchronizeCollectionHandler($data, $configuration);
+    }
+}

src/Service/NewSynchronizationService.php

@@ -149,7 +149,7 @@ public function synchronizeFromSource(Synchronization $synchronization, array $s
      */
     public function getResults(array $configuration, Source $source): array
     {
-        $response = $this->callService->call(source: $source, endpoint: $configuration['endpoint'], method: $configuration['method'], config: ['json' => ['types' => $configuration['types']]]);
+        $response = $this->callService->call(source: $source, endpoint: $configuration['endpoint'], method: $configuration['method'], config: ['json' => $configuration['body']]);
 
         $result = $this->callService->decodeResponse(source: $source, response: $response, contentType: ($configuration['content-type'] ?? 'application/json'));
 
@@ -197,7 +197,7 @@ public function synchronizeCollectionHandler(array $data, array $configuration):
         foreach ($dossiers as $dossier) {
             $dossierDot = new Dot($dossier);
 
-            $synchronization = $this->synchronizationService->findSyncBySource(source: $source, entity: $schema, sourceId: $dossierDot[$configuration['idLocation']], endpoint: $configuration['endpoint']);
+            $synchronization = $this->synchronizationService->findSyncBySource(source: $source, entity: $schema, sourceId: $dossierDot[$configuration['idField']], endpoint: $configuration['endpoint']);
 
             if ($synchronization->getMapping() === null && isset($mapping) === true) {
                 $synchronization->setMapping($mapping);

src/Service/VrijBrpService.php

@@ -16,10 +16,12 @@ public function setVrijBRPDefaults(array $configuration): array
             $configuration['method'] = 'POST';
         }
 
-        if (isset($configuration['types']) === false) {
-            $configuration['types'] = [
-                'intra_mun_relocation',
-                'inter_mun_relocation',
+        if (isset($configuration['body']) === false) {
+            $configuration['body'] = [
+                'types' => [
+                    'intra_mun_relocation',
+                    'inter_mun_relocation',
+                ]
             ];
         }