Graphql - wprowadzenie

.gitignore

@@ -12,6 +12,7 @@ node_modules/
 /fe/build/
 /fe/yarn-error.log
 /fe/.vs/
+/fe/.graphql_ppx_cache/
 /be/vendor/
 /be/config.php
 /be/config_cba.php

be/Api/index.php

@@ -7,13 +7,17 @@
 use Controller\AuthCtrl;
 use Controller\RatingsHistoryCtrl;
 use Controller\RemoveGameCtrl;
+use Controller\GraphqlCtrl;
 use Middleware\Privileges\PrivilegesIsLogged;
 use Middleware\Validation;
 
 require 'autoload.php';
 
 $app = new EloApp;
 
+$app->post('/graphql', [GraphqlCtrl::class, 'api'])
+    ->add(PrivilegesIsLogged::class);
+
 $app->get('/auth/isLogged', [AuthCtrl::class, 'isLogged']);
 
 $app->post('/auth/login', [AuthCtrl::class, 'login']);

be/Controller/GraphqlCtrl.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace Controller;
+
+use Slim\Http\Response;
+use \Psr\Http\Message\ServerRequestInterface as Request;
+use GraphQL\Type\Definition\ObjectType;
+use GraphQL\GraphQL;
+use GraphQL\Type\Schema;
+use GraphQL\Type\Definition\Type;
+use GraphQLElo\Resolvers\UsersResolver;
+use GraphQLElo\Types\UserType;
+
+class GraphqlCtrl {
+    /** @var UsersResolver */
+    private $usersResolver;
+
+    /** @var UserType */
+    private $userType;
+
+    public function __construct(UsersResolver $usersResolver, UserType $userType) {
+        $this->usersResolver = $usersResolver;
+        $this->userType = $userType;
+    }
+
+    public function api(Request $request, Response $response): Response {
+        $schema = new Schema([
+            'query' => new ObjectType([
+                'name' => 'Query',
+                'fields' => $this->getQueryFields(),
+            ]),
+        ]);
+
+        $rawInput = $request->getBody();
+        $input = json_decode($rawInput, true);
+        $query = $input['query'];
+        $variableValues = $input['variables'] ?? null;
+
+        try {
+            $result = GraphQL::executeQuery($schema, $query, null, null, $variableValues);
+            $output = $result->toArray();
+        } catch (\Exception $e) {
+            $output = [
+                'errors' => [
+                    [
+                        'message' => $e->getMessage()
+                    ]
+                ]
+            ];
+        }
+
+        return $response->withJson($output);
+    }
+
+    private function getQueryFields(): array {
+        return [
+            'users' => [
+                'type' => Type::nonNull(Type::listOf(Type::nonNull($this->userType))),
+                'resolve' => $this->usersResolver,
+            ],
+        ];
+    }
+}
+

be/GraphQLElo/Resolvers/UsersResolver.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace GraphQLElo\Resolvers;
+
+use Model\Entity\User;
+use Model\Repository\UserRepository;
+
+class UsersResolver {
+    /** @var UserRepository */
+    private $userRepository;
+
+    public function __construct(UserRepository $userRepository)
+    {
+        $this->userRepository = $userRepository;
+    }
+
+    /**
+     * @return User[];
+     */
+    public function __invoke(): array
+    {
+        return $this->userRepository->findBy(
+            ['deleted' => 0],
+            ['rating' => 'DESC', 'code' => 'ASC']
+        );
+    }
+}
+

be/GraphQLElo/Types/UserType.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace GraphQLElo\Types;
+
+use Model\Entity\User;
+use Service\UsersSvc;
+use GraphQL\Type\Definition\ObjectType;
+use GraphQL\Type\Definition\Type;
+
+class UserType extends ObjectType {
+    public function __construct(UsersSvc $usersSvc) {
+        $config = [
+            'fields' => [
+                'userNid' => [
+                    'type' => Type::nonNull(Type::int()),
+                    'resolve' => static function (User $user) {
+                        return $user->getUserNid();
+                    },
+                ],
+                'code' => [
+                    'type' => Type::nonNull(Type::string()),
+                    'resolve' => static function (User $user) {
+                        return $user->getCode();
+                    },
+                ],
+                'name' => [
+                    'type' => Type::nonNull(Type::string()),
+                    'resolve' => static function (User $user) {
+                        return $user->getName();
+                    },
+                ],
+                'rating' => [
+                    'type' => Type::nonNull(Type::int()),
+                    'resolve' => static function (User $user) {
+                        return $user->getRating();
+                    },
+                ],
+                'team' => [
+                    'type' => Type::nonNull(Type::string()),
+                    'resolve' => static function (User $user) {
+                        return $user->getTeam();
+                    },
+                ],
+                'trendRatingDiff' => [
+                    'type' => Type::nonNull(Type::int()),
+                    'resolve' => static function (User $user) use ($usersSvc) {
+                        return $usersSvc->calculateTrendRatingDiffForGql($user);
+                    },
+                ],
+            ],
+        ];
+        parent::__construct($config);
+    }
+
+}

be/Service/UsersSvc.php

@@ -29,7 +29,7 @@ public function __construct(
         $this->userRepository = $userRepository;
         $this->gameFactory = $gameFactory;
     }
-
+    
     public function getUsers(): array
     {
         $userEntityList = $this->userRepository->findBy(
@@ -68,6 +68,13 @@ private function calculateTrendRatingDiff(array $userArray): array
         return $userArray;
     }
 
+    public function calculateTrendRatingDiffForGql(User $user): int {
+        $winGamesSumRating = $this->sumRatingDiffs($user->getLastWonGameList());
+        $looseGamesSumRating = $this->sumRatingDiffs($user->getLastLostGameList());
+
+        return $winGamesSumRating - $looseGamesSumRating;
+    }
+
     private function sumRatingDiffs(Collection $gameList): int
     {
         return array_reduce($gameList->toArray(), function (int $acc, Game $game) {

be/composer.json

@@ -9,7 +9,8 @@
     "php": "7.2.*",
     "ext-json": "*",
     "doctrine/orm": "2.6.3",
-    "php-di/slim-bridge": "^2.0"
+    "php-di/slim-bridge": "^2.0",
+    "webonyx/graphql-php": "^0.13.1"
   },
   "require-dev": {
     "roave/security-advisories": "dev-master",

fe/bsconfig.json

@@ -22,7 +22,11 @@
     "@glennsl/bs-json",
     "@ahrefs/bs-reactstrap",
     "@ahrefs/bs-recharts",
-    "reason-react-document-title"
+    "reason-react-document-title",
+    "reason-apollo"
+  ],
+  "ppx-flags": [
+    "graphql_ppx/ppx"
   ],
   "refmt": 3
 }