|
| 1 | +const execa = require('execa'); |
| 2 | +const invoke = require('./utils/invoke'); |
| 3 | +const signale = require('signale'); |
| 4 | +const args = require('minimist')(process.argv.slice(2)); |
| 5 | +const fse = require('fs-extra'); |
| 6 | +const path = require('path'); |
| 7 | +const https = require('https'); |
| 8 | +const { StringDecoder } = require('string_decoder'); |
| 9 | + |
| 10 | +const pkg = '@ali/ide-core-common'; |
| 11 | + |
| 12 | +invoke(async () => { |
| 13 | + const v = args.v || args.version; |
| 14 | + const version = await getOrCheckVersion(v); |
| 15 | + console.log(version); |
| 16 | + signale.info(`版本: ${version}`); |
| 17 | + |
| 18 | + const { packages } = await getKaitianDeps(version); |
| 19 | + |
| 20 | + const pkgPathList = []; |
| 21 | + pkgPathList.push(path.resolve('./package.json')); |
| 22 | + const packagesDir = path.resolve('./packages'); |
| 23 | + const dirents = await fse.readdir(packagesDir, { withFileTypes: true }); |
| 24 | + dirents.forEach((dirent) => { |
| 25 | + if (dirent.isDirectory()) { |
| 26 | + pkgPathList.push(path.join(packagesDir, dirent.name, 'package.json')); |
| 27 | + } |
| 28 | + }); |
| 29 | + signale.await(`正在写入数据`); |
| 30 | + await Promise.all(pkgPathList.map((pkgPath) => upgradeKaitianDeps(pkgPath, version, packages))); |
| 31 | + signale.await(`yarn 重装依赖`); |
| 32 | + await execa.command('npx yarn --network-timeout 100000', { |
| 33 | + stdio: 'inherit', |
| 34 | + }); |
| 35 | +}); |
| 36 | + |
| 37 | +async function getOrCheckVersion(version) { |
| 38 | + if (version) { |
| 39 | + const { stdout: name } = await execa.command(`tnpm view ${pkg}@${version} name`); |
| 40 | + if (!name) { |
| 41 | + signale.fatal(`${version} 不存在`); |
| 42 | + process.exit(128); |
| 43 | + } |
| 44 | + } else { |
| 45 | + ({ stdout: version } = await execa.command(`tnpm view ${pkg}@latest version`)); |
| 46 | + if (!version) { |
| 47 | + signale.fatal(`查找最新版本失败`); |
| 48 | + process.exit(128); |
| 49 | + } |
| 50 | + } |
| 51 | + return version; |
| 52 | +} |
| 53 | + |
| 54 | +async function getKaitianDeps(v) { |
| 55 | + return new Promise((resolve, reject) => { |
| 56 | + const decoder = new StringDecoder('utf8'); |
| 57 | + https.get(`https://g.alipay.com/@ali/kaitian@${v}/manifest.json`, (res) => { |
| 58 | + const { statusCode } = res; |
| 59 | + if (statusCode >= 200 && statusCode < 300) { |
| 60 | + let text = ''; |
| 61 | + res.on('data', (chunk) => { |
| 62 | + text += decoder.write(chunk); |
| 63 | + }); |
| 64 | + res.on('end', () => { |
| 65 | + text += decoder.end(); |
| 66 | + return resolve(JSON.parse(text)); |
| 67 | + }); |
| 68 | + } else { |
| 69 | + reject(new Error('请求 deps 失败')); |
| 70 | + } |
| 71 | + }); |
| 72 | + }); |
| 73 | +} |
| 74 | + |
| 75 | +async function upgradeKaitianDeps(pkgPath, version, kaitianDepList) { |
| 76 | + const pkgJSON = await fse.readJSON(pkgPath); |
| 77 | + let modified = false; |
| 78 | + if (pkgJSON.engines && pkgJSON.engines.kaitian) { |
| 79 | + pkgJSON.engines.kaitian = version; |
| 80 | + modified = true; |
| 81 | + } |
| 82 | + ['dependencies', 'devDependencies'].forEach((field) => { |
| 83 | + const obj = pkgJSON[field]; |
| 84 | + if (!obj) return; |
| 85 | + Object.keys(obj).forEach((dep) => { |
| 86 | + if (kaitianDepList[dep]) { |
| 87 | + obj[dep] = kaitianDepList[dep]; |
| 88 | + modified = true; |
| 89 | + } |
| 90 | + }); |
| 91 | + }); |
| 92 | + if (modified) { |
| 93 | + await fse.writeJSON(pkgPath, pkgJSON, { spaces: 2 }); |
| 94 | + } |
| 95 | +} |
0 commit comments