OneManager-php/disk/Onedrive.php

<?php
            // https://docs.microsoft.com/en-us/graph/api/driveitem-get?view=graph-rest-1.0
            // https://docs.microsoft.com/zh-cn/graph/api/driveitem-put-content?view=graph-rest-1.0&tabs=http
            // https://developer.microsoft.com/zh-cn/graph/graph-explorer

class Onedrive {
    protected $access_token;
    protected $disktag;

    function __construct($tag) {
        $this->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 = '734ef928-d74c-4555-8d1b-d942fa0a1a41';
            $this->client_secret = '_I5gOpmG5vTC2Ts_K._wCW4nN1km~4Pk52';
        }
        $this->oauth_url = 'https://login.microsoftonline.com/common/oauth2/v2.0/';
        $this->api_url = 'https://graph.microsoft.com/v1.0';
        $this->scope = 'https://graph.microsoft.com/Files.ReadWrite.All https://graph.microsoft.com/Sites.ReadWrite.All offline_access';
        $this->client_secret = urlencode($this->client_secret);
        $this->scope = urlencode($this->scope);
        $this->DownurlStrName = '@microsoft.graph.downloadUrl';
        $this->ext_api_url = '/me/drive/root';
        $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()
    {
        return [];
    }

    public function list_files($path = '/')
    {
        global $exts;
        if (!($files = getcache('path_' . $path, $this->disktag))) {
            $pos = splitlast($path, '/');
            $parentpath = $pos[0];
            if ($parentpath=='') $parentpath = '/';
            $filename = strtolower($pos[1]);
            if ($parentfiles = getcache('path_' . $parentpath, $this->disktag)) {
                if (isset($parentfiles['children'][$filename][$this->DownurlStrName])) {
                    if (in_array(splitlast($filename,'.')[1], $exts['txt'])) {
                        if (!(isset($parentfiles['children'][$filename]['content'])&&$parentfiles['children'][$filename]['content']['stat']==200)) {
                            //$content1 = curl('GET', $parentfiles['children'][$filename][$this->DownurlStrName]);
                            //$parentfiles['children'][$filename]['content'] = $content1;
                            //savecache('path_' . $parentpath, $parentfiles, $this->disktag);
                            if ($parentfiles['children'][$filename]['size']<1024*1024) {
                                if (!(isset($parentfiles['children'][$filename]['content'])&&$parentfiles['children'][$filename]['content']['stat']==200)) {
                                    $content1 = curl('GET', $parentfiles['children'][$filename][$this->DownurlStrName]);
                                    $tmp = null;
                                    $tmp = json_decode(json_encode($content1), true);
                                    if ($tmp['body']===null) {
                                        $txtcode = chkTxtCode($content1['body']);
                                        if ($txtcode!==false) $tmp['body'] = iconv($txtcode, 'UTF-8//TRANSLIT', $content1['body']);
                                        $tmp = json_decode(json_encode($tmp), true);
                                        if ($tmp['body']) $content1['body'] = $tmp['body'];
                                    }
                                    $parentfiles['children'][$filename]['content'] = $content1;
                                    savecache('path_' . $path, $parentfiles['children'][$filename], $this->disktag);
                                }
                            } else {
                                $parentfiles['children'][$filename]['content']['stat'] = 202;
                                $parentfiles['children'][$filename]['content']['body'] = 'File too large.';
                            }
                        }
                    }
                    return $this->files_format($parentfiles['children'][$filename]);
                }
            }

            $url = $this->api_url . $this->ext_api_url;
            if ($path !== '/') {
                $url .= ':' . $path;
                if (substr($url,-1)=='/') $url=substr($url,0,-1);
            }
            $url .= '?expand=children(select=id,name,size,file,folder,parentReference,lastModifiedDateTime,'.$this->DownurlStrName.')';
            $arr = $this->MSAPI('GET', $url);
            //echo $url . '<br><pre>' . json_encode($arr, JSON_PRETTY_PRINT) . '</pre>';
            if ($arr['stat']<500) {
                $files = json_decode($arr['body'], true);
                //echo '<pre>' . json_encode($files, JSON_PRETTY_PRINT) . '</pre>';
                if (isset($files['folder'])) {
                    if ($files['folder']['childCount']>200) {
                        // files num > 200 , then get nextlink
                        $page = $_POST['pagenum']==''?1:$_POST['pagenum'];
                        if ($page>1)
                        //if (!($files = getcache('path_1' . $path . '_' . $page, $this->disktag)))
                        {
                            $children = $this->fetch_files_children($path, $page);
                            //echo '<pre>' . json_encode($children, JSON_PRETTY_PRINT) . '</pre>';
                            $files['children'] = $children['value'];
                            //$files['children'] = children_name($files['children']);
                            $files['folder']['page'] = $page;
                            //savecache('path_' . $path . '_' . $page, $files, $this->disktag);
                        }
                    } else {
                    // files num < 200 , then cache
                        if (isset($files['children'])) {
                            $files['children'] = children_name($files['children']);
                        }
                        savecache('path_' . $path, $files, $this->disktag);
                    }
                }
                if (isset($files['file'])) {
                    if (in_array(strtolower(splitlast($files['name'],'.')[1]), $exts['txt'])) {
                        if ($files['size']<1024*1024) {
                            if (!(isset($files['content'])&&$files['content']['stat']==200)) {
                                $content1 = curl('GET', $files[$this->DownurlStrName]);
                                $tmp = null;
                                $tmp = json_decode(json_encode($content1), true);
                                if ($tmp['body']===null) {
                                    $txtcode = chkTxtCode($content1['body']);
                                    if ($txtcode!==false) $tmp['body'] = iconv($txtcode, 'UTF-8//TRANSLIT', $content1['body']);
                                    $tmp = json_decode(json_encode($tmp), true);
                                    if ($tmp['body']) $content1['body'] = $tmp['body'];
                                }
                                $files['content'] = $content1;
                                savecache('path_' . $path, $files, $this->disktag);
                            }
                        } else {
                            $files['content']['stat'] = 202;
                            $files['content']['body'] = 'File too large.';
                        }
                    }
                }
                if (isset($files['error'])) {
                    $files['error']['stat'] = $arr['stat'];
                }
            } else {
                //error_log1($arr['body']);
                $files = json_decode($arr['body'], true);
                if (isset($files['error'])) {
                    $files['error']['stat'] = $arr['stat'];
                } else {
                    $files['error']['stat'] = 503;
                    $files['error']['code'] = 'unknownError';
                    $files['error']['message'] = 'unknownError ' . $arr['body'] . " ~";
                }
                //$files = json_decode( '{"unknownError":{ "stat":'.$arr['stat'].',"message":"'.$arr['body'].'"}}', true);
                //error_log1(json_encode($files, JSON_PRETTY_PRINT));
            }
        }
        //echo '<pre>' . json_encode($files, JSON_PRETTY_PRINT) . '</pre>';
        return $this->files_format($files);
    }

