add connection agent designer test

Author: chriskapp

src/Backend/Action/Connection/Agent/AgentAbstract.php

@@ -41,8 +41,13 @@ public function __construct(private Connector $connector, private FrameworkConfi
     {
     }
 
-    protected function getConnection(int $connectionId): AgentInterface
+    protected function getConnection(RequestInterface $request): AgentInterface
     {
+        $connectionId = $request->get('connection_id');
+        if (empty($connectionId)) {
+            throw new BadRequestException('Provided no connection');
+        }
+
         $connection = $this->connector->getConnection($connectionId);
         if (!$connection instanceof AgentInterface) {
             throw new BadRequestException('Provided an invalid connection');

src/Backend/Action/Connection/Agent/Send.php

@@ -49,12 +49,7 @@ public function handle(RequestInterface $request, ParametersInterface $configura
     {
         $this->assertConnectionEnabled();
 
-        $connectionId = (int) $request->get('connection_id');
-        if (empty($connectionId)) {
-            throw new BadRequestException('Provided no connection');
-        }
-
-        $agent = $this->getConnection($connectionId);
+        $agent = $this->getConnection($request);
         $payload = $request->getPayload();
 
         assert($payload instanceof AgentContent);

src/Installation/NewInstallation.php

@@ -32,7 +32,6 @@
 use Fusio\Impl\Table;
 use Fusio\Marketplace;
 use Fusio\Model;
-use Psr\Container\ContainerInterface;
 use PSX\Api\Model\Passthru;
 use PSX\Api\OperationInterface;
 use PSX\Schema\ContentType;
@@ -599,8 +598,8 @@ private static function getOperations(): array
                     httpMethod: 'POST',
                     httpPath: '/connection/:connection_id/agent',
                     httpCode: 200,
-                    outgoing: Model\Backend\AgentMessage::class,
-                    incoming: Model\Backend\AgentMessage::class,
+                    outgoing: Model\Backend\AgentContent::class,
+                    incoming: Model\Backend\AgentContent::class,
                     throws: [999 => Model\Common\Message::class],
                     description: 'Sends a message to an agent',
                 ),

tests/Backend/Api/Connection/Agent/CollectionTest.php

@@ -0,0 +1,101 @@
+<?php
+/*
+ * Fusio - Self-Hosted API Management for Builders.
+ * For the current version and information visit <https://www.fusio-project.org/>
+ *
+ * Copyright (c) Christoph Kappestein <christoph.kappestein@gmail.com>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+namespace Fusio\Impl\Tests\Backend\Api\Connection\Agent;
+
+use Fusio\Impl\Tests\DbTestCase;
+
+/**
+ * CollectionTest
+ *
+ * @author  Christoph Kappestein <christoph.kappestein@gmail.com>
+ * @license http://www.apache.org/licenses/LICENSE-2.0
+ * @link    https://www.fusio-project.org
+ */
+class CollectionTest extends DbTestCase
+{
+    public function testGet()
+    {
+        $response = $this->sendRequest('/backend/connection/Agent/agent', 'GET', array(
+            'User-Agent'    => 'Fusio TestCase',
+            'Authorization' => 'Bearer da250526d583edabca8ac2f99e37ee39aa02a3c076c0edc6929095e20ca18dcf'
+        ));
+
+        $body = (string) $response->getBody();
+
+        $this->assertEquals(404, $response->getStatusCode(), $body);
+    }
+
+    public function testPost()
+    {
+        $response = $this->sendRequest('/backend/connection/Agent/agent', 'POST', array(
+            'User-Agent'    => 'Fusio TestCase',
+            'Authorization' => 'Bearer da250526d583edabca8ac2f99e37ee39aa02a3c076c0edc6929095e20ca18dcf'
+        ), json_encode([
+            'type' => 'text',
+            'content' => 'What is the meaning of life?',
+        ]));
+
+        $body = (string) $response->getBody();
+
+        $expect = <<<JSON
+{
+    "type": "text",
+    "content": "The answer ist: 42"
+}
+JSON;
+
+        $this->assertEquals(200, $response->getStatusCode(), $body);
+        $this->assertJsonStringEqualsJsonString($expect, $body, $body);
+    }
+
+    public function testPut()
+    {
+        $response = $this->sendRequest('/backend/connection/Agent/agent', 'PUT', array(
+            'User-Agent'    => 'Fusio TestCase',
+            'Authorization' => 'Bearer da250526d583edabca8ac2f99e37ee39aa02a3c076c0edc6929095e20ca18dcf'
+        ), json_encode([
+            'foo' => 'bar',
+        ]));
+
+        $body = (string) $response->getBody();
+
+        $this->assertEquals(404, $response->getStatusCode(), $body);
+    }
+
+    public function testDelete()
+    {
+        $response = $this->sendRequest('/backend/connection/Agent/agent', 'DELETE', array(
+            'User-Agent'    => 'Fusio TestCase',
+            'Authorization' => 'Bearer da250526d583edabca8ac2f99e37ee39aa02a3c076c0edc6929095e20ca18dcf'
+        ), json_encode([
+            'foo' => 'bar',
+        ]));
+
+        $body = (string) $response->getBody();
+
+        $this->assertEquals(404, $response->getStatusCode(), $body);
+    }
+
+    protected function isTransactional(): bool
+    {
+        return false;
+    }
+}