Node.js 异步编程实践：构建稳定的 GPX 到 GeoJSON 转换器

const fsp = require('fs').promises; // 导入 Promise 版本的 fs 模块
// ...
const files = await fsp.readdir(srcDir); // 等待目录读取完成
const fileData = await fsp.readFile(fullPath, {encoding: 'utf8'}); // 等待文件读取完成
// ...
await fsp.writeFile(outputPath, JSON.stringify(newGPx), { encoding: 'utf8' }); // 等待文件写入完成

// 错误示例 (forEach 不会等待 await)
files.forEach(async (file) => {
    await someAsyncOperation(file); // 这些操作会并发执行
});

// 正确示例 (for...of 会等待 await)
for (let file of files) {
    await someAsyncOperation(file); // 这些操作会顺序执行
}

const tj = require('@mapbox/togeojson');
const fsp = require('fs').promises; // 导入 fs.promises
const path = require('path');       // 导入 path 模块处理路径
const DOMParser = require('xmldom').DOMParser;

/**
 * 将指定目录下的所有 GPX 文件合并为一个 GeoJSON 文件。
 * @param {string} trailSlug - 包含 GPX 文件的目录 slug。
 */
const gpxToJson = async function (trailSlug) {
    const srcDir = `./public/traildata/${trailSlug}/gpxFiles/`;
    const outputPath = `./public/traildata/${trailSlug}/mastergeoJSON`;

    try {
        // 1. 读取目录中的所有 GPX 文件
        const files = await fsp.readdir(srcDir);

        let newGpx; // 用于存储最终合并的 GeoJSON 对象

        // 2. 使用 for...of 循环顺序处理每个文件
        for (let file of files) {
            const fullPath = path.join(srcDir, file); // 构建完整文件路径

            // 3. 读取文件内容
            const fileData = await fsp.readFile(fullPath, { encoding: 'utf8' });

            // 4. 解析 GPX XML 数据
            const gpx = new DOMParser().parseFromString(fileData);

            // 5. 将 GPX 转换为 GeoJSON
            const converted = await tj.gpx(gpx);

            // 确保 converted 对象有 features 且 features[0] 存在
            if (!converted || !converted.features || converted.features.length === 0) {
                console.warn(`跳过文件 ${file}：未找到有效的 GeoJSON features。`);
                continue; // 跳过当前文件，处理下一个
            }

            // 设置 GeoJSON feature 的名称属性
            converted.features[0].properties.name = file.replace('-', ' ').split('.')[0];

            // 6. 合并 GeoJSON 特征
            if (!newGpx) {
                // 如果 newGpx 尚未初始化，则使用第一个转换结果进行初始化
                newGpx = converted;
            } else {
                // 否则，将当前文件的第一个 feature 推入 newGpx 的 features 数组
                newGpx.features.push(converted.features[0]);
            }
        }

        // 7. 将最终合并的 GeoJSON 写入文件
        if (newGpx) {
            await fsp.writeFile(outputPath, JSON.stringify(newGpx), { encoding: 'utf8' });
            console.log(`文件已成功保存到 ${outputPath}`);
        } else {
            console.warn(`没有生成任何 GeoJSON 数据，未写入文件。`);
        }

    } catch (err) {
        console.error('GPX 到 GeoJSON 转换过程中发生错误:', err);
        throw err; // 重新抛出错误，以便调用者可以捕获
    }
};

// 调用函数并捕获可能发生的错误
gpxToJson('terra-cotta').catch(err => {
    console.error('顶级错误捕获:', err);
});