    protected function files_format($files)
    {
        if (isset($files['file'])) {
            $tmp['type'] = 'file';
            $tmp['id'] = $files['id'];
            $tmp['name'] = $files['name'];
            $tmp['time'] = $files['lastModifiedDateTime'];
            $tmp['size'] = $files['size'];
            $tmp['mime'] = $files['file']['mimeType'];
            $tmp['url'] = $files[$this->DownurlStrName];
            $tmp['content'] = $files['content'];
        } elseif (isset($files['folder'])) {
            $tmp['type'] = 'folder';
            $tmp['id'] = $files['id'];
            $tmp['name'] = $files['name'];
            $tmp['time'] = $files['lastModifiedDateTime'];
            $tmp['size'] = $files['size'];
            $tmp['childcount'] = $files['folder']['childCount'];
            $tmp['page'] = $files['folder']['page'];
            foreach ($files['children'] as $file) {
                $filename = strtolower($file['name']);
                if (isset($file['file'])) {
                    $tmp['list'][$filename]['type'] = 'file';
                    //var_dump($file);
                    //echo $file['name'] . ':' . $this->DownurlStrName . ':' . $file[$this->DownurlStrName] . PHP_EOL;
                    $tmp['list'][$filename]['url'] = $file[$this->DownurlStrName];
                    $tmp['list'][$filename]['mime'] = $file['file']['mimeType'];
                } elseif (isset($file['folder'])) {
                    $tmp['list'][$filename]['type'] = 'folder';
                }
                $tmp['list'][$filename]['id'] = $file['id'];
                $tmp['list'][$filename]['name'] = $file['name'];
                $tmp['list'][$filename]['time'] = $file['lastModifiedDateTime'];
                $tmp['list'][$filename]['size'] = $file['size'];
            }
        } elseif (isset($files['error'])) {
            return $files;
        }
        //error_log1(json_encode($tmp));
        //echo '<pre>' . json_encode($tmp, JSON_PRETTY_PRINT) . '</pre>';
        return $tmp;
    }

    protected function fetch_files_children($path, $page, $getNextlink = false) {
        $children = getcache('files_' . $path . '_page_' . $page, $this->disktag);
        if (!$children) {
            $url = $this->api_url . $this->ext_api_url;
            if ($path !== '/') {
                $url .= ':' . $path;
                if (substr($url,-1)=='/') $url=substr($url,0,-1);
                $url .= ':';
            }
            $url .= '/children?$top=' . ($page-1)*200 . '&$select=id,name,size,file,folder,parentReference,lastModifiedDateTime,' . $this->DownurlStrName;
            $children_tmp = json_decode($this->MSAPI('GET', $url)['body'], true);
            //echo $url . '<br><pre>' . json_encode($children_tmp, JSON_PRETTY_PRINT) . '</pre>';
            $p = 1;
            $i = 0;
            foreach ($children_tmp['value'] as $child) {
                $i++;
                $value_name = 'child_' . $p;
                ${$value_name}['value'][] = $child;
                if ($i==200) {
                    savecache('files_' . $path . '_page_' . $p, ${$value_name}, $this->disktag);
                    unset(${$value_name});
                    $i = 0;
                    $p++;
                }
            }

            $url = $children_tmp['@odata.nextLink'];
            $children_tmp = json_decode($this->MSAPI('GET', $url)['body'], true);
            //echo $url . '<br><pre>' . json_encode($children_tmp, JSON_PRETTY_PRINT) . '</pre>';
            $p = $page;
            $i = 0;
            foreach ($children_tmp['value'] as $child) {
                $i++;
                $value_name = 'child_' . $p;
                ${$value_name}['value'][] = $child;
                if ($i==200) {
                    savecache('files_' . $path . '_page_' . $p, ${$value_name}, $this->disktag);
                    //unset(${$value_name});
                    $i = 0;
                    $p++;
                }
            }
            if ($i!=0) savecache('files_' . $path . '_page_' . $p, ${$value_name}, $this->disktag);
            $value_name = 'child_' . $page;
            return ${$value_name};
        }
        return $children;
        
        /*if ($getNextlink) {
            if (isset($children['@odata.nextLink'])) {
                return $children;
            } else {
                if ($page*200>9800) {
                    $children_tmp = fetch_files_children($path, floor($page/49)*49, 1);
                    $url = $children_tmp['@odata.nextLink'];
                    $children = json_decode(curl('GET', $url, false, ['Authorization' => 'Bearer ' . $this->access_token])['body'], true);
                }
            }
        }*/
    }
    protected function fetch_files_children1($files, $path, $page)
    {
        $maxpage = ceil($files['folder']['childCount']/200);
        if (!($children = getcache('files_' . $path . '_page_' . $page, $this->disktag))) {
            $pageinfochange=0;
            for ($page1=$page;$page1>=1;$page1--) {
                $page3=$page1-1;
                $url = getcache('nextlink_' . $path . '_page_' . $page3, $this->disktag);
                if ($url == '') {
                    if ($page1==1) {
                        $url = $this->api_url . $this->ext_api_url;
                        if ($path !== '/') {
                            $url .= ':' . $path;
                            if (substr($url,-1)=='/') $url=substr($url,0,-1);
                            $url .= ':';
                        }
                        $url .= '/children?$select=id,name,size,file,folder,parentReference,lastModifiedDateTime,'.$this->DownurlStrName;
                        $children = json_decode($this->MSAPI('GET', $url)['body'], true);
                        // echo $url . '<br><pre>' . json_encode($children, JSON_PRETTY_PRINT) . '</pre>';
                        savecache('files_' . $path . '_page_' . $page1, $children, $this->disktag);
                        $nextlink=getcache('nextlink_' . $path . '_page_' . $page1, $this->disktag);
                        if ($nextlink!=$children['@odata.nextLink']) {
                            savecache('nextlink_' . $path . '_page_' . $page1, $children['@odata.nextLink'], $this->disktag);
                            $pageinfocache['nextlink_' . $path . '_page_' . $page1] = $children['@odata.nextLink'];
                            $pageinfocache = clearbehindvalue($path,$page1,$maxpage,$pageinfocache);
                            $pageinfochange = 1;
                        }
                        $url = $children['@odata.nextLink'];
                        for ($page2=$page1+1;$page2<=$page;$page2++) {
                            sleep(1);
                            $children = json_decode($this->MSAPI('GET', $url)['body'], true);
                            savecache('files_' . $path . '_page_' . $page2, $children, $this->disktag);
                            $nextlink=getcache('nextlink_' . $path . '_page_' . $page2, $this->disktag);
                            if ($nextlink!=$children['@odata.nextLink']) {
                                savecache('nextlink_' . $path . '_page_' . $page2, $children['@odata.nextLink'], $this->disktag);
                                $pageinfocache['nextlink_' . $path . '_page_' . $page2] = $children['@odata.nextLink'];
                                $pageinfocache = clearbehindvalue($path,$page2,$maxpage,$pageinfocache);
                                $pageinfochange = 1;
                            }
                            $url = $children['@odata.nextLink'];
                        }
                        //echo $url . '<br><pre>' . json_encode($children, JSON_PRETTY_PRINT) . '</pre>';
                        return $children;
                        /*
                        $files['children'] = $children['value'];
                        $files['folder']['page']=$page;
                        $pageinfocache['filenum'] = $files['folder']['childCount'];
                        $pageinfocache['dirsize'] = $files['size'];
                        $pageinfocache['cachesize'] = $cachefile['size'];
                        $pageinfocache['size'] = $files['size']-$cachefile['size'];
                        if ($pageinfochange == 1) $this->MSAPI('PUT', path_format($path.'/'.$cachefilename), json_encode($pageinfocache, JSON_PRETTY_PRINT))['body'];
                        return $files;*/
                    }
                } else {
                    for ($page2=$page3+1;$page2<=$page;$page2++) {
                        sleep(1);
                        $children = json_decode($this->MSAPI('GET', $url)['body'], true);
                        savecache('files_' . $path . '_page_' . $page2, $children, $this->disktag, 3300);
                        $nextlink=getcache('nextlink_' . $path . '_page_' . $page2, $this->disktag);
                        if ($nextlink!=$children['@odata.nextLink']) {
                            savecache('nextlink_' . $path . '_page_' . $page2, $children['@odata.nextLink'], $this->disktag, 3300);
                            $pageinfocache['nextlink_' . $path . '_page_' . $page2] = $children['@odata.nextLink'];
                            $pageinfocache = clearbehindvalue($path,$page2,$maxpage,$pageinfocache);
                            $pageinfochange = 1;
                        }
                        $url = $children['@odata.nextLink'];
                    }
                    //echo $url . '<br><pre>' . json_encode($children, JSON_PRETTY_PRINT) . '</pre>';
                    return $children;

                    /*$files['children'] = $children['value'];
                    $files['folder']['page']=$page;
                    $pageinfocache['filenum'] = $files['folder']['childCount'];
                    $pageinfocache['dirsize'] = $files['size'];
                    $pageinfocache['cachesize'] = $cachefile['size'];
                    $pageinfocache['size'] = $files['size']-$cachefile['size'];
                    if ($pageinfochange == 1) $this->MSAPI('PUT', path_format($path.'/'.$cachefilename), json_encode($pageinfocache, JSON_PRETTY_PRINT))['body'];
                    return $files;*/
                }
            }
        }/* else {
            $files['folder']['page']=$page;
            for ($page4=1;$page4<=$maxpage;$page4++) {
                if (!($url = getcache('nextlink_' . $path . '_page_' . $page4, $this->disktag))) {
                    if ($files['folder'][$path.'_'.$page4]!='') savecache('nextlink_' . $path . '_page_' . $page4, $files['folder'][$path.'_'.$page4], $this->disktag);
                } else {
                    $files['folder'][$path.'_'.$page4] = $url;
                }
            }
        }*/
        return $children;
        //return $files;
    }

