Initial version

Author: legionth

LICENSE

@@ -0,0 +1,21 @@
+The MIT License (MIT)
+
+Copyright (c) 2018 Niels Theen
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is furnished
+to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

examples/01-define-api.php

@@ -0,0 +1,25 @@
+<?php
+
+require_once '../vendor/autoload.php';
+
+$loop = \React\EventLoop\Factory::create();
+
+$server = new \Legionth\React\Http\Rest\Server();
+
+$server->get('/say/hello', function (\Psr\Http\Message\ServerRequestInterface $request, callable $next) {
+    return new \React\Http\Response(200, array(), 'hello');
+});
+
+$server->post('/say/:word', function (\Psr\Http\Message\ServerRequestInterface $request, callable $next) {
+    $word = $request->getQueryParams()['word'];
+
+    return new \React\Http\Response(200, array(), 'You said: ' . $word);
+});
+
+$socket = new \React\Socket\Server(isset($argv[1]) ? $argv[1] : '0.0.0.0:0', $loop);
+
+$server->listen($socket);
+
+echo 'Listening on ' . str_replace('tcp:', 'http:', $socket->getAddress()) . PHP_EOL;
+
+$loop->run();

src/Server.php

@@ -0,0 +1,112 @@
+<?php
+
+namespace Legionth\React\Http\Rest;
+
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ServerRequestInterface;
+use RingCentral\Psr7\Response;
+
+class Server
+{
+    /**
+     * @var array
+     */
+    private $functions;
+
+    public function listen(\React\Socket\Server $socket)
+    {
+        $middleWareFunctions = array();
+
+        foreach ($this->functions as $httpMethod => $pathFunctionArray) {
+            foreach ($pathFunctionArray as $path => $function) {
+                $middleWareFunctions[] = $this->createRestfulFunction($httpMethod, $path, $function);
+            }
+        }
+
+        $middleWareFunctions[] = function (ServerRequestInterface $request) {
+            return new Response(404);
+        };
+
+        $httpServer = new \React\Http\Server($middleWareFunctions);
+
+        $httpServer->listen($socket);
+    }
+
+    public function get(string $path, callable $callable)
+    {
+        $this->functions['get'][$path] = $callable;
+    }
+
+    public function post(string $path, callable $callable)
+    {
+        $this->functions['post'][$path] = $callable;
+    }
+
+    public function put(string $path, callable $callable)
+    {
+        $this->functions['put'][$path] = $callable;
+    }
+
+    public function delete(string $path, callable $callable)
+    {
+        $this->functions['delete'][$path] = $callable;
+    }
+
+    public function head(string $path, callable $callable)
+    {
+        $this->functions['head'][$path] = $callable;
+    }
+
+    public function options(string $path, callable $callable)
+    {
+        $this->functions['options'][$path] = $callable;
+    }
+
+    public function connect(string $path, callable $callable)
+    {
+        $this->functions['connect'][$path] = $callable;
+    }
+
+    public function trace(string $path, callable $callable)
+    {
+        $this->functions['trace'][$path] = $callable;
+    }
+
+    /**
+     * @param $httpMethod
+     * @param $path
+     * @param $function
+     * @return \Closure
+     */
+    private function createRestfulFunction($httpMethod, $path, $function)
+    {
+        return function (RequestInterface $request, callable $next) use ($httpMethod, $path, $function) {
+            if ($request->getMethod() === strtoupper($httpMethod)) {
+                $requestPath = $request->getUri()->getPath();
+                $requestPathArray = explode('/', $requestPath);
+                $pathArray = explode('/', $path);
+
+                if (count($requestPathArray) !== count($pathArray)) {
+                    return $next($request);
+                }
+
+                $queryParams = $request->getQueryParams();
+
+                foreach ($pathArray as $id => $valueName) {
+                    $position = strpos($valueName, ':');
+                    if (0 === $position) {
+                        $valueName = substr($valueName, 1);
+                        $queryParams[$valueName] = $requestPathArray[$id];
+                    }
+                }
+
+                $request = $request->withQueryParams($queryParams);
+
+                return $function($request, $next);
+            }
+
+            return $next($request);
+        };
+    }
+}
+