hkbak/SrcJyAliPublic.js

function createsession(headers, deviceId, userId) {
    function getNowTime() {
        const yy = new Date().getFullYear()
        const MM = (new Date().getMonth() + 1) < 10 ? '0' + (new Date().getMonth() + 1) : (new Date().getMonth() + 1)
        const dd = new Date().getDate() < 10 ? '0' + new Date().getDate() : new Date().getDate()
        const HH = new Date().getHours() < 10 ? '0' + new Date().getHours() : new Date().getHours()
        const mm = new Date().getMinutes() < 10 ? '0' + new Date().getMinutes() : new Date().getMinutes()
        return yy + '' + dd + '' + HH + '' + MM + '' + mm
    }

    for (let i = 1; i < 5; i++) {
        let signature;
        let public_key;
        if (i == 3) {
            try {
                let getaliecc = JSON.parse(request('http://124.221.241.174:87/api', { body: 'did=' + deviceId + '&uid=' + userId + '&token=' + md5(getNowTime()), method: 'POST', timeout: 3000 }));
                if (getaliecc.code == 200) {
                    signature = getaliecc.sign;
                    public_key = getaliecc.key;
                }
                log("调用py服务器生成算法");
            } catch (e) {
                log("调用py服务器失败");
            }
        } else {
            let a = justTestSign('5dde4e1bdf9e4966b387ba58f4b3fdc3', deviceId, userId);
            signature = a.split('##')[0];
            public_key = a.split('##')[1];
        }
        headers['x-signature'] = signature;
        let data = {
            "deviceName": "Edge浏览器",
            "modelName": "Windows网页版",
            "pubKey": public_key,
        }
        if (signature && public_key) {
            let req = JSON.parse(request("https://api.aliyundrive.com/users/v1/users/device/create_session", { headers: headers, body: data, timeout: 3000 }));
            if (req.success) {
                return { "signature": signature, "success": 1 }
            }
        }
    }
    return { "success": 0 }
}

function aliSharePlayUrl(share_id, file_id, share_pwd) {
    try {
        share_pwd = share_pwd && share_pwd.length == 4 ? share_pwd : "";
        let sharetoken = getShareToken(share_id, share_pwd).share_token;
        let deviceId = userinfo.device_id;
        let userId = userinfo.user_id;
        headers['authorization'] = authorization;
        headers['x-device-id'] = deviceId;
        let aliecc = createsession(headers, deviceId, userId);
        let aliyunUrl = [];
        if (aliecc.success) {
            headers['x-signature'] = aliecc.signature;
            headers['x-share-token'] = sharetoken;
            headers['fileid'] = userId;
            let data = data = { "category": "live_transcoding", "file_id": file_id, "get_preview_url": true, "share_id": share_id, "template_id": "", "get_subtitle_info": true }
            let json = JSON.parse(request('https://api.aliyundrive.com/v2/file/get_share_link_video_preview_play_info', { headers: headers, body: data, method: 'POST', timeout: 3000 }));
            aliyunUrl = json.video_preview_play_info.live_transcoding_task_list;
            aliyunUrl.reverse();
        }
        return aliyunUrl;
    } catch (e) {
        log('根据共享链接获取播放地址失败，挂载的阿里分享应有密码>' + e.message);
        return "";
    }
}

