postcat/upload.js

const qiniu = require('qiniu');
const { AK, SK, bucket } = require('./qiniu_env.js');
const package = require('./package.json');

qiniu.conf.ACCESS_KEY = AK;
qiniu.conf.SECRET_KEY = SK;

// * 构建上传策略函数
const uptoken = (bucket, key) => new qiniu.rs.PutPolicy(bucket + ':' + key).token();

const toLatest = (name) => name.replace(/\d+\.\d+\.\d+/, 'latest');
const onlyName = (name) => name.replace(/release\//, '');

// * 构建客户端实例
const client = new qiniu.rs.Client();

// * 上传单个文件
const uploadFile = (token, file, localFile) =>
  new Promise((resolve) => {
    const extra = new qiniu.io.PutExtra();
    qiniu.io.putFile(token, file, localFile, extra, (err) => {
      console.log(err ? err : 'success');
      return err ? resolve(false) : resolve(true);
    });
  });

// * 删除单个文件
const removeFile = (spaceName, file) =>
  new Promise((resolve) => {
    client.remove(spaceName, file, (err, ret) => {
      return err ? resolve(false) : resolve(true);
    });
  });

// * 拷贝单个文件
const cpFile = (fromFile, toFile) =>
  new Promise((resolve) => {
    client.copy(bucket, fromFile, bucket, toFile, (err) => {
      return err ? resolve(false) : resolve(true);
    });
  });

const version = package.version;
const fileList = [
  'release/eoapi Setup ?.exe',
  'release/eoapi-?.dmg',
  'release/eoapi-?-arm64.dmg',
  'release/eoapi-?-mac.zip',
  'release/latest.yml',
  'release/latest-mac.yml',
].map((it) => it.replace(/\?/, `${version}`));
// const fileList = ['releass/eoapi-Setup-?.png', 'releass/eoapi-?.png', 'releass/eoapi-?-arm64.png'].map((it) =>
//   it.replace(/\?/, `${version}`)
// );

const app = async () => {
  const uploadResult = await Promise.all(
    fileList.map(async (it) => {
      let isOK;
      // * 生成上传 Token
      try {
        const token = uptoken(bucket, `${version}/${it.replace(/release\//, '')}`);
        isOK = await uploadFile(token, `${version}/${it.replace(/release\//, '')}`, it);
      } catch (error) {
        console.log('error', error);
      }
      return Promise.resolve(isOK || false);
    })
  );
  console.log('上传结果：', uploadResult);
  const deleteResult = await Promise.all(
    fileList.map(async (it) => {
      const isOK = await removeFile(bucket, `latest/${toLatest(onlyName(it))}`);
      Promise.resolve(isOK || false);
    })
  );
  console.log('删除结果：', deleteResult);
  const copyResult = await Promise.all(
    fileList.map(async (it) => {
      const isOK = await cpFile(`${version}/${onlyName(it)}`, `latest/${toLatest(onlyName(it))}`);
      Promise.resolve(isOK || false);
    })
  );
  console.log('拷贝结果', copyResult);
};

app();