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->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['downUrl']?$file['downUrl']:$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['downUrl']?$files['downUrl']:$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['id'])&&$item['shared']!==true) $this->permission('create', $item['id']); //$this->permission('delete', $files['id']); //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)) { //if (!isset($item['downUrl'])) { $res = curl('GET', $item['webContentLink'], '', '', 1); $weblink = $res['returnhead']['Location']; //if ($weblink!==null) $item['downUrl'] = $weblink; //else error_log1('Cant get link:' . json_encode($res, JSON_PRETTY_PRINT)); //} if ($res['stat']==302) { $content1 = curl('GET', $weblink, '', ["User-Agent"=>"qkqpttgf/OneManager 3.0.0", "Accept"=>"*/*"], 1); $item['content'] = $content1; } else $content1 = $res; //error_log1($item['name'] . '~' . json_encode($content1, JSON_PRETTY_PRINT) . PHP_EOL); $parent_folder['files'][$i] = $item; savecache('path_' . $path, $parent_folder, $this->disktag); } } //} //error_log1(json_encode($item, JSON_PRETTY_PRINT)); $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'; $url .= '?fields=files(id,name,mimeType,size,modifiedTime,parents,webContentLink,thumbnailLink,shared,permissions,permissionIds),nextPageToken'; //$url .= '?fields=files(*),nextPageToken'; //$url .= '?q=mimeType=\'application/vnd.google-apps.folder\''; if ($parent_file_id!='') { $q = ${parent_file_id}; } else { if ($this->default_drive_id!='') $q = $this->default_drive_id; else $q = 'root'; } $q = '\'' . $q . '\' in parents and trashed = false'; $q = urlencode($q); $url .= '&q=' . $q; 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('Set Share' . 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; } }