afup#1499 Récupération des meetups via GraphQL

composer.json

@@ -15,6 +15,7 @@
     "captioning/captioning": "^2.6",
     "ccmbenchmark/ting_bundle": "3.4.1",
     "cocur/slugify": "^2.3",
+    "cuyz/valinor": "^0.17.1",
     "doctrine/dbal": "^2.5",
     "ekino/newrelic-bundle": "^1.4",
     "erusev/parsedown": "^1.6",

sources/AppBundle/Event/Model/Meetup.php

@@ -70,7 +70,7 @@ public function getDate()
     }
 
     /**
-     * @param DateTime $date
+     * @param \DateTimeInterface $date
      *
      * @return Meetup
      */

sources/AppBundle/Indexation/Meetups/GraphQL/Edge.php

@@ -0,0 +1,19 @@
+<?php
+declare(strict_types=1);
+
+namespace AppBundle\Indexation\Meetups\GraphQL;
+
+final class Edge
+{
+    private Node $node;
+
+    public function __construct(Node $node)
+    {
+        $this->node = $node;
+    }
+
+    public function getNode(): Node
+    {
+        return $this->node;
+    }
+}

sources/AppBundle/Indexation/Meetups/GraphQL/Events.php

@@ -0,0 +1,26 @@
+<?php
+declare(strict_types=1);
+
+namespace AppBundle\Indexation\Meetups\GraphQL;
+
+final class Events
+{
+    /** @var Edge[] */
+    private array $edges;
+
+    /**
+     * @param Edge[] $edges
+     */
+    public function __construct(array $edges)
+    {
+        $this->edges = $edges;
+    }
+
+    /**
+     * @return Edge[]
+     */
+    public function getEdges(): array
+    {
+        return $this->edges;
+    }
+}

sources/AppBundle/Indexation/Meetups/GraphQL/Group.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace AppBundle\Indexation\Meetups\GraphQL;
+
+final class Group
+{
+    private Events $upcomingEvents;
+    private Events $pastEvents;
+
+    public function __construct(Events $upcomingEvents, Events $pastEvents)
+    {
+        $this->upcomingEvents = $upcomingEvents;
+        $this->pastEvents = $pastEvents;
+    }
+
+    public function getUpcomingEvents(): Events
+    {
+        return $this->upcomingEvents;
+    }
+
+    public function getPastEvents(): Events
+    {
+        return $this->pastEvents;
+    }
+}

sources/AppBundle/Indexation/Meetups/GraphQL/Node.php

@@ -0,0 +1,48 @@
+<?php
+declare(strict_types=1);
+
+namespace AppBundle\Indexation\Meetups\GraphQL;
+
+use DateTimeImmutable;
+
+final class Node
+{
+    private string $id;
+    private string $title;
+    private string $eventUrl;
+    private DateTimeImmutable $dateTime;
+
+    /**
+     * @param string $id
+     * @param string $title
+     * @param string $eventUrl
+     * @param DateTimeImmutable $dateTime
+     */
+    public function __construct(string $id, string $title, string $eventUrl, DateTimeImmutable $dateTime)
+    {
+        $this->id = $id;
+        $this->title = $title;
+        $this->eventUrl = $eventUrl;
+        $this->dateTime = $dateTime;
+    }
+
+    public function getId(): string
+    {
+        return $this->id;
+    }
+
+    public function getTitle(): string
+    {
+        return $this->title;
+    }
+
+    public function getEventUrl(): string
+    {
+        return $this->eventUrl;
+    }
+
+    public function getDateTime(): DateTimeImmutable
+    {
+        return $this->dateTime;
+    }
+}

sources/AppBundle/Indexation/Meetups/GraphQL/QueryGroupsResponse.php

@@ -0,0 +1,26 @@
+<?php
+declare(strict_types=1);
+
+namespace AppBundle\Indexation\Meetups\GraphQL;
+
+final class QueryGroupsResponse
+{
+    /** @var array<string, Group> */
+    private array $data;
+
+    /**
+     * @param array<string, Group> $data
+     */
+    public function __construct(array $data)
+    {
+        $this->data = $data;
+    }
+
+    /**
+     * @return array<string, Group>
+     */
+    public function getData(): array
+    {
+        return $this->data;
+    }
+}

sources/AppBundle/Indexation/Meetups/MeetupClient.php

@@ -0,0 +1,110 @@
+<?php
+declare(strict_types=1);
+
+namespace AppBundle\Indexation\Meetups;
+
+use AppBundle\Event\Model\Meetup;
+use AppBundle\Indexation\Meetups\GraphQL\QueryGroupsResponse;
+use AppBundle\Offices\OfficesCollection;
+use CuyZ\Valinor\Mapper\MappingError;
+use CuyZ\Valinor\Mapper\Source\Source;
+use CuyZ\Valinor\MapperBuilder;
+use GuzzleHttp\Client;
+
+/**
+ * @phpstan-import-type OfficeType from OfficesCollection
+ */
+final class MeetupClient
+{
+    private Client $client;
+
+    public function __construct(Client $client)
+    {
+        $this->client = $client;
+    }
+
+    /**
+     * @return Meetup[]
+     */
+    public function getEvents(): array
+    {
+        $response = $this->client->request('POST', 'https://www.meetup.com/gql', [
+            'body' => $this->getEventsQuery(),
+            'headers' => [
+                'Content-Type' => 'application/json',
+            ],
+        ]);
+
+        try {
+            /** @var QueryGroupsResponse $groupResponse */
+            $groupResponse = (new MapperBuilder())
+                ->mapper()
+                ->map(QueryGroupsResponse::class, Source::json($response->getBody()->getContents()));
+        } catch (MappingError $error) {
+            throw new \Exception("todo", 0, $error);
+        }
+
+        $meetups = [];
+
+        foreach ($groupResponse->getData() as $nameAntenne => $group) {
+            foreach ($group->getUpcomingEvents()->getEdges() as $edge) {
+                $meetup = new Meetup();
+                $meetup->setId((int)$edge->getNode()->getId());
+                $meetup->setTitle($edge->getNode()->getTitle());
+                $meetup->setDate($edge->getNode()->getDateTime());
+                $meetup->setAntenneName($nameAntenne);
+
+                $meetups[] = $meetup;
+            }
+
+            foreach ($group->getPastEvents()->getEdges() as $edge) {
+                $meetup = new Meetup();
+                $meetup->setId((int)$edge->getNode()->getId());
+                $meetup->setTitle($edge->getNode()->getTitle());
+                $meetup->setDate($edge->getNode()->getDateTime());
+                $meetup->setAntenneName($nameAntenne);
+
+                $meetups[] = $meetup;
+            }
+        }
+
+        return $meetups;
+    }
+
+    private function getEventsQuery(): string
+    {
+        $query = "query {\n";
+
+        foreach ((new OfficesCollection())->getAll() as $name => $office) {
+            $meetupId = $office['meetup_id'];
+            $query .= "$name: group(id: $meetupId) { ...GroupFragment }\n";
+        }
+
+        $query .= <<<GRAPHQL
+}
+
+fragment EventFragment on Event {
+    id
+    title
+    eventUrl
+    dateTime
+}
+
+fragment GroupFragment on Group {
+    upcomingEvents(input: {last: 10}) {
+        edges {
+            node { ... EventFragment }
+        }
+    }
+
+    pastEvents(input: {first: 2}, sortOrder: DESC) {
+        edges {
+            node { ... EventFragment }
+        }
+    }
+}
+GRAPHQL;
+
+        return $query;
+    }
+}