xchpc-website/scripts/UpdateScript/index.mjs

/**
 * 更新发布工具
 * 
 * Copyright © 2025 imengyu.top imengyu-update-server
 */

import { program } from 'commander';
import { password, input, confirm, select } from '@inquirer/prompts';
import { writeFile, readFile } from 'node:fs/promises';
import { postAppUpdate, postWebUpdate } from './postUpdate.mjs';
import Table from 'cli-table3';
import md5 from 'md5';
import axios from 'axios';
import path from 'path';
import { dirname } from 'node:path';
import { fileURLToPath } from 'node:url';
import { config } from './postConfig.mjs';

//基础配置
//========================================

const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);
const constant = {
  ServerUrl: config.server,
  TokenSave: path.resolve(__dirname, './_token.json'),
};
let currentData = {
  token: '',
  identifier: '',
};

function initIdentifier() {
  if (!currentData.identifier) 
    currentData.identifier = `commandClient${Math.floor(Math.random() * 1000)}`;
}

readFile(constant.TokenSave).then((res) => {
  currentData = JSON.parse(res);
  initIdentifier();
  start();
}).catch(() => {
  initIdentifier();
  start();
})

const axiosInstance = axios.create({
  baseURL: constant.ServerUrl,
  timeoutErrorMessage: '请求超时，请检查网络连接',
  responseType: 'json',
  withCredentials: false,
  validateStatus: () => true,
});

axiosInstance.interceptors.request.use((value) => {
  value.headers['authorization'] = JSON.stringify({
    auth: currentData?.token?.authName,
    validity: currentData?.token?.authKey,
    nonce: "aaaaaaaaaa",
    identifier: currentData.identifier,
    key: 'abc123',
  });  
  value.url = value.url + (value.url.includes('?') ? '&' : '?' ) + `identifier=${currentData.identifier}`
  return value;
});
axiosInstance.interceptors.response.use((value) => {
  if (value.data.success) 
    return value.data;
  else
    return Promise.reject(value.data);
});

function getErrorMessage(e) {
  return e instanceof Error ? e.message : (typeof e === 'object' ? e : ('' + e));
}

//登录相关
//========================================

async function checkLogged() {
  try {
    await axiosInstance.get('/auth');
    console.log('已登录');
  } catch (e) {
    console.error('获取状态失败：', getErrorMessage(e));
  }
}
async function login(user) {
  try {
    const pass = await password({ message: '输入密码' });
    const res = await axiosInstance.post('/auth?rember=true', {
      method: 'key',
      key: `${user}@${md5(pass)}`,
    })
    currentData.token = {
      authName: res.data.authName,
      authKey: res.data.authKey,
    };
    writeFile(constant.TokenSave, JSON.stringify(currentData));
    console.log('登录成功');
  } catch (e) {
    console.error('登录失败', getErrorMessage(e));
  }
}
async function logout() {
  currentToken = '';
  writeFile(constant.TokenSave, JSON.stringify(currentData));
  try {
    await axiosInstance.delete('/auth');
    console.log('退出登录成功');
  } catch(e) {
    console.error('退出登录失败', getErrorMessage(e));
  }
}

//版本相关
//========================================