    public function Rename($file, $newname) {
        $oldname = spurlencode($file['name']);
        $oldname = path_format($file['path'] . '/' . $oldname);
        $data = '{"name":"' . $newname . '"}';
                //echo $oldname;
        if ($file['id']) $result = $this->MSAPI('PATCH', "/items/" . $file['id'], $data);
        else $result = $this->MSAPI('PATCH', $oldname, $data);
        return output(json_encode($this->files_format(json_decode($result['body'], true))), $result['stat']);
    }
    public function Delete($file) {
        $filename = spurlencode($file['name']);
        $filename = path_format($file['path'] . '/' . $filename);
                //echo $filename;
        if ($file['id']) $result = $this->MSAPI('DELETE', "/items/" . $file['id']);
        else $result = $this->MSAPI('DELETE', $filename);
        if ($result['stat']!=204) $r_body = json_encode($this->files_format(json_decode($result['body'], true)));
        return output($r_body, $result['stat']);
        //return output($result['body'], $result['stat']);
    }
    public function Encrypt($folder, $passfilename, $pass) {
        $filename = '/items/' . $folder['id'] . ':/' . urlencode($passfilename);
        if ($pass==='') {
            $result = $this->MSAPI('DELETE', $filename);
        } else {
            $result = $this->MSAPI('PUT', $filename, $pass);
        }
        $path1 = $folder['path'];
        if ($path1!='/'&&substr($path1, -1)=='/') $path1 = substr($path1, 0, -1);
        savecache('path_' . $path1 . '/?password', '', $this->disktag, 1);
        return output(json_encode($this->files_format(json_decode($result['body'], true))), $result['stat']);
        //return output($result['body'], $result['stat']);
    }
    public function Move($file, $folder) {
        $filename = spurlencode($file['name']);
        $filename = path_format($file['path'] . '/' . $filename);
        $data = '{"parentReference":{"path": "/drive/root:' . $folder['path'] . '"}}';
        if ($file['id']) $result = $this->MSAPI('PATCH', "/items/" . $file['id'], $data);
        else $result = $this->MSAPI('PATCH', $filename, $data);
        $path2 = spurlencode($folder['path'], '/');
        if ($path2!='/'&&substr($path2, -1)=='/') $path2 = substr($path2, 0, -1);
        savecache('path_' . $path2, json_decode('{}', true), $this->disktag, 1);
        return output(json_encode($this->files_format(json_decode($result['body'], true))), $result['stat']);
        //return output($result['body'], $result['stat']);
    }
    public function Copy($file) {
        $filename = spurlencode($file['name']);
        $filename = path_format($file['path'] . '/' . $filename);
        $namearr = splitlast($file['name'], '.');
        date_default_timezone_set('UTC');
        if ($namearr[0]!='') {
            $newname = $namearr[0] . ' (' . date("Ymd\THis\Z") . ')';
            if ($namearr[1]!='') $newname .= '.' . $namearr[1];
        } else {
            $newname = '.' . $namearr[1] . ' (' . date("Ymd\THis\Z") . ')';
        }
        $data = '{ "name": "' . $newname . '" }';
        if ($file['id']) $result = $this->MSAPI('copy', "/items/" . $file['id'], $data);
        else $result = $this->MSAPI('copy', $filename, $data);
        /*$num = 0;
        while ($result['stat']==409 && json_decode($result['body'], true)['error']['code']=='nameAlreadyExists') {
            $num++;
            if ($namearr[0]!='') {
                $newname = $namearr[0] . ' (' . getconstStr('Copy') . ' ' . $num . ')';
                if ($namearr[1]!='') $newname .= '.' . $namearr[1];
            } else {
                $newname = '.' . $namearr[1] . ' ('.getconstStr('Copy'). ' ' . $num .')';
            }
            //$newname = spurlencode($newname);
            $data = '{ "name": "' . $newname . '" }';
            $result = $this->MSAPI('copy', $filename, $data);
        }*/
        return output(json_encode($this->files_format(json_decode($result['body'], true))), $result['stat']);
        //return output($result['body'], $result['stat']);
    }
    public function Edit($file, $content) {
        /*TXT一般不会超过4M，不用二段上传
        $filename = $path1 . ':/createUploadSession';
        $response=MSAPI('POST',$filename,'{"item": { "@microsoft.graph.conflictBehavior": "replace"  }}',$_SERVER['access_token']);
        $uploadurl=json_decode($response,true)['uploadUrl'];
        echo MSAPI('PUT',$uploadurl,$data,$_SERVER['access_token']);*/
        $result = $this->MSAPI('PUT', $file['path'], $content);
        //return output($result['body'], $result['stat']);
        //echo $result;
        $resultarry = json_decode($result['body'],true);
        if (isset($resultarry['error'])) return message($resultarry['error']['message']. '<hr><a href="javascript:history.back(-1)">'.getconstStr('Back').'</a>','Error', 403);
        else return output('success', 0);
    }
    public function Create($parent, $type, $name, $content = '') {
        if ($type=='file') {
            $filename = spurlencode($name);
            $filename = path_format($parent['path'] . '/' . $filename);
            $result = $this->MSAPI('PUT', $filename, $content);
        }
        if ($type=='folder') {
            $data = '{ "name": "' . $name . '",  "folder": { },  "@microsoft.graph.conflictBehavior": "rename" }';
            $result = $this->MSAPI('children', $parent['path'], $data);
        }
        //savecache('path_' . $path1, json_decode('{}',true), $_SERVER['disktag'], 1);
        return output(json_encode($this->files_format(json_decode($result['body'], true))), $result['stat']);
        //return output($result['body'], $result['stat']);
    }

