Drafting something

Author: leocavalcante

bin/server.php

@@ -0,0 +1,19 @@
+<?php declare(strict_types=1);
+
+namespace AdsWarehouse;
+
+use AdsWarehouse\Http\Handler;
+use function Siler\GraphQL\schema;
+use function Siler\Swoole\http;
+
+$basedir = dirname(__DIR__, 1);
+require_once "$basedir/vendor/autoload.php";
+
+$type_defs = graphql_files("$basedir/src/");
+$resolvers = require_once "$basedir/src/resolvers.php";
+$schema = schema($type_defs, $resolvers);
+
+$context = new Context();
+$context->schema = $schema;
+
+http(new Handler($context), 8000)->start();

composer.json

@@ -3,9 +3,10 @@
     "description": "Data warehouse for multi-data-source ads campaings.",
     "type": "project",
     "require": {
-        "leocavalcante/siler": "^1.6",
+        "leocavalcante/siler": "dev-master",
         "monolog/monolog": "^2.0",
-        "firebase/php-jwt": "^5.0"
+        "firebase/php-jwt": "^5.0",
+        "webonyx/graphql-php": "^0.13.8"
     },
     "require-dev": {
         "swoole/ide-helper": "^4.4",
@@ -18,5 +19,16 @@
             "email": "[email protected]"
         }
     ],
-    "minimum-stability": "stable"
+    "minimum-stability": "stable",
+    "autoload": {
+        "psr-4": {
+            "AdsWarehouse\\": [
+                "src/",
+                "lib/"
+            ]
+        },
+        "files": [
+            "lib/graphql_files.php"
+        ]
+    }
 }

composer.lock

@@ -0,0 +1,11 @@
+version: '3'
+services:
+  ads_warehouse:
+    container_name: ads_warehouse
+    image: leocavalcante/dwoole:dev
+    ports:
+      - 8000:8000
+    volumes:
+      - ./:/app
+    environment:
+      ENTRY_POINT_FILE: /app/bin/server.php

docker-compose.yml

@@ -0,0 +1,27 @@
+<?php declare(strict_types=1);
+
+namespace AdsWarehouse;
+
+use RecursiveDirectoryIterator;
+use RecursiveFilterIterator;
+use RecursiveIteratorIterator;
+use SplFileInfo;
+
+function graphql_files(string $basedir): string
+{
+    $dir_iter = new RecursiveDirectoryIterator($basedir);
+
+    $filter_iter = new  class ($dir_iter) extends RecursiveFilterIterator
+    {
+        public function accept()
+        {
+            return preg_match('/\.graphql$/', $this->current()->getFilename());
+        }
+    };
+
+    $iter = new RecursiveIteratorIterator($filter_iter);
+
+    return array_reduce(iterator_to_array($iter), function (string $schema, SplFileInfo $fileInfo): string {
+        return "$schema\n" . file_get_contents($fileInfo->getFilename());
+    }, "");
+}

lib/graphql_files.php

@@ -0,0 +1,4 @@
+type Ad {
+    id: ID!
+    name: String!
+}

src/Ad/Ad.graphql

@@ -0,0 +1,11 @@
+<?php declare(strict_types=1);
+
+namespace AdsWarehouse\Ad;
+
+class Ad
+{
+    /** @var string */
+    public $id;
+    /** @var string */
+    public $name;
+}

src/Ad/Ad.php

@@ -0,0 +1,6 @@
+create table ad
+(
+    id        uuid      not null primary key,
+    name      varchar   not null,
+    timestamp timestamp not null default current_timestamp
+);

src/Ad/V1__Ad.sql

@@ -0,0 +1,13 @@
+<?php declare(strict_types=1);
+
+namespace AdsWarehouse;
+
+use GraphQL\Type\Schema;
+
+class Context
+{
+    /** @var Schema */
+    public $schema;
+    /** @var mixed */
+    public $rootValue;
+}

src/Context.php

@@ -0,0 +1,38 @@
+<?php declare(strict_types=1);
+
+namespace AdsWarehouse\Http;
+
+use AdsWarehouse\Context;
+use GraphQL\Error\FormattedError;
+use Siler\Monolog as Log;
+use Swoole\Http\Request;
+use Swoole\Http\Response;
+use Throwable;
+use function Siler\Encoder\Json\decode;
+use function Siler\GraphQL\execute;
+use function Siler\Swoole\{cors, json, raw};
+
+class Handler
+{
+    /** @var Context */
+    private $context;
+
+    public function __construct(Context $context)
+    {
+        $this->context = $context;
+    }
+
+    public function __invoke(Request $request, Response $response)
+    {
+        try {
+            $input = decode(raw());
+            $response = execute($this->context->schema, $input, $this->context->rootValue, $this->context);
+        } catch (Throwable $exception) {
+            Log\error('Internal error', ['exception' => $exception]);
+            $response = FormattedError::createFromException($exception);
+        } finally {
+            cors();
+            json($response);
+        }
+    }
+}