使用nodejs进行了简单的文件分卷工具

const fs = require('fs');
const readline = require('readline');
/**
 * @description 获取questtion的返回
 * @param {String} question 用户提示
 * @param {Function} handler 验证用户输入
 * @returns {Promise} rl.question方法本身是通过回调来处理用户输入的，所以选择了返回promise来做阻塞，有序地抛出question并接收answer
 */
function getQuestionResult(question,handler){
    return new Promise((res)=>{
        // 创建一个可读流，用来读取在cmd中的输入
        const rl = readline.createInterface({
            input: process.stdin,
            output: process.stdout,
        });
        /**
         * 考虑到即使用户输入异常，question方法都会在监听到换行之后结束，所以把handleResult的结构设计成一个对象，
         * 由一个状态值success来表示是否通过handler的校验，success为false时应再次执行并且获取用户输入         */
        rl.question(question, async (ans)=>{
            const handleResult = handler(ans)
            if (handleResult.success){
                rl.close()
                res(handleResult.value)
            } else {
                //handleResult.success为false时，handleResult.value是handler中设置的错误提示
                rl.close()
                const rejecthandle = await getQuestionResult(handleResult.value,handler)
                res(rejecthandle)
            }
        })
    })
}
// 这里创建一个generator实例，我觉得generator的yield单向有序的特性很适合我这个需求
function*gen(){
    function getChangeSettingsFlag(ans){
        return ans==="Y"?{success:true,value:true}:{success:true,value:false}
    }
    const getPath = function (ans) {
        /**
         * @description 验证路径（是否是目录）
         * @param {String} path
         */
        const validatePath = function (path) {
            try {
                // node10.x及以下版本不支持readdirSync，需要你需要这种写法，在运行之前需要切换node版本
                const dir = fs.readdirSync(path)
                if (dir) {
                    return {success:true,value:path}
                }
            } catch(err){
                return {success:false,value:"提供的地址不合理,请重新输入："}
            }
        }
        return validatePath(ans)
    }
    // yield并不会返回值，这里声明的changeSettingFlag的值实际上是接收的next方法的参数
    const changeSettingFlag = yield getChangeSettingsFlag
    const settings = {
        volumeSize: 10,
        dirName: "新建分卷"
    }
    // 改变预设
    if (changeSettingFlag){
        const volumeSize = yield function(volumeSize){
            return Number(volumeSize)>0&&Number(volumeSize)!==Infinity?{success:true,value:volumeSize}:{success:false,value:"输入的数字不合理，请重新输入："}
        }
        settings.volumeSize = Number(volumeSize)||settings.volumeSize
        const dirName = yield function(dirName){
            return dirName.trim()?{success:true,value:dirName}:{success:false,value:"输入的目录名不合理，请重新输入："}
        }
        settings.dirName = dirName.trim()||settings.dirName
    }
    // 接收路径
    const pathInfo = {
        input: "",
        output: ""
    }
    const inputPath = yield getPath
    pathInfo.input = inputPath;
    const outputPath = yield getPath
    pathInfo.output = outputPath;
    const conf = {
        pathInfo,
        settings
    }
    console.log("conf",conf)
    yield conf
}
// run it 
async function workflow(generator){
    const func0 = generator.next().value
    const changeSettingFlag = await getQuestionResult("当前预设置如下：\n\t输出的分卷名：“新建分卷”;\n\t容量：10话/卷；\n希望调整预设吗？(Y/n) ",func0)
    let getvolumeSize,getdirName
    if (changeSettingFlag){
        const func1 = generator.next(changeSettingFlag).value
        getvolumeSize = await getQuestionResult("期望的卷容量(话/卷)是： ",func1)
        const func2 = generator.next(getvolumeSize).value
        getdirName = await getQuestionResult("期望的分卷名是：",func2)
    }
    const func3 = generator.next(getdirName).value
    const inputPath = await getQuestionResult("选择的源路径是：",func3)
    const func4 = generator.next(inputPath).value
    const outputPath = await getQuestionResult("期望的输出路径是：",func4)
    const conf = generator.next(outputPath).value
    // 当前计数，通过在文件名中添加count来保持排序
    let currentCount = 0;
    // 当前分卷
    let currentVolume = 0;
    /**
     * @param {String} path 
     * @param {String} newFolderName 
     */
    async function letsdance(path,newFolderName="") {
        const childs = fs.opendirSync(path)
        let chunkNum = 0        let newFolderPath = newFolderName
        for await (const dirent of childs) {
            if (dirent.isDirectory()) {
                // 填充满一个目录之后创建一个新目录
                if (currentVolume%conf.settings.volumeSize===0) {
                    chunkNum+=1;
                    newFolderPath = conf.pathInfo.output+"/"+conf.settings.dirName+"_"+chunkNum
                    fs.mkdirSync(newFolderPath)
                    // 如果你不希望命名后缀一直递增，也可以在新建目录之后把currentCount重新置为0
                }
                currentVolume+=1
                const nextLevelPath = path+"/"+dirent.name
                letsdance(nextLevelPath,newFolderPath)
            } else if (dirent.isFile()){
                currentCount += 1
                const extName = dirent.name.split(".").reverse()[0]
                const targetFilePath = path+"/"+dirent.name
                const newFileName = newFolderPath+"/"+currentCount+"."+extName
                fs.copyFileSync(targetFilePath,newFileName)
            }
        }
    }
    letsdance(conf.pathInfo.input)
}
const g = gen()
workflow(g)