async function viewVersion(type) {
  if (type === 'all' || !type) {
    const data = await axiosInstance.get('/version/list');
    const table = new Table({
      head: ['ID', '版本'], 
      colWidths: [10, 20 ]
    });

    data.data.forEach((d) => {
      table.push([ d.id, d.version ]);
    })
    console.log(table.toString());
  } else {
    let data = null;
    try {
      if (Number.isNaN(Number(type)))
        data = await axiosInstance.get('/version/get-by-name?name=' + type);
      else
        data = await axiosInstance.get('/version/' + type);
    }
    catch (e) {
      console.error('Failed to load version info', e);
      return;
    }
    const table = new Table({
      head: ['key', 'data'], 
      colWidths: [30, 60]
    });
    table.push(
      [ 'ID', data.data.id ],
      [ '状态', stateConstant[data.data.status] ],
      [ '版本号', data.data.version ],
      [ '创建时间', new Date(data.data.createAt).toString() ],
      [ '设置', data.data.config ],
      [ '激活的Web更新ID', data.data.webUpdateId ],
      [ '激活的App更新ID', data.data.appUpdateId ],
      [ '激活的下一个App更新ID', data.data.appUpdateNextId ],
    );
    console.log(table.toString());
  }
}
async function getVersion(action, type) {
  switch(action) {
    case 'view':
      await viewVersion(type);
      break;
    case 'new': {
      const version = await input({ message: 'Enter version name, like (1.0.0)' });
      try {
        await axiosInstance.post('/version', {
          version: version,
          status: 1,
          config: "{}",
        });
        console.log('Add version success');
      } catch (e) {
        console.error('Failed to add version', e);
      }
      break;
    }
    case 'delete': {
      const versionId = type ? type : await input({ message: '输入版本ID' });
      if (!await confirm({ message: `确定删除版本 ${versionId}?`, default: false }))
        return;
      if (!await confirm({ message: '确认删除版本？此操作会删除所属版本的所有更新项目、存储等，无法恢复，是否确定删除？', default: false }))
        return;
      try {
        await axiosInstance.delete('/version/' + versionId);
        console.log('删除版本成功');
      } catch (e) {
        console.error('删除版本失败', e);
      }
      break;
    }
    case 'set-state': {
      const versionId = type ? type : await input({ message: '输入版本ID' });
      const state = await select({
        message: '设置状态',
        choices: [
          {
            name: 'NotEnable',
            value: 0,
          },
          {
            name: 'Normal',
            value: 1,
          },
          {
            name: 'Deprecated',
            value: 2,
          },
        ],
      });

      try {
        await axiosInstance.put('/version/' + versionId, {
          status: state
        });
        console.log('设置状态成功');
      } catch (e) {
        console.error('设置状态失败', e);
      }
      break;
    }
    case 'set-config': {
      const versionId = type ? type : await input({ message: '输入版本ID' });
      const config = await input({ message: '输入配置Json' });
      try {
        await axiosInstance.put('/version/' + versionId, {
          config: config,
        });
        console.log('设置配置成功');
      } catch (e) {
        console.error('设置配置失败', e);
      }
      break;
    }
    case 'set-active-app-update': {
      const versionId = await input({ message: '输入版本ID' });
      const updateId = await input({ message: '输入更新ID' });
      const isNext = await confirm({ message: 'Set as next active?', default: false });

      try {
        await axiosInstance.post('/update/active/app', { versionId, updateId, isNext });
        console.log('成功');
      } catch (e) {
        console.error('失败', e);
      }
      break;
    }
    case 'set-active-web-update': {
      const versionId = await input({ message: '输入版本ID' });
      const updateId = await input({ message: '输入更新ID' });

      try {
        await axiosInstance.post('/update/active/web', { versionId, updateId });
        console.log('成功');
      } catch (e) {
        console.error('失败', e);
      }
      break;
    }
    default:
      console.error('未知参数', action);
      break;
  }
}

//选择方法
//========================================

export async function selectVersion(defaultVersionId = null) {
  const data = (await axiosInstance.get('/version/list?full=true&search=' + JSON.stringify({ 
    appId: config.appId 
  }))).data;
  if (data.length === 0) {
    console.error('没有版本');
    return;
  }
  const versionId = (await select({
    choices: data.map(p => ({
      value: p.id,
      name: p.version,
    })),
    default: defaultVersionId,
    message: '选择一个版本',
  }));
  const versionName = data.find(p => p.id === versionId).version;
  return { versionId, versionName };
}
export async function selectUpdate() {
  const { versionId } = await selectVersion();
  const data = (await axiosInstance.get('/version/update?search=' + JSON.stringify({ versionId }))).data;
  if (data.length === 0) {
    console.error('没有更新');
    return;
  }
  const resultId = (await select({
    choices: data.map(p => ({
      value: p.id,
      name: p.version,
    })),
    default: defaultVersionId,
    message: '选择一个更新',
  }));
  return resultId;
}

//更新相关
//========================================

const stateConstant = [ 'Deleted', 'Normal', 'Deprecated' ];
const typeConstant = [ 'Unknow', 'Web', 'app' ];
const storageTypeConstant = [ 'Unknow', 'LocalStorage', 'AliOSS' ];

