123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380 |
- <?php
- use League\Flysystem\Filesystem;
- use League\Flysystem\Adapter\Local;
- use League\Flysystem\Cached\CachedAdapter;
- use League\Flysystem\Cached\Storage\Adapter as ACache;
- use Hypweb\Flysystem\GoogleDrive\GoogleDriveAdapter;
- use Hypweb\Flysystem\Cached\Extra\Hasdir;
- use Hypweb\Flysystem\Cached\Extra\DisableEnsureParentDirectories;
- use Hypweb\elFinderFlysystemDriverExt\Driver as ExtDriver;
- elFinder::$netDrivers['googledrive'] = 'FlysystemGoogleDriveNetmount';
- if (!class_exists('elFinderVolumeFlysystemGoogleDriveCache', false)) {
- class elFinderVolumeFlysystemGoogleDriveCache extends ACache
- {
- use Hasdir;
- use DisableEnsureParentDirectories;
- }
- }
- class elFinderVolumeFlysystemGoogleDriveNetmount extends ExtDriver
- {
- public function __construct()
- {
- parent::__construct();
- $opts = array(
- 'acceptedName' => '#^[^/\\?*:|"<>]*[^./\\?*:|"<>]$#',
- 'rootCssClass' => 'elfinder-navbar-root-googledrive',
- 'gdAlias' => '%s@GDrive',
- 'gdCacheDir' => __DIR__ . '/.tmp',
- 'gdCachePrefix' => 'gd-',
- 'gdCacheExpire' => 600
- );
- $this->options = array_merge($this->options, $opts);
- }
- /**
- * Prepare driver before mount volume.
- * Return true if volume is ready.
- *
- * @return bool
- **/
- protected function init()
- {
- if (empty($this->options['icon'])) {
- $this->options['icon'] = true;
- }
- if ($res = parent::init()) {
- if ($this->options['icon'] === true) {
- unset($this->options['icon']);
- }
- // enable command archive
- $this->options['useRemoteArchive'] = true;
- }
- return $res;
- }
- /**
- * Prepare
- * Call from elFinder::netmout() before volume->mount()
- *
- * @param $options
- *
- * @return Array
- * @author Naoki Sawada
- */
- public function netmountPrepare($options)
- {
- if (empty($options['client_id']) && defined('ELFINDER_GOOGLEDRIVE_CLIENTID')) {
- $options['client_id'] = ELFINDER_GOOGLEDRIVE_CLIENTID;
- }
- if (empty($options['client_secret']) && defined('ELFINDER_GOOGLEDRIVE_CLIENTSECRET')) {
- $options['client_secret'] = ELFINDER_GOOGLEDRIVE_CLIENTSECRET;
- }
- if (!isset($options['pass'])) {
- $options['pass'] = '';
- }
- try {
- $client = new \Google_Client();
- $client->setClientId($options['client_id']);
- $client->setClientSecret($options['client_secret']);
- if ($options['pass'] === 'reauth') {
- $options['pass'] = '';
- $this->session->set('GoogleDriveAuthParams', [])->set('GoogleDriveTokens', []);
- } else if ($options['pass'] === 'googledrive') {
- $options['pass'] = '';
- }
- $options = array_merge($this->session->get('GoogleDriveAuthParams', []), $options);
- if (!isset($options['access_token'])) {
- $options['access_token'] = $this->session->get('GoogleDriveTokens', []);
- $this->session->remove('GoogleDriveTokens');
- }
- $aToken = $options['access_token'];
- $rootObj = $service = null;
- if ($aToken) {
- try {
- $client->setAccessToken($aToken);
- if ($client->isAccessTokenExpired()) {
- $aToken = array_merge($aToken, $client->fetchAccessTokenWithRefreshToken());
- $client->setAccessToken($aToken);
- }
- $service = new \Google_Service_Drive($client);
- $rootObj = $service->files->get('root');
- $options['access_token'] = $aToken;
- $this->session->set('GoogleDriveAuthParams', $options);
- } catch (Exception $e) {
- $aToken = [];
- $options['access_token'] = [];
- if ($options['user'] !== 'init') {
- $this->session->set('GoogleDriveAuthParams', $options);
- return array('exit' => true, 'error' => elFinder::ERROR_REAUTH_REQUIRE);
- }
- }
- }
- $itpCare = isset($options['code']);
- $code = $itpCare? $options['code'] : (isset($_GET['code'])? $_GET['code'] : '');
- if ($code || $options['user'] === 'init') {
- if (empty($options['url'])) {
- $options['url'] = elFinder::getConnectorUrl();
- }
- if (isset($options['id'])) {
- $callback = $options['url'] . (strpos($options['url'], '?') !== false? '&' : '?') . 'cmd=netmount&protocol=googledrive&host=' . ($options['id'] === 'elfinder'? '1' : $options['id']);
- $client->setRedirectUri($callback);
- }
- if (!$aToken && empty($code)) {
- $client->setScopes([Google_Service_Drive::DRIVE]);
- if (!empty($options['offline'])) {
- $client->setApprovalPrompt('force');
- $client->setAccessType('offline');
- }
- $url = $client->createAuthUrl();
- $html = '<input id="elf-volumedriver-googledrive-host-btn" class="ui-button ui-widget ui-state-default ui-corner-all ui-button-text-only" value="{msg:btnApprove}" type="button">';
- $html .= '<script>
- $("#' . $options['id'] . '").elfinder("instance").trigger("netmount", {protocol: "googledrive", mode: "makebtn", url: "' . $url . '"});
- </script>';
- if (empty($options['pass']) && $options['host'] !== '1') {
- $options['pass'] = 'return';
- $this->session->set('GoogleDriveAuthParams', $options);
- return array('exit' => true, 'body' => $html);
- } else {
- $out = array(
- 'node' => $options['id'],
- 'json' => '{"protocol": "googledrive", "mode": "makebtn", "body" : "' . str_replace($html, '"', '\\"') . '", "error" : "' . elFinder::ERROR_ACCESS_DENIED . '"}',
- 'bind' => 'netmount'
- );
- return array('exit' => 'callback', 'out' => $out);
- }
- } else {
- if ($code) {
- if (!empty($options['id'])) {
- $aToken = $client->fetchAccessTokenWithAuthCode($code);
- $options['access_token'] = $aToken;
- unset($options['code']);
- $this->session->set('GoogleDriveTokens', $aToken)->set('GoogleDriveAuthParams', $options);
- $out = array(
- 'node' => $options['id'],
- 'json' => '{"protocol": "googledrive", "mode": "done", "reset": 1}',
- 'bind' => 'netmount'
- );
- } else {
- $nodeid = ($_GET['host'] === '1')? 'elfinder' : $_GET['host'];
- $out = array(
- 'node' => $nodeid,
- 'json' => json_encode(array(
- 'protocol' => 'googledrive',
- 'host' => $nodeid,
- 'mode' => 'redirect',
- 'options' => array(
- 'id' => $nodeid,
- 'code'=> $code
- )
- )),
- 'bind' => 'netmount'
- );
- }
- if (!$itpCare) {
- return array('exit' => 'callback', 'out' => $out);
- } else {
- return array('exit' => true, 'body' => $out['json']);
- }
- }
- $folders = [];
- foreach ($service->files->listFiles([
- 'pageSize' => 1000,
- 'q' => 'trashed = false and mimeType = "application/vnd.google-apps.folder"'
- ]) as $f) {
- $folders[$f->getId()] = $f->getName();
- }
- natcasesort($folders);
- $folders = ['root' => $rootObj->getName()] + $folders;
- $folders = json_encode($folders);
- $json = '{"protocol": "googledrive", "mode": "done", "folders": ' . $folders . '}';
- $options['pass'] = 'return';
- $html = 'Google.com';
- $html .= '<script>
- $("#' . $options['id'] . '").elfinder("instance").trigger("netmount", ' . $json . ');
- </script>';
- $this->session->set('GoogleDriveAuthParams', $options);
- return array('exit' => true, 'body' => $html);
- }
- }
- } catch (Exception $e) {
- $this->session->remove('GoogleDriveAuthParams')->remove('GoogleDriveTokens');
- if (empty($options['pass'])) {
- return array('exit' => true, 'body' => '{msg:' . elFinder::ERROR_ACCESS_DENIED . '}' . ' ' . $e->getMessage());
- } else {
- return array('exit' => true, 'error' => [elFinder::ERROR_ACCESS_DENIED, $e->getMessage()]);
- }
- }
- if (!$aToken) {
- return array('exit' => true, 'error' => elFinder::ERROR_REAUTH_REQUIRE);
- }
- if ($options['path'] === '/') {
- $options['path'] = 'root';
- }
- try {
- $file = $service->files->get($options['path']);
- $options['alias'] = sprintf($this->options['gdAlias'], $file->getName());
- if (!empty($this->options['netkey'])) {
- elFinder::$instance->updateNetVolumeOption($this->options['netkey'], 'alias', $this->options['alias']);
- }
- } catch (Google_Service_Exception $e) {
- $err = json_decode($e->getMessage(), true);
- if (isset($err['error']) && $err['error']['code'] == 404) {
- return array('exit' => true, 'error' => [elFinder::ERROR_TRGDIR_NOT_FOUND, $options['path']]);
- } else {
- return array('exit' => true, 'error' => $e->getMessage());
- }
- } catch (Exception $e) {
- return array('exit' => true, 'error' => $e->getMessage());
- }
- foreach (['host', 'user', 'pass', 'id', 'offline'] as $key) {
- unset($options[$key]);
- }
- return $options;
- }
- /**
- * process of on netunmount
- * Drop table `dropbox` & rm thumbs
- *
- * @param $netVolumes
- * @param $key
- *
- * @return bool
- * @internal param array $options
- */
- public function netunmount($netVolumes, $key)
- {
- $cache = $this->options['gdCacheDir'] . DIRECTORY_SEPARATOR . $this->options['gdCachePrefix'] . $this->netMountKey;
- if (file_exists($cache) && is_writeable($cache)) {
- unlink($cache);
- }
- if ($tmbs = glob($this->tmbPath . DIRECTORY_SEPARATOR . $this->netMountKey . '*')) {
- foreach ($tmbs as $file) {
- unlink($file);
- }
- }
- return true;
- }
- /**
- * "Mount" volume.
- * Return true if volume available for read or write,
- * false - otherwise
- *
- * @param array $opts
- *
- * @return bool
- * @author Naoki Sawada
- */
- public function mount(array $opts)
- {
- $creds = null;
- if (isset($opts['access_token'])) {
- $this->netMountKey = md5(join('-', array('googledrive', $opts['path'], (isset($opts['access_token']['refresh_token']) ? $opts['access_token']['refresh_token'] : $opts['access_token']['access_token']))));
- }
- $client = new \Google_Client();
- $client->setClientId($opts['client_id']);
- $client->setClientSecret($opts['client_secret']);
- if (!empty($opts['access_token'])) {
- $client->setAccessToken($opts['access_token']);
- }
- if ($this->needOnline && $client->isAccessTokenExpired()) {
- try {
- $creds = $client->fetchAccessTokenWithRefreshToken();
- } catch (LogicException $e) {
- $this->session->remove('GoogleDriveAuthParams');
- throw $e;
- }
- }
- $service = new \Google_Service_Drive($client);
- // If path is not set, use the root
- if (!isset($opts['path']) || $opts['path'] === '') {
- $opts['path'] = 'root';
- }
- $googleDrive = new GoogleDriveAdapter($service, $opts['path'], ['useHasDir' => true]);
- $opts['fscache'] = null;
- if ($this->options['gdCacheDir'] && is_writeable($this->options['gdCacheDir'])) {
- if ($this->options['gdCacheExpire']) {
- $opts['fscache'] = new elFinderVolumeFlysystemGoogleDriveCache(new Local($this->options['gdCacheDir']), $this->options['gdCachePrefix'] . $this->netMountKey, $this->options['gdCacheExpire']);
- }
- }
- if ($opts['fscache']) {
- $filesystem = new Filesystem(new CachedAdapter($googleDrive, $opts['fscache']));
- } else {
- $filesystem = new Filesystem($googleDrive);
- }
- $opts['driver'] = 'FlysystemExt';
- $opts['filesystem'] = $filesystem;
- $opts['separator'] = '/';
- $opts['checkSubfolders'] = true;
- if (!isset($opts['alias'])) {
- $opts['alias'] = 'GoogleDrive';
- }
- if ($res = parent::mount($opts)) {
- // update access_token of session data
- if ($creds) {
- $netVolumes = $this->session->get('netvolume');
- $netVolumes[$this->netMountKey]['access_token'] = array_merge($netVolumes[$this->netMountKey]['access_token'], $creds);
- $this->session->set('netvolume', $netVolumes);
- }
- }
- return $res;
- }
- /**
- * @inheritdoc
- */
- protected function tmbname($stat)
- {
- return $this->netMountKey . substr(substr($stat['hash'], strlen($this->id)), -38) . $stat['ts'] . '.png';
- }
- /**
- * Return debug info for client.
- *
- * @return array
- **/
- public function debug()
- {
- $res = parent::debug();
- if (!empty($this->options['netkey']) && empty($this->options['refresh_token']) && $this->options['access_token'] && isset($this->options['access_token']['refresh_token'])) {
- $res['refresh_token'] = $this->options['access_token']['refresh_token'];
- }
- return $res;
- }
- }
|