Class

utils/cloud.js:3–126

const superagent = require('superagent');
const db = require('./db');
module.exports = class {
    constructor(id) {
        this.info = db('account').find({ id: id }).value()
    }

    // 登录
    async login(refresh_token) {
        try {
            if (!refresh_token) {
                let s = await superagent.post('https://auth.aliyundrive.com/v2/account/token')
                    .send({
                        refresh_token: this.info.refresh_token,
                        grant_type: "refresh_token"
                    });

                this.info = db('account').find({ id: this.info.id }).assign(s.body).write();
                return this.info
            } else {
                let s = await superagent.post('https://auth.aliyundrive.com/v2/account/token')
                    .send({
                        refresh_token: refresh_token,
                        grant_type: "refresh_token"
                    });
                let info = db('account').find({ user_id: s.body.user_id }).value()
                if (!info) {
                    info = db('account').insert(s.body).write()
                } else {
                    info = db('account').find({ user_id: s.body.user_id }).assign(s.body).write()
                }
                this.info = info
                return this.info
            }

        } catch (error) {
            // console.log(error)
            return Promise.reject('refresh_token存在问题')
        }

    }

    // 请求
    async http(url, params = {}) {
        return new Promise(async (resolve, reject) => {
            try {
                let s = await superagent.post(url)
                    .set({
                        authorization: 'Bearer ' + this.info.access_token,
                        referer: 'https://www.aliyundrive.com/',
                        'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/89.0.4389.82 Safari/537.36'
                    })
                    .send(params)
                resolve(s.body)
            } catch (error) {
                if (error.status == 401) {
                    await this.login()
                    return this.http(url, params)
                } else {
                    reject(error.response.body.message)