Merge pull request #45 from chadicus/master

Add send and startSend to ClientInterface

Author: chadicus

src/Client.php

@@ -282,6 +282,36 @@ public function delete(string $resource, string $id = null, array $data = null)
         return $this->end($this->startDelete($resource, $id, $data));
     }
 
+    /**
+     * Performs a request to the given URI and returns the response.
+     *
+     * @param string $method The HTTP method of the request to send.
+     * @param string $uri    A relative api URI to which the POST request will be made.
+     * @param array  $data   Array of data to be sent as the POST body.
+     *
+     * @return Response
+     */
+    public function send(string $method, string $uri, array $data = null) : Response
+    {
+        return $this->end($this->startSend($method, $uri, $data));
+    }
+
+    /**
+     * Starts a request to the given URI.
+     *
+     * @param string $method The HTTP method of the request to send.
+     * @param string $uri    A relative api URI to which the POST request will be made.
+     * @param array  $data   Array of data to be sent as the POST body.
+     *
+     * @return string opaque handle to be given to endDelete()
+     */
+    public function startSend(string $method, string $uri, array $data = null) : string
+    {
+        $url = "{$this->baseUrl}/{$uri}";
+        $json = $data !== null ? json_encode($data) : null;
+        return $this->start($url, $method, $json, ['Content-Type' => 'application/json']);
+    }
+
     /**
      * Get response of start*() method
      *

src/ClientInterface.php

@@ -91,6 +91,28 @@ public function startDelete(string $resource, string $id = null, array $data = n
      */
     public function delete(string $resource, string $id = null, array $data = null) : Response;
 
+    /**
+     * Performs a request to the given URI and returns the response.
+     *
+     * @param string $method The HTTP method of the request to send.
+     * @param string $uri    A relative api URI to which the POST request will be made.
+     * @param array  $data   Array of data to be sent as the POST body.
+     *
+     * @return Response
+     */
+    public function send(string $method, string $uri, array $data = null) : Response;
+
+    /**
+     * Starts a request to the given URI.
+     *
+     * @param string $method The HTTP method of the request to send.
+     * @param string $uri    A relative api URI to which the POST request will be made.
+     * @param array  $data   Array of data to be sent as the POST body.
+     *
+     * @return string opaque handle to be given to endDelete()
+     */
+    public function startSend(string $method, string $uri, array $data = null) : string;
+
     /**
      * Get response of start*() method
      *

tests/ClientTest.php

@@ -607,6 +607,38 @@ function (RequestInterface $request) {
         $this->assertSame(['Content-Type' => ['application/json']], $response->getResponseHeaders());
     }
 
+    /**
+     * @test
+     * @covers ::send
+     * @covers ::startSend
+     */
+    public function send()
+    {
+        $test = $this;
+        $adapter = new FakeAdapter(
+            function (RequestInterface $request) use ($test) {
+                if (substr($request->getUri(), -5) === 'token') {
+                    return new Psr7Response(
+                        200,
+                        ['Content-Type' => ['application/json']],
+                        json_encode(['access_token' => 'a token', 'expires_in' => 1])
+                    );
+                }
+
+                $test->assertSame('PATCH', $request->getMethod());
+                $test->assertSame('baseUrl/v1/item-logs/123/log-error', (string)$request->getUri());
+                $test->assertSame('{"message":"the message"}', (string)$request->getBody());
+                return new Psr7Response(204);
+            }
+        );
+
+        $client = new Client($adapter, $this->getAuthentication(), 'baseUrl/v1');
+
+        $response = $client->send('PATCH', 'item-logs/123/log-error', ['message' => 'the message']);
+        $this->assertSame(204, $response->getHttpCode());
+        $this->assertSame([], $response->getResponse());
+    }
+
     /**
      * Verify behavior of startDelete when no id is given.
      *