-
Notifications
You must be signed in to change notification settings - Fork 522
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(typescript): create a better ts_project worker
- Loading branch information
Dan Muller
committed
Jan 27, 2021
1 parent
3eb4260
commit b9633de
Showing
13 changed files
with
333 additions
and
149 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -1807,7 +1807,7 @@ has-values@^1.0.0: | |
| is-number "^3.0.0" | ||
| kind-of "^4.0.0" | ||
|
|
||
| has@^1.0.1: | ||
| has@^1.0.1, has@^1.0.3: | ||
| version "1.0.3" | ||
| resolved "https://registry.yarnpkg.com/has/-/has-1.0.3.tgz#722d7cbfc1f6aa8241f16dd814e011e1f41e8796" | ||
| integrity sha512-f2dvO0VU6Oej7RkWJGrehjbzMAjFp5/VKPp5tTpWIV4JHHZK1/BxbFRtf/siA2SWTe09caDmVtYYzWEIbBS4zw== | ||
|
|
@@ -2109,6 +2109,13 @@ is-buffer@^1.1.5: | |
| resolved "https://registry.yarnpkg.com/is-buffer/-/is-buffer-1.1.6.tgz#efaa2ea9daa0d7ab2ea13a97b2b8ad51fefbe8be" | ||
| integrity sha512-NcdALwpXkTm5Zvvbk7owOUSvVvBKDgKP5/ewfXEznmQFfs4ZRmanOeKBTjRVjka3QFoN6XJ+9F3USqfHqTaU5w== | ||
|
|
||
| is-core-module@^2.1.0: | ||
| version "2.2.0" | ||
| resolved "https://registry.yarnpkg.com/is-core-module/-/is-core-module-2.2.0.tgz#97037ef3d52224d85163f5597b2b63d9afed981a" | ||
| integrity sha512-XRAfAdyyY5F5cOXn7hYQDqh2Xmii+DEfIcQGxK/uNwMHhIkPWO0g8msXcbzLe+MpGoR951MlqM/2iIlU4vKDdQ== | ||
| dependencies: | ||
| has "^1.0.3" | ||
|
|
||
| is-data-descriptor@^0.1.4: | ||
| version "0.1.4" | ||
| resolved "https://registry.yarnpkg.com/is-data-descriptor/-/is-data-descriptor-0.1.4.tgz#0b5ee648388e2c860282e793f1856fec3f301b56" | ||
|
|
@@ -3032,6 +3039,11 @@ path-key@^2.0.0, path-key@^2.0.1: | |
| resolved "https://registry.yarnpkg.com/path-key/-/path-key-2.0.1.tgz#411cadb574c5a140d3a4b1910d40d80cc9f40b40" | ||
| integrity sha1-QRyttXTFoUDTpLGRDUDYDMn0C0A= | ||
|
|
||
| path-parse@^1.0.6: | ||
| version "1.0.6" | ||
| resolved "https://registry.yarnpkg.com/path-parse/-/path-parse-1.0.6.tgz#d62dbb5679405d72c4737ec58600e9ddcf06d24c" | ||
| integrity sha512-GSmOT2EbHrINBf9SR7CDELwlJ8AENk3Qn7OikK4nFYAu3Ote2+JYNVvkpAEQm3/TLNEJFD/xZJjzyxg3KBWOzw== | ||
|
|
||
| [email protected]: | ||
| version "0.1.7" | ||
| resolved "https://registry.yarnpkg.com/path-to-regexp/-/path-to-regexp-0.1.7.tgz#df604178005f522f15eb4490e7247a1bfaa67f8c" | ||
|
|
@@ -3462,6 +3474,14 @@ resolve-url@^0.2.1: | |
| resolved "https://registry.yarnpkg.com/resolve-url/-/resolve-url-0.2.1.tgz#2c637fe77c893afd2a663fe21aa9080068e2052a" | ||
| integrity sha1-LGN/53yJOv0qZj/iGqkIAGjiBSo= | ||
|
|
||
| resolve@>=1.9.0: | ||
| version "1.19.0" | ||
| resolved "https://registry.yarnpkg.com/resolve/-/resolve-1.19.0.tgz#1af5bf630409734a067cae29318aac7fa29a267c" | ||
| integrity sha512-rArEXAgsBG4UgRGcynxWIWKFvh/XZCcS8UJdHhwy91zwAvCZIbcs+vAbflgBnNjYMs/i/i+/Ux6IZhML1yPvxg== | ||
| dependencies: | ||
| is-core-module "^2.1.0" | ||
| path-parse "^1.0.6" | ||
|
|
||
| ret@~0.1.10: | ||
| version "0.1.15" | ||
| resolved "https://registry.yarnpkg.com/ret/-/ret-0.1.15.tgz#b8a4825d5bdb1fc3f6f53c2bc33f81388681c7bc" | ||
|
|
@@ -4080,6 +4100,13 @@ [email protected]: | |
| resolved "https://registry.yarnpkg.com/tty-browserify/-/tty-browserify-0.0.0.tgz#a157ba402da24e9bf957f9aa69d524eed42901a6" | ||
| integrity sha1-oVe6QC2iTpv5V/mqadUk7tQpAaY= | ||
|
|
||
| ttypescript@^1.5.12: | ||
| version "1.5.12" | ||
| resolved "https://registry.yarnpkg.com/ttypescript/-/ttypescript-1.5.12.tgz#27a8356d7d4e719d0075a8feb4df14b52384f044" | ||
| integrity sha512-1ojRyJvpnmgN9kIHmUnQPlEV1gq+VVsxVYjk/NfvMlHSmYxjK5hEvOOU2MQASrbekTUiUM7pR/nXeCc8bzvMOQ== | ||
| dependencies: | ||
| resolve ">=1.9.0" | ||
|
|
||
| type-is@~1.6.17, type-is@~1.6.18: | ||
| version "1.6.18" | ||
| resolved "https://registry.yarnpkg.com/type-is/-/type-is-1.6.18.tgz#4e552cd05df09467dcbc4ef739de89f2cf37c131" | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,95 @@ | ||
| /* THIS FILE GENERATED FROM .ts; see BUILD.bazel */ /* clang-format off */"use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| const fs = require("fs"); | ||
| const ts = require("typescript"); | ||
| const MNEMONIC = "TsProject"; | ||
| const worker = require("./worker"); | ||
| let createWatchCompilerHost; | ||
| const formatHost = { | ||
| getCanonicalFileName: (path) => path, | ||
| getCurrentDirectory: ts.sys.getCurrentDirectory, | ||
| getNewLine: () => ts.sys.newLine, | ||
| }; | ||
| const reportDiagnostic = (diagnostic) => { | ||
| worker.log(ts.formatDiagnostic(diagnostic, formatHost)); | ||
| }; | ||
| const reportWatchStatusChanged = (diagnostic) => { | ||
| worker.debug(ts.formatDiagnostic(diagnostic, formatHost)); | ||
| }; | ||
| function createWatchProgram(options, tsconfigPath, setTimeout) { | ||
| const host = createWatchCompilerHost(tsconfigPath, options, Object.assign(Object.assign({}, ts.sys), { setTimeout }), ts.createEmitAndSemanticDiagnosticsBuilderProgram, reportDiagnostic, reportWatchStatusChanged); | ||
| return ts.createWatchProgram(host); | ||
| } | ||
| let workerRequestTimestamp; | ||
| let cachedWatchedProgram; | ||
| let consolidateChangesCallback; | ||
| let cachedWatchProgramArgs; | ||
| function getWatchProgram(args) { | ||
| const newWatchArgs = args.join(" "); | ||
| if (cachedWatchedProgram && | ||
| cachedWatchProgramArgs && | ||
| cachedWatchProgramArgs !== newWatchArgs) { | ||
| cachedWatchedProgram.close(); | ||
| cachedWatchedProgram = undefined; | ||
| cachedWatchProgramArgs = undefined; | ||
| } | ||
| if (!cachedWatchedProgram) { | ||
| const parsedArgs = ts.parseCommandLine(args); | ||
| const tsconfigPath = args[args.indexOf("--project") + 1]; | ||
| cachedWatchProgramArgs = newWatchArgs; | ||
| cachedWatchedProgram = createWatchProgram(parsedArgs.options, tsconfigPath, (callback) => { | ||
| consolidateChangesCallback = callback; | ||
| }); | ||
| } | ||
| return cachedWatchedProgram; | ||
| } | ||
| function emitOnce(args) { | ||
| const watchProgram = getWatchProgram(args); | ||
| if (consolidateChangesCallback) { | ||
| consolidateChangesCallback(); | ||
| } | ||
| return new Promise((res) => { | ||
| var _a; | ||
| workerRequestTimestamp = Date.now(); | ||
| const result = (_a = watchProgram) === null || _a === void 0 ? void 0 : _a.getProgram().emit(undefined, undefined, { | ||
| isCancellationRequested: function (timestamp) { | ||
| return timestamp !== workerRequestTimestamp; | ||
| }.bind(null, workerRequestTimestamp), | ||
| throwIfCancellationRequested: function (timestamp) { | ||
| if (timestamp !== workerRequestTimestamp) { | ||
| throw new ts.OperationCanceledException(); | ||
| } | ||
| }.bind(null, workerRequestTimestamp), | ||
| }); | ||
| res(result && result.diagnostics.length === 0); | ||
| }); | ||
| } | ||
| function main() { | ||
| const typescriptRequirePath = process.argv[process.argv.indexOf('--typescript_require_path') + 1]; | ||
| try { | ||
| const customTypescriptModule = require(typescriptRequirePath); | ||
| createWatchCompilerHost = customTypescriptModule.createWatchCompilerHost; | ||
| } | ||
| catch (e) { | ||
| worker.log(`typescript_require_path '${typescriptRequirePath}' could not be resolved`); | ||
| throw e; | ||
| } | ||
| if (process.argv.includes("--persistent_worker")) { | ||
| worker.log(`Running ${MNEMONIC} as a Bazel worker`); | ||
| worker.runWorkerLoop(emitOnce); | ||
| } | ||
| else { | ||
| worker.log(`Running ${MNEMONIC} as a standalone process`); | ||
| worker.log(`Started a new process to perform this action. Your build might be misconfigured, try | ||
| --strategy=${MNEMONIC}=worker`); | ||
| let argsFilePath = process.argv.pop(); | ||
| if (argsFilePath.startsWith('@')) { | ||
| argsFilePath = argsFilePath.slice(1); | ||
| } | ||
| const args = fs.readFileSync(argsFilePath).toString().split('\n'); | ||
| emitOnce(args).finally(() => { var _a; return (_a = cachedWatchedProgram) === null || _a === void 0 ? void 0 : _a.close(); }); | ||
| } | ||
| } | ||
| if (require.main === module) { | ||
| main(); | ||
| } |
Oops, something went wrong.