    public function AddDisk() {
        global $constStr;
        global $EnvConfigs;

        $envs = '';
        foreach ($EnvConfigs as $env => $v) if (isCommonEnv($env)) $envs .= '\'' . $env . '\', ';
        $url = $_SERVER['PHP_SELF'];
        //$this->api_url = splitfirst($_SERVER['api_url'], '/v1.0')[0] . '/v1.0';

        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.<br>' . $this->disktag;
                    $title = 'Error';
                    return message($html, $title, 201);
                }
                $response = $this->get_access_token($refresh_token);
                if (!$response) return message($this->error['body'], $this->error['stat'] . ' Error', $this->error['stat']);
            }

            $tmp = null;
            $tmp['Driver'] = get_class($this);
            if ($_POST['DriveType']=='Onedrive') {
                /*$api = $this->api_url . '/me';
                $arr = curl('GET', $api, '', [ 'Authorization' => 'Bearer ' . $this->access_token ], 1);
                if ($arr['stat']==200) {
                    $userid = json_decode($arr['body'], true)['id'];
                    $api = $this->api_url . '/users/' . $userid . '/drive';
                    $arr = curl('GET', $api, '', [ 'Authorization' => 'Bearer ' . $this->access_token ], 1);
                    if ($arr['stat']!=200) return message($arr['stat'] . '<br>' . $api . '<br>' . $arr['body'], 'Get User Drive ID', $arr['stat']);
                    $tmp['DriveId'] = json_decode($arr['body'], true)['id'];
                } elseif ($arr['stat']==403||$arr['stat']==401) {
                    // 403：世纪不让列me，401：个人也不给拿
                    $api = $this->api_url . '/me/drive';
                } else {
                    return message($arr['stat'] . $arr['body'], 'Get User ID', $arr['stat']);
                }*/
                if ($tmp['Driver']=='Sharepoint') $tmp['Driver'] = 'Onedrive';
                elseif ($tmp['Driver']=='SharepointCN') $tmp['Driver'] = 'OnedriveCN';
                $tmp['sharepointSite'] = '';
                $tmp['siteid'] = '';
            } elseif ($_POST['DriveType']=='Custom') {
                // sitename计算siteid
                $tmp1 = $this->get_siteid($_POST['sharepointSite']);
                if (isset($tmp1['stat'])) return message($arr['stat'] . $tmp1['body'], 'Get Sharepoint Site ID ' . $_POST['sharepointSite'], $tmp1['stat']);
                $siteid = $tmp1;
                //$api = $this->api_url . '/sites/' . $siteid . '/drive/';
                //$arr = curl('GET', $api, '', [ 'Authorization' => 'Bearer ' . $this->access_token ], 1);
                //if ($arr['stat']!=200) return message($arr['stat'] . $arr['body'], 'Get Sharepoint Drive ID ' . $_POST['DriveType'], $arr['stat']);
                $tmp['siteid'] = $siteid;
                $tmp['sharepointSite'] = $_POST['sharepointSite'];
                if ($tmp['Driver']=='Onedrive') $tmp['Driver'] = 'Sharepoint';
                elseif ($tmp['Driver']=='OnedriveCN') $tmp['Driver'] = 'SharepointCN';
            } else {
                // 直接是siteid
                $tmp['siteid'] = $_POST['DriveType'];
                $tmp['sharepointSite'] = $_POST['sharepointSiteUrl'];
                if ($tmp['Driver']=='Onedrive') $tmp['Driver'] = 'Sharepoint';
                elseif ($tmp['Driver']=='OnedriveCN') $tmp['Driver'] = 'SharepointCN';
            }

            $response = setConfigResponse( setConfig($tmp, $this->disktag) );
            if (api_error($response)) {
                $html = api_error_msg($response);
                $title = 'Error';
                return message($html, $title, 201);
            } else {
                $html .= '<script>
                var expd = new Date();
                expd.setTime(expd.getTime()+1);
                var expires = "expires="+expd.toGMTString();
                document.cookie=\'disktag=; path=/; \'+expires;
                var i = 0;
                var status = "' . $response['DplStatus'] . '";
                var uploadList = setInterval(function(){
                    if (document.getElementById("dis").style.display=="none") {
                        console.log(i++);
                    } else {
                        clearInterval(uploadList);
                        location.href = "' . $url . '?setup&disktag=' . $_GET['disktag'] . '";
                    }
                }, 1000);
                </script>';
                return message($html, getconstStr('Wait'), 201, 1);
            }
        }

        if (isset($_GET['SelectDrive'])) {
            if (get_class($this)=='Sharelink') return message('Can not change to other.', 'Back', 201);
            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.<br>' . $this->disktag;
                    $title = 'Error';
                    return message($html, $title, 201);
                }
                $response = $this->get_access_token($refresh_token);
                if (!$response) return message($this->error['body'], $this->error['stat'] . ' Error', $this->error['stat']);
            }

            $api = $this->api_url . '/sites/root';
            $arr = $this->MSAPI('GET', $api);
            $Tenant = json_decode($arr['body'], true)['webUrl'];

            $api = $this->api_url . '/me/followedSites';
            $arr = $this->MSAPI('GET', $api);
            if (!($arr['stat']==200||$arr['stat']==403||$arr['stat']==400||$arr['stat']==404)) return message($arr['stat'] . json_encode(json_decode($arr['body']), JSON_PRETTY_PRINT), 'Get followedSites', $arr['stat']);
            error_log1($arr['body']);
            $sites = json_decode($arr['body'], true)['value'];

            $title = 'Select Driver';
            $html = '
