Assign Host to Event

This API operation is not supported by the really old and now abandoned
library we use. I added it to a new client without touching any of the
old code for the sake of speed and.. well everything needs to be
re-written cause its running on all kinda of things that do not exist
anymore...

Author: rdohms

config/container.php

@@ -1,4 +1,6 @@
 <?php
+
+use AmsterdamPHP\Console\Api\JoindInClient;
 use Crummy\Phlack\Phlack;
 use DI\ContainerBuilder;
 use DMS\Service\Meetup\AbstractMeetupClient;
@@ -13,6 +15,7 @@
 
 // Define services
 $container->set(Client::class, new Client($config['joindin']));
+$container->set(JoindInClient::class, new JoindInClient($config['joindin']));
 $container->set(AbstractMeetupClient::class, \DMS\Service\Meetup\MeetupKeyAuthClient::factory([
     'key' => $config['meetup_api_key']
 ]));

src/Api/JoindInClient.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace AmsterdamPHP\Console\Api;
+
+use GuzzleHttp\Client;
+use GuzzleHttp\Collection;
+use function json_encode;
+use function var_dump;
+
+final class JoindInClient extends Client
+{
+    const DEFAULT_BASE_URL = 'https://api.joind.in/v2.1';
+
+    /**
+     * Constructor
+     */
+    public function __construct(array $config) {
+        $defaults = array('base_url' => self::DEFAULT_BASE_URL);
+        $required = array('base_url');
+
+        $configuration = Collection::fromConfig($config, $defaults, $required);
+
+        parent::__construct($configuration->toArray());
+
+        if ($configuration->get('access_token')) {
+            $this->setDefaultOption('headers/Authorization', 'OAuth ' . $configuration->get('access_token'));
+        }
+        $this->setDefaultOption('headers/Accept-Charset', 'utf-8');
+        $this->setDefaultOption('headers/Accept', 'application/json');
+        $this->setDefaultOption('headers/Content-Type', 'application/json');
+    }
+
+    public function addEventHost($eventId, $eventHost)
+    {
+        $result = $this->post('v2.1/events/'.$eventId.'/hosts', ['body' => json_encode(['host_name' => $eventHost])]);
+        return $result;
+    }
+}

src/Command/CreateJoindInCommand.php

@@ -2,6 +2,7 @@
 
 namespace AmsterdamPHP\Console\Command;
 
+use AmsterdamPHP\Console\Api\JoindInClient;
 use Codeliner\ArrayReader\ArrayReader;
 use Crummy\Phlack\Phlack;
 use DMS\Service\Meetup\AbstractMeetupClient;
@@ -10,6 +11,7 @@
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
+use function var_dump;
 
 class CreateJoindInCommand extends Command
 {
@@ -29,18 +31,25 @@ class CreateJoindInCommand extends Command
      */
     protected $joindinEvents;
 
+    /**
+     * @var JoindInClient
+     */
+    private $joindinApi;
+
     /**
      * CreateJoindInCommand constructor.
      *
      * @param AbstractMeetupClient $meetup
      * @param Phlack               $slack
      * @param Client               $joindin
+     * @param JoindInClient        $joindinApi
      */
-    public function __construct(AbstractMeetupClient $meetup, Phlack $slack, Client $joindin)
+    public function __construct(AbstractMeetupClient $meetup, Phlack $slack, Client $joindin, JoindInClient $joindinApi)
     {
         $this->meetup = $meetup;
         $this->slack = $slack;
         $this->joindinEvents = $joindin->getService(new Events());
+        $this->joindinApi = $joindinApi;
         parent::__construct();
     }
 
@@ -97,8 +106,10 @@ protected function execute(InputInterface $input, OutputInterface $output)
         ];
 
         $result = $this->joindinEvents->submit($event);
+        $output->writeln(sprintf("<comment>=> Joind.in event created.</comment>"));
 
