feat: enhance logging and update to version 1.0.11

Author: luckfunc

index.js

@@ -6,115 +6,178 @@ const path = require('path');
 const https = require('https');
 const readline = require('readline');
 
+const colors = {
+  reset: '\x1b[0m',
+  info: '\x1b[38;2;120;220;255m',
+  warn: '\x1b[38;2;255;200;87m',
+  success: '\x1b[38;2;0;255;170m',
+  error: '\x1b[38;2;255;120;140m',
+  highlight: '\x1b[38;2;220;180;255m'
+};
+
+const tags = {
+  info: '[INFO]',
+  warn: '[WARN]',
+  success: '[DONE]',
+  error: '[FAIL]',
+  missing: '[MISSING]'
+};
+
+const logger = {
+  info(message) {
+    console.log(`${colors.info}${tags.info} ${message}${colors.reset}`);
+  },
+  warn(message) {
+    console.warn(`${colors.warn}${tags.warn} ${message}${colors.reset}`);
+  },
+  success(message) {
+    console.log(`${colors.success}${tags.success} ${message}${colors.reset}`);
+  },
+  error(message) {
+    console.error(`${colors.error}${tags.error} ${message}${colors.reset}`);
+  },
+  missing(file, url, destination) {
+    console.log(`${colors.highlight}${tags.missing} ${file}${colors.reset}`);
+    console.log(`${colors.info}Source URL: ${url}${colors.reset}`);
+    console.log(`${colors.info}Save To: ${destination}${colors.reset}`);
+  }
+};
+
+const promptArrow = '\x1b[38;2;0;200;255m\u2192\x1b[0m';
+const promptLabel = '\x1b[37m';
+const promptValue = '\x1b[38;2;0;255;255m';
+
 const userInputReader = readline.createInterface({
   input: process.stdin,
-  output: process.stdout,
+  output: process.stdout
 });
 
 let port = parseInt(process.argv[2] || '4000', 10);
 if (isNaN(port) || port < 1 || port > 65535) {
-  console.error('端口号无效，使用默认端口 4000');
+  logger.warn('Invalid port number. Using default port 4000');
   port = 4000;
 }
 