async function postUpdate(type, options) {
  switch (type) {
    case 'web': {
      await postWebUpdate(axiosInstance, options);
      break;
    }
    case 'app': {
      await postAppUpdate(axiosInstance, options);
      break;
    }
    default:
      console.error('Unknow type', type);
      break;
  }
}
async function deprecateOrDeleteUpdate(updateId) {
  if (!updateId)
    updateId = await selectUpdate();

  const { currentUpdateInfo, currentVersionInfo } = await viewUpdate(updateId);

  const deprecate = (await select({
    choices: [
      {
        name: 'Deprecate',
        value: 0,
      },
      {
        name: 'Delete',
        value: 1,
      },
    ],
    message: '删除或弃用?',
  })) === 0;

  if (deprecate && currentUpdateInfo.type !== 1) {
    console.log('只有Web更新允许弃用');
    return;
  }
  if (currentUpdateInfo.status === 0) {
    console.log(`当前状态 ${stateConstant[currentUpdateInfo.status]} 无法弃用`);
    return;
  }

  if (deprecate) {
    if (!await confirm({ message: `确定弃用当前版本 ${currentUpdateInfo.versionCode} ？弃用会删除存储文件以及备份。此操作无法恢复！`, default: false }))
      return;
  } else {
    if (!await confirm({ message: `确定删除当前版本 ${currentUpdateInfo.versionCode} ？此操作无法恢复！`, default: false }))
      return;
  }

  try {
    await axiosInstance.post(`/update/${deprecate ? 'deprecate' : 'delete'}`, { updateId });
    console.log(`${deprecate ? '弃用' : '删除'} 成功`);
  } catch (e) {
    console.error(`操作失败`, e);
  }
}
async function viewUpdate(updateId) {
  
  let currentUpdateInfo = null
  let currentVersionInfo = null

  try {
    currentUpdateInfo = (await axiosInstance.get('/update/' + updateId)).data;
  } catch (e) {
    console.error('加载更新信息失败', updateId);
  }
  try {
    currentVersionInfo = (await axiosInstance.get('/version/' + currentUpdateInfo.versionId)).data;
  } catch (e) {
    console.error('加载版本信息失败', currentUpdateInfo.versionId);
  }

  const table = new Table({
    head: ['key', 'data'], 
    colWidths: [20, 40]
  });
  table.push(
    [ 'ID', currentUpdateInfo.id ],
    [ '所属应用', currentUpdateInfo.name ],
    [ '更新信息', currentUpdateInfo.updateInfo ],
    [ '版本号', currentUpdateInfo.versionCode ],
    [ '创建时间', new Date(currentUpdateInfo.createAt).toString() ],
    [ '类型', typeConstant[currentUpdateInfo.type] ],
    [ '状态', stateConstant[currentUpdateInfo.status] ],
    [ '强制更新', currentUpdateInfo.force ],
    [ '公共访问路径', currentUpdateInfo.publicUrl ],
    [ '存储类型', storageTypeConstant[currentUpdateInfo.storageType] ],
    [ '存储路径', currentUpdateInfo.storagePath ],
  );

  console.log(table.toString());

  if (currentUpdateInfo.activeWebVersionName) {
    table.push(
      [ '使用中的Web版本', currentUpdateInfo.activeWebVersionName ],
    );
  }
  if (currentUpdateInfo.activeAppVersionName) {
    table.push(
      [ '使用中的App版本', currentUpdateInfo.activeAppVersionName ],
    );
  }

  return {
    currentUpdateInfo,
    currentVersionInfo,
  }
}
async function getUpdate(action, type, all, options) {
  const typeNotANumber = isNaN(new Number(type)); 

  if (action === 'view' && (!type || typeNotANumber)) {

    let hasSerch = false;
    const search = {};
    const sort = {
      field: "createAt",
      order: "descend"
    }
    if (typeNotANumber && type !== 'all') {
      hasSerch = true;
      search.version = type;
    }

    const data = await axiosInstance.get('/update/list?full=true' + (hasSerch ? ('&search=' + JSON.stringify(search)) : '') + '&sort=' + JSON.stringify(sort));
    const table = new Table({
      head: ['ID', '版本', '版本号', '类型', '状态'], 
      colWidths: [10, 10, 20, 10, 15 ]
    });

    if (type !== 'all' && all !== 'all' && data.data.length > 10) {
      data.data = data.data.slice(0, 10);
      console.log('filter!', all);
    }

    data.data.forEach((d) => {
      table.push([ 
        d.id, 
        (d.activeAppVersionName ? `${d.activeAppVersionName} (App)` : (
          d.activeWebVersionName? `${d.activeWebVersionName} (Web)` : '无'
        )),  
        d.versionCode, typeConstant[d.type], stateConstant[d.status] 
      ]);
    })
    
    console.log(table.toString());
  } else {
    switch (action) {
      case 'post': {
        await postUpdate(type, options);
        break;
      }
      case 'delete': {
        await deprecateOrDeleteUpdate(type);
        break;
      }
      case 'view': {
        viewUpdate(type);
        break;
      }
      default: 
        console.error('Unknow action', action);
        break;
    }
  }
}
async function testVersion(version) {
  try {
    const data = await axiosInstance.get('/update-get-info?version=' + version);
    console.log('版本信息', data.data);
  } catch(e) {
    console.log('获取失败', e);
  }
}

//程序入口
//============================================

program
  .command('login <user>')
  .description('登录')
  .action(login);
program
  .command('logstate')
  .description('检查登录状态')
  .action(checkLogged);
program
  .command('logout')
  .description('退出登录')
  .action(logout);

program
  .command('test <version>')
  .description('测试更新入口')
  .action(testVersion);

program
  .command('version <action> [type]')
  .description('查看版本信息/发布版本/删除版本/设置版本, action 可选 view/new/delete/set-web-update/set-app-update/set-next-app-update')
  .action(getVersion);
program
  .command('update <action> [type] [all]')
  .description('查看更新信息/发布更新, action 可选 view/post, view type 可选 id/all; post type 可选 web/app')
  .option('--skip', '跳过构建')
  .option('--ndelete', '不删除构建文件')
  .action(getUpdate);

function start() {
  program.parse(process.argv);
}

process.on('unhandledRejection', (reason, p) => {
  console.error('Promise: ', p, 'Reason: ', reason)
})