Merge pull request #167 from Arno2005/master

Filesystem adapter for GoogleDrive

src/Libraries/Storage/Adapters/Dropbox/DropboxApp.php

@@ -96,17 +96,17 @@ class DropboxApp
     /**
      * @var string
      */
-    private $appKey = null;
+    private $appKey;
 
     /**
      * @var string
      */
-    private $appSecret = null;
+    private $appSecret;
 
     /**
      * @var TokenServiceInterface
      */
-    private $tokenService = null;
+    private $tokenService;
 
     /**
      * DropboxApp constructor
@@ -125,8 +125,11 @@ public function __construct(string $appKey, string $appSecret, TokenServiceInter
 
     /**
      * Gets the auth URL
-     * @throws CryptorException
+     * @param string $redirectUrl
+     * @param string $tokenAccessType
+     * @return string
      * @throws AppException
+     * @throws CryptorException
      * @throws DatabaseException
      */
     public function getAuthUrl(string $redirectUrl, string $tokenAccessType = 'offline'): string

src/Libraries/Storage/Adapters/Dropbox/DropboxFileSystemAdapter.php

@@ -59,7 +59,7 @@ public static function getInstance(DropboxApp $dropboxApp): DropboxFileSystemAda
     /**
      * @inheritDoc
      */
-    public function makeDirectory(string $dirname): bool
+    public function makeDirectory(string $dirname, ?string $parentId = null): bool
     {
         try {
             $this->dropboxApp->rpcRequest(DropboxApp::ENDPOINT_CREATE_FOLDER, $this->dropboxApp->path($dirname));
@@ -97,7 +97,7 @@ public function get(string $filename)
     /**
      * @inheritDoc
      */
-    public function put(string $filename, string $content)
+    public function put(string $filename, string $content, ?string $parentId = null)
     {
         try {
             $response = $this->dropboxApp->contentRequest(DropboxApp::ENDPOINT_UPLOAD_FILE,

src/Libraries/Storage/Adapters/GoogleDrive/GoogleDriveApp.php

@@ -0,0 +1,251 @@
+<?php
+
+namespace Quantum\Libraries\Storage\Adapters\GoogleDrive;
+
+use Quantum\Exceptions\AppException;
+use Quantum\Exceptions\CryptorException;
+use Quantum\Exceptions\DatabaseException;
+use Quantum\Libraries\Curl\HttpClient;
+use Exception;
+
+class GoogleDriveApp
+{
+    /**
+     * Authorization URL
+     */
+    const AUTH_URL = 'https://accounts.google.com/o/oauth2/v2/auth';
+
+    /**
+     * Authorization scope
+     */
+    const AUTH_SCOPE = 'https://www.googleapis.com/auth/drive';
+
+    /**
+     * Token URL
+     */
+    const AUTH_TOKEN_URL = 'https://oauth2.googleapis.com/token';
+
+    /**
+     * URL for file metadata operations
+     */
+    const FILE_METADATA_URL = 'https://www.googleapis.com/drive/v3/files';
+
+    /**
+     * URL for file media operations
+     */
+    const FILE_MEDIA_URL = 'https://www.googleapis.com/upload/drive/v3/files';
+
+    /**
+     * Folder mimetype
+     */
+    const FOLDER_MIMETYPE = 'application/vnd.google-apps.folder';
+
+    /**
+     * Kind/Type  of drive file
+     */
+    const DRIVE_FILE_KIND = 'drive#file';
+
+    /**
+     * Error code for invalid token
+     */
+    const INVALID_TOKEN_ERROR_CODE = 401;
+
+    /**
+     * @var HttpClient
+     */
+    private $httpClient;
+
+    /**
+     * @var string
+     */
+    private $appKey;
+
+    /**
+     * @var string
+     */
+    private $appSecret;
+
+    /**
+     * @var TokenServiceInterface
+     */
+    private $tokenService;
+
+    /**
+     * GoogleDriveApp constructor
+     * @param string $appKey
+     * @param string $appSecret
+     * @param TokenServiceInterface $tokenService
+     * @param HttpClient $httpClient
+     */
+    public function __construct(string $appKey, string $appSecret, TokenServiceInterface $tokenService, HttpClient $httpClient)
+    {
+        $this->appKey = $appKey;
+        $this->appSecret = $appSecret;
+        $this->tokenService = $tokenService;
+        $this->httpClient = $httpClient;
+    }
+
+    /**
+     * Gets Auth URL
+     * @param string $redirectUrl
+     * @param string $accessType
+     * @return string
+     * @throws AppException
+     * @throws CryptorException
+     * @throws DatabaseException
+     */
+    public function getAuthUrl(string $redirectUrl, string $accessType = "offline"): string
+    {
+        $params = [
+            'client_id' => $this->appKey,
+            'response_type' => 'code',
+            'state' => csrf_token(),
+            'scope' => self::AUTH_SCOPE,
+            'redirect_uri' => $redirectUrl,
+            'access_type' => $accessType,
+        ];
+
+        return self::AUTH_URL . '?' . http_build_query($params, '', '&');
+    }
+
+    /**
+     * Fetch tokens
+     * @param string $code
+     * @param string $redirectUrl
+     * @param bool $byRefresh
+     * @return object|null
+     * @throws Exception
+     */
+    public function fetchTokens(string $code, string $redirectUrl = ''): ?object
+    {
+
+        $params = [
+            'code' => $code,
+            'grant_type' => 'authorization_code',
+            'client_id' => $this->appKey,
+            'client_secret' => $this->appSecret,
+            'redirect_uri' => $redirectUrl
+        ];
+
+        $response = $this->sendRequest(self::AUTH_TOKEN_URL, $params);
+
+        $this->tokenService->saveTokens($response->access_token, $response->refresh_token);
+
+        return $response;
+    }
+
+    /**
+     * Fetches the access token by refresh token
+     * @param string $refreshToken
+     * @return string
+     * @throws Exception
+     */
+    private function fetchAccessTokenByRefreshToken(string $refreshToken): string
+    {
+        $params = [
+            'refresh_token' => $refreshToken,
+            'grant_type' => 'refresh_token',
+            'client_id' => $this->appKey,
+            'client_secret' => $this->appSecret
+        ];
+
+        $response = $this->sendRequest(self::AUTH_TOKEN_URL, $params);
+
+        $this->tokenService->saveTokens($response->access_token);
+
+        return $response->access_token;
+    }
+
+    /**
+     * Sends rpc request
+     * @param string $uri
+     * @param mixed|null $data
+     * @param array $headers
+     * @param string $method
+     * @return mixed|null
+     * @throws Exception
+     */
+    public function sendRequest(string $uri, $data = null, array $headers = [], string $method = 'POST')
+    {
+        $this->httpClient
+            ->createRequest($uri)
+            ->setMethod($method)
+            ->setData($data)
+            ->setHeaders($headers)
+            ->start();
+
+        $responseBody = $this->httpClient->getResponseBody();
+
+        if ($errors = $this->httpClient->getErrors()) {
+            $code = $errors['code'];
+
+            if ($this->accessTokenNeedsRefresh($code)) {
+                $prevUrl = $this->httpClient->url();
+                $prevData = $this->httpClient->getData();
+                $prevHeaders = $this->httpClient->getRequestHeaders();
+
+                $refreshToken = $this->tokenService->getRefreshToken();
+
+                $accessToken = $this->fetchAccessTokenByRefreshToken($refreshToken);
+
+                $prevHeaders['Authorization'] = 'Bearer ' . $accessToken;
+
+                $responseBody = $this->sendRequest($prevUrl, $prevData, $prevHeaders);
+
+            } else {
+                throw new Exception(json_encode($responseBody ?? $errors), E_ERROR);
+            }
+        }
+
+        return $responseBody;
+    }
+
+    /**
+     * Sends rpc request
+     * @param string $url
+     * @param mixed $params
+     * @param string $method
+     * @param string $contentType
+     * @return mixed|null
+     * @throws Exception
+     */
+    public function rpcRequest(string $url, $params = [], string $method = 'POST', string $contentType = 'application/json')
+    {
+        try {
+            $headers = [
+                'Authorization' => 'Bearer ' . $this->tokenService->getAccessToken(),
+                'Content-Type' => $contentType
+            ];
+            return $this->sendRequest($url, $params, $headers, $method);
+        }catch (Exception $e){
+            throw new Exception($e->getMessage(), (int)$e->getCode());
+        }
+    }
+
+    /**
+     * Gets file information
+     * @param string $fileId
+     * @param bool $media
+     * @param array $params
+     * @return mixed|null
+     * @throws Exception
+     */
+    public function getFileInfo(string $fileId, bool $media = false, array $params = []){
+        $queryParam = $media ? '?alt=media' : '?fields=*';
+        return $this->rpcRequest(GoogleDriveApp::FILE_METADATA_URL . '/' . $fileId . $queryParam, $params, 'GET');
+    }
+
+    /**
+     * Checks if the access token need refresh
+     * @param int $code
+     * @return bool
+     */
+    private function accessTokenNeedsRefresh(int $code): bool
+    {
+        if ($code != 401) {
+            return false;
+        }
+
+        return true;
+    }
+}