Resolving warehouse items

Author: leocavalcante

.editorconfig

@@ -0,0 +1,11 @@
+root = true
+
+[*]
+charset = utf-8
+end_of_line = lf
+trim_trailing_whitespace = true
+insert_final_newline = true
+indent_style = space
+max_line_length = off
+indent_size = 4
+tab_width = 4

bin/server.php

@@ -3,17 +3,21 @@
 namespace AdsWarehouse;
 
 use AdsWarehouse\Http\Handler;
-use function Siler\GraphQL\schema;
+use Monolog\Handler\ErrorLogHandler;
+use PDO;
+use Siler\Monolog as Log;
 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);
+Log\handler(new ErrorLogHandler());
+
+$pdo = new PDO(getenv('POSTGRES_DSN'));
+$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::ERRMODE_EXCEPTION);
 
 $context = new Context();
-$context->schema = $schema;
+$context->schema = require_once "$basedir/src/schema.php";
+$context->warehouse = new Warehouse\Pdo($pdo);
 
-http(new Handler($context), 8000)->start();
+http(new Handler($context), 8000)->start();

composer.json

@@ -3,6 +3,7 @@
     "description": "Data warehouse for multi-data-source ads campaings.",
     "type": "project",
     "require": {
+        "ext-pdo": "*",
         "leocavalcante/siler": "dev-master",
         "monolog/monolog": "^2.0",
         "firebase/php-jwt": "^5.0",
@@ -23,12 +24,8 @@
     "autoload": {
         "psr-4": {
             "AdsWarehouse\\": [
-                "src/",
-                "lib/"
+                "src/"
             ]
-        },
-        "files": [
-            "lib/graphql_files.php"
-        ]
+        }
     }
 }

composer.lock

@@ -24,5 +24,6 @@ services:
       - "${DOCKER_HTTP_PORT}:8000"
     volumes:
       - ./:/app
+    env_file: ./.env
     environment:
-      ENTRY_POINT_FILE: /app/bin/server.php
+      ENTRY_POINT_FILE: /app/bin/server.php

docker-compose.yml

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

lib/graphql_files.php

@@ -8,4 +8,4 @@ class Ad
     public $id;
     /** @var string */
     public $name;
-}
+}

src/Ad/Ad.graphql

@@ -0,0 +1,14 @@
+<?php declare(strict_types=1);
+
+namespace AdsWarehouse\Ad\Resolver;
+
+use AdsWarehouse\Context;
+use AdsWarehouse\Resolver;
+
+class Ads implements Resolver
+{
+    public function __invoke($root, array $args, Context $context)
+    {
+        return $context->warehouse->items();
+    }
+}

src/Ad/Ad.php

@@ -26,13 +26,13 @@ public function __invoke(Request $request, Response $response)
     {
         try {
             $input = decode(raw());
-            $response = execute($this->context->schema, $input, $this->context->rootValue, $this->context);
+            $result = execute($this->context->schema, $input, $this->context->rootValue, $this->context);
         } catch (Throwable $exception) {
             Log\error('Internal error', ['exception' => $exception]);
-            $response = FormattedError::createFromException($exception);
+            $result = FormattedError::createFromException($exception);
         } finally {
             cors();
-            json($response);
+            json($result);
         }
     }
-}
+}