feat(cli): 新增配置获取/更新、同步的 cli 入口

Author: lexmin0412

packages/cli/src/index.ts

@@ -1,9 +1,12 @@
+import EventEmitter from 'events'
 import * as path from 'path'
 import pc from "picocolors"
 import { program } from 'commander'
 import { gt } from 'semver'
 import { add, current, doctor, list, remove, scan, upgrade, use } from './libs'
 import notification from './notification.json'
+import { sync } from './libs/sync'
+import { getConfig, setConfig } from './libs/config'
 const figlet = require('figlet')
 const pkgJsonPath = path.resolve(__dirname, '..', 'package.json')
 const pkgJson = require(pkgJsonPath)
@@ -13,7 +16,6 @@ if (gt('1.4.0', pkgJson.version)) {
 }
 console.log('');
 
-
 const artText = figlet.textSync('G C M', {
 	font: 'Standard',
 	horizontalLayout: 'default',
@@ -25,6 +27,9 @@ const artText = figlet.textSync('G C M', {
 console.log(`> gcm ${process.argv[2]}
 ${pc.green(artText)}`);
 
+// 解决事件监听过多，运行命令后弹出警告信息的问题（默认最大监听器数量为 10 个）
+EventEmitter.setMaxListeners(20)
+
 program
 	.version(pkgJson.version)
 	.command('use <alias>')
@@ -119,6 +124,45 @@ program
 		}
 	})
 
+program
+	.version(pkgJson.version)
+	.command('get-config <type>')
+	.description('get configuration')
+	.action((type: 'sync') => {
+		try {
+			getConfig(type)
+		} catch (error) {
+			console.error(error)
+			process.exit(1)
+		}
+	})
+
+program
+	.version(pkgJson.version)
+	.command('set-config <type>')
+	.description('update configuration')
+	.action((type: 'sync') => {
+		try {
+			setConfig(type)
+		} catch (error) {
+			console.error(error)
+			process.exit(1)
+		}
+	})
+
+program
+	.version(pkgJson.version)
+	.command('sync')
+	.description('sync config to remote')
+	.action(() => {
+		try {
+			sync()
+		} catch (error) {
+			console.error(error)
+			process.exit(1)
+		}
+	})
+
 program
 	.version(pkgJson.version)
 	.command('current')

packages/cli/src/libs/sync/const.ts

@@ -17,24 +17,8 @@ export const TEMP_SYNC_DIR = path.join(GCM_CONFIG_DIR, TEMP_FOLDER_NAME);
 /**
  * 配置仓库名称
  */
-const GIT_REPO_NAME = "config";
-/**
- * 配置仓库中用于存放 GCM 配置的目录名称
- */
-const SUB_FOLDER = "gcm";
-/**
- * GCM 配置文件名称
- */
-const GCM_CONFIG_FILE_NAME = "config.json";
+export const CONFIG_REPO_NAME = "config";
 /**
  * 仓库临时存放目录路径
  */
-export const REPO_FOLDER_PATH = path.join(TEMP_SYNC_DIR, GIT_REPO_NAME);
-/**
- * 仓库临时存放目录的 GCM 配置存放目录路径
- */
-export const CONFIG_FOLDER_PATH = path.join(REPO_FOLDER_PATH, SUB_FOLDER);
-/**
- * 仓库临时存放目录的 GCM 配置文件存放路径
- */
-export const GCM_CONFIG_FILE_PATH = path.join(CONFIG_FOLDER_PATH, GCM_CONFIG_FILE_NAME);
+export const REPO_FOLDER_PATH = path.join(TEMP_SYNC_DIR, CONFIG_REPO_NAME);

packages/cli/src/libs/sync/index.ts

@@ -1,25 +1,28 @@
 import fs from "fs";
-import { getAllUserConfigs } from "@lexmin0412/gcm-api";
-import { GCM_CONFIG_FILE_PATH } from "./const";
+import { getAllUserConfigs, readConfigs } from "@lexmin0412/gcm-api";
+import { REPO_FOLDER_PATH } from "./const";
 import { cloneConfigRepo, pushConfig, writeConfigIntoLocalRepo } from "./steps";
 import { isEqual } from "./utils";
 import { createServerAndOpenPage } from "./server";
+import path from "path";
 
 // 获取本地用户配置
 const localUserConfigs = getAllUserConfigs();
 
 /**
  * 同步配置主函数
  */
-const sync = async () => {
+export const sync = async () => {
 	// clone 用户配置仓库
 	await cloneConfigRepo();
 	// 判断本地配置是否与远程配置一致
+	const { sync } = readConfigs()
+	const GCM_CONFIG_FILE_PATH = path.join(REPO_FOLDER_PATH, sync.dir, sync.filename);
 	const remoteUserConfigs = JSON.parse(fs.readFileSync(GCM_CONFIG_FILE_PATH, "utf8"));
 	if (!remoteUserConfigs?.length) {
 		// 远程配置不存在，直接写入本地配置
 		writeConfigIntoLocalRepo(localUserConfigs);
-		pushConfig();
+		await pushConfig();
 	} else if (isEqual(localUserConfigs, remoteUserConfigs)) {
 		console.log("本地配置与远程配置一致，无需同步");
 	} else {
@@ -32,11 +35,9 @@ const sync = async () => {
 		// 写入本地配置
 		writeConfigIntoLocalRepo(mergedConfig);
 		// 推送配置
-		pushConfig();
-		process.exit(0);
+		await pushConfig();
 	}
+	process.exit(0);
 }
 
-sync()
-
 

packages/cli/src/libs/sync/server.ts

@@ -15,7 +15,7 @@ export const createServerAndOpenPage = async (options: {
 			const purePath = req.url?.slice(0, req.url.indexOf("?"));
 			if (!purePath || purePath === "/") {
 				const html = fs.readFileSync(
-					path.join(__dirname, "../../server/index.html")
+					path.join(__dirname, "../../../server/index.html")
 				);
 				res.writeHead(200, { "Content-Type": "text/html; charset=utf-8" });
 				return res.end(html);
@@ -44,9 +44,7 @@ export const createServerAndOpenPage = async (options: {
 				headless: false,
 			});
 			const page = await browser.newPage();
-			await page.goto(url, {
-
-			});
+			await page.goto(url);
 			// 给页面注入全局变量
 			await page.addScriptTag({
 				content: `
@@ -59,7 +57,7 @@ export const createServerAndOpenPage = async (options: {
 			`,
 			});
 			// 监听页面中的点击事件
-			await page.exposeFunction("onClickEvent", (event) => {
+			await page.exposeFunction("onClickEvent", (event: any) => {
 				console.log("点击事件发生:", event);
 				if (event.target === 'submit_btn') {
 
@@ -86,8 +84,11 @@ export const createServerAndOpenPage = async (options: {
 					console.log('合并输入框', document.querySelector('#mergedConfig'))
 					console.log('合并输入框的值', document.querySelector('#mergedConfig')?.innerHTML)
 					// 调用 Node.js 中暴露的函数
+					// @ts-ignore
 					window.onClickEvent({
-						target: event.target.id,
+						// @ts-ignore
+						target: event.target?.id,
+						// @ts-ignore
 						data: document.querySelector('#mergedConfig')?.value
 					});
 				});

packages/cli/src/libs/sync/steps.ts

@@ -1,8 +1,11 @@
 import fs from 'fs'
 import inquirer from "inquirer";
-import { CONFIG_FOLDER_PATH, GCM_CONFIG_FILE_PATH, REPO_FOLDER_PATH, TEMP_SYNC_DIR } from "./const";
+import { CONFIG_REPO_NAME, REPO_FOLDER_PATH, TEMP_SYNC_DIR } from "./const";
 import { execSync, type ExecSyncOptionsWithBufferEncoding } from "child_process";
 import { UserConfig } from '../../types';
+import { readConfigs } from '@lexmin0412/gcm-api';
+import { setConfig  as setSyncConfig } from '../config'
+import path from 'path';
 
 /**
  * 执行命令行脚本的统一选项
@@ -24,15 +27,25 @@ export const cloneConfigRepo = async () => {
 	// 创建临时工作目录
 	fs.mkdirSync(TEMP_SYNC_DIR);
 
-	// 获取用户配置仓库
-	const { configRepoUrl } = await inquirer.prompt([
-		{
-			type: "input",
-			name: "configRepoUrl",
-			message: "请输入配置仓库地址（建议使用 SSH 地址）",
+	// 获取用户配置仓库地址
+	const { sync } = readConfigs()
+	if (!sync?.repoUrl) {
+		const { isContinue } = await inquirer.prompt([
+			{
+				type: "confirm",
+				name: "isContinue",
+				message: "检测到同步配置不存在, 是否立即配置?",
+				default: true,
+			}
+		])
+		if (!isContinue) {
+			console.log("已取消同步配置")
+			process.exit(0)
 		}
-	])
-	execSync(`git clone ${configRepoUrl}`, {
+		await setSyncConfig('sync')
+	}
+	const { sync: newSyncConfig } = readConfigs()
+	execSync(`git clone ${newSyncConfig.repoUrl} ${CONFIG_REPO_NAME}`, {
 		cwd: TEMP_SYNC_DIR,
 	});
 	console.log("下载远程配置成功");
@@ -43,10 +56,12 @@ export const cloneConfigRepo = async () => {
  */
 export const writeConfigIntoLocalRepo = async (config: UserConfig[]) => {
 	console.log("开始写入配置到本地仓库");
-	// 判断 configFolder 是否存在，否则新建目录
+	const { sync } = readConfigs()
+	const CONFIG_FOLDER_PATH = path.join(REPO_FOLDER_PATH, sync.dir);
 	if (!fs.existsSync(CONFIG_FOLDER_PATH)) {
 		fs.mkdirSync(CONFIG_FOLDER_PATH);
 	}
+	const GCM_CONFIG_FILE_PATH = path.join(CONFIG_FOLDER_PATH, sync.filename);
 	// 判断 configPath 是否存在，否则新建文件
 	if (!fs.existsSync(GCM_CONFIG_FILE_PATH)) {
 		fs.writeFileSync(GCM_CONFIG_FILE_PATH, "{}");
@@ -73,6 +88,7 @@ export const pushConfig = async () => {
 			message: "请输入你的 git 邮箱",
 		},
 	]);
+	console.log(`用户: ${name}, ${email}`)
 	execSync(`git config user.name ${name}`, EXEC_OPTIONS);
 	execSync(`git config user.email ${email}`, EXEC_OPTIONS);
 	execSync("git add .", EXEC_OPTIONS);