danmaku/utils/oss.js

const OSS = require("ali-oss");
const path = require("path");
const fastregion = "oss-accelerate";

// 引入环境变量
require("dotenv")
	.config({ path: "../.env" });

let client = new OSS({
	region: process.env.ALI_OSS_REGION,
	accessKeyId: process.env.ALI_ACCESS_KEY,
	accessKeySecret: process.env.ALI_ACCESS_KEY_SECRET,
	bucket: process.env.OSS_BUCKET,
});

let fastclient = new OSS({
	region: fastregion,
	accessKeyId: process.env.ALI_ACCESS_KEY,
	accessKeySecret: process.env.ALI_ACCESS_KEY_SECRET,
	bucket: process.env.OSS_BUCKET,
});

async function get(objname,isFast) {
	try {
		const result = isFast ? await fastclient.get(objname) : await client.get(objname);
		return result.content.toString();
	} catch (e) {
		console.log(e);
	}
}

async function putfile(objname, localfilename, headers) {
	try {
		const res = await client.put(objname,path.normalize(localfilename),{headers});
		return res;
	} catch(e) {
		console.log(e);
	}
}

async function put(objname, content, headers) {
	try {
		const result = await client.put(objname, new Buffer.from(content), { headers });
		return result;
	} catch (e) {
		console.log(e);
	}
}

async function head(objname,isfast) {
	try {
		const result = isfast ? await fastclient.head(objname) : await client.head(objname);
		return result.res.headers;
	} catch (e) {
		console.log(e);
	}
}

async function signurl(objname, isFast) {
	try {
		let result = isFast ? await fastclient.signatureUrl(objname):await client.signatureUrl(objname);
		result = result.replace("http://", "//")
		return result;
	} catch (e) {
		console.log(e);
	}
}

async function list(prefix) {
	const result = await client.list({
		prefix,
	});
	return result;
}

async function putACL(key,acl = "public-read"){
	client.putACL(key,acl);
}

module.exports = {
	get,
	put,
	putfile,
	head,
	list,
	signurl,
	putACL
};

async function main() {
	get("SUB/database.yaml",true);
	put("SUB/test.txt", "中文");
	head("SUB/database.yaml",true);
	const url = await signurl("SUB/database.yaml", true);
	console.log(url)
}

if (!module.parent) {
	get("SUB/database.yaml");
	put("SUB/test.txt", "中文");
	head("SUB/database.yaml");
	signurl("SUB/database.yaml", true);
}