<div>
    <form name="form1" action="?Finish&disktag=' . $_GET['disktag'] . '&AddDisk=' . get_class($this) . '" method="post" onsubmit="return notnull(this);">
        <label><input type="radio" name="DriveType" value="Onedrive">' . 'Use Onedrive ' . getconstStr(' ') . '</label><br>';
            if ($sites[0]!='') foreach ($sites as $k => $v) {
                $html .= '
        <label>
            <input type="radio" name="DriveType" value="' . $v['id'] . '" onclick="document.getElementById(\'sharepointSiteUrl\').value=\'' . $v['webUrl'] . '\';">' . 'Use Sharepoint: <br><div style="width:100%;margin:0px 35px">webUrl: ' . $v['webUrl'] . '<br>siteid: ' . $v['id'] . '</div>
            <input type="hidden" id="' . $v['id'] . '" name="' . $v['id'] . '" value="' . $v['webUrl'] . '">
        </label>';
            }
            $html .= '
        <input type="hidden" id="sharepointSiteUrl" name="sharepointSiteUrl" value="">
        <label>
            <input type="radio" name="DriveType" value="Custom" id="Custom">' . 'Use Other Sharepoint:' . getconstStr(' ') . '<br>
            <div style="width:100%;margin:0px 35px"><a href="' . $Tenant . '/_layouts/15/sharepoint.aspx" target="_blank">' . getconstStr('GetSharepointSiteAddress') . '</a><br>
                <input type="text" name="sharepointSite" style="width:100%;" placeholder="' . getconstStr('InputSharepointSiteAddress') . '" onclick="document.getElementById(\'Custom\').checked=\'checked\';">
            </div>
        </label><br>
        ';
            $html .= '
        <input type="submit" value="' . getconstStr('Submit') . '">
    </form>
