wenbao-website/scripts/UpdateScript/app.mjs

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

import { program } from 'commander';
import { input, confirm, select } from '@inquirer/prompts';
import { postAppUpdate, postWebUpdate } from './postUpdate.mjs';
import Table from 'cli-table3';
import { config } from './postConfig.mjs';
import {
  axiosInstance,
  initAuth,
  login,
  logout,
  checkLogged,
} from './auth.mjs';
import consola from 'consola';
import { logError } from './utils.mjs';

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

export 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) {
      logError('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());
  }
}
export 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: "{}",
        });
        consola.success('Add version success');
      } catch (e) {
        logError('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);
        consola.success('删除版本成功');
      } catch (e) {
        logError('删除版本失败', 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
        });
        consola.success('设置状态成功');
      } catch (e) {
        logError('设置状态失败', 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,
        });
        consola.success('设置配置成功');
      } catch (e) {
        logError('设置配置失败', 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 });
        consola.success('成功');
      } catch (e) {
        logError('失败', 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 });
        consola.success('成功');
      } catch (e) {
        logError('失败', e);
      }
      break;
    }
    default:
      logError('未知参数', 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) {
    logError('没有版本，请在管理后台创建 appId ' + config.appId + ' 的版本');
    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) {
    logError('没有更新');
    return;
  }
  const resultId = (await select({
    choices: data.map(p => ({
      value: p.id,
      name: p.version,
    })),
    message: '选择一个更新',
  }));
  return resultId;
}

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

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

export async function postUpdate(type, options) {
  switch (type) {
    case 'web': {
      await postWebUpdate(axiosInstance, options);
      break;
    }
    case 'app': {
      await postAppUpdate(axiosInstance, options);
      break;
    }
    default:
      logError('Unknow type', type);
      break;
  }
}
export 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) {
    consola.warn('只有Web更新允许弃用');
    return;
  }
  if (currentUpdateInfo.status === 0) {
    consola.warn(`当前状态 ${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 });
    consola.success(`${deprecate ? '弃用' : '删除'} 成功`);
  } catch (e) {
    logError(`操作失败`, e);
  }
}
export async function viewUpdate(updateId) {
  
  let currentUpdateInfo = null
  let currentVersionInfo = null

  try {
    currentUpdateInfo = (await axiosInstance.get('/update/' + updateId)).data;
  } catch (e) {
    logError('加载更新信息失败', updateId);
  }
  try {
    currentVersionInfo = (await axiosInstance.get('/version/' + currentUpdateInfo.versionId)).data;
  } catch (e) {
    logError('加载版本信息失败', 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,
  }
}
export 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);
      consola.info('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: 
        logError('Unknow action', action);
        break;
    }
  }
}
export async function testVersion(version) {
  try {
    const data = await axiosInstance.get('/update-get-info?version=' + version);
    consola.info('版本信息', data.data);
  } catch(e) {
    logError('获取失败', e);
  }
}