add support for guzzle 6

.travis.yml

@@ -3,18 +3,19 @@ language: php
 sudo: false
 
 php:
-  - 5.4
   - 5.5
   - 5.6
   - hhvm
 
 env:
   - FIREBASE_JWT_VERSION=2.0.0
   - FIREBASE_JWT_VERSION=3.0.0
-
+  - GUZZLE_VERSION=5.3
+  - GUZZLE_VERSION=~6.0
 before_script:
   - composer install
   - composer require firebase/php-jwt:$FIREBASE_JWT_VERSION
+  - composer require guzzlehttp/guzzle:$GUZZLE_VERSION
 
 script:
   - vendor/bin/phpunit

composer.json

@@ -7,8 +7,10 @@
   "license": "Apache-2.0",
   "require": {
     "firebase/php-jwt": "~2.0|~3.0",
-    "guzzlehttp/guzzle": "5.2.*",
-    "php": ">=5.4"
+    "guzzlehttp/guzzle": "5.3|~6.0",
+    "php": ">=5.5",
+    "guzzlehttp/psr7": "1.2.*",
+    "psr/http-message": "1.0.*"
   },
   "require-dev": {
     "phpunit/phpunit": "3.7.*",

src/ApplicationDefaultCredentials.php

@@ -17,8 +17,10 @@
 
 namespace Google\Auth;
 
-use GuzzleHttp\Stream\Stream;
-use GuzzleHttp\ClientInterface;
+use Google\Auth\Credentials\AppIdentityCredentials;
+use Google\Auth\Credentials\GCECredentials;
+use Google\Auth\Middleware\AuthTokenMiddleware;
+use Google\Auth\Subscriber\AuthTokenSubscriber;
 
 /**
  * ApplicationDefaultCredentials obtains the default credentials for
@@ -30,50 +32,83 @@
  * This class implements the search for the application default credentials as
  * described in the link.
  *
- * It provides two factory methods:
+ * It provides three factory methods:
  * - #get returns the computed credentials object
- * - #getFetcher returns an AuthTokenFetcher built from the credentials object
+ * - #getSubscriber returns an AuthTokenSubscriber built from the credentials object
+ * - #getMiddleware returns an AuthTokenMiddleware built from the credentials object
  *
  * This allows it to be used as follows with GuzzleHttp\Client:
  *
- *   use GuzzleHttp\Client;
  *   use Google\Auth\ApplicationDefaultCredentials;
+ *   use GuzzleHttp\Client;
+ *   use GuzzleHttp\HandlerStack;
+ *
+ *   $middleware = ApplicationDefaultCredentials::getMiddleware(
+ *       'https://www.googleapis.com/auth/taskqueue'
+ *   );
+ *   $stack = HandlerStack::create();
+ *   $stack->push($middleware);
  *
  *   $client = new Client([
- *      'base_url' => 'https://www.googleapis.com/taskqueue/v1beta2/projects/',
- *      'defaults' => ['auth' => 'google_auth']  // authorize all requests
+ *       'handler' => $stack,
+ *       'base_uri' => 'https://www.googleapis.com/taskqueue/v1beta2/projects/',
+ *       'auth' => 'google_auth' // authorize all requests
  *   ]);
- *   $fetcher = ApplicationDefaultCredentials::getFetcher(
- *       'https://www.googleapis.com/auth/taskqueue');
- *   $client->getEmitter()->attach($fetcher);
  *
  *   $res = $client->get('myproject/taskqueues/myqueue');
  */
 class ApplicationDefaultCredentials
 {
   /**
-   * Obtains an AuthTokenFetcher that uses the default FetchAuthTokenInterface
+   * Obtains an AuthTokenSubscriber that uses the default FetchAuthTokenInterface
+   * implementation to use in this environment.
+   *
+   * If supplied, $scope is used to in creating the credentials instance if
+   * this does not fallback to the compute engine defaults.
+   *
+   * @param string|array scope the scope of the access request, expressed
+   *   either as an Array or as a space-delimited String.
+   * @param callable $httpHandler callback which delivers psr7 request
+   * @param array $cacheConfig configuration for the cache when it's present
+   * @param object $cache an implementation of CacheInterface
+   *
+   * @throws DomainException if no implementation can be obtained.
+   */
+  public static function getSubscriber(
+    $scope = null,
+    callable $httpHandler = null,
+    array $cacheConfig = null,
+    CacheInterface $cache = null
+  ) {
+    $creds = self::getCredentials($scope, $httpHandler);
+
+    return new AuthTokenSubscriber($creds, $cacheConfig, $cache, $httpHandler);
+  }
+
+  /**
+   * Obtains an AuthTokenMiddleware that uses the default FetchAuthTokenInterface
    * implementation to use in this environment.
    *
    * If supplied, $scope is used to in creating the credentials instance if
    * this does not fallback to the compute engine defaults.
    *
    * @param string|array scope the scope of the access request, expressed
    *   either as an Array or as a space-delimited String.
-   * @param $client GuzzleHttp\ClientInterface optional client.
+   * @param callable $httpHandler callback which delivers psr7 request
    * @param cacheConfig configuration for the cache when it's present
    * @param object $cache an implementation of CacheInterface
    *
    * @throws DomainException if no implementation can be obtained.
    */
-  public static function getFetcher(
-      $scope = null,
-      ClientInterface $client = null,
-      array $cacheConfig = null,
-      CacheInterface $cache = null)
-  {
-    $creds = self::getCredentials($scope, $client);
-    return new AuthTokenFetcher($creds, $cacheConfig, $cache, $client);
+  public static function getMiddleware(
+    $scope = null,
+    callable $httpHandler = null,
+    array $cacheConfig = null,
+    CacheInterface $cache = null
+  ) {
+    $creds = self::getCredentials($scope, $httpHandler);
+
+    return new AuthTokenMiddleware($creds, $cacheConfig, $cache, $httpHandler);
   }
 
   /**
@@ -86,10 +121,10 @@ public static function getFetcher(
    * @param string|array scope the scope of the access request, expressed
    *   either as an Array or as a space-delimited String.
    *
-   * @param $client GuzzleHttp\ClientInterface optional client.
+   * @param callable $httpHandler callback which delivers psr7 request
    * @throws DomainException if no implementation can be obtained.
    */
-  public static function getCredentials($scope = null, $client = null)
+  public static function getCredentials($scope = null, callable $httpHandler = null)
   {
     $creds = CredentialsLoader::fromEnv($scope);
     if (!is_null($creds)) {
@@ -102,7 +137,7 @@ public static function getCredentials($scope = null, $client = null)
     if (AppIdentityCredentials::onAppEngine()) {
       return new AppIdentityCredentials($scope);
     }
-    if (GCECredentials::onGce($client)) {
+    if (GCECredentials::onGce($httpHandler)) {
       return new GCECredentials();
     }
     throw new \DomainException(self::notFound());

src/CacheInterface.php

@@ -48,5 +48,4 @@ public function set($key, $value);
    * @param String $key
    */
   public function delete($key);
-
-}
+}

src/CacheTrait.php

@@ -0,0 +1,68 @@
+<?php
+/*
+ * Copyright 2015 Google Inc.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+namespace Google\Auth;
+
+trait CacheTrait
+{
+  /**
+   * Gets the cached value if it is present in the cache when that is
+   * available.
+   */
+  private function getCachedValue()
+  {
+    if (is_null($this->cache)) {
+      return null;
+    }
+
+    if (isset($this->fetcher)) {
+      $fetcherKey = $this->fetcher->getCacheKey();
+    } else {
+      $fetcherKey = $this->getCacheKey();
+    }
+
+    if (is_null($fetcherKey)) {
+      return null;
+    }
+
+    $key = $this->cacheConfig['prefix'] . $fetcherKey;
+    return $this->cache->get($key, $this->cacheConfig['lifetime']);
+  }
+
+  /**
+   * Saves the value in the cache when that is available.
+   */
+  private function setCachedValue($v)
+  {
+    if (is_null($this->cache)) {
+      return;
+    }
+
+    if (isset($this->fetcher)) {
+      $fetcherKey = $this->fetcher->getCacheKey();
+    } else {
+      $fetcherKey = $this->getCacheKey();
+    }
+
+    if (is_null($fetcherKey)) {
+      return;
+    }
+    $key = $this->cacheConfig['prefix'] . $fetcherKey;
+    $this->cache->set($key, $v);
+  }
+}
+

src/AppIdentityCredentials.php → src/Credentials/AppIdentityCredentials.php

@@ -15,10 +15,9 @@
  * limitations under the License.
  */
 
-namespace Google\Auth;
+namespace Google\Auth\Credentials;
 
-use GuzzleHttp\ClientInterface;
-use GuzzleHttp\Client;
+use Google\Auth\CredentialsLoader;
 
 /**
  * The AppIdentityService class is automatically defined on App Engine,
@@ -30,27 +29,26 @@
 /**
  * AppIdentityCredentials supports authorization on Google App Engine.
  *
- * It can be used to authorize requests using the AuthTokenFetcher, but will
- * only succeed if being run on App Engine:
+ * It can be used to authorize requests using the AuthTokenMiddleware or
+ * AuthTokenSubscriber, but will only succeed if being run on App Engine:
  *
+ *   use Google\Auth\Credentials\AppIdentityCredentials;
+ *   use Google\Auth\Middleware\AuthTokenMiddleware;
  *   use GuzzleHttp\Client;
- *   use Google\Auth\AppIdentityCredentials;
- *   use Google\Auth\AuthTokenFetcher;
+ *   use GuzzleHttp\HandlerStack;
  *
  *   $gae = new AppIdentityCredentials('https://www.googleapis.com/auth/books');
- *   $subscriber = new AuthTokenFetcher($gae);
+ *   $middleware = new AuthTokenMiddleware($gae);
+ *   $stack = HandlerStack::create();
+ *   $stack->push($middleware);
+ *
  *   $client = new Client([
- *      'base_url' => 'https://www.googleapis.com/books/v1',
- *      'defaults' => ['auth' => 'google_auth']
+ *       'handler' => $stack,
+ *       'base_uri' => 'https://www.googleapis.com/books/v1',
+ *       'auth' => 'google_auth'
  *   ]);
- *   $client->setDefaultOption('verify', '/etc/ca-certificates.crt');
- *   $client->getEmitter()->attach($subscriber);
- *   $res = $client->get('volumes?q=Henry+David+Thoreau&country=US');
  *
- * In Guzzle 5 and below, the App Engine certificates need to be set on the
- * guzzle client in order for SSL requests to succeed.
- *
- *   $client->setDefaultOption('verify', '/etc/ca-certificates.crt');
+ *   $res = $client->get('volumes?q=Henry+David+Thoreau&country=US');
  */
 class AppIdentityCredentials extends CredentialsLoader
 {
@@ -80,7 +78,7 @@ public static function onAppEngine()
    * As the AppIdentityService uses protobufs to fetch the access token,
    * the GuzzleHttp\ClientInterface instance passed in will not be used.
    *
-   * @param $client GuzzleHttp\ClientInterface optional client.
+   * @param callable $httpHandler callback which delivers psr7 request
    * @return array the auth metadata:
    *  array(2) {
    *   ["access_token"]=>
@@ -89,7 +87,7 @@ public static function onAppEngine()
    *   string(10) "1444339905"
    *  }
    */
-  public function fetchAuthToken(ClientInterface $unusedClient = null)
+  public function fetchAuthToken(callable $httpHandler = null)
   {
     if (!self::onAppEngine()) {
       return array();