// {app_root}/config/plugin.js
exports.aliyunUtils = {
    enable: true,
    package: 'egg-aliyun-utils'
};

// {app_root}/config/config.default.js
exports.aliyunUtils = {};

// {app_root}/service/mainService.js
const { Service } = require('egg');
const { STS, OSS } = require('egg-aliyun-utils');
const toArray = require('stream-to-array');
 
class mainService extends Service {
    async getAuth() {
        const stsIns = new STS({
            accessKeyId: 'qwe',
            accessKeySecret: 'qwer',
            bucket: 'qwe',
            stsRoleId: 'acs:ram::123123123:role/keyirole',
            region: 'oss-cn-hangzhou'
        });
        const roleSession = 'BrowserCheckFile';
        const roleAction = '"oss:GetObject"';
        const data = {
            roleSession,
            roleAction
        };
        const result = await stsIns.getTemporaryAuth(data);
        return result;
    }
 
    async upload() {
        const ossIns = new OSS({
            accessKeyId: 'qwe',
            accessKeySecret: 'qwer',
            region: 'oss-cn-hangzhou'
        });
        let stream;
        try {
            stream = await ctx.getFileStream();
        } catch (e) {
            console.log(e);
        }
        const parts = await toArray(stream);
        const buffer = Buffer.concat(parts);
        const data = {
            path: 'test',
            data: buffer,
            bucket: 'qwe'
        };
        const result = await ossIns.upload(data);
        return result;
    }
}
 
module.exports = mainService;