[Slack] Throw guzzle client exception when slack api request fails (#40)

Author: Justin Hayes

Provider.php

@@ -2,6 +2,10 @@
 
 namespace SocialiteProviders\Slack;
 
+use GuzzleHttp\Client;
+use GuzzleHttp\HandlerStack;
+use Psr\Http\Message\ResponseInterface;
+use GuzzleHttp\Exception\RequestException;
 use SocialiteProviders\Manager\OAuth2\User;
 use Laravel\Socialite\Two\ProviderInterface;
 use SocialiteProviders\Manager\OAuth2\AbstractProvider;
@@ -25,6 +29,50 @@ class Provider extends AbstractProvider implements ProviderInterface
      */
     protected $scopeSeparator = ',';
 
+    /**
+     * Middleware that throws exceptions for non successful slack api calls
+     * "http_error" request option is set to true.
+     *
+     * @return callable Returns a function that accepts the next handler.
+     */
+    private function getSlackApiErrorMiddleware()
+    {
+        return function (callable $handler) {
+            return function ($request, array $options) use ($handler) {
+                if (empty($options['http_errors'])) {
+                    return $handler($request, $options);
+                }
+                return $handler($request, $options)->then(
+                    function (ResponseInterface $response) use ($request, $handler) {
+                        $body = json_decode($response->getBody()->getContents(), true);
+                        $response->getBody()->rewind();
+
+                        if ($body['ok']) {
+                            return $response;
+                        }
+
+                        throw RequestException::create($request, $response);
+                    }
+                );
+            };
+        };
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    protected function getHttpClient()
+    {
+        $handler = HandlerStack::create();
+        $handler->push($this->getSlackApiErrorMiddleware(), 'slack_api_errors');
+
+        if (is_null($this->httpClient)) {
+            $this->httpClient = new Client(['handler' => $handler]);
+        }
+
+        return $this->httpClient;
+    }
+
     /**
      * {@inheritdoc}
      */