fix(ci): change ci and add hash judge

Author: LuckyFBB

.github/workflows/ci.yml

@@ -42,7 +42,7 @@ jobs:
               run: pnpm check-types
 
             - name: Run antlr4 all sql
-              run: pnpm antlr4 --lang all
+              run: pnpm antlr4 --all --check
 
     test:
         runs-on: ubuntu-latest

package.json

@@ -40,7 +40,8 @@
   "license": "MIT",
   "dependencies": {
     "antlr4-c3": "3.3.7",
-    "antlr4ng": "2.0.11"
+    "antlr4ng": "2.0.11",
+    "crypto": "^1.0.1"
   },
   "devDependencies": {
     "@commitlint/cli": "^17.7.2",
@@ -70,7 +71,7 @@
   },
   "repository": {
     "type": "git",
-		"url": "https://github.com/DTStack/dt-sql-parser.git"
+    "url": "https://github.com/DTStack/dt-sql-parser.git"
   },
   "publishConfig": {
     "registry": "https://registry.npmjs.org/"
@@ -89,6 +90,8 @@
     "*": [
       "prettier --write --ignore-unknown"
     ],
-    "*.g4": ["antlr-format -c ./antlr.format.json -v"]
+    "*.g4": [
+      "antlr-format -c ./antlr.format.json -v"
+    ]
   }
 }

pnpm-lock.yaml

@@ -4,6 +4,7 @@ const fs = require('fs');
 const argv = require('yargs-parser')(process.argv.slice(2));
 const inquirer = require('inquirer');
 const chalk = require('chalk');
+const crypto = require('crypto');
 const { cleanComment } = require('./cleanComment');
 
 const grammarsPath = path.resolve(__dirname, '../src/grammar');
@@ -15,26 +16,57 @@ const languageEntries = fs.readdirSync(grammarsPath).filter((language) => {
 
 const baseCmd = 'antlr4ng -Dlanguage=TypeScript -visitor -listener -Xexact-output-dir -o';
 
-function compile(language) {
-    const cmd = `${baseCmd} ${outputPath}/${language} ${grammarsPath}/${language}/*.g4`;
+function getFileHash(filePath) {
+    if (!fs.existsSync(filePath)) return null;
 
-    if (language !== 'plsql' && fs.existsSync(`${outputPath}/${language}`)) {
-        console.info(chalk.green(`\nRemoving:`, chalk.gray(`${outputPath}/${language}/*`)));
-        fs.rmSync(`${outputPath}/${language}`, { recursive: true });
-    }
+    const fileBuffer = fs.readFileSync(filePath);
+    const hashSum = crypto.createHash('sha256');
+    hashSum.update(fileBuffer);
 
-    console.info(chalk.green('Executing:'), chalk.gray(cmd));
-    exec(cmd, (err) => {
-        if (err) {
-            console.error(
-                chalk.redBright(`\n[Antlr4 compile error]:`),
-                chalk.cyan(language),
-                chalk.gray(err)
-            );
-        } else {
-            cleanComment(language);
-            console.info(chalk.greenBright(`Compile ${language} succeeded!`));
+    return hashSum.digest('hex');
+}
+
+function compile(language) {
+    return new Promise((resolve, reject) => {
+        const outputDir = `${outputPath}/${language}`;
+        const grammarFiles = fs
+            .readdirSync(`${grammarsPath}/${language}`)
+            .filter((file) => file.endsWith('.g4'));
+        const previousHashes = grammarFiles.map((file) => ({
+            file,
+            hash: getFileHash(path.join(outputDir, file.replace('.g4', '.ts'))),
+        }));
+
+        if (language !== 'plsql' && fs.existsSync(`${outputPath}/${language}`)) {
+            console.info(chalk.green(`\nRemoving:`, chalk.gray(`${outputPath}/${language}/*`)));
+            fs.rmSync(`${outputPath}/${language}`, { recursive: true });
         }
+
+        const cmd = `${baseCmd} ${outputDir} ${grammarsPath}/${language}/*.g4`;
+        console.info(chalk.green('Executing:'), chalk.gray(cmd));
+        exec(cmd, (err) => {
+            if (err) {
+                console.error(
+                    chalk.redBright(`\n[Antlr4 compile error]:`),
+                    chalk.cyan(language),
+                    chalk.gray(err)
+                );
+            } else {
+                cleanComment(language);
+                console.info(chalk.greenBright(`Compile ${language} succeeded!`));
+
+                const changedFiles = grammarFiles.filter((file) => {
+                    const newHash = getFileHash(path.join(outputDir, file.replace('.g4', '.ts')));
+                    const prevHash = previousHashes.find((h) => h.file === file)?.hash;
+                    return newHash !== prevHash;
+                });
+
+                if (changedFiles.length > 0) {
+                    return reject(`${language} not run antlr4`);
+                }
+                resolve();
+            }
+        });
     });
 }
 
@@ -61,22 +93,32 @@ function prompt() {
         });
 }
 
+async function antlr4AllSql() {
+    const errors = [];
+
+    const tasks = languageEntries.map((language) =>
+        compile(language).catch((err) => errors.push(err))
+    );
+
+    await Promise.all(tasks);
+
+    if (errors.length > 0 && argv.check) {
+        errors.forEach((error) => console.error(chalk.red(`- ${error}`)));
+        process.exit(1); // 非零退出表示错误
+    }
+}
+
 function main() {
     if (argv.all) {
-        // compile all: yarn antlr4 --all
-        languageEntries.forEach((language) => {
-            compile(language);
-        });
+        antlr4AllSql();
     } else if (argv.lang && typeof argv.lang === 'string') {
         // compile single: yarn antlr4 --lang=mysql
         const supportedLanguage = languageEntries.find((language) =>
             language.startsWith(argv.lang)
         );
 
         if (argv.lang === 'all') {
-            languageEntries.forEach((language) => {
-                compile(language);
-            });
+            antlr4AllSql();
         } else if (supportedLanguage) {
             compile(supportedLanguage);
         } else {