</div>
<script>
    var driver = "' . $_GET['AddDisk'] . '";
    if (driver=="Onedrive"||driver=="OnedriveCN") {
        document.form1.DriveType[0].checked = true;
    } else {
        var siteid = "' . getConfig('siteid', $this->disktag) . '";
        if (siteid==="") {
            document.form1.DriveType[document.form1.DriveType.length-1].checked = true;
        } else {
            for (i=0; i<document.form1.DriveType.length; i++) {
                if (document.form1.DriveType[i].value==siteid) {
                    document.form1.DriveType[i].checked = true;
                    document.getElementById(\'sharepointSiteUrl\').value = document.getElementById(siteid).value;
                }
            }
            if (document.getElementById(\'sharepointSiteUrl\').value=="") {
                document.form1.DriveType[document.form1.DriveType.length-1].checked = true;
                document.getElementById(\'sharepointSite\').value = "' . getConfig('sharepointSite', $this->disktag) . '";
            }
        }
    }
    function notnull(t)
    {
        if (t.DriveType.value==\'\') {
            alert(\'Select a Disk\');
            return false;
        }
        if (t.DriveType.value==\'Custom\') {
            if (t.sharepointSite.value==\'\') {
                alert(\'sharepoint Site Address\');
                return false;
            }
        }
        return true;
    }
</script>
';
            return message($html, $title, 201);
        }

        if (isset($_GET['install2']) && isset($_GET['code'])) {
            $tmp = curl('POST', $this->oauth_url . 'token', 'client_id=' . $this->client_id .'&client_secret=' . $this->client_secret . '&grant_type=authorization_code&requested_token_use=on_behalf_of&redirect_uri=' . $this->redirect_uri . '&code=' . $_GET['code']);
            if ($tmp['stat']==200) $ret = json_decode($tmp['body'], true);
            if (isset($ret['refresh_token'])) {
                $refresh_token = $ret['refresh_token'];
                $str = '
        refresh_token :<br>';
                $str .= '
        <textarea readonly style="width: 95%">' . $refresh_token . '</textarea><br><br>
        ' . getconstStr('SavingToken') . '
        <script>
            var texta=document.getElementsByTagName(\'textarea\');
            for(i=0;i<texta.length;i++) {
                texta[i].style.height = texta[i].scrollHeight + \'px\';
            }
        </script>';
                $tmptoken['Driver'] = $_GET['AddDisk'];
                $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);
                    $html .= '<script>
                    var i = 0;
                    var status = "' . $response['DplStatus'] . '";
                var uploadList = setInterval(function(){
                    if (document.getElementById("dis").style.display=="none") {
                        console.log(i++);
                    } else {
                        clearInterval(uploadList);
                        location.href = "' . $url . '?AddDisk=' . $_GET['AddDisk'] . '&disktag=' . $_GET['disktag'] . '&SelectDrive";
                    }
                }, 1000);
                </script>';
                    return message($html, getconstStr('Wait') . ' 3s', 201, 1);
                }
            }
            return message('<pre>' . json_encode(json_decode($tmp['body']), JSON_PRETTY_PRINT) . '</pre>', $tmp['stat']);
            //return message('<pre>' . json_encode($ret, JSON_PRETTY_PRINT) . '</pre>', 500);
        }

        if (isset($_GET['install1'])) {
            //if (get_class($this)=='Onedrive' || get_class($this)=='OnedriveCN') {
                return message('
    <a href="" id="a1">' . getconstStr('JumptoOffice') . '</a>
    <script>
        url=location.protocol + "//" + location.host + "' . $url . '?install2&disktag=' . $_GET['disktag'] . '&AddDisk=' . get_class($this) . '";
        url="' . $this->oauth_url . 'authorize?scope=' . $this->scope . '&response_type=code&client_id=' . $this->client_id . '&redirect_uri=' . $this->redirect_uri . '&state=' . '"+encodeURIComponent(url);
        document.getElementById(\'a1\').href=url;
        //window.open(url,"_blank");
        location.href = url;
    </script>
    ', 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 . '<br><button onclick="location.href = location.href;">'.getconstStr('Refresh').'</button>', 'Error', 400);
                } elseif (!(('a'<=$f && $f<='z') || ('A'<=$f && $f<='Z'))) {
                    return message('Please start with letters<br><button onclick="location.href = location.href;">'.getconstStr('Refresh').'</button>
                    <script>
                    var expd = new Date();
                    expd.setTime(expd.getTime()+1);
                    var expires = "expires="+expd.toGMTString();
                    document.cookie=\'disktag=; path=/; \'+expires;
                    </script>', 'Error', 400);
                }

                $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'] = $_POST['Drive_ver'];
                $tmp['Driver'] = $_GET['AddDisk'];
                if ($_POST['Drive_ver']=='Sharelink') {
                    $tmp['shareurl'] = $_POST['shareurl'];
                } else {
                    if ($_POST['Drive_ver']=='Onedrive' && $_POST['NT_Drive_custom']=='on') {
                        $tmp['client_id'] = $_POST['NT_client_id'];
                        $tmp['client_secret'] = $_POST['NT_client_secret'];
                    } elseif ($_POST['Drive_ver']=='OnedriveCN' && $_POST['CN_Drive_custom']=='on') {
                        $tmp['client_id'] = $_POST['CN_client_id'];
                        $tmp['client_secret'] = $_POST['CN_client_secret'];
                    }
                }
                $response = setConfigResponse( setConfig($tmp, $this->disktag) );
                if (api_error($response)) {
                    $html = api_error_msg($response);
                    $title = 'Error';
                    return message($html, $title, 400);
                } else {
                    $title = getconstStr('MayinEnv');
                    $html = getconstStr('Wait');
                    if ($_POST['Drive_ver']!='Sharelink') $url .= '?install1&disktag=' . $_GET['disktag'] . '&AddDisk=' . $_GET['AddDisk'];
                    $html .= '<script>
                    var i = 0;
                    var status = "' . $response['DplStatus'] . '";
                var uploadList = setInterval(function(){
                    if (document.getElementById("dis").style.display=="none") {
                        console.log(i++);
                    } else {
                        clearInterval(uploadList);
                        location.href = "' . $url . '";
                    }
                }, 1000);
                </script>';
                    return message($html, $title, 201, 1);
                }
                
            }
        }

        $html = '
<div>
    <form id="form1" name="form1" action="" method="post" onsubmit="return notnull(this);">
        ' . getconstStr('DiskTag') . ': (' . getConfig('disktag') . ')
        <input type="text" name="disktag_add" placeholder="' . getconstStr('EnvironmentsDescription')['disktag'] . '" style="width:100%"><br>
        ' . getconstStr('DiskName') . ':
        <input type="text" name="diskname" placeholder="' . getconstStr('EnvironmentsDescription')['diskname'] . '" style="width:100%"><br>
        <br>
        <div>
            <label><input type="radio" name="Drive_ver" value="Onedrive" onclick="document.getElementById(\'NT_custom\').style.display=\'\';document.getElementById(\'CN_custom\').style.display=\'none\';document.getElementById(\'inputshareurl\').style.display=\'none\';">MS: ' . getconstStr('DriveVerMS') . '</label><br>
            <div id="NT_custom" style="display:none;margin:0px 35px">
                <label><input type="checkbox" name="NT_Drive_custom" onclick="document.getElementById(\'NT_secret\').style.display=(this.checked?\'\':\'none\');">' . getconstStr('CustomIdSecret') . '</label><br>
                <div id="NT_secret" style="display:none;margin:10px 35px">
                    <a href="https://portal.azure.com/#blade/Microsoft_AAD_IAM/ActiveDirectoryMenuBlade/RegisteredApps" target="_blank">' . getconstStr('GetSecretIDandKEY') . '</a><br>
                    return_uri(Reply URL):<br>' . $this->redirect_uri . '<br>
                    client_id:<input type="text" name="NT_client_id" style="width:100%" placeholder="a1b2c345-90ab-cdef-ghij-klmnopqrstuv"><br>
                    client_secret:<input type="text" name="NT_client_secret" style="width:100%"><br>
                </div>
            </div><br>
            <label><input type="radio" name="Drive_ver" value="OnedriveCN" onclick="document.getElementById(\'CN_custom\').style.display=\'\';document.getElementById(\'NT_custom\').style.display=\'none\';document.getElementById(\'inputshareurl\').style.display=\'none\';">CN: ' . getconstStr('DriveVerCN') . '</label><br>
            <div id="CN_custom" style="display:none;margin:0px 35px">
                <label><input type="checkbox" name="CN_Drive_custom" onclick="document.getElementById(\'CN_secret\').style.display=(this.checked?\'\':\'none\');">' . getconstStr('CustomIdSecret') . '</label><br>
                <div id="CN_secret" style="display:none;margin:10px 35px">
                    <a href="https://portal.azure.cn/#blade/Microsoft_AAD_IAM/ActiveDirectoryMenuBlade/RegisteredApps" target="_blank">' . getconstStr('GetSecretIDandKEY') . '</a><br>
                    return_uri(Reply URL):<br>' . $this->redirect_uri . '<br>
                    client_id:<input type="text" name="CN_client_id" style="width:100%" placeholder="a1b2c345-90ab-cdef-ghij-klmnopqrstuv"><br>
                    client_secret:<input type="text" name="CN_client_secret" style="width:100%"><br>
                </div>
            </div><br>
            <label><input type="radio" name="Drive_ver" value="Sharelink" onclick="document.getElementById(\'CN_custom\').style.display=\'none\';document.getElementById(\'inputshareurl\').style.display=\'\';document.getElementById(\'NT_custom\').style.display=\'none\';">Sharelink: ' . getconstStr('DriveVerShareurl') . '</label><br>
            <div id="inputshareurl" style="display:none;margin:0px 35px">
                ' . getconstStr('UseShareLink') . '
                <input type="text" name="shareurl" style="width:100%" placeholder="https://xxxx.sharepoint.com/:f:/g/personal/xxxxxxxx/mmmmmmmmm?e=XXXX"><br>
            </div>
        </div>
        <br>';
        if ($_SERVER['language']=='zh-cn') $html .= '你要理解 scfonedrive.github.io 是github上的静态网站，<br><font color="red">除非github真的挂掉</font>了，<br>不然，稍后你如果<font color="red">连不上</font>，请检查你的运营商或其它“你懂的”问题！<br>';
        $html .='
        <input type="submit" value="' . getconstStr('Submit') . '">
    </form>
</div>
    <script>
        var driver = "' . get_class($this) . '";
        if (driver=="Onedrive" || driver=="Sharepoint") {
            document.form1.Drive_ver[0].checked = true;
            document.getElementById(\'NT_custom\').style.display=\'\';
            //document.getElementById(\'CN_custom\').style.display=\'\';
            //document.getElementById(\'inputshareurl\').style.display=\'none\';
        }
        if (driver=="OnedriveCN" || driver=="SharepointCN") {
            document.form1.Drive_ver[1].checked = true;
            document.getElementById(\'CN_custom\').style.display=\'\';
        }
        if (driver=="Sharelink") {
            document.form1.Drive_ver[2].checked = true;
            document.getElementById(\'inputshareurl\').style.display=\'\';
        }
        function notnull(t)
        {
            if (t.disktag_add.value==\'\') {
                alert(\'' . getconstStr('DiskTag') . '\');
                return false;
            }
            envs = [' . $envs . '];
            if (envs.indexOf(t.disktag_add.value)>-1) {
                alert("Do not input \"" + t.disktag_add.value + "\" in ' . getconstStr('DiskTag') . '");
                return false;
            }
            var reg = /^[a-zA-Z]([_a-zA-Z0-9]{1,})$/;
            if (!reg.test(t.disktag_add.value)) {
                alert(\'' . getconstStr('TagFormatAlert') . '\');
                return false;
            }
            if (t.Drive_ver.value==\'\') {
                    alert(\'Select a Driver\');
                    return false;
            }
            if (t.Drive_ver.value==\'Sharelink\') {
                if (t.shareurl.value==\'\') {
                    alert(\'shareurl\');
                    return false;
                }
                driver = \'Sharelink\';
            } else {
                if (t.Drive_ver.value==\'Onedrive\') {
                    if (t.NT_Drive_custom.checked==true) {
                        if (t.NT_client_secret.value==\'\'||t.NT_client_id.value==\'\') {
                            alert(\'client_id & client_secret\');
                            return false;
                        }
                    }
                    if (driver!="Onedrive" && driver!="Sharepoint") driver = "Onedrive";
                }
                if (t.Drive_ver.value==\'OnedriveCN\') {
                    if (t.CN_Drive_custom.checked==true) {
                        if (t.CN_client_secret.value==\'\'||t.CN_client_id.value==\'\') {
                            alert(\'client_id & client_secret\');
                            return false;
                        }
                    }
                    if (driver!="OnedriveCN" && driver!="SharepointCN") driver = "OnedriveCN";
                }
            }
            document.getElementById("form1").action="?install0&disktag=" + t.disktag_add.value + "&AddDisk=" + driver;
            return true;
        }
    </script>';
        $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;
            while ($response['stat']==0&&$p<3) {
                $response = curl('POST', $this->oauth_url . 'token', 'client_id=' . $this->client_id . '&client_secret=' . $this->client_secret . '&grant_type=refresh_token&requested_token_use=on_behalf_of&refresh_token=' . $refresh_token );
                $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&requested_token_use=on_behalf_of&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 get_siteid($sharepointSite)
    {
        //$sharepointSite = getConfig('sharepointSite', $this->disktag);
        while (substr($sharepointSite, -1)=='/') $sharepointSite = substr($sharepointSite, 0, -1);
        $tmp = splitlast($sharepointSite, '/');
        if ($tmp[1]==urldecode($tmp[1])) {
            $sharepointname = urlencode($tmp[1]);
        } else {
            $sharepointname = $tmp[1];
        }
        $tmp = splitlast($tmp[0], '/');
        //if (getConfig('Driver', $this->disktag)=='Onedrive') $url = 'https://graph.microsoft.com/v1.0/sites/root:/' . $tmp[1] . '/' . $sharepointname;
        //if (getConfig('Driver', $this->disktag)=='OnedriveCN') $url = 'https://microsoftgraph.chinacloudapi.cn/v1.0/sites/root:/' . $tmp[1] . '/' . $sharepointname;
        $url = $this->api_url . '/sites/root:/' . $tmp[1] . '/' . $sharepointname;

        $i=0;
        $response = [];
        while ($url!=''&&$response['stat']!=200&&$i<4) {
            $response = $this->MSAPI('GET', $url);
            $i++;
        }
        if ($response['stat']!=200) {
            error_log1('failed to get siteid. response' . json_encode($response));
            $response['body'] .= '\nfailed to get siteid.';
            return $response;
            //throw new Exception($response['stat'].', failed to get siteid.'.$response['body']);
        }
        return json_decode($response['body'],true)['id'];
    }

    public function del_upload_cache($path)
    {
        error_log1('del.tmp:GET,'.json_encode($_GET,JSON_PRETTY_PRINT));
        $tmp = splitlast($_GET['filename'], '/');
        if ($tmp[1]!='') {
            $filename = $tmp[0] . '/.' . $_GET['filelastModified'] . '_' . $_GET['filesize'] . '_' . $tmp[1] . '.tmp';
        } else {
            $filename = '.' . $_GET['filelastModified'] . '_' . $_GET['filesize'] . '_' . $_GET['filename'] . '.tmp';
        }
        $filename = path_format( path_format($_SERVER['list_path'] . path_format($path)) . '/' . spurlencode($filename, '/') );
        $tmp = $this->MSAPI('DELETE', $filename, '');
        $path1 = path_format($_SERVER['list_path'] . path_format($path));
        if ($path1!='/'&&substr($path1,-1)=='/') $path1=substr($path1,0,-1);
        savecache('path_' . $path1, json_decode('{}',true), $this->disktag, 1);
        return output($tmp['body'],$tmp['stat']);
    }

    public function get_thumbnails_url($path = '/')
    {
        $thumb_url = getcache('thumb_'.$path, $this->disktag);
        if ($thumb_url=='') {
            $url = $this->api_url . $this->ext_api_url;
            if ($path !== '/') {
                $url .= ':' . $path;
                if (substr($url,-1)=='/') $url=substr($url,0,-1);
            }
            $url .= ':/thumbnails/0/medium';
            $files = json_decode($this->MSAPI('GET', $url)['body'], true);
            if (isset($files['url'])) {
                savecache('thumb_' . $path, $files['url'], $this->disktag);
                $thumb_url = $files['url'];
            }
        }
        return $thumb_url;
    }

    public function smallfileupload($path, $tmpfile) {
        if (!$_SERVER['admin']) {
            $tmp1 = splitlast($tmpfile['name'], '.');
            if ($tmp1[0]==''||$tmp1[1]=='') $filename = md5_file($tmpfile['tmp_name']);
            else $filename = md5_file($tmpfile['tmp_name']) . '.' . $tmp1[1];
        } else {
            $filename = $tmpfile['name'];
        }
        $content = file_get_contents($tmpfile['tmp_name']);
        $result = $this->MSAPI('PUT', path_format($_SERVER['list_path'] . '/' . $path . '/' . $filename), $content);
        $res = $this->files_format(json_decode($result['body'], true));
        if (isset($res['url'])) $res['url'] = $_SERVER['host'] . path_format($_SERVER['base_disk_path'] . '/' . $path . '/' . $filename);
        return output(json_encode($res, JSON_UNESCAPED_SLASHES), $result['stat']);
    }
    public function bigfileupload($path)
    {
        if ($_POST['upbigfilename']=='') return output('error: no file name', 400);
        if (!is_numeric($_POST['filesize'])) return output('error: no file size', 400);
        if (!$_SERVER['admin']) if (!isset($_POST['filemd5'])) return output('error: no file md5', 400);

        $tmp = splitlast($_POST['upbigfilename'], '/');
        if ($tmp[1]!='') {
            $fileinfo['name'] = $tmp[1];
            if ($_SERVER['admin']) $fileinfo['path'] = $tmp[0];
        } else {
            $fileinfo['name'] = $_POST['upbigfilename'];
        }
        $fileinfo['size'] = $_POST['filesize'];
        $fileinfo['filelastModified'] = $_POST['filelastModified'];
        if ($_SERVER['admin']) {
            $filename = spurlencode($_POST['upbigfilename'], '/');
        } else {
            $tmp1 = splitlast($fileinfo['name'], '.');
            if ($tmp1[0]==''||$tmp1[1]=='') $filename = $_POST['filemd5'];
            else $filename = $_POST['filemd5'] . '.' . $tmp1[1];
        }
        if ($fileinfo['size']>10*1024*1024) {
            $cachefilename = spurlencode( $fileinfo['path'] . '/.' . $fileinfo['filelastModified'] . '_' . $fileinfo['size'] . '_' . $fileinfo['name'] . '.tmp', '/');
            $getoldupinfo = $this->list_files(path_format($path . '/' . $cachefilename));
            //error_log1(json_encode($getoldupinfo, JSON_PRETTY_PRINT));
            if (isset($getoldupinfo['url'])&&$getoldupinfo['size']<5120) {
                $getoldupinfo_j = curl('GET', $getoldupinfo['url']);
                $getoldupinfo = json_decode($getoldupinfo_j['body'], true);
                if ( json_decode( curl('GET', $getoldupinfo['uploadUrl'])['body'], true)['@odata.context']!='' ) return output($getoldupinfo_j['body'], $getoldupinfo_j['stat']);
            }
        }
        $response = $this->MSAPI('createUploadSession', path_format($path . '/' . $filename), '{"item": { "@microsoft.graph.conflictBehavior": "fail" }}');
        if ($response['stat']<500) {
            $responsearry = json_decode($response['body'],true);
            if (isset($responsearry['error'])) return output($response['body'], $response['stat']);
            $fileinfo['uploadUrl'] = $responsearry['uploadUrl'];
            if ($fileinfo['size']>10*1024*1024) $this->MSAPI('PUT', path_format($path . '/' . $cachefilename), json_encode($fileinfo, JSON_PRETTY_PRINT));
        }
        return output($response['body'], $response['stat']);
    }
    public function getDiskSpace() {
        if (!($diskSpace = getcache('diskSpace', $this->disktag))) {
            $url = $this->api_url . $this->ext_api_url;
            if (substr($url, -5)=='/root') $url = substr($url, 0, -5);
            else return $url;
            $response = json_decode($this->MSAPI('GET', $url)['body'], true)['quota'];
            $used = size_format($response['used']);
            $total = size_format($response['total']);
            $diskSpace = $used . ' / ' . $total;
            savecache('diskSpace', $diskSpace, $this->disktag);
        }
        return $diskSpace;
    }

    protected function MSAPI($method, $path, $data = '', $headers = [])
    {
        $activeLimit = getConfig('activeLimit', $this->disktag);
        if ($activeLimit!='') {
            if ($activeLimit>time()) {
                $tmp['error']['code'] = 'Retry-After';
                $tmp['error']['message'] = 'MS limit until ' . date('Y-m-d H:i:s', $activeLimit);
                return [ 'stat' => 429, 'body' => json_encode($tmp) ];
            } else {
                setConfig(['activeLimit' => ''], $this->disktag);
            }
        }
        if (substr($path,0,7) == 'http://' or substr($path,0,8) == 'https://') {
            $url = $path;
        } else {
            $url = $this->api_url . $this->ext_api_url;
            if ($path=='' or $path=='/') {
                $url .= '/';
            } elseif (substr($path, 0, 6)=="/items") {
                $url = substr($url, 0, -5);
                $url .= $path;
            } else {
                $url .= ':' . $path;
                if (substr($url,-1)=='/') $url=substr($url,0,-1);
            }
            if ($method=='GET') {
                $method = 'GET'; // do nothing
            } elseif ($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;
                } elseif (substr($path, 0, 6)=="/items") {
                    $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);
        $retry = 0;
        $response = [];
        while ($retry<3&&!$response['stat']) {
            $response['body'] = curl_exec($ch);
            $response['stat'] = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            $retry++;
        }
        //$response['Location'] = curl_getinfo($ch);
        if ($response['stat']==429) {
            $res = json_decode($response['body'], true);
            $retryAfter = $res['error']['retryAfterSeconds'];
            $retryAfter_n = (int)$retryAfter;
            if ($retryAfter_n>0) {
                $tmp1['activeLimit'] = $retryAfter_n + time();
                setConfig($tmp1, $this->disktag);
            }
        }
        curl_close($ch);
        /*error_log1($response['stat'].'
    '.$response['body'].'
    '.$url.'
    ');*/
        return $response;
    }

}