-        $output->writeln(sprintf("<comment>=> Joind.in event created, awaiting approval</comment>"));
+        $hostResult = $this->joindinApi->addEventHost($this->extractIdFromLocation($result['url']), 'amsterdamphp');
+        $output->writeln("<comment>=> Host Add request returned " . $hostResult->getStatusCode() . "</comment>");
 
         $this->sendSlackMsg(
             sprintf(
@@ -151,4 +162,16 @@ protected function getCurrentMonthlyMeetingCandidates()
             return strpos($event['name'], 'Monthly Meeting') !== false;
         });
     }
+
+    protected function extractIdFromLocation($locationUrl)
+    {
+        $matches = [];
+        preg_match(
+            "/events\/([0-9]*)/",
+            $locationUrl,
+            $matches
+        );
+
+        return $matches[1];
+    }
 }

test/Command/CreateJoindInCommandTest.php

@@ -1,12 +1,17 @@
 <?php
 namespace AmsterdamPHP\Console;
 
+use AmsterdamPHP\Console\Api\JoindInClient;
 use AmsterdamPHP\Console\Command\CreateJoindInCommand;
 use Crummy\Phlack\Builder\MessageBuilder;
 use Crummy\Phlack\Message\Message;
 use Crummy\Phlack\Phlack;
 use DMS\Service\Meetup\AbstractMeetupClient;
 use DMS\Service\Meetup\Response\MultiResultResponse;
+use Guzzle\Http\Message\Header;
+use GuzzleHttp\Message\Response;
+use GuzzleHttp\Adapter\MockAdapter;
+use GuzzleHttp\Event\Emitter;
 use Joindin\Api\Client;
 use Mockery\Mock;
 use Mockery\MockInterface;
@@ -36,20 +41,36 @@ class CreateJoindInCommandTest extends \PHPUnit_Framework_TestCase
      */
     protected $command;
 
+    /**
+     * @var MockAdapter
+     */
+    protected $adapter;
+
+    /**
+     * @var JoindInClient
+     */
+    protected $joindinClient;
+
     protected function setUp()
     {
         parent::setUp();
         $this->meetup = \Mockery::mock(AbstractMeetupClient::class);
         $this->slack  = \Mockery::mock(Phlack::class);
         $this->joindinEvents = \Mockery::mock(Client::class);
         $this->joindinEvents->shouldReceive('getService')->andReturnSelf();
+        $this->adapter         = new MockAdapter();
+        $this->joindinClient = new JoindInClient([
+            'adapter' => $this->adapter,
+            'emitter' => new Emitter()
+                                                 ]);
 
-        $this->command = new CreateJoindInCommand($this->meetup, $this->slack, $this->joindinEvents);
+        $this->command = new CreateJoindInCommand($this->meetup, $this->slack, $this->joindinEvents, $this->joindinClient);
     }
 
     public function testCommand()
     {
         $meetupResponse = \Mockery::mock(MultiResultResponse::class)->shouldDeferMissing();
+        $meetupResponse->addHeader('Content-Type', new Header('Content-Type', 'application/json'));
         $meetupResponse->setData([
             [
                 'name' => 'Monthly Meeting',
@@ -61,7 +82,9 @@ public function testCommand()
 
         $this->meetup->shouldReceive('getEvents')->andReturn($meetupResponse)->once();
 
-        $this->joindinEvents->shouldReceive('submit')->once();
+        $this->joindinEvents->shouldReceive('submit')
+                            ->andReturn(['url' => 'http://some.path.to.api/v2.1/events/34'])
+                            ->once();
 
         $this->slack->shouldReceive('getMessageBuilder')->andReturn(new MessageBuilder())->once();
         $this->slack->shouldReceive('send')->with(
@@ -73,6 +96,8 @@ function (Message $param) {
             )
         );
 
+        $this->adapter->setResponse(new Response(200));
+
         $input = new ArrayInput([]);
         $output = new DummyOutput();