From 5d524529b4a7c31105d2007debf61d161cd1f8f0 Mon Sep 17 00:00:00 2001 From: qkqpttgf <45693631+qkqpttgf@users.noreply.github.com> Date: Mon, 1 Mar 2021 17:46:01 +0800 Subject: [PATCH] Create Googledrive.php --- disk/Googledrive.php | 571 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 571 insertions(+) create mode 100644 disk/Googledrive.php diff --git a/disk/Googledrive.php b/disk/Googledrive.php new file mode 100644 index 0000000..f31b263 --- /dev/null +++ b/disk/Googledrive.php @@ -0,0 +1,571 @@ +disktag = $tag; + $this->redirect_uri = 'https://scfonedrive.github.io'; + if (getConfig('client_id', $tag) && getConfig('client_secret', $tag)) { + $this->client_id = getConfig('client_id', $tag); + $this->client_secret = getConfig('client_secret', $tag); + } else { + $this->client_id = '106151778902-ajieetaab5ondhbvia97n4tr5k0cg8eo.apps.googleusercontent.com'; + $this->client_secret = 'LlCV-rQClzYIKCEqiVddh68G'; + //$this->api_key = 'AIzaSyBjQG09ET3pqEXKs25K8OPI_YYBWuR0EZQ'; + } + //$this->oauth_url = 'https://www.googleapis.com/oauth2/v4/'; + $this->oauth_url = 'https://accounts.google.com/o/oauth2/'; + $this->api_url = 'https://www.googleapis.com/drive/v3/'; + $this->scope = 'https://www.googleapis.com/auth/drive'; + + $this->client_secret = urlencode($this->client_secret); + $this->scope = urlencode($this->scope); + //$this->DownurlStrName = '@microsoft.graph.downloadUrl'; + //$this->ext_api_url = '/me/drive/root'; + $this->default_drive_id = getConfig('default_drive_id', $tag); + $res = $this->get_access_token(getConfig('refresh_token', $tag)); + } + + public function isfine() + { + if (!$this->access_token) return false; + else return true; + } + public function show_base_class() + { + return get_class(); + //$tmp[0] = get_class(); + //$tmp[1] = get_class($this); + //return $tmp; + } + + public function ext_show_innerenv() + { + if ($this->default_drive_id!='') return ['default_drive_id']; + return []; + } + + public function list_files($path = '/') + { + $files = $this->list_path($path); + + return $this->files_format($files); + } + + protected function files_format($files) + { + if (isset($files['files'])) { + $tmp['type'] = 'folder'; + $tmp['id'] = $files['id']; + $tmp['name'] = $files['name']; + $tmp['time'] = $files['modifiedTime']; + $tmp['size'] = $files['size']; + $tmp['childcount'] = $files['folder']['childCount']; + $tmp['page'] = $files['folder']['page']; + foreach ($files['files'] as $file) { + $filename = strtolower($file['name']); + if ($file['mimeType']=='application/vnd.google-apps.folder') { + $tmp['list'][$filename]['type'] = 'folder'; + } else { + $tmp['list'][$filename]['type'] = 'file'; + //var_dump($file); + //echo $file['name'] . ':' . $this->DownurlStrName . ':' . $file[$this->DownurlStrName] . PHP_EOL; + $tmp['list'][$filename]['url'] = $file['webContentLink']; + $tmp['list'][$filename]['mime'] = $file['mimeType']; + } + $tmp['list'][$filename]['id'] = $file['id']; + $tmp['list'][$filename]['name'] = $file['name']; + $tmp['list'][$filename]['time'] = $file['modifiedTime']; + $tmp['list'][$filename]['size'] = $file['size']; + } + } elseif (isset($files['mimeType'])) { + $tmp['type'] = 'file'; + $tmp['id'] = $files['id']; + $tmp['name'] = $files['name']; + $tmp['time'] = $files['modifiedTime']; + $tmp['size'] = $files['size']; + $tmp['mime'] = $files['mimeType']; + $tmp['url'] = $files['webContentLink']; + $tmp['content'] = $files['content']; + } else/*if (isset($files['error']))*/ { + return $files; + } + //error_log1(json_encode($tmp)); + return $tmp; + } + + protected function list_path($path = '/') + { + global $exts; + while (substr($path, -1)=='/') $path = substr($path, 0, -1); + if ($path == '') $path = '/'; + + //if (!($files = getcache('path_' . $path, $this->disktag))) { + //$response = curl('GET', $this->api_url . 'drives', '', ['Authorization' => 'Bearer ' . $this->access_token]); + //$response = curl('GET', $this->api_url . 'files?fields=*,files(id,name,mimeType,size,modifiedTime,parents,webContentLink,thumbnailLink),nextPageToken' . (($this->default_drive_id!='')?'&driveId=' . $this->default_drive_id . '&corpora=teamDrive&includeItemsFromAllDrives=true&supportsAllDrives=true':''), '', ['Authorization' => 'Bearer ' . $this->access_token]); + if ($path == '/' || $path == '') { + $files = $this->fileList(); + //error_log1('root_id' . $files['id']); + //$files['id'] = 'root'; + //$files['type'] = 'folder'; + } else { + $tmp = splitlast($path, '/'); + $parent_path = $tmp[0]; + $filename = urldecode($tmp[1]); + $parent_folder = $this->list_path($parent_path); + $i = 0; + foreach ($parent_folder['files'] as $item) { + if ($item['name']==$filename) { + if ($item['mimeType']=='application/vnd.google-apps.folder') { + $files = $this->fileList($item['id']); + $files['type'] = 'folder'; + $files['id'] = $item['id']; + $files['name'] = $item['name']; + $files['time'] = $item['modifiedTime']; + $files['size'] = $item['size']; + } else { + //if (isset($item['mimeType']) && $item['mimeType']!='application/vnd.google-apps.folder') { + if (in_array(splitlast($item['name'],'.')[1], $exts['txt'])) { + if (!(isset($item['content'])&&$item['content']['stat']==200)) { + $content1 = curl('GET', $item['webContentLink'], '', '', 1); + //error_log1(json_encode($tmp, JSON_PRETTY_PRINT)); + if ($content1['stat']==302) { + $content1 = curl('GET', $content1['returnhead']['Location'], '', ["User-Agent"=>"qkqpttgf/OneManager 3.0.0", "Accept"=>"*/*"], 1); + } + error_log1($item['name'] . '~' . json_encode($content1, JSON_PRETTY_PRINT) . PHP_EOL); + $item['content'] = $content1; + $parent_folder['files'][$i] = $item; + savecache('path_' . $path, $parent_folder, $this->disktag); + } + } + if (isset($item['id'])&&$item['shared']===false) $this->permission('create', $item['id']); + //$this->permission('delete', $files['id']); + //} + $files = $item; + } + } + $i++; + } + //echo $files['name']; + } + + if (!$files) { + $files['error']['code'] = 'Not Found'; + $files['error']['message'] = 'Not Found'; + $files['error']['stat'] = 404; + } elseif (isset($files['stat'])) { + $files['error']['stat'] = $files['stat']; + $files['error']['code'] = 'Error'; + $files['error']['message'] = $files['body']; + } else { + savecache('path_' . $path, $files, $this->disktag, 600); + } + //} + //error_log1('path:' . $path . ', files:' . json_encode($files, JSON_PRETTY_PRINT)); + //error_log1('path:' . $path . ', files:' . substr(json_encode($files), 0, 150)); + return $files; + } + protected function fileList($parent_file_id = '') + { + $url = $this->api_url . 'files'; + if ($parent_file_id!='') $url .= '/' . $parent_file_id; + $url .= '?fields=files(id,name,mimeType,size,modifiedTime,parents,webContentLink,thumbnailLink,shared,permissions,permissionIds),nextPageToken'; + if ($this->default_drive_id!='') $url .= '&driveId=' . $this->default_drive_id . '&corpora=teamDrive&includeItemsFromAllDrives=true&supportsAllDrives=true'; + + $header['Authorization'] = 'Bearer ' . $this->access_token; + + $res = curl('GET', $url, '', $header); + if ($res['stat']==200) return json_decode($res['body'], true); + else return $res; + } + protected function permission($op, $fileId) + { + $url = $this->api_url . 'files/' . $fileId . '/permissions'; + if ($op=='create') { + $method = 'POST'; + $header['Content-Type'] = 'application/json'; + $tmp['role'] = 'reader'; + $tmp['type'] = 'anyone'; + $data = json_encode($tmp); + } elseif ($op=='delete') { + $url .= '/anyoneWithLink'; + $method = 'DELETE'; + $data = ''; + } else { + return false; + } + $url .= '?supportsAllDrives=true'; + $header['Authorization'] = 'Bearer ' . $this->access_token; + + $res = curl($method, $url, $data, $header); + //error_log1(json_encode($res, JSON_PRETTY_PRINT)); + return $res; + } + + public function AddDisk() { + global $constStr; + global $EnvConfigs; + + $envs = ''; + foreach ($EnvConfigs as $env => $v) if (isCommonEnv($env)) $envs .= '\'' . $env . '\', '; + $url = path_format($_SERVER['PHP_SELF'] . '/'); + + if (isset($_GET['Finish'])) { + if ($this->access_token == '') { + $refresh_token = getConfig('refresh_token', $this->disktag); + if (!$refresh_token) { + $html = 'No refresh_token config, please AddDisk again or wait minutes.
' . $this->disktag; + $title = 'Error'; + return message($html, $title, 201); + } + $response = $this->get_access_token($refresh_token); + if (!$response) return message($this->error['body'], 'Error', $this->error['stat']); + } + + $tmp = null; + if ($_POST['DriveType']=='Googledrive') { + $tmp['default_drive_id'] = ''; + } else { + // 直接是id + $tmp['default_drive_id'] = $_POST['DriveType']; + } + + $response = setConfigResponse( setConfig($tmp, $this->disktag) ); + if (api_error($response)) { + $html = api_error_msg($response); + $title = 'Error'; + return message($html, $title, 201); + } else { + $str .= ''; + return message($str, getconstStr('WaitJumpIndex'), 201); + } + } + + if (isset($_GET['SelectDrive'])) { + if ($this->access_token == '') { + $refresh_token = getConfig('refresh_token', $this->disktag); + if (!$refresh_token) { + $html = 'No refresh_token config, please AddDisk again or wait minutes.
' . $this->disktag; + $title = 'Error'; + return message($html, $title, 201); + } + $response = $this->get_access_token($refresh_token); + if (!$response) return message($this->error['body'], 'Error', $this->error['stat']); + } + + $api = $this->api_url . 'drives'; + $arr = curl('GET', $api, '', [ 'Authorization' => 'Bearer ' . $this->access_token ]); + //if (!($arr['stat']==200||$arr['stat']==403||$arr['stat']==400||$arr['stat']==404)) + if ($arr['stat']!=200) return message($arr['stat'] . json_encode(json_decode($arr['body']), JSON_PRETTY_PRINT), 'Get followedSites', $arr['stat']); + error_log1($arr['body']); + $drives = json_decode($arr['body'], true)['drives']; + + $title = 'Select Driver'; + $html = ' +
+
+
'; + if ($drives[0]!='') foreach ($drives as $k => $v) { + $html .= ' + '; + } + $html .= ' + +
+
+ + '; + return message($html, $title, 201); + } + + if (isset($_GET['install2']) && isset($_GET['code'])) { + $data['client_id'] = $this->client_id; + $data['client_secret'] = $this->client_secret; + $data['grant_type'] = 'authorization_code'; + $data['redirect_uri'] = $this->redirect_uri; + $data['code'] = $_GET['code']; + $api = $this->oauth_url . 'token'; + //$api = 'https://www.googleapis.com/oauth2/v4/token'; + $tmp = curl('POST', + $api, + json_encode($data) + ); + if ($tmp['stat']==200) $ret = json_decode($tmp['body'], true); + if (isset($ret['refresh_token'])) { + $refresh_token = $ret['refresh_token']; + $str = ' + refresh_token :
'; + $str .= ' +

+ ' . getconstStr('SavingToken') . ' + '; + $tmptoken['refresh_token'] = $refresh_token; + //$tmptoken['token_expires'] = time()+7*24*60*60; + $response = setConfigResponse( setConfig($tmptoken, $this->disktag) ); + if (api_error($response)) { + $html = api_error_msg($response); + $title = 'Error'; + return message($html, $title, 201); + } else { + savecache('access_token', $ret['access_token'], $this->disktag, $ret['expires_in'] - 60); + $str .= ' + '; + return message($str, getconstStr('Wait') . ' 3s', 201); + } + } + return message('
' . $tmp['body'] . '
', $tmp['stat']); + //return message('
' . json_encode($ret, JSON_PRETTY_PRINT) . '
', 500); + } + + if (isset($_GET['install1'])) { + if (get_class($this)=='Googledrive') { + return message(' + ' . getconstStr('JumptoOffice') . ' + + ', getconstStr('Wait') . ' 1s', 201); + } else { + return message('Something error, retry after a few seconds.', 'Retry', 201); + } + } + + if (isset($_GET['install0'])) { + if ($_POST['disktag_add']!='') { + $_POST['disktag_add'] = preg_replace('/[^0-9a-zA-Z|_]/i', '', $_POST['disktag_add']); + $f = substr($_POST['disktag_add'], 0, 1); + if (strlen($_POST['disktag_add'])==1) $_POST['disktag_add'] .= '_'; + if (isCommonEnv($_POST['disktag_add'])) { + return message('Do not input ' . $envs . '
', 'Error', 201); + } elseif (!(('a'<=$f && $f<='z') || ('A'<=$f && $f<='Z'))) { + return message('Please start with letters
+ ', 'Error', 201); + } + + $tmp = null; + // clear envs + foreach ($EnvConfigs as $env => $v) if (isInnerEnv($env)) $tmp[$env] = ''; + + //$this->disktag = $_POST['disktag_add']; + $tmp['disktag_add'] = $_POST['disktag_add']; + $tmp['diskname'] = $_POST['diskname']; + $tmp['Driver'] = 'Googledrive'; + + if ($_POST['NT_Drive_custom']=='on') { + $tmp['client_id'] = $_POST['NT_client_id']; + $tmp['client_secret'] = $_POST['NT_client_secret']; + } + + $response = setConfigResponse( setConfig($tmp, $this->disktag) ); + if (api_error($response)) { + $html = api_error_msg($response); + $title = 'Error'; + } else { + $title = getconstStr('MayinEnv'); + $html = getconstStr('Wait') . ' 3s'; + } + return message($html, $title, 201); + } + } + + $html = ' +
+
+ ' . getconstStr('DiskTag') . ': (' . getConfig('disktag') . ') +
+ ' . getconstStr('DiskName') . ': +
+
+
+
+ +
+
'; + if ($_SERVER['language']=='zh-cn') $html .= '你要理解 scfonedrive.github.io 是github上的静态网站，
除非github真的挂掉了，
不然，稍后你如果连不上，请检查你的运营商或其它“你懂的”问题！
'; + $html .=' + +
+
+ '; + $title = 'Select Account Type'; + return message($html, $title, 201); + } + + protected function get_access_token($refresh_token) { + if (!$refresh_token) { + $tmp['stat'] = 0; + $tmp['body'] = 'No refresh_token'; + $this->error = $tmp; + return false; + } + if (!($this->access_token = getcache('access_token', $this->disktag))) { + $p=0; + $data['client_id'] = $this->client_id; + $data['client_secret'] = $this->client_secret; + $data['grant_type'] = 'refresh_token'; + //$data['redirect_uri'] = $this->redirect_uri; + $data['refresh_token'] = $refresh_token; + while ($response['stat']==0&&$p<3) { + //$response = curl('POST', 'https://www.googleapis.com/oauth2/v4/token', json_encode($data)); + $response = curl('POST', $this->oauth_url . 'token', json_encode($data)); + $p++; + } + if ($response['stat']==200) $ret = json_decode($response['body'], true); + if (!isset($ret['access_token'])) { + error_log1($this->oauth_url . 'token' . '?client_id=' . $this->client_id . '&client_secret=' . $this->client_secret . '&grant_type=refresh_token&refresh_token=' . substr($refresh_token, 0, 20) . '******' . substr($refresh_token, -20)); + error_log1('failed to get [' . $this->disktag . '] access_token. response: ' . $response['body']); + $response['body'] = json_encode(json_decode($response['body']), JSON_PRETTY_PRINT); + $response['body'] .= '\nfailed to get [' . $this->disktag . '] access_token.'; + $this->error = $response; + return false; + //throw new Exception($response['stat'].', failed to get ['.$this->disktag.'] access_token.'.$response['body']); + } + $tmp = $ret; + $tmp['access_token'] = substr($tmp['access_token'], 0, 10) . '******'; + //$tmp['refresh_token'] = substr($tmp['refresh_token'], 0, 10) . '******'; + error_log1('[' . $this->disktag . '] Get access token:' . json_encode($tmp, JSON_PRETTY_PRINT)); + $this->access_token = $ret['access_token']; + savecache('access_token', $this->access_token, $this->disktag, $ret['expires_in'] - 300); + //if (time()>getConfig('token_expires', $this->disktag)) setConfig([ 'refresh_token' => $ret['refresh_token'], 'token_expires' => time()+7*24*60*60 ], $this->disktag); + return true; + } + return true; + } + + protected function GDAPI($method, $path, $data = '') + { + if (substr($path,0,7) == 'http://' or substr($path,0,8) == 'https://') { + $url=$path; + $lenth=strlen($data); + $headers['Content-Length'] = $lenth; + $lenth--; + $headers['Content-Range'] = 'bytes 0-' . $lenth . '/' . $headers['Content-Length']; + } else { + $url = $this->api_url . $this->ext_api_url; + if ($path=='' or $path=='/') { + $url .= '/'; + } else { + $url .= ':' . $path; + if (substr($url,-1)=='/') $url=substr($url,0,-1); + } + if ($method=='PUT') { + if ($path=='' or $path=='/') { + $url .= 'content'; + } else { + $url .= ':/content'; + } + $headers['Content-Type'] = 'text/plain'; + } elseif ($method=='PATCH') { + $headers['Content-Type'] = 'application/json'; + } elseif ($method=='POST') { + $headers['Content-Type'] = 'application/json'; + } elseif ($method=='DELETE') { + $headers['Content-Type'] = 'application/json'; + } else { + if ($path=='' or $path=='/') { + $url .= $method; + } else { + $url .= ':/' . $method; + } + $method='POST'; + $headers['Content-Type'] = 'application/json'; + } + } + $headers['Authorization'] = 'Bearer ' . $this->access_token; + if (!isset($headers['Accept'])) $headers['Accept'] = '*/*'; + //if (!isset($headers['Referer'])) $headers['Referer'] = $url;* + $sendHeaders = array(); + foreach ($headers as $headerName => $headerVal) { + $sendHeaders[] = $headerName . ': ' . $headerVal; + } + $ch = curl_init(); + curl_setopt($ch, CURLOPT_URL, $url); + curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method); + curl_setopt($ch, CURLOPT_POSTFIELDS, $data); + curl_setopt($ch, CURLOPT_TIMEOUT, 5); + curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 10); + curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); + curl_setopt($ch, CURLOPT_HEADER, 0); + curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0); + curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); + //curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1); + curl_setopt($ch, CURLOPT_HTTPHEADER, $sendHeaders); + $response['body'] = curl_exec($ch); + $response['stat'] = curl_getinfo($ch,CURLINFO_HTTP_CODE); + //$response['Location'] = curl_getinfo($ch); + curl_close($ch); + error_log1($response['stat'].' + '.$response['body'].' + '.$url.' + '); + return $response; + } + +}