function getAliUrl(share_id, file_id, share_pwd) {
    try {
        let urls = [];
        let names = [];
        let heads = [];
        let u = startProxyServer($.toString((share_id, file_id, share_pwd, config) => {
            function geturl(fileid, line) {
                require(config.依赖.match(/http(s)?:\/\/.*\//)[0].replace('/Ju/', '/master/') + 'SrcJyAliPublic.js');
                let playUrlList = aliSharePlayUrl(share_id, fileid, share_pwd) || [];
                let aliurl;
                playUrlList.forEach((item) => {
                    if (item.template_id == line) {
                        aliurl = item.url;
                        //JSON.parse(request(item.url, { headers: { 'Referer': 'https://www.aliyundrive.com/' }, onlyHeaders: true, redirect: false, timeout: 3000 })).headers.location[0];
                    }
                })
                //上面是获取阿里的播放地址
                //log("我在代理" + aliurl);
                let home = aliurl.split('media.m3u8')[0];
                let f = fetch(aliurl, { headers: { 'Referer': 'https://www.aliyundrive.com/' }, timeout: 3000 }).split("\n");
                let ff = f.map(it => {
                    if (it.startsWith("media-")) {
                        return "/proxy?url=" + base64Encode(home + it);
                    }
                    return it;
                }).join("\n");
                //log('ufid-'+fileid);
                writeFile('hiker://files/cache/_fileSelect_' + fileid + '.m3u8', ff);
                return ff;
            }
            let url = base64Decode(MY_PARAMS.url);
            if (url.includes(".ts")) {
                let fid = url.split('&f=')[1].split('&')[0];
                //log('sfid-'+fid);
                let f = fetch('hiker://files/cache/_fileSelect_' + fid + '.m3u8').split("\n");
                f.forEach(it => {
                    if (it && it.startsWith('/proxy?url=')) {
                        let furl = base64Decode(it.replace('/proxy?url=', ''));
                        if (url.substr(url.indexOf('/media-'), url.indexOf('.ts')) == furl.substr(furl.indexOf('/media-'), furl.indexOf('.ts'))) {
                            url = furl;
                        }
                    }
                })
                let expires = url.split('x-oss-expires=')[1].split('&')[0];
                const lasttime = parseInt(expires) - Date.now() / 1000;
                if (lasttime < 40) {
                    //log('过期更新')
                    let line = url.split('/media')[0];//取之前播放的ts段线路
                    line = line.substring(line.lastIndexOf('/') + 1);
                    let f = geturl(fid, line).split("\n");
                    f.forEach(it => {
                        if (it && it.startsWith('/proxy?url=')) {
                            let furl = base64Decode(it.replace('/proxy?url=', ''));
                            if (url.substr(url.indexOf('/media-'), url.indexOf('.ts')) == furl.substr(furl.indexOf('/media-'), furl.indexOf('.ts'))) {
                                url = furl;
                            }
                        }
                    })

                } else {
                    //log('未过期')
                    //log("代理ts：" + url);
                }
                return JSON.stringify({
                    statusCode: 302,
                    headers: {
                        "Location": url,
                        'Referer': 'https://www.aliyundrive.com/'
                    }
                });
            } else {
                //log('首次更新')
                let line = url.split('|')[1];
                let ff = geturl(file_id, line);
                return ff;
            }
        }, share_id, file_id, share_pwd, config));
        let sharetoken = getShareToken(share_id, share_pwd).share_token;
        if (getItem('aliyun_playMode', '智能') == "智能" || getItem('aliyun_playMode') == "原画") {
            let openUrl = aliOpenPlayUrl(file_id, { sharetoken: sharetoken, share_id: share_id });
            if (openUrl) {
                urls.push(openUrl + "#isVideo=true##pre#" + getItem('fastPlayMode')=="1"?"#fastPlayMode##threads=10#":"");
                names.push("原始 画质");
                heads.push({ 'Referer': 'https://www.aliyundrive.com/' });
            } else {
                log('获取开放接口原画播放地址失败');
            }
        }
        if ((getItem('aliyun_playMode', '智能') == "智能" && urls.length == 0) || getItem('aliyun_playMode') == "转码") {
            /*
            let playUrlList = aliSharePlayUrl(share_id, file_id, share_pwd) || [];
            if (playUrlList.length > 0) {
                playUrlList.forEach((item) => {
                    urls.push(u + "?url=" + base64Encode(item.url + "|" + item.template_id) + "#.m3u8#pre#");
                    names.push(transcoding[item.template_id] ? transcoding[item.template_id] : item.template_height);
                    heads.push({ 'Referer': 'https://www.aliyundrive.com/' });
                })
            } else {
                log('未获取阿里播放地址，建议重进软件再试一次')
            }
            */
            let playUrlList = aliOpenPlayUrl(file_id, { sharetoken: sharetoken, share_id: share_id }, '', 1) || [];
            playUrlList.reverse();
            playUrlList.forEach((item) => {
                if(item.url){
                    urls.push(item.url + "#isVideo=true##pre#" + getItem('fastPlayMode')=="1"?"#fastPlayMode##threads=10#":"");
                    names.push(transcoding[item.template_id] ? transcoding[item.template_id] : item.template_height);
                    heads.push({ 'Referer': 'https://www.aliyundrive.com/' });
                }
            })
        }
        return {
            urls: urls,
            names: names,
            headers: heads
        };
    } catch (e) {
        log('获取共享链接播放地址失败>' + e.message + " 错误行#" + e.lineNumber);
        return {};
    }
}
function getSubtitle(share_id, sub_file_id, share_pwd) {
    try {
        share_pwd = share_pwd && share_pwd.length == 4 ? share_pwd : "";
        let sharetoken = getShareToken(share_id, share_pwd).share_token;
        headers["authorization"] = authorization;
        headers["x-share-token"] = sharetoken;
        let data = { "expire_sec": 600, "file_id": sub_file_id, "share_id": share_id };
        let downurl = JSON.parse(request("https://api.aliyundrive.com/v2/file/get_share_link_download_url", { headers: headers, body: data, timeout: 3000 })).download_url;
        let subfile = 'hiker://files/_cache/subtitles/' + sub_file_id + '.srt';
        downloadFile(downurl, subfile, { "referer": "https://www.aliyundrive.com/" })
        if (fetch(subfile)) {
            return getPath(subfile);
        } else {
            return "";
        }
    } catch (e) {
        log('获取字幕失败>' + e.message + " 错误行#" + e.lineNumber);
    }
    return "";
}

function aliMyPlayUrl(file_id, drive_id) {
    try {
        drive_id = drive_id || alidrive_id;
        let deviceId = userinfo.device_id;
        let userId = userinfo.user_id;
        headers['authorization'] = authorization;
        headers['x-device-id'] = deviceId;
        let aliecc = createsession(headers, deviceId, userId);
        let aliyunUrl = [];
        if (aliecc.success) {
            headers['x-signature'] = aliecc.signature;
            let data = { "drive_id": drive_id, "file_id": file_id, "category": "live_transcoding", "template_id": "", "get_subtitle_info": true }
            let json = JSON.parse(request('https://api.aliyundrive.com/v2/file/get_video_preview_play_info', { headers: headers, body: data, method: 'POST', timeout: 3000 }));
            aliyunUrl = json.video_preview_play_info.live_transcoding_task_list;
            aliyunUrl.reverse();
        }
        let urls = [];
        let names = [];
        let heads = [];
        if (aliyunUrl.length > 0) {
            aliyunUrl.forEach((item) => {
                if(item.url){
                    urls.push(item.url + "#isVideo=true##pre#" + getItem('fastPlayMode')=="1"?"#fastPlayMode##threads=10#":"");
                    names.push(transcoding[item.template_id] ? transcoding[item.template_id] : item.template_height);
                    heads.push({ 'Referer': 'https://www.aliyundrive.com/' });
                }
            })
        } else {
            log('未获取阿里转码播放地址，建议重进软件再试一次')
        }
        if (getItem('aliyun_playMode', '智能') == "智能" || getItem('aliyun_playMode') == "原画") {
            let file_url = aliOpenPlayUrl(file_id, undefined, drive_id);
            if (file_url) {
                if (getItem('yundisk_updateRecord') == "1") {
                    let opentoken = getOpenToken(authorization);
                    headers['authorization'] = 'Bearer ' + opentoken;
                    fetch('https://openapi.aliyundrive.com/adrive/v1.0/openFile/video/updateRecord', { headers: headers, body: { "duration": "0", "drive_id": drive_id, "file_id": file_id, "play_cursor": "0" }, method: 'POST' });
                }

                urls.unshift(file_url + "#isVideo=true##pre#" + getItem('fastPlayMode')=="1"?"#fastPlayMode##threads=10#":"");
                names.unshift("原始 画质");
                heads.unshift({ 'Referer': 'https://www.aliyundrive.com/' });
            } else {
                clearMyVar('opentokenChecktime');
            }
        }
        return {
            urls: urls,
            names: names,
            headers: heads
        };
    } catch (e) {
        log('获取我的云盘播放地址失败>' + e.message + " 错误行#" + e.lineNumber);
        return { message: '获取我的云盘播放地址失败>' + e.message };
    }
}

function aliOpenPlayUrl(file_id, sharedata, drive_id, preview) {
    try {
        drive_id = drive_id || alidrive_id;

        let newfile_id;
        if (sharedata) {
            sharedata.file_id = file_id;
            sharedata.drive_id = drive_id;
            sharedata.authorization = authorization;
            newfile_id = fcopy(sharedata);
            if (!newfile_id) {
                return "";
            }
        }
        let getJson;
        try {
            let opentoken = getOpenToken(authorization);
            headers['authorization'] = 'Bearer ' + opentoken;
            let data3 = { "drive_id": drive_id, "file_id": newfile_id || file_id };
            let apiurl = 'https://open.aliyundrive.com/adrive/v1.0/openFile/getDownloadUrl';
            if (preview) {
                //转码播放
                data3 = { "file_id": newfile_id || file_id, "drive_id": drive_id, "category": "live_transcoding", "template_id": "", "get_subtitle_info": true, "url_expire_sec": 14400, "with_play_cursor": true };
                apiurl = 'https://open.aliyundrive.com/adrive/v1.0/openFile/getVideoPreviewPlayInfo';
            }
            getJson = JSON.parse(request(apiurl, { headers: headers, body: data3, method: 'POST', timeout: 8000 }));
        } catch (e) {
            log('获取open播放地址失败>' + e.message + " 错误行#" + e.lineNumber);
        }
        if (newfile_id) {
            sharedata.file_id = newfile_id;
            fdel(sharedata);
        }
        if (preview) {
            //转码播放
            return getJson.video_preview_play_info.live_transcoding_task_list;
        } else {
            return getJson.url;
        }
    } catch (e) {
        log('获取open出现异常>' + e.message + " 错误行#" + e.lineNumber);
    }
    return "";
}

function getOpenToken(authorization) {
    let open_access_token;
    let oldtime = parseInt(getMyVar('opentokenChecktime', '0').replace('time', ''));
    let aliopentoken = getMyVar('aliopentoken');
    if (aliopentoken && nowtime < (oldtime + 2 * 60 * 60 * 1000)) {
        open_access_token = aliopentoken;
    } else {
        headers['authorization'] = authorization;
        headers['x-canary'] = "client=web,app=adrive,version=v4.3.1";
        function alistOpenApi(refresh_token) {
            let variable;
            let data = {};
            if (refresh_token) {
                data = {
                    grant_type: "refresh_token",
                    refresh_token: refresh_token
                }
                variable = 1;
            } else {
                let json = JSON.parse(request('https://open.aliyundrive.com/oauth/users/authorize?client_id=76917ccccd4441c39457a04f6084fb2f&redirect_uri=https://alist.nn.ci/tool/aliyundrive/callback&scope=user:base,file:all:read,file:all:write&state=', {
                    headers: headers,
                    body: {
                        "authorize": 1,
                        "scope": "user:base,file:all:read,file:all:write"
                    },
                    method: 'POST',
                    timeout: 8000
                }));
                let code = json.redirectUri.split("code=")[1];
                data = { "code": code, "grant_type": "authorization_code" }
                variable = 0;
            }
            let json2 = {};
            try {
                json2 = JSON.parse(request('https://api.xhofe.top/alist/ali_open/code', { body: data, method: 'POST', timeout: 8000 }));
            } catch (e) {
                json2 = JSON.parse(request('https://api-cf.nn.ci/alist/ali_open/code', { body: data, method: 'POST', timeout: 8000 }));
            }
            json2.variable = variable;
            return json2;
        }
        function webdavOpenApi(refresh_token) {
            let data = {
                grant_type: "refresh_token",
                refresh_token: refresh_token
            };
            let json2 = {};
            try {
                json2 = JSON.parse(request('https://aliyundrive-oauth.messense.me/oauth/access_token', { body: data, method: 'POST', timeout: 8000 }));
            } catch (e) {

            }
            return json2;
        }
        function tvOpenApi(refresh_token) {
            let variable;
            let data = {};
            if (refresh_token) {
                data = {
                    grant_type: "refresh_token",
                    refresh_token: refresh_token
                }
                variable = 1;
            } else {
                let res = post("http://api.extscreen.com/aliyundrive/qrcode", {
                    body: JSON.stringify({
                        "scopes": 'user:base,file:all:read,file:all:write',
                        "width": 500,
                        "height": 500,
                    }),
                });
                let data = JSON.parse(res).data;
                let sid = data["sid"];
                let body = {
                    "authorize": 1,
                    "scope": "user:base,file:all:read,file:all:write",
                    "drives": ["backup", "resource"],
                    "scopes": ["user:base", "file:all:read", "file:all:write"],
                    "sid": sid
                }
                let json = JSON.parse(request('http://api.extscreen.com/aliyundrive/token', {
                    headers: headers,
                    body: JSON.stringify(body),
                    method: 'POST',
                    timeout: 8000
                }));
                log(json);
                return json;
                //let code = json.redirectUri.split("code=")[1];
                //data = { "code": code, "grant_type": "authorization_code" }
                variable = 0;
            }
            let json2 = {};
            try {
                json2 = JSON.parse(request('https://api.xhofe.top/alist/ali_open/code', { body: data, method: 'POST', timeout: 8000 }));
            } catch (e) {
                json2 = JSON.parse(request('https://api-cf.nn.ci/alist/ali_open/code', { body: data, method: 'POST', timeout: 8000 }));
            }
            json2.variable = variable;
            return json2;
        }

        if (getItem('aliyun_openInt') == '2') {
            let openApi = webdavOpenApi(aliOpenTokenObj.refresh_token_2);
            if (openApi.access_token) {
                open_access_token = openApi.access_token;
                aliOpenTokenObj.refresh_token_2 = openApi.refresh_token || "";
            } else if (openApi.error) {
                log('webdav开放接口获取token失败>' + openApi.error);
                toast('原画接口2失败，重新登录或切换api接口或转码播放');
            }
        } else if (getItem('aliyun_openInt') == '3') {
            let openApi = tvOpenApi(aliOpenTokenObj.refresh_token_3);
            if (openApi.access_token) {
                open_access_token = openApi.access_token;
                aliOpenTokenObj.refresh_token_3 = openApi.refresh_token || "";
            } else if (openApi.error) {
                log('tv开放接口获取token失败>' + openApi.error);
                toast('原画接口3失败，切换api接口或转码播放');
            }
        } else {
            let openApi = alistOpenApi(aliOpenTokenObj.refresh_token_1);
            if (openApi.error && openApi.variable) {
                openApi = alistOpenApi();
            }
            open_access_token = openApi.access_token;
            aliOpenTokenObj.refresh_token_1 = openApi.refresh_token || "";
        }
        if (open_access_token) {
            aliconfig.opentoken = aliOpenTokenObj;
            writeFile(alicfgfile, JSON.stringify(aliconfig));
            putMyVar('aliopentoken', open_access_token);
            putMyVar('opentokenChecktime', nowtime + 'time');
        }
    }
    return open_access_token || "";
}