Allow mappings on endpoint input and output

appinfo/routes.php

@@ -25,9 +25,9 @@
 		['name' => 'mappings#saveObject', 'url' => '/api/mappings/objects', 'verb' => 'POST'],
 		['name' => 'mappings#getObjects', 'url' => '/api/mappings/objects', 'verb' => 'GET'],
 		// Running endpoints - allow any path after /api/endpoints/
-		['name' => 'endpoints#handlePath', 'url' => '/api/endpoint/{_path}', 'verb' => 'GET', 'requirements' => ['_path' => '.+']],
-//		['name' => 'endpoints#handlePath', 'url' => '/api/endpoint/{path}', 'verb' => 'PUT', 'requirements' => ['path' => '.+']],
-//		['name' => 'endpoints#handlePath', 'url' => '/api/endpoint/{path}', 'verb' => 'POST', 'requirements' => ['path' => '.+']],
-//		['name' => 'endpoints#handlePath', 'url' => '/api/endpoint/{path}', 'verb' => 'DELETE', 'requirements' => ['path' => '.+']],
+		['name' => 'endpoints#handlePath', 'postfix' => 'read', 'url' => '/api/endpoint/{_path}', 'verb' => 'GET', 'requirements' => ['_path' => '.+']],
+		['name' => 'endpoints#handlePath', 'postfix' => 'update', 'url' => '/api/endpoint/{_path}', 'verb' => 'PUT', 'requirements' => ['_path' => '.+']],
+		['name' => 'endpoints#handlePath', 'postfix' => 'create', 'url' => '/api/endpoint/{_path}', 'verb' => 'POST', 'requirements' => ['_path' => '.+']],
+		['name' => 'endpoints#handlePath', 'postfix' => 'destroy', 'url' => '/api/endpoint/{_path}', 'verb' => 'DELETE', 'requirements' => ['_path' => '.+']],
 	],
 ];

lib/Db/Endpoint.php

@@ -23,6 +23,8 @@ class Endpoint extends Entity implements JsonSerializable
 	protected array $conditions = [];
 	protected ?DateTime $created = null;
 	protected ?DateTime $updated = null;
+	protected ?string $inputMapping = null;
+	protected ?string $outputMapping = null;
 
 	public function __construct() {
         $this->addType(fieldName:'uuid', type: 'string');
@@ -39,6 +41,9 @@ public function __construct() {
 		$this->addType(fieldName:'conditions', type: 'json');
 		$this->addType(fieldName:'created', type: 'datetime');
 		$this->addType(fieldName:'updated', type: 'datetime');
+		$this->addType(fieldName:'inputMapping', type: 'string');
+		$this->addType(fieldName:'outputMapping', type: 'string');
+
 	}
 
 	public function getJsonFields(): array
@@ -89,6 +94,8 @@ public function jsonSerialize(): array
 			'conditions' => $this->conditions,
 			'created' => isset($this->created) ? $this->created->format('c') : null,
 			'updated' => isset($this->updated) ? $this->updated->format('c') : null,
+			'inputMapping' => $this->inputMapping,
+			'outputMapping' => $this->outputMapping,
 
 		];
 	}

lib/Migration/Version1Date20241230141628.php

@@ -0,0 +1,60 @@
+<?php
+
+declare(strict_types=1);
+
+/**
+ * SPDX-FileCopyrightText: 2024 Nextcloud GmbH and Nextcloud contributors
+ * SPDX-License-Identifier: AGPL-3.0-or-later
+ */
+
+namespace OCA\OpenConnector\Migration;
+
+use Closure;
+use OCP\DB\ISchemaWrapper;
+use OCP\DB\Types;
+use OCP\Migration\IOutput;
+use OCP\Migration\SimpleMigrationStep;
+
+/**
+ * FIXME Auto-generated migration step: Please modify to your needs!
+ */
+class Version1Date20241230141628 extends SimpleMigrationStep {
+
+	/**
+	 * @param IOutput $output
+	 * @param Closure(): ISchemaWrapper $schemaClosure
+	 * @param array $options
+	 */
+	public function preSchemaChange(IOutput $output, Closure $schemaClosure, array $options): void {
+	}
+
+	/**
+	 * @param IOutput $output
+	 * @param Closure(): ISchemaWrapper $schemaClosure
+	 * @param array $options
+	 * @return null|ISchemaWrapper
+	 */
+	public function changeSchema(IOutput $output, Closure $schemaClosure, array $options): ?ISchemaWrapper {
+		/**
+		 * @var ISchemaWrapper $schema
+		 */
+		$schema = $schemaClosure();
+
+		if($schema->hasTable(tableName: 'openconnector_endpoints') === true) {
+			$table = $schema->getTable(tableName: 'openconnector_endpoints');
+			$table->addColumn('input_mapping', Types::STRING)->setNotnull(false)->setDefault(null);
+			$table->addColumn('output_mapping', Types::STRING)->setNotnull(false)->setDefault(null);
+			$table->getColumn('conditions')->setDefault('[]');
+		}
+
+		return $schema;
+	}
+
+	/**
+	 * @param IOutput $output
+	 * @param Closure(): ISchemaWrapper $schemaClosure
+	 * @param array $options
+	 */
+	public function postSchemaChange(IOutput $output, Closure $schemaClosure, array $options): void {
+	}
+}

lib/Service/EndpointService.php

@@ -46,6 +46,7 @@ public function __construct(
 		private readonly CallService     $callService,
 		private readonly LoggerInterface $logger,
 		private readonly IURLGenerator   $urlGenerator,
+		private readonly MappingService  $mappingService,
 	)
 	{
 	}
@@ -228,10 +229,17 @@ private function handleSchemaRequest(Endpoint $endpoint, IRequest $request, stri
 		$register = $target[0];
 		$schema = $target[1];
 
+
 		$mapper = $this->objectService->getMapper(schema: $schema, register: $register);
 
 		$parameters = $request->getParams();
 
+
+		if($endpoint->getInputMapping() !== null) {
+			$inputMapping = $this->mappingService->getMapping($endpoint->getInputMapping());
+			$parameters = $this->mappingService->executeMapping(mapping: $inputMapping, input: $parameters);
+		}
+
 		$pathParams = $this->getPathParameters($endpoint->getEndpointArray(), $path);
 
 		unset($parameters['_route'], $parameters['_path']);