-const promptArrow = '\x1b[38;2;0;200;255m\u2192\x1b[0m';
-const promptLabel = '\x1b[37m';
-const promptValue = '\x1b[38;2;0;255;255m';
-
-console.log(`${promptArrow}${promptLabel}Local server running at: ${promptValue}http://127.0.0.1:${port}\x1b[0m`);
+logger.info(`Local server running at http://127.0.0.1:${port}`);
 
 function streamDownload(url, filePath) {
   return new Promise((resolve, reject) => {
     const fileStream = fs.createWriteStream(filePath);
     const request = https.get(url, (response) => {
       if (response.statusCode !== 200) {
         fs.unlink(filePath, () => {});
-        reject(new Error(`Request failed, status code: ${response.statusCode}`));
+        reject(new Error(`HTTP ${response.statusCode}`));
         return;
       }
       response.pipe(fileStream);
     });
+
     fileStream.on('finish', () => {
       fileStream.close(() => {
-        const stats = fs.statSync(filePath);
-        if (stats.size === 0) {
-          fs.unlink(filePath, () => {});
-          reject(new Error('Downloaded file is empty'));
-        } else {
-          resolve(stats.size);
+        try {
+          const stats = fs.statSync(filePath);
+          if (stats.size === 0) {
+            fs.unlink(filePath, () => {});
+            reject(new Error('received empty file'));
+          } else {
+            resolve(stats.size);
+          }
+        } catch (err) {
+          reject(new Error(`stat error: ${err.message}`));
         }
       });
     });
+
     request.on('error', (err) => {
       fs.unlink(filePath, () => {});
-      reject(new Error(`Request error: ${err.message}`));
+      reject(new Error(`request error: ${err.message}`));
     });
+
     fileStream.on('error', (err) => {
       fs.unlink(filePath, () => {});
-      reject(new Error(`File stream error: ${err.message}`));
+      reject(new Error(`file stream error: ${err.message}`));
     });
   });
 }
 
 async function downloadFileWithRetries(url, filePath, maxRetries = 3) {
   fs.mkdirSync(path.dirname(filePath), { recursive: true });
   if (fs.existsSync(filePath)) {
-    console.log(`文件已存在，跳过下载: ${filePath}`);
+    logger.info(`Skip download, file already exists → ${filePath}`);
     return;
   }
+
   for (let attempt = 1; attempt <= maxRetries; attempt++) {
     try {
       const fileSize = await streamDownload(url, filePath);
-      console.log(`下载完成: ${filePath} (${fileSize} bytes)`);
+      logger.success(`Downloaded ${filePath} (${fileSize} bytes)`);
       return;
     } catch (error) {
-      console.log(`第 ${attempt}/${maxRetries} 次尝试失败: ${filePath}: ${error.message}`);
-      if (attempt === maxRetries) {
-        console.error(`重试 ${maxRetries} 次后，下载失败: ${filePath}`);
+      if (attempt < maxRetries) {
+        logger.warn(`Retry ${attempt}/${maxRetries} for ${filePath} — ${error.message} (${url})`);
+      } else {
+        logger.error(`Download failed for ${filePath} from ${url} after ${maxRetries} retries: ${error.message}`);
       }
     }
   }
 }
 
 userInputReader.question(`${promptArrow}${promptLabel}请输入资源所在的根 URL: \x1b[0m`, (baseUrl) => {
-  console.log(`${promptArrow}${promptLabel}根 URL 已设置为: ${promptValue}${baseUrl}\x1b[0m`);
+  logger.info(`根 URL 已设置为: ${baseUrl}`);
   userInputReader.close();
 
-  console.log('\n--------------------------------------------------------');
-  console.log(`${promptArrow}${promptLabel}监控已启动。`);
-  console.log(`${promptArrow}${promptLabel}下一步: 请用浏览器打开 ${promptValue}http://127.0.0.1:${port}${promptLabel}`);
-  console.log(`${promptArrow}${promptLabel}脚本将会自动从 ${promptValue}${baseUrl}${promptLabel} 下载任何缺失的资源。`);
-  console.log('--------------------------------------------------------\n');
+  const divider = '─'.repeat(56);
+  const introLines = [
+    '监控已启动',
+    `下一步: 打开 http://127.0.0.1:${port}`,
+    `缺失的资源会自动从 ${baseUrl} 拉取`
+  ];
+
+  console.log();
+  logger.info(divider);
+  introLines.forEach((line) => logger.info(line));
+  logger.info(divider);
+  console.log();
 
   const httpServerProcess = exec(`npx http-server -p ${port}`);
 
   httpServerProcess.stdout.on('data', async (data) => {
     const output = data.toString();
     const missingFileRegex = /"GET (\/.*?)" Error \(404\):/g;
-    const missingFileMatches = [...output.matchAll(missingFileRegex)];
-    if (missingFileMatches.length > 0) {
-      const ignoreList = [
-        '/.well-known/appspecific/com.chrome.devtools.json',
-      ];
-      for (const match of missingFileMatches) {
-        const encodedFilePath = match[1].replace(/"/g, '');
-        const decodedFilePath = decodeURIComponent(encodedFilePath);
-        if (ignoreList.includes(decodedFilePath)) {
-          continue;
-        }
-        console.log('检测到缺失文件:', decodedFilePath);
-        const localFilePath = path.join(process.cwd(), decodedFilePath);
-        const remoteFileUrl = `${baseUrl}${encodedFilePath}`;
-        await downloadFileWithRetries(remoteFileUrl, localFilePath);
+    const matches = [...output.matchAll(missingFileRegex)];
+
+    if (matches.length === 0) {
+      return;
+    }
+
+    const ignoreList = [
+      '/.well-known/appspecific/com.chrome.devtools.json'
+    ];
+
+    for (const match of matches) {
+      const encodedPath = match[1].replace(/"/g, '');
+      const decodedPath = decodeURIComponent(encodedPath);
+      if (ignoreList.includes(decodedPath)) {
+        continue;
       }
+
+      const localFilePath = path.join(process.cwd(), decodedPath);
+      const remoteFileUrl = `${baseUrl}${encodedPath}`;
+
+      logger.missing(decodedPath, remoteFileUrl, localFilePath);
+      await downloadFileWithRetries(remoteFileUrl, localFilePath);
     }
   });
 
   httpServerProcess.stderr.on('data', (data) => {
-    console.error('http-server 错误:', data.toString());
+    logger.error(`http-server stderr: ${data.toString().trim()}`);
+  });
+
+  httpServerProcess.on('error', (err) => {
+    logger.error(`Unable to start http-server: ${err.message}`);
   });
 
   httpServerProcess.on('close', (code) => {
-    console.log(`http-server 进程已退出，退出码: ${code}`);
+    logger.info(`http-server process exited with code ${code}`);
   });
 });

package.json

@@ -1,6 +1,6 @@
 {
   "name": "resource-save-script",
-  "version": "1.0.10",
+  "version": "1.0.11",
   "description": "HTTP server with auto-download capability",
   "homepage": "https://github.com/luckfunc/resource-save-script#readme",
   "bugs": {