|
| 1 | +require("./wasm_exec.js"); |
| 2 | + |
| 3 | +/** |
| 4 | + * @typedef {(go: Go) => Promise<WebAssembly.WebAssemblyInstantiatedSource>} WasmLoader |
| 5 | + * @typedef {(source: string, path: string) => Promise<LintResult[]>} RunActionlint |
| 6 | + * |
| 7 | + * @typedef {Object} LintResult |
| 8 | + * @property {string} Message |
| 9 | + * @property {string} Filepath |
| 10 | + * @property {number} Line |
| 11 | + * @property {number} Column |
| 12 | + * @property {string} Kind |
| 13 | + */ |
| 14 | + |
| 15 | +/** |
| 16 | + * @param {WasmLoader} loader |
| 17 | + * @returns {RunActionlint} |
| 18 | + */ |
| 19 | +module.exports.createActionlint = function createActionlint(loader) { |
| 20 | + const go = new Go(); |
| 21 | + |
| 22 | + /** @type {(() => void)[] | undefined} */ |
| 23 | + let queued = undefined; |
| 24 | + |
| 25 | + // This function gets called from go once the wasm module is ready and it |
| 26 | + // executes the linter for all queued calls. |
| 27 | + globalThis.actionlintInitialized = () => { |
| 28 | + queued?.forEach((f) => f()); |
| 29 | + queued = globalThis.actionlintInitialized = undefined; |
| 30 | + }; |
| 31 | + |
| 32 | + loader(go).then((wasm) => { |
| 33 | + // Do not await this promise, because it only resolves once the go main() |
| 34 | + // function has exited. But we need the main function to stay alive to be |
| 35 | + // able to call the `runActionlint` function. |
| 36 | + go.run(wasm.instance); |
| 37 | + }); |
| 38 | + |
| 39 | + /** |
| 40 | + * @param {string} src |
| 41 | + * @param {string} path |
| 42 | + * @returns {Promise<LintResult[]>} |
| 43 | + */ |
| 44 | + return async function runLint(src, path) { |
| 45 | + // Return a promise, because we need to queue calls to `runLint()` while the |
| 46 | + // wasm module is still loading and execute them once the wasm module is |
| 47 | + //ready. |
| 48 | + return new Promise((resolve, reject) => { |
| 49 | + if (typeof runActionlint === "function") { |
| 50 | + const [result, err] = runActionlint(src, path); |
| 51 | + return err ? reject(err) : resolve(result); |
| 52 | + } |
| 53 | + |
| 54 | + if (!queued) { |
| 55 | + queued = []; |
| 56 | + } |
| 57 | + |
| 58 | + queued.push(() => { |
| 59 | + const [result, err] = runActionlint?.(src, path) ?? [ |
| 60 | + [], |
| 61 | + new Error('"runActionlint" is not defined'), |
| 62 | + ]; |
| 63 | + return err ? reject(err) : resolve(result); |
| 64 | + }); |
| 65 | + }); |
| 66 | + }; |
| 67 | +}; |
0 commit comments