123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899 |
- <?php
-
- use Google\Auth\CredentialsLoader;
- use Google\Auth\HttpHandler\HttpHandlerFactory;
- use Google\Auth\FetchAuthTokenCache;
- use Google\Auth\Subscriber\AuthTokenSubscriber;
- use Google\Auth\Subscriber\ScopedAccessTokenSubscriber;
- use Google\Auth\Subscriber\SimpleSubscriber;
- use GuzzleHttp\Client;
- use GuzzleHttp\ClientInterface;
- use Psr\Cache\CacheItemPoolInterface;
-
- /**
- *
- */
- class Google_AuthHandler_Guzzle5AuthHandler
- {
- protected $cache;
- protected $cacheConfig;
-
- public function __construct(CacheItemPoolInterface $cache = null, array $cacheConfig = [])
- {
- $this->cache = $cache;
- $this->cacheConfig = $cacheConfig;
- }
-
- public function attachCredentials(
- ClientInterface $http,
- CredentialsLoader $credentials,
- callable $tokenCallback = null
- ) {
- // use the provided cache
- if ($this->cache) {
- $credentials = new FetchAuthTokenCache(
- $credentials,
- $this->cacheConfig,
- $this->cache
- );
- }
- // if we end up needing to make an HTTP request to retrieve credentials, we
- // can use our existing one, but we need to throw exceptions so the error
- // bubbles up.
- $authHttp = $this->createAuthHttp($http);
- $authHttpHandler = HttpHandlerFactory::build($authHttp);
- $subscriber = new AuthTokenSubscriber(
- $credentials,
- $authHttpHandler,
- $tokenCallback
- );
-
- $http->setDefaultOption('auth', 'google_auth');
- $http->getEmitter()->attach($subscriber);
-
- return $http;
- }
-
- public function attachToken(ClientInterface $http, array $token, array $scopes)
- {
- $tokenFunc = function ($scopes) use ($token) {
- return $token['access_token'];
- };
-
- $subscriber = new ScopedAccessTokenSubscriber(
- $tokenFunc,
- $scopes,
- $this->cacheConfig,
- $this->cache
- );
-
- $http->setDefaultOption('auth', 'scoped');
- $http->getEmitter()->attach($subscriber);
-
- return $http;
- }
-
- public function attachKey(ClientInterface $http, $key)
- {
- $subscriber = new SimpleSubscriber(['key' => $key]);
-
- $http->setDefaultOption('auth', 'simple');
- $http->getEmitter()->attach($subscriber);
-
- return $http;
- }
-
- private function createAuthHttp(ClientInterface $http)
- {
- return new Client(
- [
- 'base_url' => $http->getBaseUrl(),
- 'defaults' => [
- 'exceptions' => true,
- 'verify' => $http->getDefaultOption('verify'),
- 'proxy' => $http->getDefaultOption('proxy'),
- ]
- ]
- );
- }
- }
|