nx-cloud - npm Package Compare versions

Comparing version 16.0.3 to 16.0.4

lib/core/api/error-reporter.api.js

@@ -1,1 +0,1 @@
-const a0_0x5350=['value','Unable\x20to\x20record\x20the\x20following\x20error:\x20\x27','next','apiAxiosInstance','throw','__awaiter','ErrorReporterApi','__esModule','done','axiosMultipleTries','then','apply'];(function(_0x32647c,_0x53505e){const _0x1bf648=function(_0x19453d){while(--_0x19453d){_0x32647c['push'](_0x32647c['shift']());}};_0x1bf648(++_0x53505e);}(a0_0x5350,0x137));const a0_0x1bf6=function(_0x32647c,_0x53505e){_0x32647c=_0x32647c-0x0;let _0x1bf648=a0_0x5350[_0x32647c];return _0x1bf648;};'use strict';var __awaiter=this&&this[a0_0x1bf6('0x6')]||function(_0x4f4b84,_0x3cce52,_0x13a841,_0x5acf9b){function _0x401538(_0x1834de){return _0x1834de instanceof _0x13a841?_0x1834de:new _0x13a841(function(_0x4305c3){_0x4305c3(_0x1834de);});}return new(_0x13a841||(_0x13a841=Promise))(function(_0x42a5f2,_0x401a33){function _0x3b6c48(_0x31ce17){try{_0x59894d(_0x5acf9b['next'](_0x31ce17));}catch(_0x461963){_0x401a33(_0x461963);}}function _0xfd991d(_0x1acdf6){try{_0x59894d(_0x5acf9b[a0_0x1bf6('0x5')](_0x1acdf6));}catch(_0x4809c2){_0x401a33(_0x4809c2);}}function _0x59894d(_0x8e6f9){_0x8e6f9[a0_0x1bf6('0x9')]?_0x42a5f2(_0x8e6f9[a0_0x1bf6('0x1')]):_0x401538(_0x8e6f9[a0_0x1bf6('0x1')])[a0_0x1bf6('0xb')](_0x3b6c48,_0xfd991d);}_0x59894d((_0x5acf9b=_0x5acf9b[a0_0x1bf6('0x0')](_0x4f4b84,_0x3cce52||[]))[a0_0x1bf6('0x3')]());});};Object['defineProperty'](exports,a0_0x1bf6('0x8'),{'value':!![]});exports[a0_0x1bf6('0x7')]=void 0x0;const axios_1=require('../../utilities/axios');const {output}=require('../../utilities/nx-imports');class ErrorReporterApi{constructor(_0x557d1b){this[a0_0x1bf6('0x4')]=(0x0,axios_1['createApiAxiosInstance'])(_0x557d1b);}['reportError'](_0x2fed64){return __awaiter(this,void 0x0,void 0x0,function*(){try{yield(0x0,axios_1[a0_0x1bf6('0xa')])(()=>this[a0_0x1bf6('0x4')]['post']('/nx-cloud/report-client-error',{'message':_0x2fed64}));}catch(_0x58d2a2){output['warn']({'title':a0_0x1bf6('0x2')+_0x2fed64+'\x27','bodyLines':[_0x58d2a2['message']]});}});}}exports[a0_0x1bf6('0x7')]=ErrorReporterApi;
+const a0_0x5f3e=['/nx-cloud/report-client-error','__awaiter','message','apiAxiosInstance','../../utilities/nx-imports','next','then','done','apply','throw','post','createApiAxiosInstance','defineProperty','ErrorReporterApi','../../utilities/axios','warn','value','__esModule'];(function(_0x4e01cc,_0x5f3e4b){const _0x168513=function(_0x298559){while(--_0x298559){_0x4e01cc['push'](_0x4e01cc['shift']());}};_0x168513(++_0x5f3e4b);}(a0_0x5f3e,0x1ab));const a0_0x1685=function(_0x4e01cc,_0x5f3e4b){_0x4e01cc=_0x4e01cc-0x0;let _0x168513=a0_0x5f3e[_0x4e01cc];return _0x168513;};'use strict';var __awaiter=this&&this[a0_0x1685('0x6')]||function(_0x25fa6c,_0x4ccec4,_0x54323f,_0x5729ec){function _0x3d4033(_0x3515b6){return _0x3515b6 instanceof _0x54323f?_0x3515b6:new _0x54323f(function(_0x3ef79f){_0x3ef79f(_0x3515b6);});}return new(_0x54323f||(_0x54323f=Promise))(function(_0x5945e2,_0x2f6fe8){function _0x4326d4(_0xe09826){try{_0x373177(_0x5729ec[a0_0x1685('0xa')](_0xe09826));}catch(_0x1f026b){_0x2f6fe8(_0x1f026b);}}function _0x1a8a8f(_0x5487ba){try{_0x373177(_0x5729ec[a0_0x1685('0xe')](_0x5487ba));}catch(_0x3a4d27){_0x2f6fe8(_0x3a4d27);}}function _0x373177(_0x283378){_0x283378[a0_0x1685('0xc')]?_0x5945e2(_0x283378[a0_0x1685('0x3')]):_0x3d4033(_0x283378['value'])[a0_0x1685('0xb')](_0x4326d4,_0x1a8a8f);}_0x373177((_0x5729ec=_0x5729ec[a0_0x1685('0xd')](_0x25fa6c,_0x4ccec4||[]))[a0_0x1685('0xa')]());});};Object[a0_0x1685('0x11')](exports,a0_0x1685('0x4'),{'value':!![]});exports['ErrorReporterApi']=void 0x0;const axios_1=require(a0_0x1685('0x1'));const {output}=require(a0_0x1685('0x9'));class ErrorReporterApi{constructor(_0x242381){this[a0_0x1685('0x8')]=(0x0,axios_1[a0_0x1685('0x10')])(_0x242381);}['reportError'](_0x185691){return __awaiter(this,void 0x0,void 0x0,function*(){try{yield(0x0,axios_1['axiosMultipleTries'])(()=>this['apiAxiosInstance'][a0_0x1685('0xf')](a0_0x1685('0x5'),{'message':_0x185691}));}catch(_0x51422d){output[a0_0x1685('0x2')]({'title':'Unable\x20to\x20record\x20the\x20following\x20error:\x20\x27'+_0x185691+'\x27','bodyLines':[_0x51422d[a0_0x1685('0x7')]]});}});}}exports[a0_0x1685('0x0')]=ErrorReporterApi;

lib/core/api/run-group.api.js

@@ -1,1 +0,1 @@
-const a1_0x3cc4=['createRunGroup','createApiAxiosInstance','value','mapRespToPerfEntry','RunGroupApi','../../utilities/nx-imports','../../utilities/axios','exit','defineProperty','apiAxiosInstance','error','message','../../utilities/metric-logger','axiosException','throw','axiosMultipleTries','/nx-cloud/executions/create-run-group','completeRunGroup','post','then','response','apply','recordMetric','RUNNER_FAILURE_PERF_ENTRY','createMetricRecorder','__esModule'];(function(_0x2a53e7,_0x3cc48e){const _0x19d2ec=function(_0x5dbd52){while(--_0x5dbd52){_0x2a53e7['push'](_0x2a53e7['shift']());}};_0x19d2ec(++_0x3cc48e);}(a1_0x3cc4,0x115));const a1_0x19d2=function(_0x2a53e7,_0x3cc48e){_0x2a53e7=_0x2a53e7-0x0;let _0x19d2ec=a1_0x3cc4[_0x2a53e7];return _0x19d2ec;};'use strict';var __awaiter=this&&this['__awaiter']||function(_0x4369c5,_0x43679f,_0x2d9bdb,_0x44cf8c){function _0x2a64ab(_0x216240){return _0x216240 instanceof _0x2d9bdb?_0x216240:new _0x2d9bdb(function(_0xb478f6){_0xb478f6(_0x216240);});}return new(_0x2d9bdb||(_0x2d9bdb=Promise))(function(_0x471c03,_0x3748bd){function _0x1df7d4(_0x28aecf){try{_0x52a679(_0x44cf8c['next'](_0x28aecf));}catch(_0x17df07){_0x3748bd(_0x17df07);}}function _0x613f45(_0x398777){try{_0x52a679(_0x44cf8c[a1_0x19d2('0x17')](_0x398777));}catch(_0x4e3b24){_0x3748bd(_0x4e3b24);}}function _0x52a679(_0x264422){_0x264422['done']?_0x471c03(_0x264422[a1_0x19d2('0xb')]):_0x2a64ab(_0x264422[a1_0x19d2('0xb')])[a1_0x19d2('0x2')](_0x1df7d4,_0x613f45);}_0x52a679((_0x44cf8c=_0x44cf8c[a1_0x19d2('0x4')](_0x4369c5,_0x43679f||[]))['next']());});};Object[a1_0x19d2('0x11')](exports,a1_0x19d2('0x8'),{'value':!![]});exports[a1_0x19d2('0xd')]=void 0x0;const axios_1=require(a1_0x19d2('0xf'));const metric_logger_1=require(a1_0x19d2('0x15'));const {output}=require(a1_0x19d2('0xe'));class RunGroupApi{constructor(_0x2385b6){this[a1_0x19d2('0x12')]=(0x0,axios_1[a1_0x19d2('0xa')])(_0x2385b6);}['createRunGroup'](_0x4e511a,_0x1206a0,_0x3514f4,_0x2d8922,_0x5a4d78,_0x22e511,_0x3a3b1b){var _0x3871b1;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x551d41=(0x0,metric_logger_1[a1_0x19d2('0x7')])(a1_0x19d2('0x9'));try{const _0x272ab0=yield(0x0,axios_1[a1_0x19d2('0x18')])(()=>this['apiAxiosInstance'][a1_0x19d2('0x1')](a1_0x19d2('0x19'),{'branch':_0x4e511a,'runGroup':_0x1206a0,'ciExecutionId':_0x3514f4,'ciExecutionEnv':_0x2d8922,'stopAgentsOnFailure':_0x5a4d78,'agentCount':_0x22e511,'stopAgentsAfter':_0x3a3b1b}));_0x551d41[a1_0x19d2('0x5')]((0x0,metric_logger_1['mapRespToPerfEntry'])(_0x272ab0));}catch(_0x34d470){_0x551d41['recordMetric'](((_0x3871b1=_0x34d470===null||_0x34d470===void 0x0?void 0x0:_0x34d470['axiosException'])===null||_0x3871b1===void 0x0?void 0x0:_0x3871b1[a1_0x19d2('0x3')])?(0x0,metric_logger_1['mapRespToPerfEntry'])(_0x34d470[a1_0x19d2('0x16')][a1_0x19d2('0x3')]):metric_logger_1[a1_0x19d2('0x6')]);output['error']({'title':_0x34d470[a1_0x19d2('0x14')]});process['exit'](0x1);}});}['completeRunGroup'](_0x42db8f,_0x46f02e,_0x5221e3,_0x4322db){var _0x2061fa;return __awaiter(this,void 0x0,void 0x0,function*(){const _0xbd2e8f=(0x0,metric_logger_1[a1_0x19d2('0x7')])(a1_0x19d2('0x0'));try{const _0x32bc46=yield(0x0,axios_1[a1_0x19d2('0x18')])(()=>this[a1_0x19d2('0x12')][a1_0x19d2('0x1')]('/nx-cloud/executions/complete-run-group',{'branch':_0x42db8f,'runGroup':_0x46f02e,'ciExecutionId':_0x5221e3,'ciExecutionEnv':_0x4322db}));_0xbd2e8f[a1_0x19d2('0x5')]((0x0,metric_logger_1[a1_0x19d2('0xc')])(_0x32bc46));}catch(_0x549c92){_0xbd2e8f[a1_0x19d2('0x5')](((_0x2061fa=_0x549c92===null||_0x549c92===void 0x0?void 0x0:_0x549c92[a1_0x19d2('0x16')])===null||_0x2061fa===void 0x0?void 0x0:_0x2061fa[a1_0x19d2('0x3')])?(0x0,metric_logger_1[a1_0x19d2('0xc')])(_0x549c92[a1_0x19d2('0x16')][a1_0x19d2('0x3')]):metric_logger_1[a1_0x19d2('0x6')]);output[a1_0x19d2('0x13')]({'title':_0x549c92[a1_0x19d2('0x14')]});process[a1_0x19d2('0x10')](0x1);}});}}exports[a1_0x19d2('0xd')]=RunGroupApi;
+const a1_0x43d9=['../../utilities/nx-imports','exit','__esModule','next','createRunGroup','RunGroupApi','mapRespToPerfEntry','throw','response','post','../../utilities/metric-logger','recordMetric','../../utilities/axios','error','axiosException','createMetricRecorder','done','/nx-cloud/executions/create-run-group','RUNNER_FAILURE_PERF_ENTRY','then','completeRunGroup','value','message','__awaiter','apply','apiAxiosInstance'];(function(_0x54c179,_0x43d99d){const _0x1de676=function(_0x356ea1){while(--_0x356ea1){_0x54c179['push'](_0x54c179['shift']());}};_0x1de676(++_0x43d99d);}(a1_0x43d9,0x1c8));const a1_0x1de6=function(_0x54c179,_0x43d99d){_0x54c179=_0x54c179-0x0;let _0x1de676=a1_0x43d9[_0x54c179];return _0x1de676;};'use strict';var __awaiter=this&&this[a1_0x1de6('0x9')]||function(_0x1a7c1d,_0x418852,_0x5a4970,_0x391f51){function _0xc8f896(_0x453c87){return _0x453c87 instanceof _0x5a4970?_0x453c87:new _0x5a4970(function(_0x23ff24){_0x23ff24(_0x453c87);});}return new(_0x5a4970||(_0x5a4970=Promise))(function(_0x2225e1,_0x5178da){function _0x59e2d5(_0x434de0){try{_0x3adb64(_0x391f51[a1_0x1de6('0xf')](_0x434de0));}catch(_0x277263){_0x5178da(_0x277263);}}function _0x38b07a(_0x98bb23){try{_0x3adb64(_0x391f51[a1_0x1de6('0x13')](_0x98bb23));}catch(_0x586938){_0x5178da(_0x586938);}}function _0x3adb64(_0x2d82f9){_0x2d82f9[a1_0x1de6('0x2')]?_0x2225e1(_0x2d82f9[a1_0x1de6('0x7')]):_0xc8f896(_0x2d82f9[a1_0x1de6('0x7')])[a1_0x1de6('0x5')](_0x59e2d5,_0x38b07a);}_0x3adb64((_0x391f51=_0x391f51[a1_0x1de6('0xa')](_0x1a7c1d,_0x418852||[]))[a1_0x1de6('0xf')]());});};Object['defineProperty'](exports,a1_0x1de6('0xe'),{'value':!![]});exports['RunGroupApi']=void 0x0;const axios_1=require(a1_0x1de6('0x18'));const metric_logger_1=require(a1_0x1de6('0x16'));const {output}=require(a1_0x1de6('0xc'));class RunGroupApi{constructor(_0x8ffc9){this['apiAxiosInstance']=(0x0,axios_1['createApiAxiosInstance'])(_0x8ffc9);}['createRunGroup'](_0x2fd648,_0x1576cc,_0x22e808,_0x102bfa,_0x1f95e0,_0x359993,_0x23819e){var _0x16d822;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x49bc6e=(0x0,metric_logger_1[a1_0x1de6('0x1')])(a1_0x1de6('0x10'));try{const _0x5417c6=yield(0x0,axios_1['axiosMultipleTries'])(()=>this[a1_0x1de6('0xb')][a1_0x1de6('0x15')](a1_0x1de6('0x3'),{'branch':_0x2fd648,'runGroup':_0x1576cc,'ciExecutionId':_0x22e808,'ciExecutionEnv':_0x102bfa,'stopAgentsOnFailure':_0x1f95e0,'agentCount':_0x359993,'stopAgentsAfter':_0x23819e}));_0x49bc6e[a1_0x1de6('0x17')]((0x0,metric_logger_1[a1_0x1de6('0x12')])(_0x5417c6));}catch(_0x468427){_0x49bc6e[a1_0x1de6('0x17')](((_0x16d822=_0x468427===null||_0x468427===void 0x0?void 0x0:_0x468427['axiosException'])===null||_0x16d822===void 0x0?void 0x0:_0x16d822[a1_0x1de6('0x14')])?(0x0,metric_logger_1['mapRespToPerfEntry'])(_0x468427[a1_0x1de6('0x0')][a1_0x1de6('0x14')]):metric_logger_1[a1_0x1de6('0x4')]);output[a1_0x1de6('0x19')]({'title':_0x468427[a1_0x1de6('0x8')]});process[a1_0x1de6('0xd')](0x1);}});}['completeRunGroup'](_0x47ee0a,_0x13ec39,_0x2acf87,_0x24ec7e){var _0xc0fda9;return __awaiter(this,void 0x0,void 0x0,function*(){const _0xb18f88=(0x0,metric_logger_1['createMetricRecorder'])(a1_0x1de6('0x6'));try{const _0x6935cb=yield(0x0,axios_1['axiosMultipleTries'])(()=>this[a1_0x1de6('0xb')][a1_0x1de6('0x15')]('/nx-cloud/executions/complete-run-group',{'branch':_0x47ee0a,'runGroup':_0x13ec39,'ciExecutionId':_0x2acf87,'ciExecutionEnv':_0x24ec7e}));_0xb18f88[a1_0x1de6('0x17')]((0x0,metric_logger_1[a1_0x1de6('0x12')])(_0x6935cb));}catch(_0x1fde73){_0xb18f88['recordMetric'](((_0xc0fda9=_0x1fde73===null||_0x1fde73===void 0x0?void 0x0:_0x1fde73['axiosException'])===null||_0xc0fda9===void 0x0?void 0x0:_0xc0fda9[a1_0x1de6('0x14')])?(0x0,metric_logger_1[a1_0x1de6('0x12')])(_0x1fde73[a1_0x1de6('0x0')]['response']):metric_logger_1['RUNNER_FAILURE_PERF_ENTRY']);output[a1_0x1de6('0x19')]({'title':_0x1fde73['message']});process[a1_0x1de6('0xd')](0x1);}});}}exports[a1_0x1de6('0x11')]=RunGroupApi;

lib/core/commands/upload-and-show-run-details.js

@@ -24,2 +24,3 @@ "use strict";
 const remove_trailing_slash_1 = require("../../utilities/remove-trailing-slash");
+const print_cloud_connection_disabled_message_1 = require("../../utilities/print-cloud-connection-disabled-message");
 const { workspaceRoot, output, cacheDirectory, } = require('../../utilities/nx-imports');
@@ -48,3 +49,8 @@ function uploadRunDetails(options) {
     return __awaiter(this, void 0, void 0, function* () {
-        const options = readOptions();
+        const nxJson = readNxJson();
+        if (nxJson.neverConnectToCloud) {
+            (0, print_cloud_connection_disabled_message_1.printCloudConnectionDisabledMessage)();
+            process.exit(1);
+        }
+        const options = readOptions(nxJson);
         const url = yield uploadRunDetails(options);
@@ -59,6 +65,5 @@ output.success({
 exports.uploadAndShowRunDetails = uploadAndShowRunDetails;
-function readOptions() {
-    var _a, _b, _c;
+function readNxJson() {
     try {
-        return (_c = (_b = (_a = JSON.parse(stripJsonComments((0, fs_1.readFileSync)((0, path_1.join)(workspaceRoot, 'nx.json')).toString()))) === null || _a === void 0 ? void 0 : _a.tasksRunnerOptions) === null || _b === void 0 ? void 0 : _b.default) === null || _c === void 0 ? void 0 : _c.options;
+        return JSON.parse(stripJsonComments((0, fs_1.readFileSync)((0, path_1.join)(workspaceRoot, 'nx.json')).toString()));
     }
@@ -69,2 +74,6 @@ catch (e) {
 }
+function readOptions(nxJson) {
+    var _a, _b;
+    return (_b = (_a = nxJson === null || nxJson === void 0 ? void 0 : nxJson.tasksRunnerOptions) === null || _a === void 0 ? void 0 : _a.default) === null || _b === void 0 ? void 0 : _b.options;
+}
 //# sourceMappingURL=upload-and-show-run-details.js.map

lib/core/runners/cloud-enabled/cloud-enabled-life-cycle.js

@@ -1,1 +0,1 @@
-const a0_0x2f6b=['Cannot\x20find\x20task\x20','readTaskTerminalOutput','target','taskId','local-cache','terminalOutput','scheduleTask','cacheDirectory','toISOString','CloudEnabledLifeCycle','tasks','push','remote-cache','__esModule','statuses','local-cache-hit','obfuscate','task','updateStartedTask','find','remote-cache-hit','endCommand','serializeOverrides','keys','project','cacheStatus','endTime','startsWith','startTask','local-cache-kept-existing','hashDetails','runtime','cache','cache-miss','outputObfuscator','status','code','runContext','cleanUpHashDetails','filter','scheduledTasks','nodes','endTasks','forEach','params','cacheableOperations','startTime','getTerminalOutput','hash','defineProperty'];(function(_0x44f6ae,_0x2f6b2d){const _0x151090=function(_0x1cfcf3){while(--_0x1cfcf3){_0x44f6ae['push'](_0x44f6ae['shift']());}};_0x151090(++_0x2f6b2d);}(a0_0x2f6b,0x185));const a0_0x1510=function(_0x44f6ae,_0x2f6b2d){_0x44f6ae=_0x44f6ae-0x0;let _0x151090=a0_0x2f6b[_0x44f6ae];return _0x151090;};'use strict';Object[a0_0x1510('0xa')](exports,a0_0x1510('0x18'),{'value':!![]});exports[a0_0x1510('0x14')]=void 0x0;const serializer_overrides_1=require('../../../utilities/serializer-overrides');const read_task_terminal_output_1=require('../../terminal-output/read-task-terminal-output');class CloudEnabledLifeCycle{constructor(_0x33b928,_0x406215,_0x161992,_0x26f70d,_0x4abbef,_0x2663f0){this['runContext']=_0x33b928;this[a0_0x1510('0x12')]=_0x406215;this['collectTerminalOutput']=_0x161992;this[a0_0x1510('0x6')]=_0x26f70d;this['outputObfuscator']=_0x4abbef;this['tasks']=_0x2663f0;}[a0_0x1510('0x11')](_0x43154d){this[a0_0x1510('0x30')][a0_0x1510('0x1')][a0_0x1510('0x16')](_0x43154d);}[a0_0x1510('0x27')](_0xe02658){this[a0_0x1510('0x15')][a0_0x1510('0x16')]({'taskId':_0xe02658['id'],'startTime':new Date()[a0_0x1510('0x13')](),'target':_0xe02658[a0_0x1510('0xd')]['target'],'projectName':_0xe02658[a0_0x1510('0xd')][a0_0x1510('0x23')],'hash':_0xe02658[a0_0x1510('0x9')],'hashDetails':this[a0_0x1510('0x31')](_0xe02658[a0_0x1510('0x29')]),'params':(0x0,serializer_overrides_1[a0_0x1510('0x21')])(_0xe02658),'uploadedToStorage':![]});}[a0_0x1510('0x3')](_0x580c71){for(let _0x24641a of _0x580c71){let _0x2c804b;const _0x4a95de=_0x24641a['status']===a0_0x1510('0x17');const _0x4cd3f2=_0x24641a[a0_0x1510('0x2e')]===a0_0x1510('0x2b');const _0xd766af=_0x24641a[a0_0x1510('0x2e')]===a0_0x1510('0xf')||_0x24641a[a0_0x1510('0x2e')]===a0_0x1510('0x28')||_0x4cd3f2;if(this['runContext']['statuses'][_0x24641a[a0_0x1510('0x1c')][a0_0x1510('0x9')]]){_0x2c804b=this['runContext'][a0_0x1510('0x19')][_0x24641a[a0_0x1510('0x1c')][a0_0x1510('0x9')]];}else if(_0x4a95de){_0x2c804b=a0_0x1510('0x1f');}else if(_0xd766af){_0x2c804b=a0_0x1510('0x1a');}else{_0x2c804b=a0_0x1510('0x2c');}this[a0_0x1510('0x1d')](_0x24641a,_0x2c804b);}}[a0_0x1510('0x20')](){}[a0_0x1510('0x1d')](_0x42091e,_0x30b521){const _0x10077a=this[a0_0x1510('0x15')][a0_0x1510('0x1e')](_0x1b68d2=>_0x1b68d2[a0_0x1510('0xe')]===_0x42091e['task']['id']);if(!_0x10077a){throw new Error(a0_0x1510('0xb')+_0x42091e['task']['id']);}if((_0x42091e===null||_0x42091e===void 0x0?void 0x0:_0x42091e['startTime'])&&(_0x42091e===null||_0x42091e===void 0x0?void 0x0:_0x42091e[a0_0x1510('0x25')])){_0x10077a[a0_0x1510('0x7')]=new Date(_0x42091e['startTime'])['toISOString']();_0x10077a[a0_0x1510('0x25')]=new Date(_0x42091e[a0_0x1510('0x25')])[a0_0x1510('0x13')]();}else{_0x10077a['endTime']=new Date()[a0_0x1510('0x13')]();}_0x10077a[a0_0x1510('0x2e')]=_0x42091e[a0_0x1510('0x2f')];_0x10077a[a0_0x1510('0x5')]=this[a0_0x1510('0x2d')][a0_0x1510('0x1b')](_0x10077a[a0_0x1510('0x5')]);_0x10077a[a0_0x1510('0x24')]=_0x30b521;if(this['collectTerminalOutput']){_0x10077a[a0_0x1510('0x10')]=this['getTerminalOutput'](_0x42091e[a0_0x1510('0x1c')][a0_0x1510('0x9')],_0x10077a[a0_0x1510('0x24')],_0x42091e[a0_0x1510('0x2f')]);}}[a0_0x1510('0x8')](_0x530023,_0x38b1fc,_0x1b0e56){return(0x0,read_task_terminal_output_1[a0_0x1510('0xc')])(this[a0_0x1510('0x12')],this['outputObfuscator'],_0x530023,_0x38b1fc,_0x1b0e56);}[a0_0x1510('0x31')](_0x51b8c9){const _0x32e538={};Object[a0_0x1510('0x22')](_0x51b8c9[a0_0x1510('0x2')])[a0_0x1510('0x0')](_0x241b7d=>!_0x241b7d[a0_0x1510('0x26')]('npm:'))[a0_0x1510('0x4')](_0x13bea6=>{_0x32e538[_0x13bea6]=_0x51b8c9[a0_0x1510('0x2')][_0x13bea6];});return{'nodes':_0x32e538,'runtime':_0x51b8c9[a0_0x1510('0x2a')],'implicitDeps':_0x51b8c9['implicitDeps']};}}exports[a0_0x1510('0x14')]=CloudEnabledLifeCycle;
+const a0_0x20e2=['cacheDirectory','../../../utilities/serializer-overrides','runtime','statuses','filter','collectTerminalOutput','keys','cacheStatus','readTaskTerminalOutput','scheduleTask','target','local-cache-kept-existing','updateStartedTask','hash','task','tasks','obfuscate','startsWith','endTime','CloudEnabledLifeCycle','find','scheduledTasks','status','../../terminal-output/read-task-terminal-output','implicitDeps','project','remote-cache','outputObfuscator','taskId','hashDetails','nodes','local-cache','endCommand','terminalOutput','push','runContext','toISOString','getTerminalOutput','params','code','startTime','forEach','defineProperty','serializeOverrides'];(function(_0x8ee36b,_0x20e241){const _0x2b3df9=function(_0x158a16){while(--_0x158a16){_0x8ee36b['push'](_0x8ee36b['shift']());}};_0x2b3df9(++_0x20e241);}(a0_0x20e2,0x89));const a0_0x2b3d=function(_0x8ee36b,_0x20e241){_0x8ee36b=_0x8ee36b-0x0;let _0x2b3df9=a0_0x20e2[_0x8ee36b];return _0x2b3df9;};'use strict';Object[a0_0x2b3d('0x25')](exports,'__esModule',{'value':!![]});exports[a0_0x2b3d('0xe')]=void 0x0;const serializer_overrides_1=require(a0_0x2b3d('0x28'));const read_task_terminal_output_1=require(a0_0x2b3d('0x12'));class CloudEnabledLifeCycle{constructor(_0x72ba49,_0x150802,_0x58afa7,_0x2b69bd,_0x25ddce,_0x17307a){this[a0_0x2b3d('0x1e')]=_0x72ba49;this['cacheDirectory']=_0x150802;this[a0_0x2b3d('0x0')]=_0x58afa7;this['cacheableOperations']=_0x2b69bd;this[a0_0x2b3d('0x16')]=_0x25ddce;this[a0_0x2b3d('0xa')]=_0x17307a;}[a0_0x2b3d('0x4')](_0x5319dc){this['runContext'][a0_0x2b3d('0x10')][a0_0x2b3d('0x1d')](_0x5319dc);}['startTask'](_0x46f505){this[a0_0x2b3d('0xa')][a0_0x2b3d('0x1d')]({'taskId':_0x46f505['id'],'startTime':new Date()[a0_0x2b3d('0x1f')](),'target':_0x46f505[a0_0x2b3d('0x5')]['target'],'projectName':_0x46f505['target'][a0_0x2b3d('0x14')],'hash':_0x46f505[a0_0x2b3d('0x8')],'hashDetails':this['cleanUpHashDetails'](_0x46f505[a0_0x2b3d('0x18')]),'params':(0x0,serializer_overrides_1[a0_0x2b3d('0x26')])(_0x46f505),'uploadedToStorage':![]});}['endTasks'](_0x1a05d6){for(let _0x5209cf of _0x1a05d6){let _0x197e8e;const _0x1d2415=_0x5209cf[a0_0x2b3d('0x11')]===a0_0x2b3d('0x15');const _0x7de9a5=_0x5209cf['status']==='cache';const _0x47bf37=_0x5209cf[a0_0x2b3d('0x11')]===a0_0x2b3d('0x1a')||_0x5209cf[a0_0x2b3d('0x11')]===a0_0x2b3d('0x6')||_0x7de9a5;if(this[a0_0x2b3d('0x1e')][a0_0x2b3d('0x2a')][_0x5209cf[a0_0x2b3d('0x9')][a0_0x2b3d('0x8')]]){_0x197e8e=this[a0_0x2b3d('0x1e')][a0_0x2b3d('0x2a')][_0x5209cf['task']['hash']];}else if(_0x1d2415){_0x197e8e='remote-cache-hit';}else if(_0x47bf37){_0x197e8e='local-cache-hit';}else{_0x197e8e='cache-miss';}this[a0_0x2b3d('0x7')](_0x5209cf,_0x197e8e);}}[a0_0x2b3d('0x1b')](){}[a0_0x2b3d('0x7')](_0x5a9c2f,_0x15f4f3){const _0x2e0587=this[a0_0x2b3d('0xa')][a0_0x2b3d('0xf')](_0x3180b5=>_0x3180b5[a0_0x2b3d('0x17')]===_0x5a9c2f['task']['id']);if(!_0x2e0587){throw new Error('Cannot\x20find\x20task\x20'+_0x5a9c2f['task']['id']);}if((_0x5a9c2f===null||_0x5a9c2f===void 0x0?void 0x0:_0x5a9c2f['startTime'])&&(_0x5a9c2f===null||_0x5a9c2f===void 0x0?void 0x0:_0x5a9c2f[a0_0x2b3d('0xd')])){_0x2e0587['startTime']=new Date(_0x5a9c2f[a0_0x2b3d('0x23')])[a0_0x2b3d('0x1f')]();_0x2e0587[a0_0x2b3d('0xd')]=new Date(_0x5a9c2f[a0_0x2b3d('0xd')])[a0_0x2b3d('0x1f')]();}else{_0x2e0587['endTime']=new Date()[a0_0x2b3d('0x1f')]();}_0x2e0587['status']=_0x5a9c2f[a0_0x2b3d('0x22')];_0x2e0587[a0_0x2b3d('0x21')]=this[a0_0x2b3d('0x16')][a0_0x2b3d('0xb')](_0x2e0587['params']);_0x2e0587[a0_0x2b3d('0x2')]=_0x15f4f3;if(this[a0_0x2b3d('0x0')]){_0x2e0587[a0_0x2b3d('0x1c')]=this[a0_0x2b3d('0x20')](_0x5a9c2f[a0_0x2b3d('0x9')][a0_0x2b3d('0x8')],_0x2e0587['cacheStatus'],_0x5a9c2f['code']);}}[a0_0x2b3d('0x20')](_0x3299fc,_0x5e8270,_0x13b219){return(0x0,read_task_terminal_output_1[a0_0x2b3d('0x3')])(this[a0_0x2b3d('0x27')],this[a0_0x2b3d('0x16')],_0x3299fc,_0x5e8270,_0x13b219);}['cleanUpHashDetails'](_0x300a58){const _0x513958={};Object[a0_0x2b3d('0x1')](_0x300a58[a0_0x2b3d('0x19')])[a0_0x2b3d('0x2b')](_0x5a1af6=>!_0x5a1af6[a0_0x2b3d('0xc')]('npm:'))[a0_0x2b3d('0x24')](_0x4940b2=>{_0x513958[_0x4940b2]=_0x300a58[a0_0x2b3d('0x19')][_0x4940b2];});return{'nodes':_0x513958,'runtime':_0x300a58[a0_0x2b3d('0x29')],'implicitDeps':_0x300a58[a0_0x2b3d('0x13')]};}}exports[a0_0x2b3d('0xe')]=CloudEnabledLifeCycle;

lib/core/runners/cloud-enabled/cloud-enabled.runner.js

@@ -1,1 +0,1 @@
-const a1_0x1f26=['submitRunMetrics','startRun','printCacheHitsMessage','../../../utilities/nx-imports','OutputObfuscator','../../api/error-reporter.api','extractGitSha','parseCommand','done','getCIExecutionEnv','./id-generator','endRun','note','getCIExecutionId','cacheableOperations','complete','find','runUrl','store','delayedStoreRequests','defineProperty','url','/runs/','https://nx.app','Nx\x20Cloud\x20Problems','nx-cloud/lib/daemon/process-run-end','waitForStoreRequestsToComplete','env','CloudRunApi','tasks-hashes-','subscribe','VERBOSE_LOGGING','FileStorage','maskedProperties','taskId','Nx\x20Cloud\x20wasn\x27t\x20able\x20to\x20store\x20artifacts.','push','ErrorReporterApi','stringify','cloudEnabledTasksRunner','warn','hash','.commit','NX_CLOUD_DISTRIBUTED_EXECUTION_ID','getMachineInfo','then','cloud-enabled-runner','processInBackground','./cloud-run.api','printMessages','path','value','../../terminal-output/end-of-run-message','daemon','length','error','map','encryptionKey','getRunGroup','MessageReporter','exit','anyErrors','./cloud-remote-cache','catch','../../../utilities/metric-logger','obfuscate','forEach','pathExists','CloudRemoteCache','next','agentRunningInDistributedExecution','storedHashes','toISOString','rxjs/internal/Subject','accessToken','ENCRYPTION_KEY','lifeCycle','join','ACCESS_TOKEN','__esModule','local-cache-hit','Nx\x20Cloud\x20wasn\x27t\x20able\x20to\x20record\x20its\x20run.','generateUniqueLinkId','assign','../../terminal-output/message-reporter','DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE','enabled','E2EEncryption','EndOfRunMessage'];(function(_0x182a37,_0x1f26e1){const _0x50dbe9=function(_0x563e5d){while(--_0x563e5d){_0x182a37['push'](_0x182a37['shift']());}};_0x50dbe9(++_0x1f26e1);}(a1_0x1f26,0xc9));const a1_0x50db=function(_0x182a37,_0x1f26e1){_0x182a37=_0x182a37-0x0;let _0x50dbe9=a1_0x1f26[_0x182a37];return _0x50dbe9;};'use strict';var __awaiter=this&&this['__awaiter']||function(_0x4d9283,_0x5a5fd4,_0x8966bf,_0x450deb){function _0x3140e8(_0x33e156){return _0x33e156 instanceof _0x8966bf?_0x33e156:new _0x8966bf(function(_0x394f87){_0x394f87(_0x33e156);});}return new(_0x8966bf||(_0x8966bf=Promise))(function(_0x577ea4,_0x2104c6){function _0x54dfd3(_0x2e642d){try{_0x307e95(_0x450deb['next'](_0x2e642d));}catch(_0x26ecf6){_0x2104c6(_0x26ecf6);}}function _0x2f74bb(_0x475c20){try{_0x307e95(_0x450deb['throw'](_0x475c20));}catch(_0x7f9342){_0x2104c6(_0x7f9342);}}function _0x307e95(_0x2d02dc){_0x2d02dc[a1_0x50db('0x4a')]?_0x577ea4(_0x2d02dc[a1_0x50db('0x1c')]):_0x3140e8(_0x2d02dc[a1_0x50db('0x1c')])['then'](_0x54dfd3,_0x2f74bb);}_0x307e95((_0x450deb=_0x450deb['apply'](_0x4d9283,_0x5a5fd4||[]))['next']());});};Object[a1_0x50db('0x56')](exports,a1_0x50db('0x38'),{'value':!![]});exports[a1_0x50db('0x10')]=void 0x0;const message_reporter_1=require(a1_0x50db('0x3d'));const end_of_run_message_1=require(a1_0x50db('0x1d'));const output_obfuscator_1=require('../../terminal-output/output-obfuscator');const cloud_enabled_life_cycle_1=require('./cloud-enabled-life-cycle');const file_storage_1=require('../../file-storage/file-storage');const e2e_encryption_1=require('../../file-storage/e2e-encryption');const environment_1=require('../../../utilities/environment');const cloud_remote_cache_1=require(a1_0x50db('0x27'));const cloud_run_api_1=require(a1_0x50db('0x19'));const fs_1=require('fs');const path=require(a1_0x50db('0x1b'));const path_1=require(a1_0x50db('0x1b'));const metric_logger_1=require(a1_0x50db('0x29'));const error_reporter_api_1=require(a1_0x50db('0x47'));const fs_extra_1=require('fs-extra');const id_generator_1=require(a1_0x50db('0x4c'));const remove_trailing_slash_1=require('../../../utilities/remove-trailing-slash');const {tasksRunner,output,cacheDirectory}=require(a1_0x50db('0x45'));function createApi(_0x218e15,_0x2fa998,_0x17bd59){const _0x84d47b=(0x0,environment_1[a1_0x50db('0x15')])(_0x2fa998);return new cloud_run_api_1[(a1_0x50db('0x5'))](_0x218e15,_0x17bd59,_0x2fa998,_0x84d47b);}function storeTaskHashes(_0x50d93d,_0x3745a8,_0x43b045){const _0x499f1c=JSON[a1_0x50db('0xf')](_0x50d93d[a1_0x50db('0x21')](_0x102cd2=>({'taskId':_0x102cd2[a1_0x50db('0xb')],'hash':_0x102cd2[a1_0x50db('0x12')]})));if(environment_1[a1_0x50db('0x8')]){output[a1_0x50db('0x4e')]({'title':'Executed\x20tasks\x20with\x20hashes:\x20'+_0x499f1c});}(0x0,fs_1['writeFileSync'])(path['join'](_0x3745a8,a1_0x50db('0x6')+_0x43b045),_0x499f1c);}function storeLocalCacheHits(_0x4e3195,_0xb46204,_0x2e6ea3){const _0x992470=_0x4e3195['filter'](_0x3c6bb2=>_0x3c6bb2['cacheStatus']===a1_0x50db('0x39'))[a1_0x50db('0x21')](_0x16af0c=>_0x16af0c['hash']);_0x992470[a1_0x50db('0x2b')](_0x1bcc2f=>_0xb46204[a1_0x50db('0x54')](_0x1bcc2f,_0x2e6ea3));}function onComplete({daemon,options,fileStorage,remoteCache,api,outputObfuscator,runStartTime,messages,endOfRunMessage,taskExecutions,versionOfNxBefore133,inner,encryptionKey,storeInCurrentProcess,distributedExecutionId,runContext}){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x9d1587=new Date()[a1_0x50db('0x31')]();const _0x49eb75=(0x0,environment_1['getBranch'])();const _0x440b93={'command':outputObfuscator[a1_0x50db('0x2a')]((0x0,environment_1[a1_0x50db('0x49')])()),'startTime':runStartTime,'endTime':_0x9d1587,'distributedExecutionId':distributedExecutionId,'branch':_0x49eb75,'runGroup':(0x0,environment_1[a1_0x50db('0x23')])(),'sha':_0x49eb75?(0x0,environment_1[a1_0x50db('0x48')])():undefined,'inner':inner};const _0x35f627={'branch':_0x49eb75,'runGroup':(0x0,environment_1[a1_0x50db('0x23')])(),'ciExecutionId':(0x0,environment_1[a1_0x50db('0x4f')])(),'ciExecutionEnv':(0x0,environment_1[a1_0x50db('0x4b')])()};if(storeInCurrentProcess){if((0x0,environment_1['agentRunningInDistributedExecution'])(distributedExecutionId)){storeTaskHashes(taskExecutions,cacheDirectory,distributedExecutionId);storeLocalCacheHits(taskExecutions,remoteCache,cacheDirectory);}try{yield remoteCache[a1_0x50db('0x3')]();}catch(_0x49a333){output[a1_0x50db('0x20')]({'title':a1_0x50db('0xc')});messages[a1_0x50db('0x1a')]();return![];}for(const _0x5551e6 of fileStorage[a1_0x50db('0x30')]){const _0x479f2d=taskExecutions[a1_0x50db('0x52')](_0xa23f7e=>_0xa23f7e[a1_0x50db('0x12')]===_0x5551e6);if(!_0x479f2d){throw new Error('Task\x20with\x20hash\x20'+_0x5551e6+'\x20isn\x27t\x20recorded');}_0x479f2d['uploadedToStorage']=!![];}try{yield api[a1_0x50db('0x4d')](_0x440b93,taskExecutions,_0x35f627);}catch(_0x384d8a){output[a1_0x50db('0x20')]({'title':a1_0x50db('0x3a')});messages[a1_0x50db('0x1a')]();return![];}yield(0x0,metric_logger_1[a1_0x50db('0x42')])(options);}else{try{const _0x128dc8=environment_1[a1_0x50db('0x37')]?environment_1[a1_0x50db('0x37')]:options[a1_0x50db('0x33')];const _0x549727=(0x0,id_generator_1[a1_0x50db('0x3b')])();yield daemon[a1_0x50db('0x18')](a1_0x50db('0x2'),{'encryptionKey':encryptionKey,'runnerOptions':Object[a1_0x50db('0x3c')](Object['assign']({},options),{'accessToken':_0x128dc8}),'delayedStoreRequests':remoteCache[a1_0x50db('0x55')],'ciExecutionContext':_0x35f627,'runEnd':{'runData':_0x440b93,'taskExecutions':taskExecutions,'linkId':_0x549727}});runContext[a1_0x50db('0x53')]=(0x0,remove_trailing_slash_1['removeTrailingSlash'])(options[a1_0x50db('0x57')]||a1_0x50db('0x0'))+a1_0x50db('0x58')+_0x549727;}catch(_0x35cad6){output[a1_0x50db('0x11')]({'title':a1_0x50db('0x1'),'bodyLines':[_0x35cad6['message']||_0x35cad6['toString']()]});return![];}}if(versionOfNxBefore133){setTimeout(()=>{messages[a1_0x50db('0x1a')]();if(!messages['anyErrors']&&!inner){endOfRunMessage[a1_0x50db('0x44')]();}},0x0);}else{messages[a1_0x50db('0x1a')]();if(!messages[a1_0x50db('0x26')]&&!inner){endOfRunMessage[a1_0x50db('0x44')]();}}return!![];});}function createLifeCycle(_0x31e0d4,_0x796d01,_0x3f4ec5,_0x280243){const _0x30e961=new cloud_enabled_life_cycle_1['CloudEnabledLifeCycle'](_0x31e0d4,cacheDirectory,!![],_0x796d01[a1_0x50db('0x50')]||[],_0x3f4ec5,_0x280243);try{const {CompositeLifeCycle}=require('../../../utilities/nx-imports');if(!CompositeLifeCycle)return _0x30e961;return new CompositeLifeCycle([_0x796d01[a1_0x50db('0x35')],_0x30e961]);}catch(_0x3953e7){return _0x30e961;}}function fetchUrlsForKnownHashesUpfront(_0x567037,_0x44661a,_0x5e125c,_0x2333b5,_0x23be75){return __awaiter(this,void 0x0,void 0x0,function*(){if(_0x2333b5['skipNxCache'])return;let _0x28730e=_0x5e125c['map'](_0x25af12=>_0x25af12[a1_0x50db('0x12')])['filter'](_0x3fb5ba=>!!_0x3fb5ba);const _0x5e75da=yield Promise['all'](_0x28730e[a1_0x50db('0x21')](_0x5802bf=>{const _0x25a499=(0x0,path_1[a1_0x50db('0x36')])(cacheDirectory,_0x5802bf+a1_0x50db('0x13'));return(0x0,fs_extra_1[a1_0x50db('0x2c')])(_0x25a499);}));const _0x43d36d=[];for(let _0x53603f=0x0;_0x53603f<_0x5e75da[a1_0x50db('0x1f')];++_0x53603f){if(!_0x5e75da[_0x53603f]){_0x43d36d[a1_0x50db('0xd')](_0x28730e[_0x53603f]);}}if(_0x43d36d[a1_0x50db('0x1f')]>0x0){const _0x10d543=_0x567037[a1_0x50db('0x43')](_0x23be75,_0x43d36d);for(const _0x2f6f51 of _0x43d36d){_0x44661a['requests'][_0x2f6f51]=_0x10d543;}}});}function cloudEnabledTasksRunner(_0x3cf0a3,_0x55b100,_0x536523,_0x1282eb=![]){var _0x160fc4;const _0xc71013=process[a1_0x50db('0x4')]['NX_CLOUD_DISTRIBUTED_EXECUTION_ID'];const _0x4caca8={'statuses':{},'scheduledTasks':[],'requests':{},'allTasks':_0x3cf0a3};const _0x3e11a0=_0x55b100[a1_0x50db('0x35')]===undefined;const _0x214546=[];const _0x4bafae=new message_reporter_1[(a1_0x50db('0x24'))](_0x55b100);const _0x289cc1=createApi(_0x4bafae,_0x55b100,_0x4caca8);const _0xfe51a=new end_of_run_message_1[(a1_0x50db('0x41'))](_0x4caca8,_0x214546,_0xc71013);const _0x3c4578=new output_obfuscator_1[(a1_0x50db('0x46'))](_0x55b100[a1_0x50db('0xa')]);const _0x610666=new Date()[a1_0x50db('0x31')]();const _0x265df3=createLifeCycle(_0x4caca8,_0x55b100,_0x3c4578,_0x214546);const _0x34d9cd=environment_1[a1_0x50db('0x34')]||_0x55b100[a1_0x50db('0x22')];const _0x585439=new e2e_encryption_1[(a1_0x50db('0x40'))](_0x34d9cd);const _0x55730b=new error_reporter_api_1[(a1_0x50db('0xe'))](_0x55b100);const _0x3885b9=(0x0,environment_1[a1_0x50db('0x2f')])(_0xc71013)||!((_0x160fc4=_0x536523['daemon'])===null||_0x160fc4===void 0x0?void 0x0:_0x160fc4[a1_0x50db('0x3f')]());const _0x3c63d2=new file_storage_1[(a1_0x50db('0x9'))](_0x585439,_0x55730b,_0x55b100,a1_0x50db('0x17'));const _0x36b432=new cloud_remote_cache_1[(a1_0x50db('0x2d'))](_0x4bafae,_0x289cc1,_0x4caca8,_0x3c63d2,_0xc71013,_0x3885b9);fetchUrlsForKnownHashesUpfront(_0x289cc1,_0x4caca8,_0x3cf0a3,_0x55b100,_0xc71013);delete process[a1_0x50db('0x4')][a1_0x50db('0x14')];const _0x37be4a=tasksRunner(_0x3cf0a3,Object['assign'](Object[a1_0x50db('0x3c')]({},_0x55b100),{'remoteCache':_0x36b432,'lifeCycle':_0x265df3}),_0x536523);if(_0x37be4a[a1_0x50db('0x7')]){const {Subject}=require(a1_0x50db('0x32'));const _0xc6da43=new Subject();_0x37be4a[a1_0x50db('0x7')]({'next':_0x56502c=>_0xc6da43[a1_0x50db('0x2e')](_0x56502c),'error':_0x36cf3c=>_0xc6da43[a1_0x50db('0x20')](_0x36cf3c),'complete':()=>__awaiter(this,void 0x0,void 0x0,function*(){const _0x3ca342=yield onComplete({'daemon':_0x536523[a1_0x50db('0x1e')],'options':_0x55b100,'fileStorage':_0x3c63d2,'remoteCache':_0x36b432,'api':_0x289cc1,'outputObfuscator':_0x3c4578,'runStartTime':_0x610666,'messages':_0x4bafae,'endOfRunMessage':_0xfe51a,'taskExecutions':_0x214546,'versionOfNxBefore133':_0x3e11a0,'inner':_0x1282eb,'encryptionKey':_0x34d9cd,'storeInCurrentProcess':_0x3885b9,'runContext':_0x4caca8,'distributedExecutionId':_0xc71013});if(!_0x3ca342&&(0x0,environment_1[a1_0x50db('0x2f')])(_0xc71013)){process[a1_0x50db('0x25')](environment_1[a1_0x50db('0x3e')]);}_0xc6da43[a1_0x50db('0x51')]();})});return _0xc6da43;}else{return _0x37be4a[a1_0x50db('0x16')](_0x5433dd=>__awaiter(this,void 0x0,void 0x0,function*(){const _0x4ffdfe=yield onComplete({'daemon':_0x536523[a1_0x50db('0x1e')],'options':_0x55b100,'fileStorage':_0x3c63d2,'remoteCache':_0x36b432,'api':_0x289cc1,'outputObfuscator':_0x3c4578,'runStartTime':_0x610666,'messages':_0x4bafae,'endOfRunMessage':_0xfe51a,'taskExecutions':_0x214546,'versionOfNxBefore133':_0x3e11a0,'inner':_0x1282eb,'encryptionKey':_0x34d9cd,'storeInCurrentProcess':_0x3885b9,'runContext':_0x4caca8,'distributedExecutionId':_0xc71013});if(!_0x4ffdfe&&(0x0,environment_1['agentRunningInDistributedExecution'])(_0xc71013)){process[a1_0x50db('0x25')](environment_1[a1_0x50db('0x3e')]);}return _0x5433dd;}))[a1_0x50db('0x28')](_0x5e3b29=>__awaiter(this,void 0x0,void 0x0,function*(){const _0x2c96b7=yield onComplete({'daemon':_0x536523[a1_0x50db('0x1e')],'options':_0x55b100,'fileStorage':_0x3c63d2,'remoteCache':_0x36b432,'api':_0x289cc1,'outputObfuscator':_0x3c4578,'runStartTime':_0x610666,'messages':_0x4bafae,'endOfRunMessage':_0xfe51a,'taskExecutions':_0x214546,'versionOfNxBefore133':_0x3e11a0,'inner':_0x1282eb,'encryptionKey':_0x34d9cd,'storeInCurrentProcess':_0x3885b9,'runContext':_0x4caca8,'distributedExecutionId':_0xc71013});if(!_0x2c96b7&&(0x0,environment_1[a1_0x50db('0x2f')])(_0xc71013)){process[a1_0x50db('0x25')](environment_1[a1_0x50db('0x3e')]);}throw _0x5e3b29;}));}}exports[a1_0x50db('0x10')]=cloudEnabledTasksRunner;
+const a1_0x5bec=['Nx\x20Cloud\x20wasn\x27t\x20able\x20to\x20store\x20artifacts.','toString','Executed\x20tasks\x20with\x20hashes:\x20','length','local-cache-hit','getMachineInfo','./id-generator','getRunGroup','ACCESS_TOKEN','removeTrailingSlash','../../terminal-output/output-obfuscator','daemon','generateUniqueLinkId','OutputObfuscator','uploadedToStorage','warn','toISOString','exit','message','error','find','printMessages','__awaiter','taskId','submitRunMetrics','apply','push','MessageReporter','delayedStoreRequests','ENCRYPTION_KEY','../../../utilities/environment','Task\x20with\x20hash\x20','../../../utilities/remove-trailing-slash','../../terminal-output/end-of-run-message','printCacheHitsMessage','DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE','encryptionKey','nx-cloud/lib/daemon/process-run-end','done','anyErrors','agentRunningInDistributedExecution','VERBOSE_LOGGING','getBranch','obfuscate','requests','./cloud-remote-cache','store','../../file-storage/file-storage','E2EEncryption','FileStorage','.commit','map','next','writeFileSync','maskedProperties','NX_CLOUD_DISTRIBUTED_EXECUTION_ID','url','startRun','note','cloudEnabledTasksRunner','endRun','stringify','processInBackground','lifeCycle','../../../utilities/nx-imports','extractGitSha','cacheableOperations','defineProperty','getCIExecutionId','runUrl','CloudEnabledLifeCycle','subscribe','Nx\x20Cloud\x20Problems','skipNxCache','tasks-hashes-','cloud-enabled-runner','complete','waitForStoreRequestsToComplete','throw','assign','forEach','getCIExecutionEnv','env','value','CloudRunApi','join','rxjs/internal/Subject','../../../utilities/metric-logger','then','hash','path','enabled'];(function(_0x2b1d9c,_0x5bec17){const _0x4aacd1=function(_0x322acf){while(--_0x322acf){_0x2b1d9c['push'](_0x2b1d9c['shift']());}};_0x4aacd1(++_0x5bec17);}(a1_0x5bec,0x119));const a1_0x4aac=function(_0x2b1d9c,_0x5bec17){_0x2b1d9c=_0x2b1d9c-0x0;let _0x4aacd1=a1_0x5bec[_0x2b1d9c];return _0x4aacd1;};'use strict';var __awaiter=this&&this[a1_0x4aac('0x11')]||function(_0x423cec,_0x402e25,_0x25bbe2,_0x17b9a0){function _0x2fea5c(_0x42d9f6){return _0x42d9f6 instanceof _0x25bbe2?_0x42d9f6:new _0x25bbe2(function(_0x2fbb88){_0x2fbb88(_0x42d9f6);});}return new(_0x25bbe2||(_0x25bbe2=Promise))(function(_0x856482,_0x1d560f){function _0xa98a4d(_0x5e7f31){try{_0x455b74(_0x17b9a0[a1_0x4aac('0x2f')](_0x5e7f31));}catch(_0x5ef32d){_0x1d560f(_0x5ef32d);}}function _0xb42971(_0x228173){try{_0x455b74(_0x17b9a0[a1_0x4aac('0x49')](_0x228173));}catch(_0x39fb69){_0x1d560f(_0x39fb69);}}function _0x455b74(_0x367785){_0x367785[a1_0x4aac('0x21')]?_0x856482(_0x367785[a1_0x4aac('0x4e')]):_0x2fea5c(_0x367785['value'])['then'](_0xa98a4d,_0xb42971);}_0x455b74((_0x17b9a0=_0x17b9a0[a1_0x4aac('0x14')](_0x423cec,_0x402e25||[]))['next']());});};Object[a1_0x4aac('0x3e')](exports,'__esModule',{'value':!![]});exports[a1_0x4aac('0x36')]=void 0x0;const message_reporter_1=require('../../terminal-output/message-reporter');const end_of_run_message_1=require(a1_0x4aac('0x1c'));const output_obfuscator_1=require(a1_0x4aac('0x5'));const cloud_enabled_life_cycle_1=require('./cloud-enabled-life-cycle');const file_storage_1=require(a1_0x4aac('0x2a'));const e2e_encryption_1=require('../../file-storage/e2e-encryption');const environment_1=require(a1_0x4aac('0x19'));const cloud_remote_cache_1=require(a1_0x4aac('0x28'));const cloud_run_api_1=require('./cloud-run.api');const fs_1=require('fs');const path=require(a1_0x4aac('0x55'));const path_1=require(a1_0x4aac('0x55'));const metric_logger_1=require(a1_0x4aac('0x52'));const error_reporter_api_1=require('../../api/error-reporter.api');const fs_extra_1=require('fs-extra');const id_generator_1=require(a1_0x4aac('0x1'));const remove_trailing_slash_1=require(a1_0x4aac('0x1b'));const {tasksRunner,output,cacheDirectory}=require(a1_0x4aac('0x3b'));function createApi(_0x5bfe73,_0x46cf41,_0x3c21bb){const _0x118261=(0x0,environment_1[a1_0x4aac('0x0')])(_0x46cf41);return new cloud_run_api_1[(a1_0x4aac('0x4f'))](_0x5bfe73,_0x3c21bb,_0x46cf41,_0x118261);}function storeTaskHashes(_0x3f995c,_0xd5cd33,_0x3e074b){const _0x20e24c=JSON[a1_0x4aac('0x38')](_0x3f995c['map'](_0x1360c0=>({'taskId':_0x1360c0[a1_0x4aac('0x12')],'hash':_0x1360c0[a1_0x4aac('0x54')]})));if(environment_1[a1_0x4aac('0x24')]){output[a1_0x4aac('0x35')]({'title':a1_0x4aac('0x59')+_0x20e24c});}(0x0,fs_1[a1_0x4aac('0x30')])(path[a1_0x4aac('0x50')](_0xd5cd33,a1_0x4aac('0x45')+_0x3e074b),_0x20e24c);}function storeLocalCacheHits(_0xe0ef90,_0x8574ec,_0x166b8d){const _0x1097fd=_0xe0ef90['filter'](_0x2e3218=>_0x2e3218['cacheStatus']===a1_0x4aac('0x5b'))[a1_0x4aac('0x2e')](_0x415ad2=>_0x415ad2[a1_0x4aac('0x54')]);_0x1097fd[a1_0x4aac('0x4b')](_0x539f6e=>_0x8574ec[a1_0x4aac('0x29')](_0x539f6e,_0x166b8d));}function onComplete({daemon,options,fileStorage,remoteCache,api,outputObfuscator,runStartTime,messages,endOfRunMessage,taskExecutions,versionOfNxBefore133,inner,encryptionKey,storeInCurrentProcess,distributedExecutionId,runContext}){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x226fca=new Date()[a1_0x4aac('0xb')]();const _0x55ec12=(0x0,environment_1[a1_0x4aac('0x25')])();const _0x122feb={'command':outputObfuscator[a1_0x4aac('0x26')]((0x0,environment_1['parseCommand'])()),'startTime':runStartTime,'endTime':_0x226fca,'distributedExecutionId':distributedExecutionId,'branch':_0x55ec12,'runGroup':(0x0,environment_1[a1_0x4aac('0x2')])(),'sha':_0x55ec12?(0x0,environment_1[a1_0x4aac('0x3c')])():undefined,'inner':inner};const _0x418a9b={'branch':_0x55ec12,'runGroup':(0x0,environment_1[a1_0x4aac('0x2')])(),'ciExecutionId':(0x0,environment_1[a1_0x4aac('0x3f')])(),'ciExecutionEnv':(0x0,environment_1[a1_0x4aac('0x4c')])()};if(storeInCurrentProcess){if((0x0,environment_1['agentRunningInDistributedExecution'])(distributedExecutionId)){storeTaskHashes(taskExecutions,cacheDirectory,distributedExecutionId);storeLocalCacheHits(taskExecutions,remoteCache,cacheDirectory);}try{yield remoteCache[a1_0x4aac('0x48')]();}catch(_0x1a9b63){output[a1_0x4aac('0xe')]({'title':a1_0x4aac('0x57')});messages[a1_0x4aac('0x10')]();return![];}for(const _0x289c90 of fileStorage['storedHashes']){const _0x5aad09=taskExecutions[a1_0x4aac('0xf')](_0x27ec69=>_0x27ec69['hash']===_0x289c90);if(!_0x5aad09){throw new Error(a1_0x4aac('0x1a')+_0x289c90+'\x20isn\x27t\x20recorded');}_0x5aad09[a1_0x4aac('0x9')]=!![];}try{yield api[a1_0x4aac('0x37')](_0x122feb,taskExecutions,_0x418a9b);}catch(_0x5ef38d){output[a1_0x4aac('0xe')]({'title':'Nx\x20Cloud\x20wasn\x27t\x20able\x20to\x20record\x20its\x20run.'});messages[a1_0x4aac('0x10')]();return![];}yield(0x0,metric_logger_1[a1_0x4aac('0x13')])(options);}else{try{const _0x35af11=environment_1[a1_0x4aac('0x3')]?environment_1['ACCESS_TOKEN']:options['accessToken'];const _0x5955f5=(0x0,id_generator_1[a1_0x4aac('0x7')])();yield daemon[a1_0x4aac('0x39')](a1_0x4aac('0x20'),{'encryptionKey':encryptionKey,'runnerOptions':Object['assign'](Object[a1_0x4aac('0x4a')]({},options),{'accessToken':_0x35af11}),'delayedStoreRequests':remoteCache[a1_0x4aac('0x17')],'ciExecutionContext':_0x418a9b,'runEnd':{'runData':_0x122feb,'taskExecutions':taskExecutions,'linkId':_0x5955f5}});runContext[a1_0x4aac('0x40')]=(0x0,remove_trailing_slash_1[a1_0x4aac('0x4')])(options[a1_0x4aac('0x33')]||'https://nx.app')+'/runs/'+_0x5955f5;}catch(_0x1f577e){output[a1_0x4aac('0xa')]({'title':a1_0x4aac('0x43'),'bodyLines':[_0x1f577e[a1_0x4aac('0xd')]||_0x1f577e[a1_0x4aac('0x58')]()]});return![];}}if(versionOfNxBefore133){setTimeout(()=>{messages[a1_0x4aac('0x10')]();if(!messages[a1_0x4aac('0x22')]&&!inner){endOfRunMessage[a1_0x4aac('0x1d')]();}},0x0);}else{messages[a1_0x4aac('0x10')]();if(!messages[a1_0x4aac('0x22')]&&!inner){endOfRunMessage[a1_0x4aac('0x1d')]();}}return!![];});}function createLifeCycle(_0x1dedef,_0x55cbb4,_0x2841bb,_0x1bc0de){const _0x32d3cf=new cloud_enabled_life_cycle_1[(a1_0x4aac('0x41'))](_0x1dedef,cacheDirectory,!![],_0x55cbb4[a1_0x4aac('0x3d')]||[],_0x2841bb,_0x1bc0de);try{const {CompositeLifeCycle}=require('../../../utilities/nx-imports');if(!CompositeLifeCycle)return _0x32d3cf;return new CompositeLifeCycle([_0x55cbb4[a1_0x4aac('0x3a')],_0x32d3cf]);}catch(_0xe5c5a1){return _0x32d3cf;}}function fetchUrlsForKnownHashesUpfront(_0x244674,_0x14fb58,_0x2bc2d5,_0x1bf165,_0x2a5658){return __awaiter(this,void 0x0,void 0x0,function*(){if(_0x1bf165[a1_0x4aac('0x44')])return;let _0x47e40f=_0x2bc2d5[a1_0x4aac('0x2e')](_0x8e92c8=>_0x8e92c8['hash'])['filter'](_0x422355=>!!_0x422355);const _0x1d70ee=yield Promise['all'](_0x47e40f[a1_0x4aac('0x2e')](_0x373204=>{const _0xafff76=(0x0,path_1[a1_0x4aac('0x50')])(cacheDirectory,_0x373204+a1_0x4aac('0x2d'));return(0x0,fs_extra_1['pathExists'])(_0xafff76);}));const _0x519429=[];for(let _0x5f3a75=0x0;_0x5f3a75<_0x1d70ee[a1_0x4aac('0x5a')];++_0x5f3a75){if(!_0x1d70ee[_0x5f3a75]){_0x519429[a1_0x4aac('0x15')](_0x47e40f[_0x5f3a75]);}}if(_0x519429[a1_0x4aac('0x5a')]>0x0){const _0x575943=_0x244674[a1_0x4aac('0x34')](_0x2a5658,_0x519429);for(const _0x5c67f2 of _0x519429){_0x14fb58[a1_0x4aac('0x27')][_0x5c67f2]=_0x575943;}}});}function cloudEnabledTasksRunner(_0x4afeb7,_0xa15997,_0x508d22,_0x384129=![]){var _0x558800;const _0xcc07b4=process['env'][a1_0x4aac('0x32')];const _0xdb5e85={'statuses':{},'scheduledTasks':[],'requests':{},'allTasks':_0x4afeb7};const _0x2a718c=_0xa15997[a1_0x4aac('0x3a')]===undefined;const _0x3daf12=[];const _0x282efe=new message_reporter_1[(a1_0x4aac('0x16'))](_0xa15997);const _0x54ff09=createApi(_0x282efe,_0xa15997,_0xdb5e85);const _0xed9c22=new end_of_run_message_1['EndOfRunMessage'](_0xdb5e85,_0x3daf12,_0xcc07b4);const _0x3bc534=new output_obfuscator_1[(a1_0x4aac('0x8'))](_0xa15997[a1_0x4aac('0x31')]);const _0x55cce4=new Date()[a1_0x4aac('0xb')]();const _0x237df5=createLifeCycle(_0xdb5e85,_0xa15997,_0x3bc534,_0x3daf12);const _0x2c76c2=environment_1[a1_0x4aac('0x18')]||_0xa15997[a1_0x4aac('0x1f')];const _0x24566e=new e2e_encryption_1[(a1_0x4aac('0x2b'))](_0x2c76c2);const _0x301489=new error_reporter_api_1['ErrorReporterApi'](_0xa15997);const _0x410dce=(0x0,environment_1[a1_0x4aac('0x23')])(_0xcc07b4)||!((_0x558800=_0x508d22[a1_0x4aac('0x6')])===null||_0x558800===void 0x0?void 0x0:_0x558800[a1_0x4aac('0x56')]());const _0x4f4870=new file_storage_1[(a1_0x4aac('0x2c'))](_0x24566e,_0x301489,_0xa15997,a1_0x4aac('0x46'));const _0x38b14b=new cloud_remote_cache_1['CloudRemoteCache'](_0x282efe,_0x54ff09,_0xdb5e85,_0x4f4870,_0xcc07b4,_0x410dce);fetchUrlsForKnownHashesUpfront(_0x54ff09,_0xdb5e85,_0x4afeb7,_0xa15997,_0xcc07b4);delete process[a1_0x4aac('0x4d')]['NX_CLOUD_DISTRIBUTED_EXECUTION_ID'];const _0x317ab5=tasksRunner(_0x4afeb7,Object[a1_0x4aac('0x4a')](Object[a1_0x4aac('0x4a')]({},_0xa15997),{'remoteCache':_0x38b14b,'lifeCycle':_0x237df5}),_0x508d22);if(_0x317ab5[a1_0x4aac('0x42')]){const {Subject}=require(a1_0x4aac('0x51'));const _0x5ca57d=new Subject();_0x317ab5[a1_0x4aac('0x42')]({'next':_0x46dc92=>_0x5ca57d['next'](_0x46dc92),'error':_0x474cad=>_0x5ca57d[a1_0x4aac('0xe')](_0x474cad),'complete':()=>__awaiter(this,void 0x0,void 0x0,function*(){const _0x394191=yield onComplete({'daemon':_0x508d22[a1_0x4aac('0x6')],'options':_0xa15997,'fileStorage':_0x4f4870,'remoteCache':_0x38b14b,'api':_0x54ff09,'outputObfuscator':_0x3bc534,'runStartTime':_0x55cce4,'messages':_0x282efe,'endOfRunMessage':_0xed9c22,'taskExecutions':_0x3daf12,'versionOfNxBefore133':_0x2a718c,'inner':_0x384129,'encryptionKey':_0x2c76c2,'storeInCurrentProcess':_0x410dce,'runContext':_0xdb5e85,'distributedExecutionId':_0xcc07b4});if(!_0x394191&&(0x0,environment_1[a1_0x4aac('0x23')])(_0xcc07b4)){process[a1_0x4aac('0xc')](environment_1[a1_0x4aac('0x1e')]);}_0x5ca57d[a1_0x4aac('0x47')]();})});return _0x5ca57d;}else{return _0x317ab5[a1_0x4aac('0x53')](_0x4ee949=>__awaiter(this,void 0x0,void 0x0,function*(){const _0xf35cdf=yield onComplete({'daemon':_0x508d22[a1_0x4aac('0x6')],'options':_0xa15997,'fileStorage':_0x4f4870,'remoteCache':_0x38b14b,'api':_0x54ff09,'outputObfuscator':_0x3bc534,'runStartTime':_0x55cce4,'messages':_0x282efe,'endOfRunMessage':_0xed9c22,'taskExecutions':_0x3daf12,'versionOfNxBefore133':_0x2a718c,'inner':_0x384129,'encryptionKey':_0x2c76c2,'storeInCurrentProcess':_0x410dce,'runContext':_0xdb5e85,'distributedExecutionId':_0xcc07b4});if(!_0xf35cdf&&(0x0,environment_1['agentRunningInDistributedExecution'])(_0xcc07b4)){process[a1_0x4aac('0xc')](environment_1[a1_0x4aac('0x1e')]);}return _0x4ee949;}))['catch'](_0x50333e=>__awaiter(this,void 0x0,void 0x0,function*(){const _0x3fc1e1=yield onComplete({'daemon':_0x508d22[a1_0x4aac('0x6')],'options':_0xa15997,'fileStorage':_0x4f4870,'remoteCache':_0x38b14b,'api':_0x54ff09,'outputObfuscator':_0x3bc534,'runStartTime':_0x55cce4,'messages':_0x282efe,'endOfRunMessage':_0xed9c22,'taskExecutions':_0x3daf12,'versionOfNxBefore133':_0x2a718c,'inner':_0x384129,'encryptionKey':_0x2c76c2,'storeInCurrentProcess':_0x410dce,'runContext':_0xdb5e85,'distributedExecutionId':_0xcc07b4});if(!_0x3fc1e1&&(0x0,environment_1[a1_0x4aac('0x23')])(_0xcc07b4)){process[a1_0x4aac('0xc')](environment_1[a1_0x4aac('0x1e')]);}throw _0x50333e;}));}}exports['cloudEnabledTasksRunner']=cloudEnabledTasksRunner;

lib/core/runners/cloud-enabled/cloud-remote-cache.js

@@ -1,1 +0,1 @@
-const a2_0x33fa=['forEach','statuses','note','filter','cache-miss','push','value','hash','api','axiosException','messages','indexOf','delayedStoreRequests','There\x20are\x20several\x20reasons\x20why\x20this\x20can\x20happen.','extractErrorMessage','CloudRemoteCache','requests','Maybe\x20you\x20are\x20using\x20a\x20read-only\x20token\x20or\x20the\x20artifact\x20has\x20already\x20being\x20uploaded.','waitForStoreRequestsToComplete','apply','response','hashUrls','put','VERBOSE_LOGGING','Nx\x20Cloud:\x20Skipping\x20storing\x20','distributedExecutionId','remote-cache-hit','next','fileStorage','storeRequests','__esModule','scheduledTasks','Error\x20when\x20storing\x20artifacts','all','defineProperty','../../../utilities/environment','get','startRun','store','storage','runContext','reduce','map','status','Nx\x20Cloud:\x20Cache\x20miss\x20','../../../utilities/nx-imports','cacheError','storeInCurrentProcess'];(function(_0x5a848a,_0x33fa1a){const _0x204660=function(_0x5aed55){while(--_0x5aed55){_0x5a848a['push'](_0x5a848a['shift']());}};_0x204660(++_0x33fa1a);}(a2_0x33fa,0x1e0));const a2_0x2046=function(_0x5a848a,_0x33fa1a){_0x5a848a=_0x5a848a-0x0;let _0x204660=a2_0x33fa[_0x5a848a];return _0x204660;};'use strict';var __awaiter=this&&this['__awaiter']||function(_0x4f349e,_0x17d554,_0xa6ffda,_0x5589e0){function _0x1f020f(_0x472b46){return _0x472b46 instanceof _0xa6ffda?_0x472b46:new _0xa6ffda(function(_0x3276b3){_0x3276b3(_0x472b46);});}return new(_0xa6ffda||(_0xa6ffda=Promise))(function(_0x2dcb82,_0x5941ea){function _0x37b7f3(_0x69e26d){try{_0x444d85(_0x5589e0['next'](_0x69e26d));}catch(_0xf107aa){_0x5941ea(_0xf107aa);}}function _0x4e06fe(_0x2f9055){try{_0x444d85(_0x5589e0['throw'](_0x2f9055));}catch(_0x577034){_0x5941ea(_0x577034);}}function _0x444d85(_0x5d69af){_0x5d69af['done']?_0x2dcb82(_0x5d69af['value']):_0x1f020f(_0x5d69af[a2_0x2046('0x6')])['then'](_0x37b7f3,_0x4e06fe);}_0x444d85((_0x5589e0=_0x5589e0[a2_0x2046('0x13')](_0x4f349e,_0x17d554||[]))[a2_0x2046('0x1b')]());});};Object[a2_0x2046('0x22')](exports,a2_0x2046('0x1e'),{'value':!![]});exports['CloudRemoteCache']=void 0x0;const environment_1=require(a2_0x2046('0x23'));const {output}=require(a2_0x2046('0x2d'));class CloudRemoteCache{constructor(_0x50e72d,_0x4ad09a,_0x5650db,_0x13722a,_0x264cd5,_0x1191dc){this[a2_0x2046('0xa')]=_0x50e72d;this[a2_0x2046('0x8')]=_0x4ad09a;this[a2_0x2046('0x28')]=_0x5650db;this[a2_0x2046('0x1c')]=_0x13722a;this[a2_0x2046('0x19')]=_0x264cd5;this[a2_0x2046('0x2f')]=_0x1191dc;this[a2_0x2046('0x1d')]=[];this[a2_0x2046('0xc')]=[];}['retrieve'](_0x225c66,_0x181b07){var _0x3c9b5e;return __awaiter(this,void 0x0,void 0x0,function*(){if(this[a2_0x2046('0xa')][a2_0x2046('0x2e')])return![];const _0x9973d8=yield this[a2_0x2046('0x15')](_0x225c66);if(!_0x9973d8||!_0x9973d8[a2_0x2046('0x24')]){if(environment_1['VERBOSE_LOGGING']){output[a2_0x2046('0x2')]({'title':a2_0x2046('0x2c')+_0x225c66+'.'});}this[a2_0x2046('0x28')][a2_0x2046('0x1')][_0x225c66]='cache-miss';return![];}try{yield this[a2_0x2046('0x1c')]['retrieve'](_0x225c66,_0x9973d8['get'],_0x181b07);this[a2_0x2046('0x28')][a2_0x2046('0x1')][_0x225c66]=a2_0x2046('0x1a');return!![];}catch(_0x399ee5){const _0x5ca40a=(_0x3c9b5e=_0x399ee5[a2_0x2046('0x9')])!==null&&_0x3c9b5e!==void 0x0?_0x3c9b5e:_0x399ee5;if(_0x5ca40a[a2_0x2046('0x14')]&&_0x5ca40a[a2_0x2046('0x14')][a2_0x2046('0x2b')]===0x194){if(environment_1[a2_0x2046('0x17')]){output[a2_0x2046('0x2')]({'title':'Nx\x20Cloud:\x20Cache\x20miss\x20'+_0x225c66+'.\x20Status\x20404.'});}}else{this[a2_0x2046('0xa')]['cacheError']=this['messages']['extractErrorMessage'](_0x5ca40a,'storage');}this['runContext'][a2_0x2046('0x1')][_0x225c66]=a2_0x2046('0x4');return![];}});}[a2_0x2046('0x26')](_0x2091d,_0x809314){return __awaiter(this,void 0x0,void 0x0,function*(){if(this[a2_0x2046('0xa')][a2_0x2046('0x2e')])return![];const _0x739342=Promise['resolve']()['then'](()=>__awaiter(this,void 0x0,void 0x0,function*(){var _0x48c4b9;const _0x227d7f=yield this['hashUrls'](_0x2091d);if(!_0x227d7f)return![];if(!_0x227d7f[a2_0x2046('0x16')]){if(environment_1[a2_0x2046('0x17')]){output[a2_0x2046('0x2')]({'title':a2_0x2046('0x18')+_0x2091d+'.','bodyLines':[a2_0x2046('0xd'),a2_0x2046('0x11')]});}return!![];}if(!this[a2_0x2046('0x2f')]){this[a2_0x2046('0xc')][a2_0x2046('0x5')]({'hash':_0x2091d,'url':_0x227d7f[a2_0x2046('0x16')]});return!![];}try{yield this[a2_0x2046('0x1c')]['store'](_0x2091d,_0x227d7f[a2_0x2046('0x16')],_0x809314);return!![];}catch(_0x5548d3){const _0x5db756=(_0x48c4b9=_0x5548d3[a2_0x2046('0x9')])!==null&&_0x48c4b9!==void 0x0?_0x48c4b9:_0x5548d3;this[a2_0x2046('0xa')]['cacheError']=this['messages'][a2_0x2046('0xe')](_0x5db756,a2_0x2046('0x27'));return![];}}));this[a2_0x2046('0x1d')]['push'](_0x739342);return _0x739342;});}[a2_0x2046('0x15')](_0x5b0faf){return __awaiter(this,void 0x0,void 0x0,function*(){if(_0x5b0faf in this[a2_0x2046('0x28')][a2_0x2046('0x10')]){return(yield this[a2_0x2046('0x28')][a2_0x2046('0x10')][_0x5b0faf])[_0x5b0faf];}else{const _0x3d5947=this[a2_0x2046('0x28')][a2_0x2046('0x1f')][a2_0x2046('0x3')](_0x9f1674=>!this['runContext'][a2_0x2046('0x10')][_0x9f1674[a2_0x2046('0x7')]])[a2_0x2046('0x2a')](_0x54a9b6=>_0x54a9b6[a2_0x2046('0x7')]);if(_0x3d5947[a2_0x2046('0xb')](_0x5b0faf)===-0x1){_0x3d5947['push'](_0x5b0faf);}const _0x493790=this[a2_0x2046('0x8')][a2_0x2046('0x25')](this[a2_0x2046('0x19')],_0x3d5947);_0x3d5947[a2_0x2046('0x0')](_0x435abc=>{this['runContext'][a2_0x2046('0x10')][_0x435abc]=_0x493790;});return(yield _0x493790)[_0x5b0faf];}});}[a2_0x2046('0x12')](){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x4b8f6b=yield Promise[a2_0x2046('0x21')](this[a2_0x2046('0x1d')])['then'](_0x41d094=>_0x41d094[a2_0x2046('0x29')]((_0xda1bd1,_0x2ea9ae)=>_0xda1bd1&&_0x2ea9ae,!![]));if(!_0x4b8f6b){throw new Error(a2_0x2046('0x20'));}});}}exports[a2_0x2046('0xf')]=CloudRemoteCache;
+const a2_0x1f5b=['remote-cache-hit','push','There\x20are\x20several\x20reasons\x20why\x20this\x20can\x20happen.','extractErrorMessage','then','storeRequests','done','api','Nx\x20Cloud:\x20Cache\x20miss\x20','forEach','map','__esModule','all','messages','CloudRemoteCache','delayedStoreRequests','throw','apply','hashUrls','storeInCurrentProcess','Nx\x20Cloud:\x20Skipping\x20storing\x20','runContext','distributedExecutionId','cache-miss','hash','cacheError','reduce','storage','response','statuses','retrieve','store','axiosException','get','VERBOSE_LOGGING','note','requests','.\x20Status\x20404.','scheduledTasks','Maybe\x20you\x20are\x20using\x20a\x20read-only\x20token\x20or\x20the\x20artifact\x20has\x20already\x20being\x20uploaded.','put','defineProperty','next','status','value','__awaiter','startRun'];(function(_0xb2218d,_0x1f5b7e){const _0x4acc79=function(_0x10645e){while(--_0x10645e){_0xb2218d['push'](_0xb2218d['shift']());}};_0x4acc79(++_0x1f5b7e);}(a2_0x1f5b,0x92));const a2_0x4acc=function(_0xb2218d,_0x1f5b7e){_0xb2218d=_0xb2218d-0x0;let _0x4acc79=a2_0x1f5b[_0xb2218d];return _0x4acc79;};'use strict';var __awaiter=this&&this[a2_0x4acc('0x28')]||function(_0xee59e6,_0x43995c,_0x3a8288,_0x596bbc){function _0x584815(_0x29871e){return _0x29871e instanceof _0x3a8288?_0x29871e:new _0x3a8288(function(_0x3cf49e){_0x3cf49e(_0x29871e);});}return new(_0x3a8288||(_0x3a8288=Promise))(function(_0x21cec7,_0x2f8de1){function _0x594f5e(_0x4e0e0f){try{_0x502beb(_0x596bbc[a2_0x4acc('0x25')](_0x4e0e0f));}catch(_0x5d7163){_0x2f8de1(_0x5d7163);}}function _0x3fcce5(_0x6f2e30){try{_0x502beb(_0x596bbc[a2_0x4acc('0xb')](_0x6f2e30));}catch(_0x12ed33){_0x2f8de1(_0x12ed33);}}function _0x502beb(_0x795800){_0x795800[a2_0x4acc('0x1')]?_0x21cec7(_0x795800[a2_0x4acc('0x27')]):_0x584815(_0x795800['value'])['then'](_0x594f5e,_0x3fcce5);}_0x502beb((_0x596bbc=_0x596bbc[a2_0x4acc('0xc')](_0xee59e6,_0x43995c||[]))[a2_0x4acc('0x25')]());});};Object[a2_0x4acc('0x24')](exports,a2_0x4acc('0x6'),{'value':!![]});exports[a2_0x4acc('0x9')]=void 0x0;const environment_1=require('../../../utilities/environment');const {output}=require('../../../utilities/nx-imports');class CloudRemoteCache{constructor(_0x2459c6,_0x198da2,_0x3fa485,_0x13f86e,_0x34c266,_0x572413){this[a2_0x4acc('0x8')]=_0x2459c6;this['api']=_0x198da2;this[a2_0x4acc('0x10')]=_0x3fa485;this['fileStorage']=_0x13f86e;this[a2_0x4acc('0x11')]=_0x34c266;this[a2_0x4acc('0xe')]=_0x572413;this[a2_0x4acc('0x0')]=[];this[a2_0x4acc('0xa')]=[];}[a2_0x4acc('0x19')](_0xa6d11c,_0x3e197c){var _0x3e888d;return __awaiter(this,void 0x0,void 0x0,function*(){if(this[a2_0x4acc('0x8')][a2_0x4acc('0x14')])return![];const _0x2247b1=yield this[a2_0x4acc('0xd')](_0xa6d11c);if(!_0x2247b1||!_0x2247b1[a2_0x4acc('0x1c')]){if(environment_1[a2_0x4acc('0x1d')]){output[a2_0x4acc('0x1e')]({'title':a2_0x4acc('0x3')+_0xa6d11c+'.'});}this[a2_0x4acc('0x10')][a2_0x4acc('0x18')][_0xa6d11c]='cache-miss';return![];}try{yield this['fileStorage'][a2_0x4acc('0x19')](_0xa6d11c,_0x2247b1[a2_0x4acc('0x1c')],_0x3e197c);this[a2_0x4acc('0x10')][a2_0x4acc('0x18')][_0xa6d11c]=a2_0x4acc('0x2a');return!![];}catch(_0x537ad4){const _0x30736a=(_0x3e888d=_0x537ad4[a2_0x4acc('0x1b')])!==null&&_0x3e888d!==void 0x0?_0x3e888d:_0x537ad4;if(_0x30736a[a2_0x4acc('0x17')]&&_0x30736a[a2_0x4acc('0x17')][a2_0x4acc('0x26')]===0x194){if(environment_1['VERBOSE_LOGGING']){output[a2_0x4acc('0x1e')]({'title':a2_0x4acc('0x3')+_0xa6d11c+a2_0x4acc('0x20')});}}else{this[a2_0x4acc('0x8')][a2_0x4acc('0x14')]=this['messages'][a2_0x4acc('0x2d')](_0x30736a,a2_0x4acc('0x16'));}this['runContext'][a2_0x4acc('0x18')][_0xa6d11c]=a2_0x4acc('0x12');return![];}});}[a2_0x4acc('0x1a')](_0x5ef2e0,_0x3e47b3){return __awaiter(this,void 0x0,void 0x0,function*(){if(this[a2_0x4acc('0x8')]['cacheError'])return![];const _0x4440e2=Promise['resolve']()[a2_0x4acc('0x2e')](()=>__awaiter(this,void 0x0,void 0x0,function*(){var _0x485552;const _0x16b4cd=yield this[a2_0x4acc('0xd')](_0x5ef2e0);if(!_0x16b4cd)return![];if(!_0x16b4cd[a2_0x4acc('0x23')]){if(environment_1[a2_0x4acc('0x1d')]){output[a2_0x4acc('0x1e')]({'title':a2_0x4acc('0xf')+_0x5ef2e0+'.','bodyLines':[a2_0x4acc('0x2c'),a2_0x4acc('0x22')]});}return!![];}if(!this[a2_0x4acc('0xe')]){this[a2_0x4acc('0xa')]['push']({'hash':_0x5ef2e0,'url':_0x16b4cd['put']});return!![];}try{yield this['fileStorage'][a2_0x4acc('0x1a')](_0x5ef2e0,_0x16b4cd[a2_0x4acc('0x23')],_0x3e47b3);return!![];}catch(_0x1543d8){const _0x2b458d=(_0x485552=_0x1543d8['axiosException'])!==null&&_0x485552!==void 0x0?_0x485552:_0x1543d8;this[a2_0x4acc('0x8')][a2_0x4acc('0x14')]=this[a2_0x4acc('0x8')][a2_0x4acc('0x2d')](_0x2b458d,a2_0x4acc('0x16'));return![];}}));this[a2_0x4acc('0x0')]['push'](_0x4440e2);return _0x4440e2;});}[a2_0x4acc('0xd')](_0x5c4dec){return __awaiter(this,void 0x0,void 0x0,function*(){if(_0x5c4dec in this[a2_0x4acc('0x10')][a2_0x4acc('0x1f')]){return(yield this['runContext']['requests'][_0x5c4dec])[_0x5c4dec];}else{const _0x3ce798=this[a2_0x4acc('0x10')][a2_0x4acc('0x21')]['filter'](_0x486730=>!this[a2_0x4acc('0x10')][a2_0x4acc('0x1f')][_0x486730[a2_0x4acc('0x13')]])[a2_0x4acc('0x5')](_0x1cb0ef=>_0x1cb0ef['hash']);if(_0x3ce798['indexOf'](_0x5c4dec)===-0x1){_0x3ce798[a2_0x4acc('0x2b')](_0x5c4dec);}const _0x2f1ff3=this[a2_0x4acc('0x2')][a2_0x4acc('0x29')](this[a2_0x4acc('0x11')],_0x3ce798);_0x3ce798[a2_0x4acc('0x4')](_0x38eeaf=>{this[a2_0x4acc('0x10')][a2_0x4acc('0x1f')][_0x38eeaf]=_0x2f1ff3;});return(yield _0x2f1ff3)[_0x5c4dec];}});}['waitForStoreRequestsToComplete'](){return __awaiter(this,void 0x0,void 0x0,function*(){const _0xa82693=yield Promise[a2_0x4acc('0x7')](this[a2_0x4acc('0x0')])[a2_0x4acc('0x2e')](_0x51d5f6=>_0x51d5f6[a2_0x4acc('0x15')]((_0x1d1e8d,_0x4db435)=>_0x1d1e8d&&_0x4db435,!![]));if(!_0xa82693){throw new Error('Error\x20when\x20storing\x20artifacts');}});}}exports['CloudRemoteCache']=CloudRemoteCache;

lib/core/runners/cloud-enabled/cloud-run.api.js

@@ -1,1 +0,1 @@
-const a3_0x1be2=['urls','getRunGroup','isConnectedToPrivateCloud','gzip','../../../utilities/metric-logger','Invalid\x20Nx\x20Cloud\x20response:\x20','promisify','next','toString','assign','RUNNER_FAILURE_PERF_ENTRY','machineInfo','response','nxCloudVersion','status','printDuration','runContext','VERBOSE_LOGGING','RunEnd.\x20Completed\x20tasks','then','stack','__awaiter','map','extractErrorMessage','mapRespToPerfEntry','post','string','length','endRun','done','Run\x20completion\x20responded\x20with\x20`undefined`.','createReqBody','../../../utilities/nx-imports','error','unknown','getBranch','data','/nx-cloud/runs/start','Invalid\x20end\x20run\x20response:\x20','../../../utilities/environment','value','nx-cloud','../../../utilities/axios','terminalOutput','defineProperty','package.json','note','recordMetric','runUrl','...','../../../utilities/is-private-cloud','application/octet-stream','createApiAxiosInstance','zlib','axiosMultipleTries','readFileSync','getCIExecutionEnv','Invalid\x20end\x20run\x20response','RunStart','Stack\x20Trace:','stringify','api','/nx-cloud/runs/end','devDependencies','CloudRunApi','apiError','messages','Nx\x20Cloud:\x20Unknown\x20Error\x20Occurred','apiAxiosInstance','success','axiosException','message','createMetricRecorder','headers','from','Run\x20Details:','RunStart\x20duration','throw'];(function(_0x31e6f4,_0x1be2cf){const _0x15efe7=function(_0xf3ceac){while(--_0xf3ceac){_0x31e6f4['push'](_0x31e6f4['shift']());}};_0x15efe7(++_0x1be2cf);}(a3_0x1be2,0x135));const a3_0x15ef=function(_0x31e6f4,_0x1be2cf){_0x31e6f4=_0x31e6f4-0x0;let _0x15efe7=a3_0x1be2[_0x31e6f4];return _0x15efe7;};'use strict';var __awaiter=this&&this[a3_0x15ef('0x18')]||function(_0x5b15cb,_0x45d3ef,_0xe45779,_0x49700e){function _0x51dd4e(_0xb344ae){return _0xb344ae instanceof _0xe45779?_0xb344ae:new _0xe45779(function(_0x1e1541){_0x1e1541(_0xb344ae);});}return new(_0xe45779||(_0xe45779=Promise))(function(_0x179c4c,_0x1c0971){function _0x2bf6c6(_0x5d4f02){try{_0x5056b7(_0x49700e['next'](_0x5d4f02));}catch(_0x3f9f01){_0x1c0971(_0x3f9f01);}}function _0x48d911(_0x443cbc){try{_0x5056b7(_0x49700e[a3_0x15ef('0x2')](_0x443cbc));}catch(_0x430999){_0x1c0971(_0x430999);}}function _0x5056b7(_0x8cd91){_0x8cd91[a3_0x15ef('0x20')]?_0x179c4c(_0x8cd91['value']):_0x51dd4e(_0x8cd91[a3_0x15ef('0x2b')])[a3_0x15ef('0x16')](_0x2bf6c6,_0x48d911);}_0x5056b7((_0x49700e=_0x49700e['apply'](_0x5b15cb,_0x45d3ef||[]))[a3_0x15ef('0xa')]());});};Object[a3_0x15ef('0x2f')](exports,'__esModule',{'value':!![]});exports['CloudRunApi']=void 0x0;const axios_1=require(a3_0x15ef('0x2d'));const environment_1=require(a3_0x15ef('0x2a'));const fs_1=require('fs');const zlib_1=require(a3_0x15ef('0x38'));const util_1=require('util');const metric_logger_1=require(a3_0x15ef('0x7'));const is_private_cloud_1=require(a3_0x15ef('0x35'));const {output}=require(a3_0x15ef('0x23'));class CloudRunApi{constructor(_0x3d99e6,_0x40282e,_0xa189d9,_0x26305a){this[a3_0x15ef('0x45')]=_0x3d99e6;this['runContext']=_0x40282e;this[a3_0x15ef('0xe')]=_0x26305a;this[a3_0x15ef('0x47')]=(0x0,axios_1[a3_0x15ef('0x37')])(_0xa189d9);}['startRun'](_0x9accc2,_0x527bb7){var _0x53bf0d;return __awaiter(this,void 0x0,void 0x0,function*(){if(this[a3_0x15ef('0x45')]['apiError'])return{};const _0x368330=(0x0,metric_logger_1[a3_0x15ef('0x4b')])('startRun');try{const _0x39afe3={'meta':{'nxCloudVersion':this['nxCloudVersion']()},'branch':(0x0,environment_1[a3_0x15ef('0x26')])(),'runGroup':(0x0,environment_1[a3_0x15ef('0x4')])(),'ciExecutionId':(0x0,environment_1['getCIExecutionId'])(),'ciExecutionEnv':(0x0,environment_1[a3_0x15ef('0x3b')])(),'distributedExecutionId':_0x9accc2,'hashes':_0x527bb7};if(environment_1[a3_0x15ef('0x14')]){output[a3_0x15ef('0x31')]({'title':a3_0x15ef('0x3d'),'bodyLines':['\x0a'+JSON[a3_0x15ef('0x3f')](_0x39afe3,null,0x2)]});}const _0x33e41e=yield(0x0,axios_1[a3_0x15ef('0x12')])(a3_0x15ef('0x1'),()=>(0x0,axios_1[a3_0x15ef('0x39')])(()=>this['apiAxiosInstance'][a3_0x15ef('0x1c')](a3_0x15ef('0x28'),_0x39afe3)));_0x368330[a3_0x15ef('0x32')]((0x0,metric_logger_1[a3_0x15ef('0x1b')])(_0x33e41e));if(_0x33e41e[a3_0x15ef('0x27')]&&_0x33e41e[a3_0x15ef('0x27')]['message']){this[a3_0x15ef('0x45')][a3_0x15ef('0x4a')]=_0x33e41e['data'][a3_0x15ef('0x4a')];}if(!_0x33e41e[a3_0x15ef('0x27')]||!_0x33e41e[a3_0x15ef('0x27')][a3_0x15ef('0x3')]){this[a3_0x15ef('0x45')][a3_0x15ef('0x44')]=a3_0x15ef('0x8')+JSON[a3_0x15ef('0x3f')](_0x33e41e[a3_0x15ef('0x27')]);return{};}return _0x33e41e[a3_0x15ef('0x27')]['urls'];}catch(_0x13c0b0){_0x368330['recordMetric'](((_0x53bf0d=_0x13c0b0===null||_0x13c0b0===void 0x0?void 0x0:_0x13c0b0[a3_0x15ef('0x49')])===null||_0x53bf0d===void 0x0?void 0x0:_0x53bf0d['response'])?(0x0,metric_logger_1[a3_0x15ef('0x1b')])(_0x13c0b0[a3_0x15ef('0x49')][a3_0x15ef('0xf')]):metric_logger_1[a3_0x15ef('0xd')]);this['messages']['apiError']=this[a3_0x15ef('0x45')]['extractErrorMessage'](_0x13c0b0,'api');return{};}});}[a3_0x15ef('0x22')](_0x5495be,_0xca0e58,_0x4b5f08,_0x7dceea){if((0x0,is_private_cloud_1[a3_0x15ef('0x5')])()){for(let _0x3edfdf of _0xca0e58){delete _0x3edfdf['uploadedToStorage'];}}const _0x3861db=Object[a3_0x15ef('0xc')](Object[a3_0x15ef('0xc')]({'meta':{'nxCloudVersion':this[a3_0x15ef('0x10')]()},'tasks':_0xca0e58,'run':_0x5495be,'linkId':_0x7dceea},(0x0,is_private_cloud_1['isConnectedToPrivateCloud'])()?{}:_0x4b5f08),{'machineInfo':this[a3_0x15ef('0xe')]});return JSON[a3_0x15ef('0x3f')](_0x3861db);}[a3_0x15ef('0x1f')](_0x44b81f,_0x598179,_0x26242c,_0x4c9150){var _0x425a7d,_0x74f232;return __awaiter(this,void 0x0,void 0x0,function*(){if(this[a3_0x15ef('0x45')]['apiError'])return![];let _0x585219=this[a3_0x15ef('0x22')](_0x44b81f,_0x598179,_0x26242c,_0x4c9150);if(_0x585219[a3_0x15ef('0x1e')]>0x14*0x3e8*0x3e8){_0x585219=this[a3_0x15ef('0x22')](_0x44b81f,_0x598179[a3_0x15ef('0x19')](_0x39d9a3=>Object[a3_0x15ef('0xc')](Object['assign']({},_0x39d9a3),{'hashDetails':undefined})),_0x26242c,_0x4c9150);}const _0x205e2d=Buffer[a3_0x15ef('0x4d')](_0x585219);const _0x3c69b3=yield(0x0,util_1[a3_0x15ef('0x9')])(zlib_1[a3_0x15ef('0x6')])(_0x205e2d);const _0x26fd51=(0x0,metric_logger_1[a3_0x15ef('0x4b')])(a3_0x15ef('0x1f'));try{if(environment_1[a3_0x15ef('0x14')]){const _0x20602c=_0x598179[a3_0x15ef('0x19')](_0x41cf21=>{return Object[a3_0x15ef('0xc')](Object['assign']({},_0x41cf21),{'terminalOutput':_0x41cf21[a3_0x15ef('0x2e')]?_0x41cf21['terminalOutput']['slice'](0x0,0x14)+a3_0x15ef('0x34'):undefined});});output[a3_0x15ef('0x31')]({'title':a3_0x15ef('0x15'),'bodyLines':['\x0a'+JSON[a3_0x15ef('0x3f')](_0x20602c,null,0x2)]});}const _0x795549=yield(0x0,axios_1[a3_0x15ef('0x12')])('RunEnd\x20duration',()=>(0x0,axios_1[a3_0x15ef('0x39')])(()=>this[a3_0x15ef('0x47')]['post'](a3_0x15ef('0x41'),_0x3c69b3,{'headers':Object[a3_0x15ef('0xc')](Object[a3_0x15ef('0xc')]({},this[a3_0x15ef('0x47')]['defaults'][a3_0x15ef('0x4c')]),{'Content-Encoding':a3_0x15ef('0x6'),'Content-Type':a3_0x15ef('0x36')})})));if(_0x795549){_0x26fd51[a3_0x15ef('0x32')]((0x0,metric_logger_1['mapRespToPerfEntry'])(_0x795549));if(_0x795549[a3_0x15ef('0x27')]&&_0x795549['data'][a3_0x15ef('0x33')]&&_0x795549[a3_0x15ef('0x27')][a3_0x15ef('0x11')]===a3_0x15ef('0x48')){this[a3_0x15ef('0x13')][a3_0x15ef('0x33')]=_0x795549[a3_0x15ef('0x27')][a3_0x15ef('0x33')];return!![];}if(_0x795549[a3_0x15ef('0x27')]&&_0x795549[a3_0x15ef('0x27')][a3_0x15ef('0x11')]){this[a3_0x15ef('0x45')][a3_0x15ef('0x44')]=a3_0x15ef('0x29')+JSON[a3_0x15ef('0x3f')](_0x795549[a3_0x15ef('0x27')][a3_0x15ef('0x4a')]);}else if(_0x795549[a3_0x15ef('0x27')]&&typeof _0x795549[a3_0x15ef('0x27')]===a3_0x15ef('0x1d')){if(_0x795549[a3_0x15ef('0x27')]!==a3_0x15ef('0x48')){this[a3_0x15ef('0x45')][a3_0x15ef('0x44')]=a3_0x15ef('0x29')+JSON[a3_0x15ef('0x3f')](_0x795549[a3_0x15ef('0x27')]);}}else{this['messages'][a3_0x15ef('0x44')]=a3_0x15ef('0x29')+JSON[a3_0x15ef('0x3f')](_0x795549[a3_0x15ef('0x27')]);}if(environment_1[a3_0x15ef('0x14')]){output[a3_0x15ef('0x31')]({'title':a3_0x15ef('0x3c'),'bodyLines':[JSON[a3_0x15ef('0x3f')](_0x795549[a3_0x15ef('0x27')],null,0x2)]});}}else{output[a3_0x15ef('0x24')]({'title':a3_0x15ef('0x46'),'bodyLines':[a3_0x15ef('0x21'),a3_0x15ef('0x0'),JSON[a3_0x15ef('0x3f')](_0x44b81f,null,0x2),a3_0x15ef('0x3e'),JSON['stringify'](new Error()[a3_0x15ef('0x17')],null,0x2)]});}return![];}catch(_0x5a8f19){_0x26fd51['recordMetric'](((_0x425a7d=_0x5a8f19===null||_0x5a8f19===void 0x0?void 0x0:_0x5a8f19[a3_0x15ef('0x49')])===null||_0x425a7d===void 0x0?void 0x0:_0x425a7d[a3_0x15ef('0xf')])?(0x0,metric_logger_1[a3_0x15ef('0x1b')])(_0x5a8f19[a3_0x15ef('0x49')][a3_0x15ef('0xf')]):metric_logger_1[a3_0x15ef('0xd')]);const _0x3db8d1=(_0x74f232=_0x5a8f19[a3_0x15ef('0x49')])!==null&&_0x74f232!==void 0x0?_0x74f232:_0x5a8f19;this[a3_0x15ef('0x45')][a3_0x15ef('0x44')]=this[a3_0x15ef('0x45')][a3_0x15ef('0x1a')](_0x3db8d1,a3_0x15ef('0x40'));return![];}});}[a3_0x15ef('0x10')](){try{const _0x55ca2d=JSON['parse']((0x0,fs_1[a3_0x15ef('0x3a')])(a3_0x15ef('0x30'))[a3_0x15ef('0xb')]());return _0x55ca2d[a3_0x15ef('0x42')][a3_0x15ef('0x2c')]||_0x55ca2d['devDependencies']['@nrwl/nx-cloud'];}catch(_0x36652e){return a3_0x15ef('0x25');}}}exports[a3_0x15ef('0x43')]=CloudRunApi;
+const a3_0x31f7=['apply','apiError','Stack\x20Trace:','createApiAxiosInstance','response','axiosException','slice','printDuration','messages','zlib','Invalid\x20end\x20run\x20response','getRunGroup','gzip','Run\x20Details:','mapRespToPerfEntry','post','Invalid\x20Nx\x20Cloud\x20response:\x20','createReqBody','note','machineInfo','/nx-cloud/runs/end','stack','axiosMultipleTries','parse','../../../utilities/environment','devDependencies','map','value','RUNNER_FAILURE_PERF_ENTRY','Nx\x20Cloud:\x20Unknown\x20Error\x20Occurred','message','startRun','error','__awaiter','runContext','isConnectedToPrivateCloud','api','../../../utilities/nx-imports','urls','util','from','terminalOutput','recordMetric','...','next','success','runUrl','assign','getBranch','endRun','nxCloudVersion','../../../utilities/metric-logger','createMetricRecorder','stringify','promisify','uploadedToStorage','apiAxiosInstance','Invalid\x20end\x20run\x20response:\x20','data','extractErrorMessage','RunStart\x20duration','RunEnd.\x20Completed\x20tasks','throw','getCIExecutionId','string','VERBOSE_LOGGING','status','CloudRunApi','done','Run\x20completion\x20responded\x20with\x20`undefined`.','defineProperty'];(function(_0x16c578,_0x31f7b){const _0xe598a6=function(_0x1ec9e2){while(--_0x1ec9e2){_0x16c578['push'](_0x16c578['shift']());}};_0xe598a6(++_0x31f7b);}(a3_0x31f7,0xc3));const a3_0xe598=function(_0x16c578,_0x31f7b){_0x16c578=_0x16c578-0x0;let _0xe598a6=a3_0x31f7[_0x16c578];return _0xe598a6;};'use strict';var __awaiter=this&&this[a3_0xe598('0x33')]||function(_0x1eed4f,_0x167442,_0x1f096a,_0x51042f){function _0x2279df(_0x5c869c){return _0x5c869c instanceof _0x1f096a?_0x5c869c:new _0x1f096a(function(_0x111064){_0x111064(_0x5c869c);});}return new(_0x1f096a||(_0x1f096a=Promise))(function(_0x13cccb,_0x185f0c){function _0x164f43(_0xa01128){try{_0x5e8fe4(_0x51042f[a3_0xe598('0x3e')](_0xa01128));}catch(_0x3ae33d){_0x185f0c(_0x3ae33d);}}function _0x2caf38(_0x4d7a71){try{_0x5e8fe4(_0x51042f[a3_0xe598('0x9')](_0x4d7a71));}catch(_0x29e410){_0x185f0c(_0x29e410);}}function _0x5e8fe4(_0x5e0fbe){_0x5e0fbe[a3_0xe598('0xf')]?_0x13cccb(_0x5e0fbe[a3_0xe598('0x2d')]):_0x2279df(_0x5e0fbe[a3_0xe598('0x2d')])['then'](_0x164f43,_0x2caf38);}_0x5e8fe4((_0x51042f=_0x51042f[a3_0xe598('0x12')](_0x1eed4f,_0x167442||[]))[a3_0xe598('0x3e')]());});};Object[a3_0xe598('0x11')](exports,'__esModule',{'value':!![]});exports[a3_0xe598('0xe')]=void 0x0;const axios_1=require('../../../utilities/axios');const environment_1=require(a3_0xe598('0x2a'));const fs_1=require('fs');const zlib_1=require(a3_0xe598('0x1b'));const util_1=require(a3_0xe598('0x39'));const metric_logger_1=require(a3_0xe598('0x45'));const is_private_cloud_1=require('../../../utilities/is-private-cloud');const {output}=require(a3_0xe598('0x37'));class CloudRunApi{constructor(_0x17fc48,_0x77c247,_0x27a2a1,_0x1a7c5c){this[a3_0xe598('0x1a')]=_0x17fc48;this[a3_0xe598('0x34')]=_0x77c247;this['machineInfo']=_0x1a7c5c;this[a3_0xe598('0x3')]=(0x0,axios_1[a3_0xe598('0x15')])(_0x27a2a1);}[a3_0xe598('0x31')](_0x3d2460,_0x2508d1){var _0x44bc9f;return __awaiter(this,void 0x0,void 0x0,function*(){if(this['messages']['apiError'])return{};const _0x487ffd=(0x0,metric_logger_1[a3_0xe598('0x46')])(a3_0xe598('0x31'));try{const _0x15b455={'meta':{'nxCloudVersion':this[a3_0xe598('0x44')]()},'branch':(0x0,environment_1[a3_0xe598('0x42')])(),'runGroup':(0x0,environment_1[a3_0xe598('0x1d')])(),'ciExecutionId':(0x0,environment_1[a3_0xe598('0xa')])(),'ciExecutionEnv':(0x0,environment_1['getCIExecutionEnv'])(),'distributedExecutionId':_0x3d2460,'hashes':_0x2508d1};if(environment_1['VERBOSE_LOGGING']){output['note']({'title':'RunStart','bodyLines':['\x0a'+JSON[a3_0xe598('0x0')](_0x15b455,null,0x2)]});}const _0x2c5044=yield(0x0,axios_1[a3_0xe598('0x19')])(a3_0xe598('0x7'),()=>(0x0,axios_1[a3_0xe598('0x28')])(()=>this[a3_0xe598('0x3')][a3_0xe598('0x21')]('/nx-cloud/runs/start',_0x15b455)));_0x487ffd[a3_0xe598('0x3c')]((0x0,metric_logger_1[a3_0xe598('0x20')])(_0x2c5044));if(_0x2c5044['data']&&_0x2c5044[a3_0xe598('0x5')]['message']){this[a3_0xe598('0x1a')][a3_0xe598('0x30')]=_0x2c5044[a3_0xe598('0x5')]['message'];}if(!_0x2c5044[a3_0xe598('0x5')]||!_0x2c5044[a3_0xe598('0x5')][a3_0xe598('0x38')]){this[a3_0xe598('0x1a')][a3_0xe598('0x13')]=a3_0xe598('0x22')+JSON['stringify'](_0x2c5044['data']);return{};}return _0x2c5044[a3_0xe598('0x5')][a3_0xe598('0x38')];}catch(_0x1427c0){_0x487ffd['recordMetric'](((_0x44bc9f=_0x1427c0===null||_0x1427c0===void 0x0?void 0x0:_0x1427c0['axiosException'])===null||_0x44bc9f===void 0x0?void 0x0:_0x44bc9f[a3_0xe598('0x16')])?(0x0,metric_logger_1[a3_0xe598('0x20')])(_0x1427c0[a3_0xe598('0x17')]['response']):metric_logger_1[a3_0xe598('0x2e')]);this[a3_0xe598('0x1a')]['apiError']=this[a3_0xe598('0x1a')][a3_0xe598('0x6')](_0x1427c0,a3_0xe598('0x36'));return{};}});}[a3_0xe598('0x23')](_0x5dde42,_0xe4d03a,_0x183c1b,_0x4ca1de){if((0x0,is_private_cloud_1['isConnectedToPrivateCloud'])()){for(let _0x145d85 of _0xe4d03a){delete _0x145d85[a3_0xe598('0x2')];}}const _0xbca24b=Object[a3_0xe598('0x41')](Object[a3_0xe598('0x41')]({'meta':{'nxCloudVersion':this[a3_0xe598('0x44')]()},'tasks':_0xe4d03a,'run':_0x5dde42,'linkId':_0x4ca1de},(0x0,is_private_cloud_1[a3_0xe598('0x35')])()?{}:_0x183c1b),{'machineInfo':this[a3_0xe598('0x25')]});return JSON['stringify'](_0xbca24b);}[a3_0xe598('0x43')](_0x3120c8,_0x547526,_0x14b4f8,_0x32e0d3){var _0x24ecb7,_0x5cba22;return __awaiter(this,void 0x0,void 0x0,function*(){if(this[a3_0xe598('0x1a')][a3_0xe598('0x13')])return![];let _0x140de4=this[a3_0xe598('0x23')](_0x3120c8,_0x547526,_0x14b4f8,_0x32e0d3);if(_0x140de4['length']>0x14*0x3e8*0x3e8){_0x140de4=this[a3_0xe598('0x23')](_0x3120c8,_0x547526[a3_0xe598('0x2c')](_0x8a2cc2=>Object[a3_0xe598('0x41')](Object[a3_0xe598('0x41')]({},_0x8a2cc2),{'hashDetails':undefined})),_0x14b4f8,_0x32e0d3);}const _0x1f2922=Buffer[a3_0xe598('0x3a')](_0x140de4);const _0x293078=yield(0x0,util_1[a3_0xe598('0x1')])(zlib_1[a3_0xe598('0x1e')])(_0x1f2922);const _0x933b03=(0x0,metric_logger_1[a3_0xe598('0x46')])(a3_0xe598('0x43'));try{if(environment_1[a3_0xe598('0xc')]){const _0x11e884=_0x547526[a3_0xe598('0x2c')](_0x5de1a7=>{return Object['assign'](Object[a3_0xe598('0x41')]({},_0x5de1a7),{'terminalOutput':_0x5de1a7[a3_0xe598('0x3b')]?_0x5de1a7['terminalOutput'][a3_0xe598('0x18')](0x0,0x14)+a3_0xe598('0x3d'):undefined});});output[a3_0xe598('0x24')]({'title':a3_0xe598('0x8'),'bodyLines':['\x0a'+JSON['stringify'](_0x11e884,null,0x2)]});}const _0x7e0e86=yield(0x0,axios_1[a3_0xe598('0x19')])('RunEnd\x20duration',()=>(0x0,axios_1[a3_0xe598('0x28')])(()=>this[a3_0xe598('0x3')][a3_0xe598('0x21')](a3_0xe598('0x26'),_0x293078,{'headers':Object[a3_0xe598('0x41')](Object[a3_0xe598('0x41')]({},this[a3_0xe598('0x3')]['defaults']['headers']),{'Content-Encoding':a3_0xe598('0x1e'),'Content-Type':'application/octet-stream'})})));if(_0x7e0e86){_0x933b03[a3_0xe598('0x3c')]((0x0,metric_logger_1[a3_0xe598('0x20')])(_0x7e0e86));if(_0x7e0e86[a3_0xe598('0x5')]&&_0x7e0e86[a3_0xe598('0x5')][a3_0xe598('0x40')]&&_0x7e0e86['data'][a3_0xe598('0xd')]===a3_0xe598('0x3f')){this[a3_0xe598('0x34')][a3_0xe598('0x40')]=_0x7e0e86[a3_0xe598('0x5')][a3_0xe598('0x40')];return!![];}if(_0x7e0e86[a3_0xe598('0x5')]&&_0x7e0e86[a3_0xe598('0x5')][a3_0xe598('0xd')]){this[a3_0xe598('0x1a')][a3_0xe598('0x13')]=a3_0xe598('0x4')+JSON[a3_0xe598('0x0')](_0x7e0e86[a3_0xe598('0x5')][a3_0xe598('0x30')]);}else if(_0x7e0e86[a3_0xe598('0x5')]&&typeof _0x7e0e86[a3_0xe598('0x5')]===a3_0xe598('0xb')){if(_0x7e0e86[a3_0xe598('0x5')]!==a3_0xe598('0x3f')){this[a3_0xe598('0x1a')][a3_0xe598('0x13')]=a3_0xe598('0x4')+JSON[a3_0xe598('0x0')](_0x7e0e86['data']);}}else{this['messages'][a3_0xe598('0x13')]='Invalid\x20end\x20run\x20response:\x20'+JSON[a3_0xe598('0x0')](_0x7e0e86[a3_0xe598('0x5')]);}if(environment_1[a3_0xe598('0xc')]){output[a3_0xe598('0x24')]({'title':a3_0xe598('0x1c'),'bodyLines':[JSON[a3_0xe598('0x0')](_0x7e0e86[a3_0xe598('0x5')],null,0x2)]});}}else{output[a3_0xe598('0x32')]({'title':a3_0xe598('0x2f'),'bodyLines':[a3_0xe598('0x10'),a3_0xe598('0x1f'),JSON[a3_0xe598('0x0')](_0x3120c8,null,0x2),a3_0xe598('0x14'),JSON['stringify'](new Error()[a3_0xe598('0x27')],null,0x2)]});}return![];}catch(_0x18e020){_0x933b03[a3_0xe598('0x3c')](((_0x24ecb7=_0x18e020===null||_0x18e020===void 0x0?void 0x0:_0x18e020['axiosException'])===null||_0x24ecb7===void 0x0?void 0x0:_0x24ecb7[a3_0xe598('0x16')])?(0x0,metric_logger_1['mapRespToPerfEntry'])(_0x18e020[a3_0xe598('0x17')][a3_0xe598('0x16')]):metric_logger_1[a3_0xe598('0x2e')]);const _0x3efa68=(_0x5cba22=_0x18e020[a3_0xe598('0x17')])!==null&&_0x5cba22!==void 0x0?_0x5cba22:_0x18e020;this['messages']['apiError']=this[a3_0xe598('0x1a')][a3_0xe598('0x6')](_0x3efa68,a3_0xe598('0x36'));return![];}});}[a3_0xe598('0x44')](){try{const _0x4c34d3=JSON[a3_0xe598('0x29')]((0x0,fs_1['readFileSync'])('package.json')['toString']());return _0x4c34d3['devDependencies']['nx-cloud']||_0x4c34d3[a3_0xe598('0x2b')]['@nrwl/nx-cloud'];}catch(_0x15bdeb){return'unknown';}}}exports[a3_0xe598('0xe')]=CloudRunApi;

lib/core/runners/cloud-enabled/id-generator.js

@@ -1,1 +0,1 @@
-const a4_0x3192=['length','ABCDEFGHIJKLMNOPQRSTUVWXYZ','__esModule','0123456789','toLowerCase','floor','generateUniqueLinkId','defineProperty'];(function(_0x4ffe96,_0x3192f1){const _0x3723f3=function(_0x2c35a7){while(--_0x2c35a7){_0x4ffe96['push'](_0x4ffe96['shift']());}};_0x3723f3(++_0x3192f1);}(a4_0x3192,0x1b4));const a4_0x3723=function(_0x4ffe96,_0x3192f1){_0x4ffe96=_0x4ffe96-0x0;let _0x3723f3=a4_0x3192[_0x4ffe96];return _0x3723f3;};'use strict';Object[a4_0x3723('0x3')](exports,a4_0x3723('0x6'),{'value':!![]});exports[a4_0x3723('0x2')]=void 0x0;const upper=a4_0x3723('0x5');const digits=a4_0x3723('0x7');const lower=upper[a4_0x3723('0x0')]();const alphanum=upper+lower+digits;function generateUniqueLinkId(){let _0x300927='';for(let _0x4baa4a=0x0;_0x4baa4a<0xa;++_0x4baa4a){_0x300927+=alphanum[Math[a4_0x3723('0x1')](Math['random']()*alphanum[a4_0x3723('0x4')])];}return _0x300927;}exports['generateUniqueLinkId']=generateUniqueLinkId;
+const a4_0x1cba=['ABCDEFGHIJKLMNOPQRSTUVWXYZ','0123456789','length','generateUniqueLinkId','defineProperty','__esModule','random','floor'];(function(_0x113ea4,_0x1cbaaf){const _0x33c1e7=function(_0x19c107){while(--_0x19c107){_0x113ea4['push'](_0x113ea4['shift']());}};_0x33c1e7(++_0x1cbaaf);}(a4_0x1cba,0xac));const a4_0x33c1=function(_0x113ea4,_0x1cbaaf){_0x113ea4=_0x113ea4-0x0;let _0x33c1e7=a4_0x1cba[_0x113ea4];return _0x33c1e7;};'use strict';Object[a4_0x33c1('0x0')](exports,a4_0x33c1('0x1'),{'value':!![]});exports[a4_0x33c1('0x7')]=void 0x0;const upper=a4_0x33c1('0x4');const digits=a4_0x33c1('0x5');const lower=upper['toLowerCase']();const alphanum=upper+lower+digits;function generateUniqueLinkId(){let _0x98afaa='';for(let _0x270c9b=0x0;_0x270c9b<0xa;++_0x270c9b){_0x98afaa+=alphanum[Math[a4_0x33c1('0x3')](Math[a4_0x33c1('0x2')]()*alphanum[a4_0x33c1('0x6')])];}return _0x98afaa;}exports['generateUniqueLinkId']=generateUniqueLinkId;

lib/core/runners/distributed-agent/distributed-agent.api.js

@@ -1,1 +0,1 @@
-const a5_0x3fd6=['ciExecutionId','ciExecutionEnv:\x20','done','../../../utilities/nx-imports','axiosException','then','error','response','../../../utilities/environment','ciExecutionEnv','tasks','post','DistributedAgentApi','__esModule','createMetricRecorder','error:\x20','VERBOSE_LOGGING','RUNNER_FAILURE_PERF_ENTRY','runGroup:\x20','mapRespToPerfEntry','../../../utilities/axios','defineProperty','__awaiter','axiosMultipleTries','next','branch','apiAxiosInstance','apply','/nx-cloud/executions/complete-run-group','throw','agentName','runGroup','completeRunGroupWithError','/nx-cloud/executions/tasks','note','ciExecutionId:\x20','recordMetric','value'];(function(_0x4016e5,_0x3fd6a5){const _0x326e35=function(_0x5a0c56){while(--_0x5a0c56){_0x4016e5['push'](_0x4016e5['shift']());}};_0x326e35(++_0x3fd6a5);}(a5_0x3fd6,0x171));const a5_0x326e=function(_0x4016e5,_0x3fd6a5){_0x4016e5=_0x4016e5-0x0;let _0x326e35=a5_0x3fd6[_0x4016e5];return _0x326e35;};'use strict';var __awaiter=this&&this[a5_0x326e('0x21')]||function(_0x43267d,_0x4a6949,_0xbcff8e,_0x3330e6){function _0x185e41(_0x24e6bf){return _0x24e6bf instanceof _0xbcff8e?_0x24e6bf:new _0xbcff8e(function(_0x4207f9){_0x4207f9(_0x24e6bf);});}return new(_0xbcff8e||(_0xbcff8e=Promise))(function(_0x2df85a,_0x311c56){function _0x386e3c(_0x418ac6){try{_0x3df263(_0x3330e6[a5_0x326e('0x23')](_0x418ac6));}catch(_0xf481c7){_0x311c56(_0xf481c7);}}function _0x58400b(_0x2e7a49){try{_0x3df263(_0x3330e6[a5_0x326e('0x2')](_0x2e7a49));}catch(_0x1864c1){_0x311c56(_0x1864c1);}}function _0x3df263(_0x598e03){_0x598e03[a5_0x326e('0xd')]?_0x2df85a(_0x598e03[a5_0x326e('0xa')]):_0x185e41(_0x598e03[a5_0x326e('0xa')])[a5_0x326e('0x10')](_0x386e3c,_0x58400b);}_0x3df263((_0x3330e6=_0x3330e6[a5_0x326e('0x0')](_0x43267d,_0x4a6949||[]))[a5_0x326e('0x23')]());});};Object[a5_0x326e('0x20')](exports,a5_0x326e('0x18'),{'value':!![]});exports[a5_0x326e('0x17')]=void 0x0;const axios_1=require(a5_0x326e('0x1f'));const environment_1=require(a5_0x326e('0x13'));const metric_logger_1=require('../../../utilities/metric-logger');const {output}=require(a5_0x326e('0xe'));class DistributedAgentApi{constructor(_0x119fb2,_0x1123d4,_0x255b7f,_0x2ed522,_0x1f0f34,_0x261f19){this[a5_0x326e('0x24')]=_0x1123d4;this['runGroup']=_0x255b7f;this[a5_0x326e('0xb')]=_0x2ed522;this[a5_0x326e('0x14')]=_0x1f0f34;this['agentName']=_0x261f19;this['apiAxiosInstance']=(0x0,axios_1['createApiAxiosInstance'])(_0x119fb2);}[a5_0x326e('0x15')](_0x2180ad,_0x5e0741,_0x5a3f8c,_0x4bb877){var _0x52431e;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x51846d=(0x0,metric_logger_1['createMetricRecorder'])('dtePollTasks');try{const _0x41aff7=yield(0x0,axios_1[a5_0x326e('0x22')])(()=>this[a5_0x326e('0x25')][a5_0x326e('0x16')](a5_0x326e('0x6'),{'runGroup':this[a5_0x326e('0x4')],'ciExecutionId':this[a5_0x326e('0xb')],'ciExecutionEnv':this[a5_0x326e('0x14')],'agentName':this[a5_0x326e('0x3')],'executionId':_0x2180ad,'statusCode':_0x5e0741,'completedTasks':_0x5a3f8c,'targets':_0x4bb877}));_0x51846d['recordMetric']((0x0,metric_logger_1[a5_0x326e('0x1e')])(_0x41aff7));return _0x41aff7['data'];}catch(_0x1297ab){_0x51846d['recordMetric'](((_0x52431e=_0x1297ab===null||_0x1297ab===void 0x0?void 0x0:_0x1297ab['axiosException'])===null||_0x52431e===void 0x0?void 0x0:_0x52431e[a5_0x326e('0x12')])?(0x0,metric_logger_1[a5_0x326e('0x1e')])(_0x1297ab[a5_0x326e('0xf')][a5_0x326e('0x12')]):metric_logger_1[a5_0x326e('0x1c')]);throw _0x1297ab;}});}[a5_0x326e('0x5')](_0xa3aa83){var _0x5f01e7;return __awaiter(this,void 0x0,void 0x0,function*(){if(environment_1['VERBOSE_LOGGING']){output[a5_0x326e('0x7')]({'title':'Completing\x20with\x20an\x20error','bodyLines':[a5_0x326e('0x8')+this[a5_0x326e('0xb')],a5_0x326e('0xc')+this[a5_0x326e('0x14')],a5_0x326e('0x1d')+this[a5_0x326e('0x4')],a5_0x326e('0x1a')+_0xa3aa83]});}const _0x4eab99=(0x0,metric_logger_1[a5_0x326e('0x19')])('completeRunGroup');try{const _0x41e074=yield(0x0,axios_1[a5_0x326e('0x22')])(()=>this[a5_0x326e('0x25')][a5_0x326e('0x16')](a5_0x326e('0x1'),{'branch':this[a5_0x326e('0x24')],'runGroup':this[a5_0x326e('0x4')],'ciExecutionId':this[a5_0x326e('0xb')],'ciExecutionEnv':this[a5_0x326e('0x14')],'agentName':this['agentName'],'criticalErrorMessage':_0xa3aa83}));if(environment_1[a5_0x326e('0x1b')]){output[a5_0x326e('0x7')]({'title':'Completed\x20run\x20group\x20with\x20an\x20error'});}_0x4eab99[a5_0x326e('0x9')]((0x0,metric_logger_1[a5_0x326e('0x1e')])(_0x41e074));}catch(_0x56069b){_0x4eab99[a5_0x326e('0x9')](((_0x5f01e7=_0x56069b===null||_0x56069b===void 0x0?void 0x0:_0x56069b[a5_0x326e('0xf')])===null||_0x5f01e7===void 0x0?void 0x0:_0x5f01e7['response'])?(0x0,metric_logger_1['mapRespToPerfEntry'])(_0x56069b['axiosException'][a5_0x326e('0x12')]):metric_logger_1[a5_0x326e('0x1c')]);console[a5_0x326e('0x11')](_0x56069b);}});}}exports['DistributedAgentApi']=DistributedAgentApi;
+const a5_0x419c=['data','apply','throw','ciExecutionEnv:\x20','../../../utilities/axios','completeRunGroupWithError','__esModule','apiAxiosInstance','agentName','dtePollTasks','VERBOSE_LOGGING','post','note','__awaiter','error:\x20','RUNNER_FAILURE_PERF_ENTRY','../../../utilities/nx-imports','error','response','defineProperty','runGroup:\x20','axiosMultipleTries','ciExecutionEnv','Completing\x20with\x20an\x20error','branch','../../../utilities/environment','createMetricRecorder','../../../utilities/metric-logger','next','axiosException','createApiAxiosInstance','tasks','ciExecutionId','value','runGroup','/nx-cloud/executions/tasks','recordMetric','mapRespToPerfEntry','/nx-cloud/executions/complete-run-group','Completed\x20run\x20group\x20with\x20an\x20error','DistributedAgentApi','then'];(function(_0x5a85da,_0x419c30){const _0x5a1de4=function(_0x34e763){while(--_0x34e763){_0x5a85da['push'](_0x5a85da['shift']());}};_0x5a1de4(++_0x419c30);}(a5_0x419c,0x1e0));const a5_0x5a1d=function(_0x5a85da,_0x419c30){_0x5a85da=_0x5a85da-0x0;let _0x5a1de4=a5_0x419c[_0x5a85da];return _0x5a1de4;};'use strict';var __awaiter=this&&this[a5_0x5a1d('0x25')]||function(_0x49069a,_0x22004c,_0x20ac07,_0x29eb46){function _0x334cd4(_0x96aebc){return _0x96aebc instanceof _0x20ac07?_0x96aebc:new _0x20ac07(function(_0x3d9cc2){_0x3d9cc2(_0x96aebc);});}return new(_0x20ac07||(_0x20ac07=Promise))(function(_0xea4631,_0x2d71c0){function _0x4ff8e0(_0x1476f7){try{_0x2668fa(_0x29eb46[a5_0x5a1d('0xa')](_0x1476f7));}catch(_0x1069f9){_0x2d71c0(_0x1069f9);}}function _0x2a012d(_0x3f62f3){try{_0x2668fa(_0x29eb46[a5_0x5a1d('0x1a')](_0x3f62f3));}catch(_0x1b1338){_0x2d71c0(_0x1b1338);}}function _0x2668fa(_0xb8168b){_0xb8168b['done']?_0xea4631(_0xb8168b['value']):_0x334cd4(_0xb8168b[a5_0x5a1d('0xf')])[a5_0x5a1d('0x17')](_0x4ff8e0,_0x2a012d);}_0x2668fa((_0x29eb46=_0x29eb46[a5_0x5a1d('0x19')](_0x49069a,_0x22004c||[]))[a5_0x5a1d('0xa')]());});};Object[a5_0x5a1d('0x1')](exports,a5_0x5a1d('0x1e'),{'value':!![]});exports['DistributedAgentApi']=void 0x0;const axios_1=require(a5_0x5a1d('0x1c'));const environment_1=require(a5_0x5a1d('0x7'));const metric_logger_1=require(a5_0x5a1d('0x9'));const {output}=require(a5_0x5a1d('0x28'));class DistributedAgentApi{constructor(_0xc2b8f7,_0x12f563,_0x19c06f,_0x256d69,_0x561958,_0x1c1afd){this['branch']=_0x12f563;this[a5_0x5a1d('0x10')]=_0x19c06f;this[a5_0x5a1d('0xe')]=_0x256d69;this[a5_0x5a1d('0x4')]=_0x561958;this['agentName']=_0x1c1afd;this[a5_0x5a1d('0x1f')]=(0x0,axios_1[a5_0x5a1d('0xc')])(_0xc2b8f7);}[a5_0x5a1d('0xd')](_0x4e6bac,_0x3da582,_0x146d02,_0x545eb1){var _0x3557f9;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x40992b=(0x0,metric_logger_1[a5_0x5a1d('0x8')])(a5_0x5a1d('0x21'));try{const _0x2a6d8d=yield(0x0,axios_1['axiosMultipleTries'])(()=>this[a5_0x5a1d('0x1f')][a5_0x5a1d('0x23')](a5_0x5a1d('0x11'),{'runGroup':this['runGroup'],'ciExecutionId':this[a5_0x5a1d('0xe')],'ciExecutionEnv':this[a5_0x5a1d('0x4')],'agentName':this[a5_0x5a1d('0x20')],'executionId':_0x4e6bac,'statusCode':_0x3da582,'completedTasks':_0x146d02,'targets':_0x545eb1}));_0x40992b[a5_0x5a1d('0x12')]((0x0,metric_logger_1[a5_0x5a1d('0x13')])(_0x2a6d8d));return _0x2a6d8d[a5_0x5a1d('0x18')];}catch(_0x38eb9c){_0x40992b[a5_0x5a1d('0x12')](((_0x3557f9=_0x38eb9c===null||_0x38eb9c===void 0x0?void 0x0:_0x38eb9c[a5_0x5a1d('0xb')])===null||_0x3557f9===void 0x0?void 0x0:_0x3557f9[a5_0x5a1d('0x0')])?(0x0,metric_logger_1[a5_0x5a1d('0x13')])(_0x38eb9c[a5_0x5a1d('0xb')][a5_0x5a1d('0x0')]):metric_logger_1[a5_0x5a1d('0x27')]);throw _0x38eb9c;}});}[a5_0x5a1d('0x1d')](_0x256da1){var _0x14b2f4;return __awaiter(this,void 0x0,void 0x0,function*(){if(environment_1[a5_0x5a1d('0x22')]){output[a5_0x5a1d('0x24')]({'title':a5_0x5a1d('0x5'),'bodyLines':['ciExecutionId:\x20'+this[a5_0x5a1d('0xe')],a5_0x5a1d('0x1b')+this['ciExecutionEnv'],a5_0x5a1d('0x2')+this[a5_0x5a1d('0x10')],a5_0x5a1d('0x26')+_0x256da1]});}const _0x1dbd0a=(0x0,metric_logger_1[a5_0x5a1d('0x8')])('completeRunGroup');try{const _0x484fe0=yield(0x0,axios_1[a5_0x5a1d('0x3')])(()=>this[a5_0x5a1d('0x1f')][a5_0x5a1d('0x23')](a5_0x5a1d('0x14'),{'branch':this[a5_0x5a1d('0x6')],'runGroup':this[a5_0x5a1d('0x10')],'ciExecutionId':this[a5_0x5a1d('0xe')],'ciExecutionEnv':this[a5_0x5a1d('0x4')],'agentName':this[a5_0x5a1d('0x20')],'criticalErrorMessage':_0x256da1}));if(environment_1[a5_0x5a1d('0x22')]){output[a5_0x5a1d('0x24')]({'title':a5_0x5a1d('0x15')});}_0x1dbd0a[a5_0x5a1d('0x12')]((0x0,metric_logger_1[a5_0x5a1d('0x13')])(_0x484fe0));}catch(_0x3d4ca8){_0x1dbd0a[a5_0x5a1d('0x12')](((_0x14b2f4=_0x3d4ca8===null||_0x3d4ca8===void 0x0?void 0x0:_0x3d4ca8[a5_0x5a1d('0xb')])===null||_0x14b2f4===void 0x0?void 0x0:_0x14b2f4[a5_0x5a1d('0x0')])?(0x0,metric_logger_1['mapRespToPerfEntry'])(_0x3d4ca8[a5_0x5a1d('0xb')][a5_0x5a1d('0x0')]):metric_logger_1[a5_0x5a1d('0x27')]);console[a5_0x5a1d('0x29')](_0x3d4ca8);}});}}exports[a5_0x5a1d('0x16')]=DistributedAgentApi;

lib/core/runners/distributed-agent/distributed-agent.impl.js

@@ -1,1 +0,1 @@
-const a6_0x569d=['Other\x20Nx\x20Cloud\x20Agents\x20Detected','invokeTasksUsingNxImperativeApi','Agent\x20','next','../../error/print-cacheable-targets-error','./execute-tasks','Organization\x20administrators\x20can\x20find\x20more\x20information\x20on\x20the\x20\x27Billing\x20and\x20Plans\x27\x20page\x20in\x20the\x20Nx\x20Cloud\x20Webapp','warn','printCacheableTargetsError','../../../utilities/nx-imports','existsSync','../../../utilities/is-workspace-enabled','printRunGroupError','getCIExecutionEnv','then','Starting\x20an\x20agent\x20for\x20running\x20Nx\x20target(s)\x20[','options','Agent\x20was\x20terminated\x20via\x20SIGINT','error','../../file-storage/file-storage','ENCRYPTION_KEY','/lockfiles','value','split','some','strip-json-comments','../../file-storage/e2e-encryption','readdirSync','We\x20have\x20detected\x20another\x20agent\x20with\x20this\x20ID\x20running\x20in\x20this\x20workspace.\x20This\x20should\x20not\x20happen.','submitRunMetrics','readFileSync','floor','mkdirSync','cacheableOperations','runner','SIGTERM','NX_AGENT_NAME','.lock','message','length','tasksRunnerOptions','../../../utilities/metric-logger','getCIExecutionId','__esModule','parse','Agent\x20was\x20terminated\x20via\x20SIGTERM','SIGINT','toString','executeTasks','__awaiter','@nrwl/nx-cloud','getRunGroup','End\x20all\x20currently\x20running\x20agents,\x20run\x20\x22npx\x20nx-cloud\x20clean-up-agents\x22,\x20and\x20try\x20again.','Starting\x20an\x20agent\x20for\x20running\x20Nx\x20tasks','dte-agent','ErrorReporterApi','/nx.json','random','map','invokeTasksUsingRunMany','note','./invoke-tasks-using-run-many','We\x20have\x20detected\x20other\x20agents\x20running\x20in\x20this\x20workspace.\x20This\x20can\x20cause\x20unexpected\x20behavior.','FileStorage','isWorkspaceEnabled','../../../utilities/dte-artifact-storage','writeFileSync','canDetectRunGroup','targets','encryptionKey','yargs-parser','join','catch','./invoke-tasks-using-nx-imperative-api','startAgent','CIRCLE_STAGE','E2EEncryption','includes','DistributedAgentApi','completeRunGroupWithError','throw','apply','CIRCLECI','exit','../../api/error-reporter.api','Distributed\x20Task\x20Execution\x20is\x20disabled\x20when\x20your\x20workspace\x20is\x20disabled','Duplicate\x20Agent\x20ID\x20Detected','CIRCLE_JOB','nx-cloud','DteArtifactStorage','env'];(function(_0x3157c2,_0x569d51){const _0x8c2635=function(_0x117d07){while(--_0x117d07){_0x3157c2['push'](_0x3157c2['shift']());}};_0x8c2635(++_0x569d51);}(a6_0x569d,0x133));const a6_0x8c26=function(_0x3157c2,_0x569d51){_0x3157c2=_0x3157c2-0x0;let _0x8c2635=a6_0x569d[_0x3157c2];return _0x8c2635;};'use strict';var __awaiter=this&&this[a6_0x8c26('0xf')]||function(_0x534a4d,_0x43188c,_0x2f9614,_0x224c4c){function _0x48c3da(_0x2dd054){return _0x2dd054 instanceof _0x2f9614?_0x2dd054:new _0x2f9614(function(_0x14e6e1){_0x14e6e1(_0x2dd054);});}return new(_0x2f9614||(_0x2f9614=Promise))(function(_0x1b13c6,_0x5e38d3){function _0x4f83a5(_0x3a695b){try{_0x4183bd(_0x224c4c[a6_0x8c26('0x3c')](_0x3a695b));}catch(_0x2b6231){_0x5e38d3(_0x2b6231);}}function _0x18cd8d(_0xbf501){try{_0x4183bd(_0x224c4c[a6_0x8c26('0x2e')](_0xbf501));}catch(_0x335a5a){_0x5e38d3(_0x335a5a);}}function _0x4183bd(_0x6c57e5){_0x6c57e5['done']?_0x1b13c6(_0x6c57e5['value']):_0x48c3da(_0x6c57e5[a6_0x8c26('0x4f')])[a6_0x8c26('0x47')](_0x4f83a5,_0x18cd8d);}_0x4183bd((_0x224c4c=_0x224c4c[a6_0x8c26('0x2f')](_0x534a4d,_0x43188c||[]))[a6_0x8c26('0x3c')]());});};Object['defineProperty'](exports,a6_0x8c26('0x9'),{'value':!![]});exports[a6_0x8c26('0x28')]=void 0x0;const fs_1=require('fs');const stripJsonComments=require(a6_0x8c26('0x52'));const yargsParser=require(a6_0x8c26('0x24'));const environment_1=require('../../../utilities/environment');const metric_logger_1=require(a6_0x8c26('0x7'));const print_cacheable_targets_error_1=require(a6_0x8c26('0x3d'));const print_invalid_runner_error_1=require('../../error/print-invalid-runner-error');const print_run_group_error_1=require('../../error/print-run-group-error');const distributed_agent_api_1=require('./distributed-agent.api');const execute_tasks_1=require(a6_0x8c26('0x3e'));const dte_artifact_storage_1=require(a6_0x8c26('0x1f'));const file_storage_1=require(a6_0x8c26('0x4c'));const e2e_encryption_1=require(a6_0x8c26('0x53'));const error_reporter_api_1=require(a6_0x8c26('0x32'));const invoke_tasks_using_run_many_1=require(a6_0x8c26('0x1b'));const invoke_tasks_using_nx_imperative_api_1=require(a6_0x8c26('0x27'));const is_workspace_enabled_1=require(a6_0x8c26('0x44'));const {output,initTasksRunner,workspaceRoot,cacheDirectory}=require(a6_0x8c26('0x42'));const args=yargsParser(process['argv'],{'array':[a6_0x8c26('0x22')],'default':{}});if(args[a6_0x8c26('0x22')]&&args[a6_0x8c26('0x22')][a6_0x8c26('0x5')]===0x1){args['targets']=args[a6_0x8c26('0x22')][0x0][a6_0x8c26('0x50')](',')[a6_0x8c26('0x18')](_0x3369c1=>_0x3369c1['trim']());}function startAgent(){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x6d7982=(0x0,environment_1['getBranch'])();const _0x27832b=(0x0,environment_1[a6_0x8c26('0x11')])();const _0x48817b=(0x0,environment_1[a6_0x8c26('0x8')])();const _0x4120fb=(0x0,environment_1[a6_0x8c26('0x46')])();if(!(0x0,print_run_group_error_1[a6_0x8c26('0x21')])(_0x27832b,_0x48817b)){(0x0,print_run_group_error_1[a6_0x8c26('0x45')])();process[a6_0x8c26('0x31')](0x1);}if(args['targets']&&args[a6_0x8c26('0x22')][a6_0x8c26('0x5')]){output[a6_0x8c26('0x1a')]({'title':a6_0x8c26('0x48')+args['targets'][a6_0x8c26('0x25')](',\x20')+']'});}else{output[a6_0x8c26('0x1a')]({'title':a6_0x8c26('0x13')});}const _0x446ccd=JSON[a6_0x8c26('0xa')](stripJsonComments((0x0,fs_1[a6_0x8c26('0x57')])(workspaceRoot+a6_0x8c26('0x16'))[a6_0x8c26('0xd')]()))[a6_0x8c26('0x6')]['default'];if(_0x446ccd[a6_0x8c26('0x0')]!==a6_0x8c26('0x36')&&_0x446ccd[a6_0x8c26('0x0')]!==a6_0x8c26('0x10')){(0x0,print_invalid_runner_error_1['printInvalidRunnerError'])();return process[a6_0x8c26('0x31')](0x1);}const _0x9cdfae=_0x446ccd[a6_0x8c26('0x49')];if(args[a6_0x8c26('0x22')]&&args[a6_0x8c26('0x22')][a6_0x8c26('0x51')](_0x559570=>{var _0x42ad60;return!((_0x42ad60=_0x9cdfae[a6_0x8c26('0x5a')])===null||_0x42ad60===void 0x0?void 0x0:_0x42ad60[a6_0x8c26('0x2b')](_0x559570));})){const _0x445d50=args['targets']['filter'](_0x22d9aa=>{var _0x2e8f65;return!((_0x2e8f65=_0x9cdfae[a6_0x8c26('0x5a')])===null||_0x2e8f65===void 0x0?void 0x0:_0x2e8f65['includes'](_0x22d9aa));});(0x0,print_cacheable_targets_error_1[a6_0x8c26('0x41')])(_0x445d50);return process[a6_0x8c26('0x31')](0x1);}const _0xba2995=yield(0x0,is_workspace_enabled_1[a6_0x8c26('0x1e')])(_0x9cdfae);if(!_0xba2995){output[a6_0x8c26('0x4b')]({'title':'Nx\x20Cloud:\x20Workspace\x20is\x20disabled','bodyLines':[a6_0x8c26('0x33'),'',a6_0x8c26('0x3f')]});process[a6_0x8c26('0x31')](0x1);}const _0x3d7f9d=getAgentName();const _0x2872fd=new distributed_agent_api_1[(a6_0x8c26('0x2c'))](_0x9cdfae,_0x6d7982,_0x27832b,_0x48817b,_0x4120fb,_0x3d7f9d);createAgentLockfileAndSetUpListeners(_0x2872fd,_0x9cdfae,_0x3d7f9d);const _0x333df1=new e2e_encryption_1[(a6_0x8c26('0x2a'))](environment_1[a6_0x8c26('0x4d')]||_0x9cdfae[a6_0x8c26('0x23')]);const _0x1d0bbb=new error_reporter_api_1[(a6_0x8c26('0x15'))](_0x9cdfae);const _0x3d1f02=new dte_artifact_storage_1[(a6_0x8c26('0x37'))](new file_storage_1[(a6_0x8c26('0x1d'))](_0x333df1,_0x1d0bbb,_0x9cdfae,a6_0x8c26('0x14')),cacheDirectory);const _0x37966f=initTasksRunner?yield(0x0,invoke_tasks_using_nx_imperative_api_1[a6_0x8c26('0x3a')])(_0x9cdfae):yield(0x0,invoke_tasks_using_run_many_1[a6_0x8c26('0x19')])();return(0x0,execute_tasks_1[a6_0x8c26('0xe')])(_0x3d7f9d,_0x2872fd,_0x3d1f02,_0x37966f,args[a6_0x8c26('0x22')])[a6_0x8c26('0x47')](_0x3fbefd=>__awaiter(this,void 0x0,void 0x0,function*(){yield(0x0,metric_logger_1[a6_0x8c26('0x56')])(_0x9cdfae);return _0x3fbefd;}))[a6_0x8c26('0x26')](_0x497a12=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x2872fd[a6_0x8c26('0x2d')]('Critical\x20Error\x20in\x20Agent:\x20\x22'+_0x497a12[a6_0x8c26('0x4')]+'\x22');throw _0x497a12;}));});}exports[a6_0x8c26('0x28')]=startAgent;function getAgentName(){if(process['env']['NX_AGENT_NAME']!==undefined){return process[a6_0x8c26('0x38')][a6_0x8c26('0x2')];}else if(process['env'][a6_0x8c26('0x30')]!==undefined&&process['env'][a6_0x8c26('0x29')]){return process[a6_0x8c26('0x38')][a6_0x8c26('0x29')];}else if(process[a6_0x8c26('0x38')][a6_0x8c26('0x30')]!==undefined&&process[a6_0x8c26('0x38')][a6_0x8c26('0x35')]){return process[a6_0x8c26('0x38')][a6_0x8c26('0x35')];}else{return a6_0x8c26('0x3b')+Math[a6_0x8c26('0x58')](Math[a6_0x8c26('0x17')]()*0x186a0);}}function createAgentLockfileAndSetUpListeners(_0x2574c9,_0x402426,_0xea4abd){const _0x57af73=cacheDirectory+a6_0x8c26('0x4e');const _0x33998e=_0x57af73+'/'+_0xea4abd+a6_0x8c26('0x3');if(!(0x0,fs_1[a6_0x8c26('0x43')])(_0x57af73)){(0x0,fs_1[a6_0x8c26('0x59')])(_0x57af73,{'recursive':!![]});}const _0x5b3a32=(0x0,fs_1[a6_0x8c26('0x54')])(_0x57af73);if(_0x5b3a32[a6_0x8c26('0x5')]){if(_0x5b3a32[a6_0x8c26('0x2b')](_0xea4abd+a6_0x8c26('0x3'))){output['error']({'title':a6_0x8c26('0x34'),'bodyLines':[a6_0x8c26('0x55'),'',a6_0x8c26('0x12')]});process[a6_0x8c26('0x31')](0x1);}output[a6_0x8c26('0x40')]({'title':a6_0x8c26('0x39'),'bodyLines':[a6_0x8c26('0x1c'),'','This\x20can\x20also\x20be\x20a\x20false\x20positive\x20caused\x20by\x20agents\x20that\x20did\x20not\x20shut\x20down\x20correctly.','If\x20you\x20believe\x20this\x20is\x20the\x20case,\x20run\x20\x22npx\x20nx-cloud\x20clean-up-agents\x22.']});}(0x0,fs_1[a6_0x8c26('0x20')])(_0x33998e,'');process['on'](a6_0x8c26('0x31'),_0x5f339b=>{cleanupAgentLockfile(_0x33998e,_0x5f339b);});process['on'](a6_0x8c26('0x1'),()=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x2574c9[a6_0x8c26('0x2d')](a6_0x8c26('0xb'));cleanupAgentLockfile(_0x33998e,0x1);}));process['on'](a6_0x8c26('0xc'),()=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x2574c9[a6_0x8c26('0x2d')](a6_0x8c26('0x4a'));cleanupAgentLockfile(_0x33998e,0x1);}));}function cleanupAgentLockfile(_0x4e69dd,_0x466034){if((0x0,fs_1['existsSync'])(_0x4e69dd)){(0x0,fs_1['unlinkSync'])(_0x4e69dd);process[a6_0x8c26('0x31')](_0x466034);}}
+const a6_0x12c8=['defineProperty','readdirSync','startAgent','../../api/error-reporter.api','note','throw','./execute-tasks','../../file-storage/file-storage','value','exit','We\x20have\x20detected\x20another\x20agent\x20with\x20this\x20ID\x20running\x20in\x20this\x20workspace.\x20This\x20should\x20not\x20happen.','Starting\x20an\x20agent\x20for\x20running\x20Nx\x20target(s)\x20[','ErrorReporterApi','../../../utilities/dte-artifact-storage','some','getCIExecutionId','printRunGroupError','strip-json-comments','writeFileSync','ENCRYPTION_KEY','next','map','Agent\x20','join','Other\x20Nx\x20Cloud\x20Agents\x20Detected','CIRCLE_JOB','options','targets','../../../utilities/metric-logger','isWorkspaceEnabled','split','dte-agent','printCacheableTargetsError','DistributedAgentApi','./distributed-agent.api','getBranch','apply','../../../utilities/environment','env','yargs-parser','Organization\x20administrators\x20can\x20find\x20more\x20information\x20on\x20the\x20\x27Billing\x20and\x20Plans\x27\x20page\x20in\x20the\x20Nx\x20Cloud\x20Webapp','runner','getRunGroup','If\x20you\x20believe\x20this\x20is\x20the\x20case,\x20run\x20\x22npx\x20nx-cloud\x20clean-up-agents\x22.','filter','/nx.json','../../../utilities/nx-imports','tasksRunnerOptions','mkdirSync','/lockfiles','../../error/print-cacheable-targets-error','canDetectRunGroup','.lock','CIRCLE_STAGE','We\x20have\x20detected\x20other\x20agents\x20running\x20in\x20this\x20workspace.\x20This\x20can\x20cause\x20unexpected\x20behavior.','Nx\x20Cloud:\x20Workspace\x20is\x20disabled','NX_AGENT_NAME','invokeTasksUsingRunMany','End\x20all\x20currently\x20running\x20agents,\x20run\x20\x22npx\x20nx-cloud\x20clean-up-agents\x22,\x20and\x20try\x20again.','then','E2EEncryption','error','cacheableOperations','length','includes','CIRCLECI','../../file-storage/e2e-encryption','../../../utilities/is-workspace-enabled','toString','Agent\x20was\x20terminated\x20via\x20SIGINT','argv','completeRunGroupWithError','message','random','catch','floor','./invoke-tasks-using-nx-imperative-api','Distributed\x20Task\x20Execution\x20is\x20disabled\x20when\x20your\x20workspace\x20is\x20disabled','parse','done','SIGINT','SIGTERM'];(function(_0x46607b,_0x12c863){const _0x299110=function(_0x5320db){while(--_0x5320db){_0x46607b['push'](_0x46607b['shift']());}};_0x299110(++_0x12c863);}(a6_0x12c8,0x18b));const a6_0x2991=function(_0x46607b,_0x12c863){_0x46607b=_0x46607b-0x0;let _0x299110=a6_0x12c8[_0x46607b];return _0x299110;};'use strict';var __awaiter=this&&this['__awaiter']||function(_0x249ab1,_0x58f5db,_0x30d9f0,_0x51218e){function _0x3b5c8f(_0xcbc06){return _0xcbc06 instanceof _0x30d9f0?_0xcbc06:new _0x30d9f0(function(_0x5e3cf5){_0x5e3cf5(_0xcbc06);});}return new(_0x30d9f0||(_0x30d9f0=Promise))(function(_0x18830c,_0x4c808a){function _0x1f5d27(_0x1444b7){try{_0x20aeae(_0x51218e[a6_0x2991('0x23')](_0x1444b7));}catch(_0x538630){_0x4c808a(_0x538630);}}function _0x1bbd5d(_0x511791){try{_0x20aeae(_0x51218e[a6_0x2991('0x14')](_0x511791));}catch(_0x2940e7){_0x4c808a(_0x2940e7);}}function _0x20aeae(_0x263d9a){_0x263d9a[a6_0x2991('0xc')]?_0x18830c(_0x263d9a[a6_0x2991('0x17')]):_0x3b5c8f(_0x263d9a['value'])[a6_0x2991('0x4a')](_0x1f5d27,_0x1bbd5d);}_0x20aeae((_0x51218e=_0x51218e[a6_0x2991('0x33')](_0x249ab1,_0x58f5db||[]))[a6_0x2991('0x23')]());});};Object[a6_0x2991('0xf')](exports,'__esModule',{'value':!![]});exports[a6_0x2991('0x11')]=void 0x0;const fs_1=require('fs');const stripJsonComments=require(a6_0x2991('0x20'));const yargsParser=require(a6_0x2991('0x36'));const environment_1=require(a6_0x2991('0x34'));const metric_logger_1=require(a6_0x2991('0x2b'));const print_cacheable_targets_error_1=require(a6_0x2991('0x41'));const print_invalid_runner_error_1=require('../../error/print-invalid-runner-error');const print_run_group_error_1=require('../../error/print-run-group-error');const distributed_agent_api_1=require(a6_0x2991('0x31'));const execute_tasks_1=require(a6_0x2991('0x15'));const dte_artifact_storage_1=require(a6_0x2991('0x1c'));const file_storage_1=require(a6_0x2991('0x16'));const e2e_encryption_1=require(a6_0x2991('0x51'));const error_reporter_api_1=require(a6_0x2991('0x12'));const invoke_tasks_using_run_many_1=require('./invoke-tasks-using-run-many');const invoke_tasks_using_nx_imperative_api_1=require(a6_0x2991('0x9'));const is_workspace_enabled_1=require(a6_0x2991('0x0'));const {output,initTasksRunner,workspaceRoot,cacheDirectory}=require(a6_0x2991('0x3d'));const args=yargsParser(process[a6_0x2991('0x3')],{'array':[a6_0x2991('0x2a')],'default':{}});if(args[a6_0x2991('0x2a')]&&args[a6_0x2991('0x2a')][a6_0x2991('0x4e')]===0x1){args[a6_0x2991('0x2a')]=args[a6_0x2991('0x2a')][0x0][a6_0x2991('0x2d')](',')[a6_0x2991('0x24')](_0x55f7d0=>_0x55f7d0['trim']());}function startAgent(){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x44bb1f=(0x0,environment_1[a6_0x2991('0x32')])();const _0x4c8748=(0x0,environment_1[a6_0x2991('0x39')])();const _0x575dc4=(0x0,environment_1[a6_0x2991('0x1e')])();const _0x285eb8=(0x0,environment_1['getCIExecutionEnv'])();if(!(0x0,print_run_group_error_1[a6_0x2991('0x42')])(_0x4c8748,_0x575dc4)){(0x0,print_run_group_error_1[a6_0x2991('0x1f')])();process['exit'](0x1);}if(args[a6_0x2991('0x2a')]&&args[a6_0x2991('0x2a')][a6_0x2991('0x4e')]){output[a6_0x2991('0x13')]({'title':a6_0x2991('0x1a')+args[a6_0x2991('0x2a')][a6_0x2991('0x26')](',\x20')+']'});}else{output[a6_0x2991('0x13')]({'title':'Starting\x20an\x20agent\x20for\x20running\x20Nx\x20tasks'});}const _0x3ffa5e=JSON[a6_0x2991('0xb')](stripJsonComments((0x0,fs_1['readFileSync'])(workspaceRoot+a6_0x2991('0x3c'))[a6_0x2991('0x1')]()))[a6_0x2991('0x3e')]['default'];if(_0x3ffa5e[a6_0x2991('0x38')]!=='nx-cloud'&&_0x3ffa5e['runner']!=='@nrwl/nx-cloud'){(0x0,print_invalid_runner_error_1['printInvalidRunnerError'])();return process[a6_0x2991('0x18')](0x1);}const _0x189a6b=_0x3ffa5e[a6_0x2991('0x29')];if(args['targets']&&args[a6_0x2991('0x2a')][a6_0x2991('0x1d')](_0x3c87c0=>{var _0x442c71;return!((_0x442c71=_0x189a6b[a6_0x2991('0x4d')])===null||_0x442c71===void 0x0?void 0x0:_0x442c71[a6_0x2991('0x4f')](_0x3c87c0));})){const _0x2a2a68=args['targets'][a6_0x2991('0x3b')](_0x44f2dc=>{var _0x5e694e;return!((_0x5e694e=_0x189a6b[a6_0x2991('0x4d')])===null||_0x5e694e===void 0x0?void 0x0:_0x5e694e[a6_0x2991('0x4f')](_0x44f2dc));});(0x0,print_cacheable_targets_error_1[a6_0x2991('0x2f')])(_0x2a2a68);return process[a6_0x2991('0x18')](0x1);}const _0x50b961=yield(0x0,is_workspace_enabled_1[a6_0x2991('0x2c')])(_0x189a6b);if(!_0x50b961){output[a6_0x2991('0x4c')]({'title':a6_0x2991('0x46'),'bodyLines':[a6_0x2991('0xa'),'',a6_0x2991('0x37')]});process[a6_0x2991('0x18')](0x1);}const _0x4af64a=getAgentName();const _0x2a7761=new distributed_agent_api_1[(a6_0x2991('0x30'))](_0x189a6b,_0x44bb1f,_0x4c8748,_0x575dc4,_0x285eb8,_0x4af64a);createAgentLockfileAndSetUpListeners(_0x2a7761,_0x189a6b,_0x4af64a);const _0x4ac795=new e2e_encryption_1[(a6_0x2991('0x4b'))](environment_1[a6_0x2991('0x22')]||_0x189a6b['encryptionKey']);const _0x3b0e4a=new error_reporter_api_1[(a6_0x2991('0x1b'))](_0x189a6b);const _0x426853=new dte_artifact_storage_1['DteArtifactStorage'](new file_storage_1['FileStorage'](_0x4ac795,_0x3b0e4a,_0x189a6b,a6_0x2991('0x2e')),cacheDirectory);const _0x40e1a3=initTasksRunner?yield(0x0,invoke_tasks_using_nx_imperative_api_1['invokeTasksUsingNxImperativeApi'])(_0x189a6b):yield(0x0,invoke_tasks_using_run_many_1[a6_0x2991('0x48')])();return(0x0,execute_tasks_1['executeTasks'])(_0x4af64a,_0x2a7761,_0x426853,_0x40e1a3,args[a6_0x2991('0x2a')])[a6_0x2991('0x4a')](_0x1b8afc=>__awaiter(this,void 0x0,void 0x0,function*(){yield(0x0,metric_logger_1['submitRunMetrics'])(_0x189a6b);return _0x1b8afc;}))[a6_0x2991('0x7')](_0x1799ed=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x2a7761[a6_0x2991('0x4')]('Critical\x20Error\x20in\x20Agent:\x20\x22'+_0x1799ed[a6_0x2991('0x5')]+'\x22');throw _0x1799ed;}));});}exports[a6_0x2991('0x11')]=startAgent;function getAgentName(){if(process['env'][a6_0x2991('0x47')]!==undefined){return process[a6_0x2991('0x35')][a6_0x2991('0x47')];}else if(process[a6_0x2991('0x35')][a6_0x2991('0x50')]!==undefined&&process[a6_0x2991('0x35')][a6_0x2991('0x44')]){return process[a6_0x2991('0x35')]['CIRCLE_STAGE'];}else if(process[a6_0x2991('0x35')][a6_0x2991('0x50')]!==undefined&&process[a6_0x2991('0x35')][a6_0x2991('0x28')]){return process[a6_0x2991('0x35')][a6_0x2991('0x28')];}else{return a6_0x2991('0x25')+Math[a6_0x2991('0x8')](Math[a6_0x2991('0x6')]()*0x186a0);}}function createAgentLockfileAndSetUpListeners(_0x6dec70,_0x408475,_0x36f2a5){const _0xf3eaf2=cacheDirectory+a6_0x2991('0x40');const _0x55f25d=_0xf3eaf2+'/'+_0x36f2a5+a6_0x2991('0x43');if(!(0x0,fs_1['existsSync'])(_0xf3eaf2)){(0x0,fs_1[a6_0x2991('0x3f')])(_0xf3eaf2,{'recursive':!![]});}const _0x51a88c=(0x0,fs_1[a6_0x2991('0x10')])(_0xf3eaf2);if(_0x51a88c[a6_0x2991('0x4e')]){if(_0x51a88c[a6_0x2991('0x4f')](_0x36f2a5+a6_0x2991('0x43'))){output[a6_0x2991('0x4c')]({'title':'Duplicate\x20Agent\x20ID\x20Detected','bodyLines':[a6_0x2991('0x19'),'',a6_0x2991('0x49')]});process[a6_0x2991('0x18')](0x1);}output['warn']({'title':a6_0x2991('0x27'),'bodyLines':[a6_0x2991('0x45'),'','This\x20can\x20also\x20be\x20a\x20false\x20positive\x20caused\x20by\x20agents\x20that\x20did\x20not\x20shut\x20down\x20correctly.',a6_0x2991('0x3a')]});}(0x0,fs_1[a6_0x2991('0x21')])(_0x55f25d,'');process['on'](a6_0x2991('0x18'),_0x4218ef=>{cleanupAgentLockfile(_0x55f25d,_0x4218ef);});process['on'](a6_0x2991('0xe'),()=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x6dec70[a6_0x2991('0x4')]('Agent\x20was\x20terminated\x20via\x20SIGTERM');cleanupAgentLockfile(_0x55f25d,0x1);}));process['on'](a6_0x2991('0xd'),()=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x6dec70[a6_0x2991('0x4')](a6_0x2991('0x2'));cleanupAgentLockfile(_0x55f25d,0x1);}));}function cleanupAgentLockfile(_0x3c14ad,_0x3c81f9){if((0x0,fs_1['existsSync'])(_0x3c14ad)){(0x0,fs_1['unlinkSync'])(_0x3c14ad);process[a6_0x2991('0x18')](_0x3c81f9);}}

lib/core/runners/distributed-agent/execute-tasks.js

@@ -1,1 +0,1 @@
-const a7_0x55c4=['__awaiter','taskId','No\x20new\x20messages\x20received\x20after\x20','tasks','completedTasks','length','getTime','\x20fetching\x20tasks...','\x20downloading\x20artifacts\x20for\x20','../../../utilities/create-unchanged-value-timeout','Error:','url','retryDuring','next','\x20received\x20an\x20API\x20Response','../../../utilities/environment','executionId','value','NO_FURTHER_TASKS_TO_RUN','executeTasks','completedStatusCode','Distributed\x20Execution\x20Terminated','reset','\x20seconds','\x20waiting...','createUnchangedValueTimeout','\x20Hash:\x20','number\x20of\x20tasks:\x20','status','__esModule','error','apply','hash','error:\x20','then','wait','exit','status:\x20','VERBOSE_LOGGING','completed','maxParallel:\x20','retrieveAndExtract','done','../../../utilities/waiter','note','criticalErrorMessage','map','join','executionId:\x20','maxParallel'];(function(_0xe28ac0,_0x55c4d6){const _0x27de7=function(_0x404d9e){while(--_0x404d9e){_0xe28ac0['push'](_0xe28ac0['shift']());}};_0x27de7(++_0x55c4d6);}(a7_0x55c4,0x9f));const a7_0x27de=function(_0xe28ac0,_0x55c4d6){_0xe28ac0=_0xe28ac0-0x0;let _0x27de7=a7_0x55c4[_0xe28ac0];return _0x27de7;};'use strict';var __awaiter=this&&this[a7_0x27de('0x29')]||function(_0x179404,_0x30ca85,_0x1a26aa,_0x2d6f51){function _0x4eba0b(_0x35a04f){return _0x35a04f instanceof _0x1a26aa?_0x35a04f:new _0x1a26aa(function(_0x5951f3){_0x5951f3(_0x35a04f);});}return new(_0x1a26aa||(_0x1a26aa=Promise))(function(_0x5424a3,_0x3a83f0){function _0x2edee1(_0x49c1b3){try{_0x2addce(_0x2d6f51[a7_0x27de('0x4')](_0x49c1b3));}catch(_0x447d3b){_0x3a83f0(_0x447d3b);}}function _0x590c73(_0xf55329){try{_0x2addce(_0x2d6f51['throw'](_0xf55329));}catch(_0x5e06d4){_0x3a83f0(_0x5e06d4);}}function _0x2addce(_0x17972d){_0x17972d[a7_0x27de('0x21')]?_0x5424a3(_0x17972d[a7_0x27de('0x8')]):_0x4eba0b(_0x17972d[a7_0x27de('0x8')])[a7_0x27de('0x19')](_0x2edee1,_0x590c73);}_0x2addce((_0x2d6f51=_0x2d6f51[a7_0x27de('0x16')](_0x179404,_0x30ca85||[]))[a7_0x27de('0x4')]());});};Object['defineProperty'](exports,a7_0x27de('0x14'),{'value':!![]});exports[a7_0x27de('0xa')]=void 0x0;const create_unchanged_value_timeout_1=require(a7_0x27de('0x0'));const environment_1=require(a7_0x27de('0x6'));const waiter_1=require(a7_0x27de('0x22'));const {output}=require('../../../utilities/nx-imports');function executeTasks(_0x20374a,_0x4b0a30,_0x18c7e5,_0x5eeb30,_0x36caa6){return __awaiter(this,void 0x0,void 0x0,function*(){let _0x4e3728=0x0;let _0x56a5b8=null;const _0x29435e=(0x0,create_unchanged_value_timeout_1[a7_0x27de('0x10')])({'title':a7_0x27de('0x2b')+environment_1['NO_MESSAGES_TIMEOUT']/0x3e8+a7_0x27de('0xe'),'timeout':environment_1['NO_MESSAGES_TIMEOUT']});const _0x154f6d=new waiter_1['Waiter']();let _0x5c1a73=[];const _0x1bf701=new Date();let _0xb9ff0=![];const _0x49f25b={};while(!![]){if(environment_1['VERBOSE_LOGGING']){output[a7_0x27de('0x23')]({'title':_0x20374a+a7_0x27de('0x30')});}_0x56a5b8=yield _0x4b0a30[a7_0x27de('0x2c')](_0x56a5b8?_0x56a5b8[a7_0x27de('0x7')]:null,_0x4e3728,_0x5c1a73,_0x36caa6);if(environment_1[a7_0x27de('0x1d')]){output['note']({'title':_0x20374a+a7_0x27de('0x5'),'bodyLines':['completed:\x20'+_0x56a5b8[a7_0x27de('0x1e')],a7_0x27de('0x1c')+_0x56a5b8[a7_0x27de('0x13')],'retryDuring:\x20'+_0x56a5b8[a7_0x27de('0x3')],a7_0x27de('0x27')+_0x56a5b8[a7_0x27de('0x7')],a7_0x27de('0x12')+_0x56a5b8['tasks'][a7_0x27de('0x2e')],a7_0x27de('0x18')+_0x56a5b8[a7_0x27de('0x24')],a7_0x27de('0x1f')+_0x56a5b8[a7_0x27de('0x28')]]});}if(_0x56a5b8['criticalErrorMessage']){output[a7_0x27de('0x15')]({'title':a7_0x27de('0xc'),'bodyLines':[a7_0x27de('0x1'),_0x56a5b8['criticalErrorMessage']]});process[a7_0x27de('0x1b')](0x0);}if((_0x56a5b8===null||_0x56a5b8===void 0x0?void 0x0:_0x56a5b8[a7_0x27de('0x3')])&&(_0x56a5b8===null||_0x56a5b8===void 0x0?void 0x0:_0x56a5b8[a7_0x27de('0x3')])!==0x0&&!_0xb9ff0&&new Date()[a7_0x27de('0x2f')]()-_0x1bf701[a7_0x27de('0x2f')]()>_0x56a5b8[a7_0x27de('0x3')]){yield _0x154f6d[a7_0x27de('0x1a')]();continue;}if((_0x56a5b8===null||_0x56a5b8===void 0x0?void 0x0:_0x56a5b8[a7_0x27de('0x13')])!==undefined){if(_0x56a5b8[a7_0x27de('0x13')]==='RUN_GROUP_COMPLETED'||_0x56a5b8[a7_0x27de('0x13')]===a7_0x27de('0x9')){return;}}else if(_0x56a5b8[a7_0x27de('0x1e')]){return;}_0x29435e(_0x56a5b8[a7_0x27de('0x2c')][a7_0x27de('0x25')](_0x13705d=>_0x13705d[a7_0x27de('0x2a')])[a7_0x27de('0x26')](''));if(!_0x56a5b8[a7_0x27de('0x7')]){if(environment_1['VERBOSE_LOGGING']){output[a7_0x27de('0x23')]({'title':_0x20374a+a7_0x27de('0xf')});}yield _0x154f6d['wait']();_0x4e3728=0x0;_0x5c1a73=[];continue;}_0x154f6d[a7_0x27de('0xd')]();_0xb9ff0=!![];if(_0x56a5b8['completedTasks']){for(const _0xfae783 of _0x56a5b8[a7_0x27de('0x2d')]){if(_0x49f25b[_0xfae783[a7_0x27de('0x2a')]])continue;output[a7_0x27de('0x23')]({'title':_0x20374a+a7_0x27de('0x31')+_0xfae783[a7_0x27de('0x2a')]+a7_0x27de('0x11')+_0xfae783[a7_0x27de('0x17')]+'\x20Url:\x20'+_0xfae783[a7_0x27de('0x2')]});yield _0x18c7e5[a7_0x27de('0x20')](_0xfae783[a7_0x27de('0x17')],_0xfae783['url']);_0x49f25b[_0xfae783[a7_0x27de('0x2a')]]=!![];}}const _0x205e52=yield _0x5eeb30(_0x56a5b8['executionId'],_0x56a5b8[a7_0x27de('0x2c')],_0x56a5b8[a7_0x27de('0x28')]);for(const _0x2a5281 of _0x205e52[a7_0x27de('0x2d')]){_0x49f25b[_0x2a5281['taskId']]=!![];}_0x4e3728=_0x205e52[a7_0x27de('0xb')];_0x5c1a73=_0x205e52[a7_0x27de('0x2d')];}});}exports[a7_0x27de('0xa')]=executeTasks;
+const a7_0x2dfa=['exit','retrieveAndExtract','next','value','\x20Url:\x20','\x20seconds','\x20fetching\x20tasks...','reset','completed','VERBOSE_LOGGING','tasks','map','retryDuring:\x20','executionId:\x20','status','note','createUnchangedValueTimeout','criticalErrorMessage','retryDuring','../../../utilities/nx-imports','Distributed\x20Execution\x20Terminated','length','hash','completedStatusCode','number\x20of\x20tasks:\x20','\x20downloading\x20artifacts\x20for\x20','__awaiter','url','then','done','No\x20new\x20messages\x20received\x20after\x20','executionId','wait','join','Error:','__esModule','maxParallel','Waiter','getTime','\x20waiting...','taskId','maxParallel:\x20','RUN_GROUP_COMPLETED','error:\x20','completed:\x20','error','completedTasks','NO_FURTHER_TASKS_TO_RUN'];(function(_0x33c172,_0x2dfa22){const _0x223875=function(_0x2199e4){while(--_0x2199e4){_0x33c172['push'](_0x33c172['shift']());}};_0x223875(++_0x2dfa22);}(a7_0x2dfa,0x13d));const a7_0x2238=function(_0x33c172,_0x2dfa22){_0x33c172=_0x33c172-0x0;let _0x223875=a7_0x2dfa[_0x33c172];return _0x223875;};'use strict';var __awaiter=this&&this[a7_0x2238('0x2d')]||function(_0x109fe9,_0x2ac8b1,_0xf4c91e,_0x3f613d){function _0x4be09f(_0x40d9ba){return _0x40d9ba instanceof _0xf4c91e?_0x40d9ba:new _0xf4c91e(function(_0x3f742c){_0x3f742c(_0x40d9ba);});}return new(_0xf4c91e||(_0xf4c91e=Promise))(function(_0x4c3ed8,_0x2da7f0){function _0x1c3b1e(_0x4bd9a5){try{_0x4f3921(_0x3f613d[a7_0x2238('0x15')](_0x4bd9a5));}catch(_0xe13272){_0x2da7f0(_0xe13272);}}function _0x2d777a(_0x27c06f){try{_0x4f3921(_0x3f613d['throw'](_0x27c06f));}catch(_0x534a17){_0x2da7f0(_0x534a17);}}function _0x4f3921(_0x36ad7c){_0x36ad7c[a7_0x2238('0x0')]?_0x4c3ed8(_0x36ad7c[a7_0x2238('0x16')]):_0x4be09f(_0x36ad7c['value'])[a7_0x2238('0x2f')](_0x1c3b1e,_0x2d777a);}_0x4f3921((_0x3f613d=_0x3f613d['apply'](_0x109fe9,_0x2ac8b1||[]))[a7_0x2238('0x15')]());});};Object['defineProperty'](exports,a7_0x2238('0x6'),{'value':!![]});exports['executeTasks']=void 0x0;const create_unchanged_value_timeout_1=require('../../../utilities/create-unchanged-value-timeout');const environment_1=require('../../../utilities/environment');const waiter_1=require('../../../utilities/waiter');const {output}=require(a7_0x2238('0x26'));function executeTasks(_0x3109a3,_0x387fe6,_0x1ee480,_0x84faf5,_0x532b13){return __awaiter(this,void 0x0,void 0x0,function*(){let _0x4d640b=0x0;let _0x26bf43=null;const _0xf8996a=(0x0,create_unchanged_value_timeout_1[a7_0x2238('0x23')])({'title':a7_0x2238('0x1')+environment_1['NO_MESSAGES_TIMEOUT']/0x3e8+a7_0x2238('0x18'),'timeout':environment_1['NO_MESSAGES_TIMEOUT']});const _0x3d4ac5=new waiter_1[(a7_0x2238('0x8'))]();let _0x55143d=[];const _0x35fb0e=new Date();let _0x5115bc=![];const _0x1723bd={};while(!![]){if(environment_1[a7_0x2238('0x1c')]){output[a7_0x2238('0x22')]({'title':_0x3109a3+a7_0x2238('0x19')});}_0x26bf43=yield _0x387fe6[a7_0x2238('0x1d')](_0x26bf43?_0x26bf43['executionId']:null,_0x4d640b,_0x55143d,_0x532b13);if(environment_1['VERBOSE_LOGGING']){output[a7_0x2238('0x22')]({'title':_0x3109a3+'\x20received\x20an\x20API\x20Response','bodyLines':[a7_0x2238('0xf')+_0x26bf43[a7_0x2238('0x1b')],'status:\x20'+_0x26bf43['status'],a7_0x2238('0x1f')+_0x26bf43[a7_0x2238('0x25')],a7_0x2238('0x20')+_0x26bf43[a7_0x2238('0x2')],a7_0x2238('0x2b')+_0x26bf43[a7_0x2238('0x1d')][a7_0x2238('0x28')],a7_0x2238('0xe')+_0x26bf43['criticalErrorMessage'],a7_0x2238('0xc')+_0x26bf43[a7_0x2238('0x7')]]});}if(_0x26bf43[a7_0x2238('0x24')]){output[a7_0x2238('0x10')]({'title':a7_0x2238('0x27'),'bodyLines':[a7_0x2238('0x5'),_0x26bf43[a7_0x2238('0x24')]]});process[a7_0x2238('0x13')](0x0);}if((_0x26bf43===null||_0x26bf43===void 0x0?void 0x0:_0x26bf43[a7_0x2238('0x25')])&&(_0x26bf43===null||_0x26bf43===void 0x0?void 0x0:_0x26bf43[a7_0x2238('0x25')])!==0x0&&!_0x5115bc&&new Date()[a7_0x2238('0x9')]()-_0x35fb0e[a7_0x2238('0x9')]()>_0x26bf43[a7_0x2238('0x25')]){yield _0x3d4ac5[a7_0x2238('0x3')]();continue;}if((_0x26bf43===null||_0x26bf43===void 0x0?void 0x0:_0x26bf43['status'])!==undefined){if(_0x26bf43[a7_0x2238('0x21')]===a7_0x2238('0xd')||_0x26bf43[a7_0x2238('0x21')]===a7_0x2238('0x12')){return;}}else if(_0x26bf43[a7_0x2238('0x1b')]){return;}_0xf8996a(_0x26bf43[a7_0x2238('0x1d')][a7_0x2238('0x1e')](_0x4ef727=>_0x4ef727[a7_0x2238('0xb')])[a7_0x2238('0x4')](''));if(!_0x26bf43[a7_0x2238('0x2')]){if(environment_1['VERBOSE_LOGGING']){output[a7_0x2238('0x22')]({'title':_0x3109a3+a7_0x2238('0xa')});}yield _0x3d4ac5['wait']();_0x4d640b=0x0;_0x55143d=[];continue;}_0x3d4ac5[a7_0x2238('0x1a')]();_0x5115bc=!![];if(_0x26bf43[a7_0x2238('0x11')]){for(const _0x4aa2d4 of _0x26bf43[a7_0x2238('0x11')]){if(_0x1723bd[_0x4aa2d4[a7_0x2238('0xb')]])continue;output[a7_0x2238('0x22')]({'title':_0x3109a3+a7_0x2238('0x2c')+_0x4aa2d4[a7_0x2238('0xb')]+'\x20Hash:\x20'+_0x4aa2d4['hash']+a7_0x2238('0x17')+_0x4aa2d4['url']});yield _0x1ee480[a7_0x2238('0x14')](_0x4aa2d4[a7_0x2238('0x29')],_0x4aa2d4[a7_0x2238('0x2e')]);_0x1723bd[_0x4aa2d4[a7_0x2238('0xb')]]=!![];}}const _0xb830f4=yield _0x84faf5(_0x26bf43['executionId'],_0x26bf43['tasks'],_0x26bf43[a7_0x2238('0x7')]);for(const _0x17fa21 of _0xb830f4[a7_0x2238('0x11')]){_0x1723bd[_0x17fa21[a7_0x2238('0xb')]]=!![];}_0x4d640b=_0xb830f4[a7_0x2238('0x2a')];_0x55143d=_0xb830f4[a7_0x2238('0x11')];}});}exports['executeTasks']=executeTasks;

lib/core/runners/distributed-agent/invoke-tasks-using-nx-imperative-api.js

@@ -1,1 +0,1 @@
-const a8_0x5ca5=['status','length','yargs-parser','unparse','taskGraph','throw','hash','../../../utilities/serializer-overrides','apply','NX_CLOUD_DISTRIBUTED_EXECUTION_ID','projectName','target','NX_PREFIX_OUTPUT','configuration','invoke','../../../utilities/nx-imports','value','assign','env','then','true','__esModule','invokeTasksUsingNxImperativeApi','tasks','map','taskId'];(function(_0x1fd7d7,_0x5ca531){const _0x5c7831=function(_0x54a716){while(--_0x54a716){_0x1fd7d7['push'](_0x1fd7d7['shift']());}};_0x5c7831(++_0x5ca531);}(a8_0x5ca5,0xe9));const a8_0x5c78=function(_0x1fd7d7,_0x5ca531){_0x1fd7d7=_0x1fd7d7-0x0;let _0x5c7831=a8_0x5ca5[_0x1fd7d7];return _0x5c7831;};'use strict';var __awaiter=this&&this['__awaiter']||function(_0x1f3bbd,_0x594a73,_0x28287f,_0x3aea10){function _0x231f40(_0x2c46be){return _0x2c46be instanceof _0x28287f?_0x2c46be:new _0x28287f(function(_0x4428fe){_0x4428fe(_0x2c46be);});}return new(_0x28287f||(_0x28287f=Promise))(function(_0x322b74,_0x3522ab){function _0x3515db(_0x9771fb){try{_0x4eec44(_0x3aea10['next'](_0x9771fb));}catch(_0x472182){_0x3522ab(_0x472182);}}function _0x50c54b(_0x473c9d){try{_0x4eec44(_0x3aea10[a8_0x5c78('0x6')](_0x473c9d));}catch(_0x1ddc7e){_0x3522ab(_0x1ddc7e);}}function _0x4eec44(_0x1ec591){_0x1ec591['done']?_0x322b74(_0x1ec591[a8_0x5c78('0x11')]):_0x231f40(_0x1ec591['value'])[a8_0x5c78('0x14')](_0x3515db,_0x50c54b);}_0x4eec44((_0x3aea10=_0x3aea10[a8_0x5c78('0x9')](_0x1f3bbd,_0x594a73||[]))['next']());});};Object['defineProperty'](exports,a8_0x5c78('0x16'),{'value':!![]});exports[a8_0x5c78('0x17')]=void 0x0;const {initTasksRunner}=require(a8_0x5c78('0x10'));const parser=require(a8_0x5c78('0x3'));const serializer_overrides_1=require(a8_0x5c78('0x8'));function invokeTasksUsingNxImperativeApi(_0x31be49){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x1f8b20=yield initTasksRunner(_0x31be49);return(_0xd20843,_0x847055,_0x1f5031)=>__awaiter(this,void 0x0,void 0x0,function*(){const _0x407cf5=_0x847055[a8_0x5c78('0x19')](_0x137167=>{const _0x2a616e=parser(_0x137167['params'],{'configuration':{'camel-case-expansion':![],'dot-notation':!![]}});const _0x5909ae=(0x0,serializer_overrides_1[a8_0x5c78('0x4')])(_0x2a616e);if(_0x2a616e['_'][a8_0x5c78('0x2')]==0x0){delete _0x2a616e['_'];}return{'id':_0x137167[a8_0x5c78('0x0')],'target':{'project':_0x137167[a8_0x5c78('0xb')],'target':_0x137167[a8_0x5c78('0xc')],'configuration':_0x137167[a8_0x5c78('0xe')]},'overrides':Object[a8_0x5c78('0x12')](Object[a8_0x5c78('0x12')]({},_0x2a616e),{'__overrides_unparsed__':_0x5909ae})};});process['env']['NX_CACHE_FAILURES']=a8_0x5c78('0x15');process[a8_0x5c78('0x13')][a8_0x5c78('0xa')]=_0xd20843;process[a8_0x5c78('0x13')]['NX_STREAM_OUTPUT']=a8_0x5c78('0x15');process[a8_0x5c78('0x13')][a8_0x5c78('0xd')]=a8_0x5c78('0x15');const _0x3915e9=yield _0x1f8b20[a8_0x5c78('0xf')]({'tasks':_0x407cf5,'parallel':_0x1f5031});const _0x548966=Object['values'](_0x3915e9[a8_0x5c78('0x5')][a8_0x5c78('0x18')]);return{'completedTasks':_0x548966[a8_0x5c78('0x19')](_0x5ac3db=>({'taskId':_0x5ac3db['id'],'hash':_0x5ac3db[a8_0x5c78('0x7')]})),'completedStatusCode':_0x3915e9[a8_0x5c78('0x1')]};});});}exports['invokeTasksUsingNxImperativeApi']=invokeTasksUsingNxImperativeApi;
+const a8_0x3648=['map','NX_PREFIX_OUTPUT','yargs-parser','next','__esModule','env','assign','NX_CLOUD_DISTRIBUTED_EXECUTION_ID','invokeTasksUsingNxImperativeApi','values','taskId','../../../utilities/nx-imports','true','value','throw','NX_CACHE_FAILURES','invoke','defineProperty','params','then','configuration','unparse','done','../../../utilities/serializer-overrides','NX_STREAM_OUTPUT','tasks'];(function(_0x1489ac,_0x364875){const _0x323422=function(_0x4dab5f){while(--_0x4dab5f){_0x1489ac['push'](_0x1489ac['shift']());}};_0x323422(++_0x364875);}(a8_0x3648,0xba));const a8_0x3234=function(_0x1489ac,_0x364875){_0x1489ac=_0x1489ac-0x0;let _0x323422=a8_0x3648[_0x1489ac];return _0x323422;};'use strict';var __awaiter=this&&this['__awaiter']||function(_0x4415f9,_0x4f34a1,_0x2f1660,_0x348aff){function _0x383a40(_0x181ace){return _0x181ace instanceof _0x2f1660?_0x181ace:new _0x2f1660(function(_0x1fa501){_0x1fa501(_0x181ace);});}return new(_0x2f1660||(_0x2f1660=Promise))(function(_0x57a7e8,_0x544cf6){function _0x3c19c5(_0x244d39){try{_0x12f0e1(_0x348aff[a8_0x3234('0x19')](_0x244d39));}catch(_0x2c4091){_0x544cf6(_0x2c4091);}}function _0x544edc(_0x1b2256){try{_0x12f0e1(_0x348aff[a8_0x3234('0xa')](_0x1b2256));}catch(_0x2acc5e){_0x544cf6(_0x2acc5e);}}function _0x12f0e1(_0x2d8a72){_0x2d8a72[a8_0x3234('0x12')]?_0x57a7e8(_0x2d8a72[a8_0x3234('0x9')]):_0x383a40(_0x2d8a72[a8_0x3234('0x9')])[a8_0x3234('0xf')](_0x3c19c5,_0x544edc);}_0x12f0e1((_0x348aff=_0x348aff['apply'](_0x4415f9,_0x4f34a1||[]))['next']());});};Object[a8_0x3234('0xd')](exports,a8_0x3234('0x0'),{'value':!![]});exports[a8_0x3234('0x4')]=void 0x0;const {initTasksRunner}=require(a8_0x3234('0x7'));const parser=require(a8_0x3234('0x18'));const serializer_overrides_1=require(a8_0x3234('0x13'));function invokeTasksUsingNxImperativeApi(_0x5c92ed){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x254085=yield initTasksRunner(_0x5c92ed);return(_0x4b5bd2,_0x444c57,_0x46ce5d)=>__awaiter(this,void 0x0,void 0x0,function*(){const _0x45c51c=_0x444c57[a8_0x3234('0x16')](_0x31d341=>{const _0x1e452e=parser(_0x31d341[a8_0x3234('0xe')],{'configuration':{'camel-case-expansion':![],'dot-notation':!![]}});const _0x1806d8=(0x0,serializer_overrides_1[a8_0x3234('0x11')])(_0x1e452e);if(_0x1e452e['_']['length']==0x0){delete _0x1e452e['_'];}return{'id':_0x31d341[a8_0x3234('0x6')],'target':{'project':_0x31d341['projectName'],'target':_0x31d341['target'],'configuration':_0x31d341[a8_0x3234('0x10')]},'overrides':Object['assign'](Object[a8_0x3234('0x2')]({},_0x1e452e),{'__overrides_unparsed__':_0x1806d8})};});process[a8_0x3234('0x1')][a8_0x3234('0xb')]='true';process[a8_0x3234('0x1')][a8_0x3234('0x3')]=_0x4b5bd2;process[a8_0x3234('0x1')][a8_0x3234('0x14')]=a8_0x3234('0x8');process[a8_0x3234('0x1')][a8_0x3234('0x17')]=a8_0x3234('0x8');const _0x304857=yield _0x254085[a8_0x3234('0xc')]({'tasks':_0x45c51c,'parallel':_0x46ce5d});const _0x61839d=Object[a8_0x3234('0x5')](_0x304857['taskGraph'][a8_0x3234('0x15')]);return{'completedTasks':_0x61839d['map'](_0x1194e0=>({'taskId':_0x1194e0['id'],'hash':_0x1194e0['hash']})),'completedStatusCode':_0x304857['status']};});});}exports[a8_0x3234('0x4')]=invokeTasksUsingNxImperativeApi;

lib/core/runners/distributed-agent/invoke-tasks-using-run-many.js

@@ -1,1 +0,1 @@
-const a9_0x56f0=['unlinkSync','Command\x20execution\x20failed\x20(distributed\x20task\x20execution:\x20',').\x20Tasks\x20hashes\x20haven\x27t\x20been\x20recorded.','VERBOSE_LOGGING','value','../../../utilities/environment','params','Executing:\x20\x27','child_process','inherit','configuration','next','readFileSync','apply','projectName','invokeTasksUsingRunMany','parse','\x20--parallel\x20--max-parallel=','ignore','assign','defineProperty','throw','__esModule','DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE','push','../../../utilities/nx-imports','done','note','then','env','projects','execSync','join','find','true','target','\x20--projects=','--configuration='];(function(_0x2c7890,_0x56f0e3){const _0xb72cca=function(_0x529e2e){while(--_0x529e2e){_0x2c7890['push'](_0x2c7890['shift']());}};_0xb72cca(++_0x56f0e3);}(a9_0x56f0,0x11e));const a9_0xb72c=function(_0x2c7890,_0x56f0e3){_0x2c7890=_0x2c7890-0x0;let _0xb72cca=a9_0x56f0[_0x2c7890];return _0xb72cca;};'use strict';var __awaiter=this&&this['__awaiter']||function(_0xa848c7,_0x4fdc58,_0x56c80a,_0x4858cc){function _0x4c5b04(_0x26b740){return _0x26b740 instanceof _0x56c80a?_0x26b740:new _0x56c80a(function(_0x2ead80){_0x2ead80(_0x26b740);});}return new(_0x56c80a||(_0x56c80a=Promise))(function(_0x1d6fac,_0x5e74ea){function _0x3650f2(_0x3ab8ac){try{_0x3a2590(_0x4858cc['next'](_0x3ab8ac));}catch(_0x273c50){_0x5e74ea(_0x273c50);}}function _0x4831df(_0x6bf356){try{_0x3a2590(_0x4858cc[a9_0xb72c('0x1')](_0x6bf356));}catch(_0x53f00f){_0x5e74ea(_0x53f00f);}}function _0x3a2590(_0x2a48b4){_0x2a48b4[a9_0xb72c('0x6')]?_0x1d6fac(_0x2a48b4[a9_0xb72c('0x16')]):_0x4c5b04(_0x2a48b4['value'])[a9_0xb72c('0x8')](_0x3650f2,_0x4831df);}_0x3a2590((_0x4858cc=_0x4858cc[a9_0xb72c('0x1f')](_0xa848c7,_0x4fdc58||[]))[a9_0xb72c('0x1d')]());});};Object[a9_0xb72c('0x0')](exports,a9_0xb72c('0x2'),{'value':!![]});exports[a9_0xb72c('0x21')]=void 0x0;const environment_1=require(a9_0xb72c('0x17'));const child_process_1=require(a9_0xb72c('0x1a'));const fs_1=require('fs');const {output,cacheDirectory}=require(a9_0xb72c('0x5'));function invokeTasksUsingRunMany(){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x5970cb=completedTasksReader();return function _0x4deaaa(_0x4b32f5,_0x128e5b,_0x211488){return __awaiter(this,void 0x0,void 0x0,function*(){let _0x21336d=0x0;const _0x1d903b=[];for(const _0x434f26 of groupByTarget(_0x128e5b)){const _0x218f1c=_0x434f26[a9_0xb72c('0x1c')]?a9_0xb72c('0x11')+_0x434f26[a9_0xb72c('0x1c')]:'';const _0x376e46=_0x211488>0x1?a9_0xb72c('0x23')+_0x211488:'';const _0x5d7080='npx\x20nx\x20run-many\x20--target='+_0x434f26[a9_0xb72c('0xf')]+'\x20'+_0x218f1c+a9_0xb72c('0x10')+_0x434f26[a9_0xb72c('0xa')][a9_0xb72c('0xc')](',')+'\x20'+_0x434f26[a9_0xb72c('0x18')]+_0x376e46;if(environment_1[a9_0xb72c('0x15')]){output[a9_0xb72c('0x7')]({'title':a9_0xb72c('0x19')+_0x5d7080+'\x27'});}try{(0x0,child_process_1[a9_0xb72c('0xb')])(_0x5d7080,{'stdio':[a9_0xb72c('0x24'),a9_0xb72c('0x1b'),'inherit'],'env':Object[a9_0xb72c('0x25')](Object[a9_0xb72c('0x25')]({},process[a9_0xb72c('0x9')]),{'NX_CACHE_FAILURES':a9_0xb72c('0xe'),'NX_CLOUD_DISTRIBUTED_EXECUTION_ID':_0x4b32f5,'NX_STREAM_OUTPUT':'true','NX_PREFIX_OUTPUT':'true'})});_0x1d903b[a9_0xb72c('0x4')](..._0x5970cb(_0x4b32f5));}catch(_0x392684){if(_0x392684['status']===environment_1[a9_0xb72c('0x3')]){throw _0x392684;}else{_0x21336d=0x1;_0x1d903b[a9_0xb72c('0x4')](..._0x5970cb(_0x4b32f5));}}}return{'completedStatusCode':_0x21336d,'completedTasks':_0x1d903b};});};});}exports[a9_0xb72c('0x21')]=invokeTasksUsingRunMany;function groupByTarget(_0xee9ce1){const _0x42c618=[];_0xee9ce1['forEach'](_0x159b72=>{const _0x569bc2=_0x42c618[a9_0xb72c('0xd')](_0x41fb30=>_0x41fb30[a9_0xb72c('0xf')]===_0x159b72[a9_0xb72c('0xf')]&&_0x41fb30[a9_0xb72c('0x1c')]===_0x159b72[a9_0xb72c('0x1c')]);if(_0x569bc2){_0x569bc2[a9_0xb72c('0xa')][a9_0xb72c('0x4')](_0x159b72['projectName']);}else{_0x42c618[a9_0xb72c('0x4')]({'target':_0x159b72[a9_0xb72c('0xf')],'projects':[_0x159b72[a9_0xb72c('0x20')]],'params':_0x159b72[a9_0xb72c('0x18')],'configuration':_0x159b72[a9_0xb72c('0x1c')]});}});return _0x42c618;}function completedTasksReader(){return _0x251541=>{const _0x3cacb1=a9_0xb72c('0x13')+_0x251541+a9_0xb72c('0x14');let _0xc9724b;try{const _0x2a3e8a=cacheDirectory+'/tasks-hashes-'+_0x251541;_0xc9724b=JSON[a9_0xb72c('0x22')]((0x0,fs_1[a9_0xb72c('0x1e')])(_0x2a3e8a)['toString']());(0x0,fs_1[a9_0xb72c('0x12')])(_0x2a3e8a);}catch(_0xafa75d){throw new Error(_0x3cacb1);}if(_0xc9724b['length']==0x0){throw new Error(_0x3cacb1);}return _0xc9724b;};}
+const a9_0x4c66=['__esModule','\x20--parallel\x20--max-parallel=','note','length','npx\x20nx\x20run-many\x20--target=','defineProperty','toString','\x20--projects=','readFileSync','status','throw','VERBOSE_LOGGING','configuration','push','parse','inherit','find','__awaiter','/tasks-hashes-','Command\x20execution\x20failed\x20(distributed\x20task\x20execution:\x20','DISTRIBUTED_TASK_EXECUTION_INTERNAL_ERROR_STATUS_CODE','child_process','value','projectName','--configuration=','join','env','ignore','next','invokeTasksUsingRunMany','params','true','forEach','projects','target'];(function(_0x4330d4,_0x4c6643){const _0x35bf33=function(_0x3e9cb4){while(--_0x3e9cb4){_0x4330d4['push'](_0x4330d4['shift']());}};_0x35bf33(++_0x4c6643);}(a9_0x4c66,0x17e));const a9_0x35bf=function(_0x4330d4,_0x4c6643){_0x4330d4=_0x4330d4-0x0;let _0x35bf33=a9_0x4c66[_0x4330d4];return _0x35bf33;};'use strict';var __awaiter=this&&this[a9_0x35bf('0x14')]||function(_0x2bf6f4,_0x84cc88,_0x18c582,_0x8544d1){function _0x583b0c(_0x1e8a93){return _0x1e8a93 instanceof _0x18c582?_0x1e8a93:new _0x18c582(function(_0x3c8168){_0x3c8168(_0x1e8a93);});}return new(_0x18c582||(_0x18c582=Promise))(function(_0x5f3089,_0x27c87d){function _0x136661(_0xf583fc){try{_0x859689(_0x8544d1[a9_0x35bf('0x1f')](_0xf583fc));}catch(_0x1a5903){_0x27c87d(_0x1a5903);}}function _0x58dd2b(_0x4e06d7){try{_0x859689(_0x8544d1[a9_0x35bf('0xd')](_0x4e06d7));}catch(_0x490f37){_0x27c87d(_0x490f37);}}function _0x859689(_0x561df9){_0x561df9['done']?_0x5f3089(_0x561df9[a9_0x35bf('0x19')]):_0x583b0c(_0x561df9[a9_0x35bf('0x19')])['then'](_0x136661,_0x58dd2b);}_0x859689((_0x8544d1=_0x8544d1['apply'](_0x2bf6f4,_0x84cc88||[]))[a9_0x35bf('0x1f')]());});};Object[a9_0x35bf('0x8')](exports,a9_0x35bf('0x3'),{'value':!![]});exports[a9_0x35bf('0x20')]=void 0x0;const environment_1=require('../../../utilities/environment');const child_process_1=require(a9_0x35bf('0x18'));const fs_1=require('fs');const {output,cacheDirectory}=require('../../../utilities/nx-imports');function invokeTasksUsingRunMany(){return __awaiter(this,void 0x0,void 0x0,function*(){const _0xd76617=completedTasksReader();return function _0x206f38(_0x223b50,_0xdf124b,_0x136269){return __awaiter(this,void 0x0,void 0x0,function*(){let _0x117f68=0x0;const _0xadece7=[];for(const _0x2fb261 of groupByTarget(_0xdf124b)){const _0xd32b2e=_0x2fb261[a9_0x35bf('0xf')]?a9_0x35bf('0x1b')+_0x2fb261[a9_0x35bf('0xf')]:'';const _0x15321c=_0x136269>0x1?a9_0x35bf('0x4')+_0x136269:'';const _0x49dafd=a9_0x35bf('0x7')+_0x2fb261[a9_0x35bf('0x2')]+'\x20'+_0xd32b2e+a9_0x35bf('0xa')+_0x2fb261[a9_0x35bf('0x1')][a9_0x35bf('0x1c')](',')+'\x20'+_0x2fb261[a9_0x35bf('0x21')]+_0x15321c;if(environment_1[a9_0x35bf('0xe')]){output[a9_0x35bf('0x5')]({'title':'Executing:\x20\x27'+_0x49dafd+'\x27'});}try{(0x0,child_process_1['execSync'])(_0x49dafd,{'stdio':[a9_0x35bf('0x1e'),'inherit',a9_0x35bf('0x12')],'env':Object['assign'](Object['assign']({},process[a9_0x35bf('0x1d')]),{'NX_CACHE_FAILURES':a9_0x35bf('0x22'),'NX_CLOUD_DISTRIBUTED_EXECUTION_ID':_0x223b50,'NX_STREAM_OUTPUT':a9_0x35bf('0x22'),'NX_PREFIX_OUTPUT':'true'})});_0xadece7[a9_0x35bf('0x10')](..._0xd76617(_0x223b50));}catch(_0x560ded){if(_0x560ded[a9_0x35bf('0xc')]===environment_1[a9_0x35bf('0x17')]){throw _0x560ded;}else{_0x117f68=0x1;_0xadece7[a9_0x35bf('0x10')](..._0xd76617(_0x223b50));}}}return{'completedStatusCode':_0x117f68,'completedTasks':_0xadece7};});};});}exports[a9_0x35bf('0x20')]=invokeTasksUsingRunMany;function groupByTarget(_0xb4cc8b){const _0x5982fb=[];_0xb4cc8b[a9_0x35bf('0x0')](_0x2fff99=>{const _0x282da7=_0x5982fb[a9_0x35bf('0x13')](_0xe77f0f=>_0xe77f0f[a9_0x35bf('0x2')]===_0x2fff99[a9_0x35bf('0x2')]&&_0xe77f0f[a9_0x35bf('0xf')]===_0x2fff99[a9_0x35bf('0xf')]);if(_0x282da7){_0x282da7[a9_0x35bf('0x1')]['push'](_0x2fff99[a9_0x35bf('0x1a')]);}else{_0x5982fb[a9_0x35bf('0x10')]({'target':_0x2fff99[a9_0x35bf('0x2')],'projects':[_0x2fff99['projectName']],'params':_0x2fff99[a9_0x35bf('0x21')],'configuration':_0x2fff99[a9_0x35bf('0xf')]});}});return _0x5982fb;}function completedTasksReader(){return _0x21caa3=>{const _0x431e61=a9_0x35bf('0x16')+_0x21caa3+').\x20Tasks\x20hashes\x20haven\x27t\x20been\x20recorded.';let _0xb8c3e5;try{const _0x2e93fc=cacheDirectory+a9_0x35bf('0x15')+_0x21caa3;_0xb8c3e5=JSON[a9_0x35bf('0x11')]((0x0,fs_1[a9_0x35bf('0xb')])(_0x2e93fc)[a9_0x35bf('0x9')]());(0x0,fs_1['unlinkSync'])(_0x2e93fc);}catch(_0x2936fc){throw new Error(_0x431e61);}if(_0xb8c3e5[a9_0x35bf('0x6')]==0x0){throw new Error(_0x431e61);}return _0xb8c3e5;};}

lib/core/runners/distributed-execution/distributed-execution.api.js

@@ -1,1 +0,1 @@
-const a10_0x1066=['dteStart','RUNNER_FAILURE_PERF_ENTRY','throw','axiosException','dteStatus','agentCount','then','value','VERBOSE_LOGGING','completeRunGroup','note','Workspace\x20is\x20disabled.\x20Cannot\x20perform\x20distributed\x20task\x20executions.','Starting\x20a\x20distributed\x20execution','createStartRequest','false','recordMetric','error','parallel','createApiAxiosInstance','serializeOverrides','/nx-cloud/executions/status','parseCommand','completeRunGroupWithError','start','../../../utilities/axios','__awaiter','apiAxiosInstance','stopAgentsOnFailure','apply','createMetricRecorder','project','target','DistributedExecutionApi','hash','NX_CLOUD_DISTRIBUTED_EXECUTION_STOP_AGENTS_ON_FAILURE','maxParallel','enabled','response','axiosMultipleTries','post','status','data','error:\x20','../../../utilities/environment','../../../utilities/serializer-overrides','../../../utilities/nx-imports','map','ciExecutionEnv:\x20','mapRespToPerfEntry','runGroup:\x20','ciExecutionId:\x20','defineProperty','Completing\x20with\x20an\x20error','NX_CLOUD_DISTRIBUTED_EXECUTION_AGENT_COUNT'];(function(_0x5e07c6,_0x10661b){const _0x1ccced=function(_0x33a019){while(--_0x33a019){_0x5e07c6['push'](_0x5e07c6['shift']());}};_0x1ccced(++_0x10661b);}(a10_0x1066,0x1ef));const a10_0x1ccc=function(_0x5e07c6,_0x10661b){_0x5e07c6=_0x5e07c6-0x0;let _0x1ccced=a10_0x1066[_0x5e07c6];return _0x1ccced;};'use strict';var __awaiter=this&&this[a10_0x1ccc('0x10')]||function(_0xd4397c,_0x10d2e8,_0x477630,_0x19f45b){function _0x1be26a(_0x4b43bc){return _0x4b43bc instanceof _0x477630?_0x4b43bc:new _0x477630(function(_0x10c2ac){_0x10c2ac(_0x4b43bc);});}return new(_0x477630||(_0x477630=Promise))(function(_0x149872,_0x168cf3){function _0x1e50d9(_0x59f94a){try{_0x438a33(_0x19f45b['next'](_0x59f94a));}catch(_0x1e574d){_0x168cf3(_0x1e574d);}}function _0x415ee4(_0x54d388){try{_0x438a33(_0x19f45b[a10_0x1ccc('0x2f')](_0x54d388));}catch(_0x418143){_0x168cf3(_0x418143);}}function _0x438a33(_0x556103){_0x556103['done']?_0x149872(_0x556103[a10_0x1ccc('0x34')]):_0x1be26a(_0x556103['value'])[a10_0x1ccc('0x33')](_0x1e50d9,_0x415ee4);}_0x438a33((_0x19f45b=_0x19f45b[a10_0x1ccc('0x13')](_0xd4397c,_0x10d2e8||[]))['next']());});};Object[a10_0x1ccc('0x2a')](exports,'__esModule',{'value':!![]});exports[a10_0x1ccc('0x4')]=exports[a10_0x1ccc('0x17')]=void 0x0;const axios_1=require(a10_0x1ccc('0xf'));const environment_1=require(a10_0x1ccc('0x22'));const metric_logger_1=require('../../../utilities/metric-logger');const serializer_overrides_1=require(a10_0x1ccc('0x23'));const {output}=require(a10_0x1ccc('0x24'));class DistributedExecutionApi{constructor(_0x46300b){this['apiAxiosInstance']=(0x0,axios_1[a10_0x1ccc('0x9')])(_0x46300b);}[a10_0x1ccc('0xe')](_0x17f8b5){var _0x33a8f0;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x26d3f7=(0x0,metric_logger_1[a10_0x1ccc('0x14')])(a10_0x1ccc('0x2d'));let _0x18892d;if(environment_1[a10_0x1ccc('0x35')]){output[a10_0x1ccc('0x1')]({'title':a10_0x1ccc('0x3'),'bodyLines':[JSON['stringify'](_0x17f8b5,null,0x2)]});}try{_0x18892d=yield(0x0,axios_1['axiosMultipleTries'])(()=>this[a10_0x1ccc('0x11')][a10_0x1ccc('0x1e')]('/nx-cloud/executions/start',_0x17f8b5));_0x26d3f7['recordMetric']((0x0,metric_logger_1[a10_0x1ccc('0x27')])(_0x18892d));}catch(_0x3daa1c){_0x26d3f7['recordMetric'](((_0x33a8f0=_0x3daa1c===null||_0x3daa1c===void 0x0?void 0x0:_0x3daa1c[a10_0x1ccc('0x30')])===null||_0x33a8f0===void 0x0?void 0x0:_0x33a8f0[a10_0x1ccc('0x1c')])?(0x0,metric_logger_1[a10_0x1ccc('0x27')])(_0x3daa1c[a10_0x1ccc('0x30')]['response']):metric_logger_1[a10_0x1ccc('0x2e')]);throw _0x3daa1c;}if(!_0x18892d[a10_0x1ccc('0x20')][a10_0x1ccc('0x1b')]){throw new Error(a10_0x1ccc('0x2'));}if(_0x18892d[a10_0x1ccc('0x20')][a10_0x1ccc('0x7')]){throw new Error(_0x18892d['data'][a10_0x1ccc('0x7')]);}return _0x18892d[a10_0x1ccc('0x20')]['id'];});}[a10_0x1ccc('0x1f')](_0x25606c){var _0x4caa6a;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x848932=(0x0,metric_logger_1[a10_0x1ccc('0x14')])(a10_0x1ccc('0x31'));try{const _0x1b15b5=yield(0x0,axios_1['axiosMultipleTries'])(()=>this[a10_0x1ccc('0x11')]['post'](a10_0x1ccc('0xb'),{'id':_0x25606c}));_0x848932['recordMetric']((0x0,metric_logger_1[a10_0x1ccc('0x27')])(_0x1b15b5));return _0x1b15b5['data'];}catch(_0x224c78){_0x848932['recordMetric'](((_0x4caa6a=_0x224c78===null||_0x224c78===void 0x0?void 0x0:_0x224c78[a10_0x1ccc('0x30')])===null||_0x4caa6a===void 0x0?void 0x0:_0x4caa6a[a10_0x1ccc('0x1c')])?(0x0,metric_logger_1[a10_0x1ccc('0x27')])(_0x224c78[a10_0x1ccc('0x30')][a10_0x1ccc('0x1c')]):metric_logger_1[a10_0x1ccc('0x2e')]);output[a10_0x1ccc('0x7')]({'title':_0x224c78['message']});process['exit'](0x1);}});}[a10_0x1ccc('0xd')](_0x3107e2,_0x18b933,_0x2e909f,_0x10f988,_0x2f9450){var _0x192c96;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x491892=(0x0,metric_logger_1['createMetricRecorder'])(a10_0x1ccc('0x0'));if(environment_1[a10_0x1ccc('0x35')]){output['note']({'title':a10_0x1ccc('0x2b'),'bodyLines':[a10_0x1ccc('0x29')+_0x2e909f,a10_0x1ccc('0x26')+_0x10f988,a10_0x1ccc('0x28')+_0x18b933,a10_0x1ccc('0x21')+_0x2f9450]});}try{const _0x1e7605=yield(0x0,axios_1[a10_0x1ccc('0x1d')])(()=>this[a10_0x1ccc('0x11')]['post']('/nx-cloud/executions/complete-run-group',{'runGroup':_0x18b933,'ciExecutionId':_0x2e909f,'ciExecutionEnv':_0x10f988,'criticalErrorMessage':_0x2f9450}),0x3);_0x491892[a10_0x1ccc('0x6')]((0x0,metric_logger_1[a10_0x1ccc('0x27')])(_0x1e7605));}catch(_0x284e2f){_0x491892['recordMetric'](((_0x192c96=_0x284e2f===null||_0x284e2f===void 0x0?void 0x0:_0x284e2f[a10_0x1ccc('0x30')])===null||_0x192c96===void 0x0?void 0x0:_0x192c96[a10_0x1ccc('0x1c')])?(0x0,metric_logger_1[a10_0x1ccc('0x27')])(_0x284e2f[a10_0x1ccc('0x30')]['response']):metric_logger_1[a10_0x1ccc('0x2e')]);}});}}exports[a10_0x1ccc('0x17')]=DistributedExecutionApi;function createStartRequest(_0x2b4af8,_0x1e3bc1,_0x2e0134,_0x54c26e,_0x646c5b,_0x1a98ac){const _0x594eca=_0x646c5b[a10_0x1ccc('0x25')](_0x1e146d=>{return _0x1e146d[a10_0x1ccc('0x25')](_0x1aebf1=>{return{'taskId':_0x1aebf1['id'],'hash':_0x1aebf1[a10_0x1ccc('0x18')],'projectName':_0x1aebf1['target'][a10_0x1ccc('0x15')],'target':_0x1aebf1[a10_0x1ccc('0x16')][a10_0x1ccc('0x16')],'configuration':_0x1aebf1['target']['configuration']||null,'params':(0x0,serializer_overrides_1[a10_0x1ccc('0xa')])(_0x1aebf1)};});});const _0x4ea063={'command':(0x0,environment_1[a10_0x1ccc('0xc')])(),'branch':_0x2b4af8,'runGroup':_0x1e3bc1,'ciExecutionId':_0x2e0134,'ciExecutionEnv':_0x54c26e,'tasks':_0x594eca,'maxParallel':calculateMaxParallel(_0x1a98ac)};if(environment_1[a10_0x1ccc('0x2c')]){_0x4ea063[a10_0x1ccc('0x32')]=environment_1['NX_CLOUD_DISTRIBUTED_EXECUTION_AGENT_COUNT'];}if(!environment_1[a10_0x1ccc('0x19')]){_0x4ea063[a10_0x1ccc('0x12')]=![];}return _0x4ea063;}exports[a10_0x1ccc('0x4')]=createStartRequest;function calculateMaxParallel(_0xa08807){if(_0xa08807['parallel']===a10_0x1ccc('0x5')||_0xa08807['parallel']===![]){return 0x1;}else if(_0xa08807[a10_0x1ccc('0x8')]==='true'||_0xa08807[a10_0x1ccc('0x8')]===!![]){return Number(_0xa08807[a10_0x1ccc('0x1a')]||0x3);}else if(_0xa08807[a10_0x1ccc('0x8')]===undefined){return _0xa08807['maxParallel']?Number(_0xa08807[a10_0x1ccc('0x1a')]):0x3;}else{return Number(_0xa08807[a10_0x1ccc('0x8')])||0x3;}}
+const a10_0xae8c=['../../../utilities/environment','axiosMultipleTries','ciExecutionId:\x20','note','value','map','Starting\x20a\x20distributed\x20execution','../../../utilities/axios','__awaiter','then','configuration','/nx-cloud/executions/status','post','parseCommand','status','next','false','createMetricRecorder','throw','recordMetric','hash','dteStatus','data','enabled','ciExecutionEnv:\x20','stringify','runGroup:\x20','DistributedExecutionApi','message','axiosException','maxParallel','apiAxiosInstance','true','dteStart','completeRunGroup','Workspace\x20is\x20disabled.\x20Cannot\x20perform\x20distributed\x20task\x20executions.','start','done','stopAgentsOnFailure','target','../../../utilities/metric-logger','mapRespToPerfEntry','response','agentCount','Completing\x20with\x20an\x20error','RUNNER_FAILURE_PERF_ENTRY','parallel','completeRunGroupWithError','VERBOSE_LOGGING','../../../utilities/nx-imports','createStartRequest','/nx-cloud/executions/start','NX_CLOUD_DISTRIBUTED_EXECUTION_AGENT_COUNT','defineProperty','apply','error'];(function(_0x269bfd,_0xae8cea){const _0x4c6ef3=function(_0x3d5cfd){while(--_0x3d5cfd){_0x269bfd['push'](_0x269bfd['shift']());}};_0x4c6ef3(++_0xae8cea);}(a10_0xae8c,0x106));const a10_0x4c6e=function(_0x269bfd,_0xae8cea){_0x269bfd=_0x269bfd-0x0;let _0x4c6ef3=a10_0xae8c[_0x269bfd];return _0x4c6ef3;};'use strict';var __awaiter=this&&this[a10_0x4c6e('0x1a')]||function(_0x1ca801,_0x203385,_0x4b049,_0xaa5b0a){function _0x53f235(_0x21f008){return _0x21f008 instanceof _0x4b049?_0x21f008:new _0x4b049(function(_0x23d727){_0x23d727(_0x21f008);});}return new(_0x4b049||(_0x4b049=Promise))(function(_0x22d5cc,_0x559736){function _0x3c7fb4(_0x8b796b){try{_0x2997fd(_0xaa5b0a['next'](_0x8b796b));}catch(_0x5d1804){_0x559736(_0x5d1804);}}function _0xb4ac15(_0x3da257){try{_0x2997fd(_0xaa5b0a[a10_0x4c6e('0x24')](_0x3da257));}catch(_0x4f19bc){_0x559736(_0x4f19bc);}}function _0x2997fd(_0x197967){_0x197967[a10_0x4c6e('0x37')]?_0x22d5cc(_0x197967[a10_0x4c6e('0x16')]):_0x53f235(_0x197967[a10_0x4c6e('0x16')])[a10_0x4c6e('0x1b')](_0x3c7fb4,_0xb4ac15);}_0x2997fd((_0xaa5b0a=_0xaa5b0a[a10_0x4c6e('0x10')](_0x1ca801,_0x203385||[]))[a10_0x4c6e('0x21')]());});};Object[a10_0x4c6e('0xf')](exports,'__esModule',{'value':!![]});exports[a10_0x4c6e('0xc')]=exports[a10_0x4c6e('0x2d')]=void 0x0;const axios_1=require(a10_0x4c6e('0x19'));const environment_1=require(a10_0x4c6e('0x12'));const metric_logger_1=require(a10_0x4c6e('0x2'));const serializer_overrides_1=require('../../../utilities/serializer-overrides');const {output}=require(a10_0x4c6e('0xb'));class DistributedExecutionApi{constructor(_0x3a9375){this['apiAxiosInstance']=(0x0,axios_1['createApiAxiosInstance'])(_0x3a9375);}[a10_0x4c6e('0x36')](_0x121718){var _0x5343a6;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x451cda=(0x0,metric_logger_1[a10_0x4c6e('0x23')])(a10_0x4c6e('0x33'));let _0x4d6fec;if(environment_1[a10_0x4c6e('0xa')]){output[a10_0x4c6e('0x15')]({'title':a10_0x4c6e('0x18'),'bodyLines':[JSON[a10_0x4c6e('0x2b')](_0x121718,null,0x2)]});}try{_0x4d6fec=yield(0x0,axios_1[a10_0x4c6e('0x13')])(()=>this[a10_0x4c6e('0x31')][a10_0x4c6e('0x1e')](a10_0x4c6e('0xd'),_0x121718));_0x451cda['recordMetric']((0x0,metric_logger_1[a10_0x4c6e('0x3')])(_0x4d6fec));}catch(_0x37bc83){_0x451cda[a10_0x4c6e('0x25')](((_0x5343a6=_0x37bc83===null||_0x37bc83===void 0x0?void 0x0:_0x37bc83['axiosException'])===null||_0x5343a6===void 0x0?void 0x0:_0x5343a6[a10_0x4c6e('0x4')])?(0x0,metric_logger_1['mapRespToPerfEntry'])(_0x37bc83[a10_0x4c6e('0x2f')][a10_0x4c6e('0x4')]):metric_logger_1['RUNNER_FAILURE_PERF_ENTRY']);throw _0x37bc83;}if(!_0x4d6fec[a10_0x4c6e('0x28')][a10_0x4c6e('0x29')]){throw new Error(a10_0x4c6e('0x35'));}if(_0x4d6fec[a10_0x4c6e('0x28')][a10_0x4c6e('0x11')]){throw new Error(_0x4d6fec[a10_0x4c6e('0x28')][a10_0x4c6e('0x11')]);}return _0x4d6fec[a10_0x4c6e('0x28')]['id'];});}[a10_0x4c6e('0x20')](_0x1a9d87){var _0x575a6e;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x232945=(0x0,metric_logger_1[a10_0x4c6e('0x23')])(a10_0x4c6e('0x27'));try{const _0x102c7f=yield(0x0,axios_1[a10_0x4c6e('0x13')])(()=>this[a10_0x4c6e('0x31')][a10_0x4c6e('0x1e')](a10_0x4c6e('0x1d'),{'id':_0x1a9d87}));_0x232945[a10_0x4c6e('0x25')]((0x0,metric_logger_1['mapRespToPerfEntry'])(_0x102c7f));return _0x102c7f['data'];}catch(_0x52e323){_0x232945[a10_0x4c6e('0x25')](((_0x575a6e=_0x52e323===null||_0x52e323===void 0x0?void 0x0:_0x52e323[a10_0x4c6e('0x2f')])===null||_0x575a6e===void 0x0?void 0x0:_0x575a6e['response'])?(0x0,metric_logger_1[a10_0x4c6e('0x3')])(_0x52e323[a10_0x4c6e('0x2f')][a10_0x4c6e('0x4')]):metric_logger_1[a10_0x4c6e('0x7')]);output[a10_0x4c6e('0x11')]({'title':_0x52e323[a10_0x4c6e('0x2e')]});process['exit'](0x1);}});}[a10_0x4c6e('0x9')](_0x23b206,_0x18375f,_0x234374,_0x32a554,_0x12ad17){var _0x6b69ee;return __awaiter(this,void 0x0,void 0x0,function*(){const _0x5acef8=(0x0,metric_logger_1[a10_0x4c6e('0x23')])(a10_0x4c6e('0x34'));if(environment_1[a10_0x4c6e('0xa')]){output[a10_0x4c6e('0x15')]({'title':a10_0x4c6e('0x6'),'bodyLines':[a10_0x4c6e('0x14')+_0x234374,a10_0x4c6e('0x2a')+_0x32a554,a10_0x4c6e('0x2c')+_0x18375f,'error:\x20'+_0x12ad17]});}try{const _0x5378bc=yield(0x0,axios_1['axiosMultipleTries'])(()=>this[a10_0x4c6e('0x31')][a10_0x4c6e('0x1e')]('/nx-cloud/executions/complete-run-group',{'runGroup':_0x18375f,'ciExecutionId':_0x234374,'ciExecutionEnv':_0x32a554,'criticalErrorMessage':_0x12ad17}),0x3);_0x5acef8[a10_0x4c6e('0x25')]((0x0,metric_logger_1[a10_0x4c6e('0x3')])(_0x5378bc));}catch(_0x244020){_0x5acef8['recordMetric'](((_0x6b69ee=_0x244020===null||_0x244020===void 0x0?void 0x0:_0x244020['axiosException'])===null||_0x6b69ee===void 0x0?void 0x0:_0x6b69ee[a10_0x4c6e('0x4')])?(0x0,metric_logger_1[a10_0x4c6e('0x3')])(_0x244020[a10_0x4c6e('0x2f')]['response']):metric_logger_1[a10_0x4c6e('0x7')]);}});}}exports[a10_0x4c6e('0x2d')]=DistributedExecutionApi;function createStartRequest(_0x15ccb0,_0x550857,_0x36e1a0,_0x4edff4,_0xe32065,_0x18eccd){const _0x530f40=_0xe32065['map'](_0x2b7250=>{return _0x2b7250[a10_0x4c6e('0x17')](_0x522686=>{return{'taskId':_0x522686['id'],'hash':_0x522686[a10_0x4c6e('0x26')],'projectName':_0x522686['target']['project'],'target':_0x522686[a10_0x4c6e('0x1')][a10_0x4c6e('0x1')],'configuration':_0x522686['target'][a10_0x4c6e('0x1c')]||null,'params':(0x0,serializer_overrides_1['serializeOverrides'])(_0x522686)};});});const _0x3a5551={'command':(0x0,environment_1[a10_0x4c6e('0x1f')])(),'branch':_0x15ccb0,'runGroup':_0x550857,'ciExecutionId':_0x36e1a0,'ciExecutionEnv':_0x4edff4,'tasks':_0x530f40,'maxParallel':calculateMaxParallel(_0x18eccd)};if(environment_1[a10_0x4c6e('0xe')]){_0x3a5551[a10_0x4c6e('0x5')]=environment_1[a10_0x4c6e('0xe')];}if(!environment_1['NX_CLOUD_DISTRIBUTED_EXECUTION_STOP_AGENTS_ON_FAILURE']){_0x3a5551[a10_0x4c6e('0x0')]=![];}return _0x3a5551;}exports[a10_0x4c6e('0xc')]=createStartRequest;function calculateMaxParallel(_0x590bb8){if(_0x590bb8[a10_0x4c6e('0x8')]===a10_0x4c6e('0x22')||_0x590bb8['parallel']===![]){return 0x1;}else if(_0x590bb8['parallel']===a10_0x4c6e('0x32')||_0x590bb8['parallel']===!![]){return Number(_0x590bb8[a10_0x4c6e('0x30')]||0x3);}else if(_0x590bb8[a10_0x4c6e('0x8')]===undefined){return _0x590bb8[a10_0x4c6e('0x30')]?Number(_0x590bb8[a10_0x4c6e('0x30')]):0x3;}else{return Number(_0x590bb8[a10_0x4c6e('0x8')])||0x3;}}

lib/core/runners/distributed-execution/distributed-execution.runner.js

@@ -1,1 +0,1 @@
-const a11_0x28e5=['start','__awaiter','createTaskGraphCompat','ErrorReporterApi','encryptionKey','./split-task-graph-into-stages','DTE\x20needs\x20the\x20cache\x20to\x20share\x20files\x20between\x20agents.','scheduleTask','next','getCIExecutionId','__esModule','VERBOSE_LOGGING','Main\x20job\x20was\x20terminated\x20via\x20SIGTERM','endTasks','--skip-nx-cache\x20is\x20ignored\x20when\x20using\x20distributed\x20tasks\x20execution\x20(DTE).','FileStorage','error','./task-graph-creator','./distributed-execution.api','./process-tasks','log','SIGINT','Successfully\x20completed\x20running\x20the\x20command.','getBranch','../../file-storage/file-storage','../../file-storage/e2e-encryption','Main\x20job\x20was\x20terminated\x20via\x20SIGINT','E2EEncryption','Starting\x20distributed\x20command\x20execution','then','runUrl','lifeCycle','See\x20run\x20details\x20at\x20','value','splitTasksIntoStages','success','exit','printRunGroupError','commandStatus','message','skipNxCache','../../../utilities/metric-logger','axiosException','note','throw','DteArtifactStorage','../../api/error-reporter.api','ENCRYPTION_KEY','nxCloudDistributedTasksRunner','apply','completeRunGroupWithError','getCIExecutionEnv','Unable\x20to\x20complete\x20a\x20run.','dte-main','Main\x20job\x20terminated\x20with\x20an\x20error:\x20\x22','../../../utilities/dte-artifact-storage','submitRunMetrics','taskGraph'];(function(_0x3e194e,_0x28e55b){const _0x5d43d9=function(_0xfff169){while(--_0xfff169){_0x3e194e['push'](_0x3e194e['shift']());}};_0x5d43d9(++_0x28e55b);}(a11_0x28e5,0x169));const a11_0x5d43=function(_0x3e194e,_0x28e55b){_0x3e194e=_0x3e194e-0x0;let _0x5d43d9=a11_0x28e5[_0x3e194e];return _0x5d43d9;};'use strict';var __awaiter=this&&this[a11_0x5d43('0x2e')]||function(_0x488dc9,_0x5c18d4,_0xc5d1db,_0x415723){function _0x7a4ceb(_0xd4fef7){return _0xd4fef7 instanceof _0xc5d1db?_0xd4fef7:new _0xc5d1db(function(_0x251873){_0x251873(_0xd4fef7);});}return new(_0xc5d1db||(_0xc5d1db=Promise))(function(_0x51f762,_0x33ec59){function _0x1f8e28(_0x1d8860){try{_0xe0b705(_0x415723['next'](_0x1d8860));}catch(_0x51c005){_0x33ec59(_0x51c005);}}function _0x9f320c(_0x12f6a9){try{_0xe0b705(_0x415723[a11_0x5d43('0x1f')](_0x12f6a9));}catch(_0x4f21be){_0x33ec59(_0x4f21be);}}function _0xe0b705(_0x47bce4){_0x47bce4['done']?_0x51f762(_0x47bce4['value']):_0x7a4ceb(_0x47bce4[a11_0x5d43('0x14')])[a11_0x5d43('0x10')](_0x1f8e28,_0x9f320c);}_0xe0b705((_0x415723=_0x415723[a11_0x5d43('0x24')](_0x488dc9,_0x5c18d4||[]))[a11_0x5d43('0x35')]());});};Object['defineProperty'](exports,a11_0x5d43('0x37'),{'value':!![]});exports[a11_0x5d43('0x23')]=void 0x0;const environment_1=require('../../../utilities/environment');const metric_logger_1=require(a11_0x5d43('0x1c'));const error_reporter_api_1=require(a11_0x5d43('0x21'));const print_run_group_error_1=require('../../error/print-run-group-error');const e2e_encryption_1=require(a11_0x5d43('0xc'));const file_storage_1=require(a11_0x5d43('0xb'));const distributed_execution_api_1=require(a11_0x5d43('0x5'));const split_task_graph_into_stages_1=require(a11_0x5d43('0x32'));const task_graph_creator_1=require(a11_0x5d43('0x4'));const process_tasks_1=require(a11_0x5d43('0x6'));const dte_artifact_storage_1=require(a11_0x5d43('0x2a'));const {output,cacheDirectory}=require('../../../utilities/nx-imports');class NoopLifeCycle{[a11_0x5d43('0x34')](_0x38c28a){}['startTask'](_0x7e46fd){}[a11_0x5d43('0x0')](_0x5c42d4){}}const nxCloudDistributedTasksRunner=(_0x39f43c,_0x197e54,_0x145bd0)=>__awaiter(void 0x0,void 0x0,void 0x0,function*(){if(_0x197e54[a11_0x5d43('0x1b')]){output['warn']({'title':a11_0x5d43('0x1'),'bodyLine':[a11_0x5d43('0x33')]});}if(environment_1[a11_0x5d43('0x38')]){output[a11_0x5d43('0x1e')]({'title':a11_0x5d43('0xf')});}_0x197e54[a11_0x5d43('0x12')]=new NoopLifeCycle();const _0x54a7c0=(0x0,environment_1[a11_0x5d43('0xa')])();const _0x1b8bfc=(0x0,environment_1['getRunGroup'])();const _0x3ee064=(0x0,environment_1[a11_0x5d43('0x36')])();const _0x50ee7d=(0x0,environment_1[a11_0x5d43('0x26')])();if(!(0x0,print_run_group_error_1['canDetectRunGroup'])(_0x1b8bfc,_0x3ee064)){(0x0,print_run_group_error_1[a11_0x5d43('0x18')])();process[a11_0x5d43('0x17')](0x1);}const _0x1f155c=new e2e_encryption_1[(a11_0x5d43('0xe'))](environment_1[a11_0x5d43('0x22')]||_0x197e54[a11_0x5d43('0x31')]);const _0x421f59=new error_reporter_api_1[(a11_0x5d43('0x30'))](_0x197e54);const _0x1408a1=new dte_artifact_storage_1[(a11_0x5d43('0x20'))](new file_storage_1[(a11_0x5d43('0x2'))](_0x1f155c,_0x421f59,_0x197e54,a11_0x5d43('0x28')),cacheDirectory);const _0x41e219=new distributed_execution_api_1['DistributedExecutionApi'](_0x197e54);attachSignalListenersToCompleteRunGroupOnError(_0x41e219,_0x54a7c0,_0x1b8bfc,_0x3ee064,_0x50ee7d);try{const _0x333a03=getTaskGraph(_0x145bd0,_0x39f43c,_0x197e54);const _0x2ea53b=yield runDistributedExecution(_0x41e219,_0x197e54,_0x1408a1,_0x54a7c0,_0x1b8bfc,_0x3ee064,_0x50ee7d,_0x333a03);if(_0x2ea53b['commandStatus']===0x0){output[a11_0x5d43('0x16')]({'title':a11_0x5d43('0x9'),'bodyLines':['See\x20run\x20details\x20at\x20'+_0x2ea53b[a11_0x5d43('0x11')]]});}else{output['error']({'title':'Command\x20execution\x20failed.','bodyLines':[a11_0x5d43('0x13')+_0x2ea53b[a11_0x5d43('0x11')]]});}yield(0x0,metric_logger_1[a11_0x5d43('0x2b')])(_0x197e54);process[a11_0x5d43('0x17')](_0x2ea53b[a11_0x5d43('0x19')]);}catch(_0x3d1762){output[a11_0x5d43('0x3')]({'title':a11_0x5d43('0x27'),'bodyLines':[_0x3d1762['message']]});if(_0x3d1762[a11_0x5d43('0x1d')]){console['log'](_0x3d1762['axiosException']);}else{console[a11_0x5d43('0x7')](_0x3d1762);}try{yield _0x41e219[a11_0x5d43('0x25')](_0x54a7c0,_0x1b8bfc,_0x3ee064,_0x50ee7d,a11_0x5d43('0x29')+_0x3d1762[a11_0x5d43('0x1a')]+'\x22');}finally{process[a11_0x5d43('0x17')](0x1);}}});exports[a11_0x5d43('0x23')]=nxCloudDistributedTasksRunner;function getTaskGraph(_0x26745d,_0x3fa10d,_0x1f62ed){if(_0x26745d[a11_0x5d43('0x2c')]){return _0x26745d[a11_0x5d43('0x2c')];}else{return(0x0,task_graph_creator_1[a11_0x5d43('0x2f')])(_0x1f62ed,_0x26745d['projectGraph'],_0x3fa10d);}}function attachSignalListenersToCompleteRunGroupOnError(_0x32346e,_0x3a4a3c,_0x45e478,_0x5a6022,_0x28f0d4){process['on'](a11_0x5d43('0x8'),()=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x32346e['completeRunGroupWithError'](_0x3a4a3c,_0x45e478,_0x5a6022,_0x28f0d4,a11_0x5d43('0xd'));process[a11_0x5d43('0x17')](0x1);}));process['on']('SIGTERM',()=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x32346e['completeRunGroupWithError'](_0x3a4a3c,_0x45e478,_0x5a6022,_0x28f0d4,a11_0x5d43('0x39'));process[a11_0x5d43('0x17')](0x1);}));}function runDistributedExecution(_0x1c88c0,_0x25108d,_0x169e2e,_0x89cf12,_0x4fd77c,_0x22f5b9,_0x1995c3,_0xe75dc6){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x5532be=yield _0x1c88c0[a11_0x5d43('0x2d')]((0x0,distributed_execution_api_1['createStartRequest'])(_0x89cf12,_0x4fd77c,_0x22f5b9,_0x1995c3,(0x0,split_task_graph_into_stages_1[a11_0x5d43('0x15')])(_0xe75dc6),_0x25108d));return yield(0x0,process_tasks_1['processTasks'])(_0x1c88c0,_0x169e2e,_0x5532be,Object['values'](_0xe75dc6['tasks']));});}
+const a11_0x15e0=['../../../utilities/dte-artifact-storage','ENCRYPTION_KEY','./process-tasks','../../file-storage/e2e-encryption','canDetectRunGroup','dte-main','DteArtifactStorage','splitTasksIntoStages','../../../utilities/nx-imports','--skip-nx-cache\x20is\x20ignored\x20when\x20using\x20distributed\x20tasks\x20execution\x20(DTE).','../../file-storage/file-storage','tasks','value','taskGraph','VERBOSE_LOGGING','projectGraph','lifeCycle','./task-graph-creator','../../../utilities/metric-logger','message','DTE\x20needs\x20the\x20cache\x20to\x20share\x20files\x20between\x20agents.','See\x20run\x20details\x20at\x20','SIGINT','note','../../../utilities/environment','getCIExecutionId','FileStorage','then','__awaiter','ErrorReporterApi','processTasks','endTasks','success','runUrl','throw','values','error','Main\x20job\x20was\x20terminated\x20via\x20SIGINT','defineProperty','next','commandStatus','exit','printRunGroupError','submitRunMetrics','skipNxCache','nxCloudDistributedTasksRunner','Successfully\x20completed\x20running\x20the\x20command.','warn','Main\x20job\x20terminated\x20with\x20an\x20error:\x20\x22','createTaskGraphCompat','startTask','start','encryptionKey','completeRunGroupWithError','axiosException','DistributedExecutionApi','../../api/error-reporter.api','createStartRequest','scheduleTask','log','Main\x20job\x20was\x20terminated\x20via\x20SIGTERM','getBranch','Command\x20execution\x20failed.'];(function(_0x55e035,_0x15e0a0){const _0x2b17a5=function(_0x168421){while(--_0x168421){_0x55e035['push'](_0x55e035['shift']());}};_0x2b17a5(++_0x15e0a0);}(a11_0x15e0,0x1cd));const a11_0x2b17=function(_0x55e035,_0x15e0a0){_0x55e035=_0x55e035-0x0;let _0x2b17a5=a11_0x15e0[_0x55e035];return _0x2b17a5;};'use strict';var __awaiter=this&&this[a11_0x2b17('0x8')]||function(_0x4e23d7,_0x43d312,_0x2f5f08,_0x584270){function _0x20dbef(_0x1a708b){return _0x1a708b instanceof _0x2f5f08?_0x1a708b:new _0x2f5f08(function(_0x2dcb14){_0x2dcb14(_0x1a708b);});}return new(_0x2f5f08||(_0x2f5f08=Promise))(function(_0x389544,_0x212aa9){function _0x41fd49(_0x23c668){try{_0x87e9(_0x584270[a11_0x2b17('0x13')](_0x23c668));}catch(_0xce2583){_0x212aa9(_0xce2583);}}function _0x2b4b04(_0x3166a7){try{_0x87e9(_0x584270[a11_0x2b17('0xe')](_0x3166a7));}catch(_0x38d973){_0x212aa9(_0x38d973);}}function _0x87e9(_0x4a1585){_0x4a1585['done']?_0x389544(_0x4a1585[a11_0x2b17('0x37')]):_0x20dbef(_0x4a1585[a11_0x2b17('0x37')])[a11_0x2b17('0x7')](_0x41fd49,_0x2b4b04);}_0x87e9((_0x584270=_0x584270['apply'](_0x4e23d7,_0x43d312||[]))[a11_0x2b17('0x13')]());});};Object[a11_0x2b17('0x12')](exports,'__esModule',{'value':!![]});exports['nxCloudDistributedTasksRunner']=void 0x0;const environment_1=require(a11_0x2b17('0x4'));const metric_logger_1=require(a11_0x2b17('0x3d'));const error_reporter_api_1=require(a11_0x2b17('0x24'));const print_run_group_error_1=require('../../error/print-run-group-error');const e2e_encryption_1=require(a11_0x2b17('0x2e'));const file_storage_1=require(a11_0x2b17('0x35'));const distributed_execution_api_1=require('./distributed-execution.api');const split_task_graph_into_stages_1=require('./split-task-graph-into-stages');const task_graph_creator_1=require(a11_0x2b17('0x3c'));const process_tasks_1=require(a11_0x2b17('0x2d'));const dte_artifact_storage_1=require(a11_0x2b17('0x2b'));const {output,cacheDirectory}=require(a11_0x2b17('0x33'));class NoopLifeCycle{[a11_0x2b17('0x26')](_0x413e16){}[a11_0x2b17('0x1e')](_0x562ea2){}[a11_0x2b17('0xb')](_0x561373){}}const nxCloudDistributedTasksRunner=(_0x506bc4,_0x547df9,_0x36fcad)=>__awaiter(void 0x0,void 0x0,void 0x0,function*(){if(_0x547df9[a11_0x2b17('0x18')]){output[a11_0x2b17('0x1b')]({'title':a11_0x2b17('0x34'),'bodyLine':[a11_0x2b17('0x0')]});}if(environment_1[a11_0x2b17('0x39')]){output[a11_0x2b17('0x3')]({'title':'Starting\x20distributed\x20command\x20execution'});}_0x547df9[a11_0x2b17('0x3b')]=new NoopLifeCycle();const _0x368bdb=(0x0,environment_1[a11_0x2b17('0x29')])();const _0x3984e5=(0x0,environment_1['getRunGroup'])();const _0x1a8346=(0x0,environment_1[a11_0x2b17('0x5')])();const _0x411f23=(0x0,environment_1['getCIExecutionEnv'])();if(!(0x0,print_run_group_error_1[a11_0x2b17('0x2f')])(_0x3984e5,_0x1a8346)){(0x0,print_run_group_error_1[a11_0x2b17('0x16')])();process[a11_0x2b17('0x15')](0x1);}const _0x604e48=new e2e_encryption_1['E2EEncryption'](environment_1[a11_0x2b17('0x2c')]||_0x547df9[a11_0x2b17('0x20')]);const _0x1b070e=new error_reporter_api_1[(a11_0x2b17('0x9'))](_0x547df9);const _0x34f690=new dte_artifact_storage_1[(a11_0x2b17('0x31'))](new file_storage_1[(a11_0x2b17('0x6'))](_0x604e48,_0x1b070e,_0x547df9,a11_0x2b17('0x30')),cacheDirectory);const _0x3f0aec=new distributed_execution_api_1[(a11_0x2b17('0x23'))](_0x547df9);attachSignalListenersToCompleteRunGroupOnError(_0x3f0aec,_0x368bdb,_0x3984e5,_0x1a8346,_0x411f23);try{const _0x59aab1=getTaskGraph(_0x36fcad,_0x506bc4,_0x547df9);const _0x2ec094=yield runDistributedExecution(_0x3f0aec,_0x547df9,_0x34f690,_0x368bdb,_0x3984e5,_0x1a8346,_0x411f23,_0x59aab1);if(_0x2ec094[a11_0x2b17('0x14')]===0x0){output[a11_0x2b17('0xc')]({'title':a11_0x2b17('0x1a'),'bodyLines':[a11_0x2b17('0x1')+_0x2ec094['runUrl']]});}else{output[a11_0x2b17('0x10')]({'title':a11_0x2b17('0x2a'),'bodyLines':[a11_0x2b17('0x1')+_0x2ec094[a11_0x2b17('0xd')]]});}yield(0x0,metric_logger_1[a11_0x2b17('0x17')])(_0x547df9);process['exit'](_0x2ec094[a11_0x2b17('0x14')]);}catch(_0x4d2643){output['error']({'title':'Unable\x20to\x20complete\x20a\x20run.','bodyLines':[_0x4d2643[a11_0x2b17('0x3e')]]});if(_0x4d2643['axiosException']){console[a11_0x2b17('0x27')](_0x4d2643[a11_0x2b17('0x22')]);}else{console[a11_0x2b17('0x27')](_0x4d2643);}try{yield _0x3f0aec['completeRunGroupWithError'](_0x368bdb,_0x3984e5,_0x1a8346,_0x411f23,a11_0x2b17('0x1c')+_0x4d2643[a11_0x2b17('0x3e')]+'\x22');}finally{process['exit'](0x1);}}});exports[a11_0x2b17('0x19')]=nxCloudDistributedTasksRunner;function getTaskGraph(_0x48c912,_0x37a3fe,_0x45916b){if(_0x48c912['taskGraph']){return _0x48c912[a11_0x2b17('0x38')];}else{return(0x0,task_graph_creator_1[a11_0x2b17('0x1d')])(_0x45916b,_0x48c912[a11_0x2b17('0x3a')],_0x37a3fe);}}function attachSignalListenersToCompleteRunGroupOnError(_0x5aac75,_0x587cd2,_0xca68e6,_0x344f79,_0x1e24d2){process['on'](a11_0x2b17('0x2'),()=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x5aac75[a11_0x2b17('0x21')](_0x587cd2,_0xca68e6,_0x344f79,_0x1e24d2,a11_0x2b17('0x11'));process['exit'](0x1);}));process['on']('SIGTERM',()=>__awaiter(this,void 0x0,void 0x0,function*(){yield _0x5aac75[a11_0x2b17('0x21')](_0x587cd2,_0xca68e6,_0x344f79,_0x1e24d2,a11_0x2b17('0x28'));process[a11_0x2b17('0x15')](0x1);}));}function runDistributedExecution(_0x3dc837,_0x2ac697,_0x3511cb,_0x3bbe16,_0x40dbae,_0x27df88,_0x59f5d9,_0x3b1651){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x21085d=yield _0x3dc837[a11_0x2b17('0x1f')]((0x0,distributed_execution_api_1[a11_0x2b17('0x25')])(_0x3bbe16,_0x40dbae,_0x27df88,_0x59f5d9,(0x0,split_task_graph_into_stages_1[a11_0x2b17('0x32')])(_0x3b1651),_0x2ac697));return yield(0x0,process_tasks_1[a11_0x2b17('0xa')])(_0x3dc837,_0x3511cb,_0x21085d,Object[a11_0x2b17('0xf')](_0x3b1651[a11_0x2b17('0x36')]));});}

lib/core/runners/distributed-execution/process-task.js

@@ -1,1 +0,1 @@
-const a12_0x4f4e=['retrieveAndExtract','serializeOverrides','logCommand','url','join','Found\x20unknown\x20task:\x20','throw','../../../utilities/environment','Processing\x20task\x20','VERBOSE_LOGGING','run','target','next','__awaiter','taskId','../../../utilities/serializer-overrides','value','done','then','find','project','stdout','configuration'];(function(_0x499a1d,_0x4f4e85){const _0x18ec7a=function(_0x138847){while(--_0x138847){_0x499a1d['push'](_0x499a1d['shift']());}};_0x18ec7a(++_0x4f4e85);}(a12_0x4f4e,0x199));const a12_0x18ec=function(_0x499a1d,_0x4f4e85){_0x499a1d=_0x499a1d-0x0;let _0x18ec7a=a12_0x4f4e[_0x499a1d];return _0x18ec7a;};'use strict';var __awaiter=this&&this[a12_0x18ec('0x12')]||function(_0x77e3cb,_0x43bf67,_0x2697e9,_0x1e7650){function _0x303495(_0x17e350){return _0x17e350 instanceof _0x2697e9?_0x17e350:new _0x2697e9(function(_0x497148){_0x497148(_0x17e350);});}return new(_0x2697e9||(_0x2697e9=Promise))(function(_0x38036d,_0x2bcb1b){function _0x5b58b6(_0x57b8c9){try{_0x2bc118(_0x1e7650[a12_0x18ec('0x11')](_0x57b8c9));}catch(_0x84a552){_0x2bcb1b(_0x84a552);}}function _0x4676bc(_0x500974){try{_0x2bc118(_0x1e7650[a12_0x18ec('0xb')](_0x500974));}catch(_0x1b0bfa){_0x2bcb1b(_0x1b0bfa);}}function _0x2bc118(_0x2b5402){_0x2b5402[a12_0x18ec('0x16')]?_0x38036d(_0x2b5402['value']):_0x303495(_0x2b5402[a12_0x18ec('0x15')])[a12_0x18ec('0x0')](_0x5b58b6,_0x4676bc);}_0x2bc118((_0x1e7650=_0x1e7650['apply'](_0x77e3cb,_0x43bf67||[]))[a12_0x18ec('0x11')]());});};Object['defineProperty'](exports,'__esModule',{'value':!![]});exports['processTask']=void 0x0;const environment_1=require(a12_0x18ec('0xc'));const serializer_overrides_1=require(a12_0x18ec('0x14'));const {output}=require('../../../utilities/nx-imports');function processTask(_0xc7cc3d,_0x184992,_0xffb8d9){return __awaiter(this,void 0x0,void 0x0,function*(){if(environment_1[a12_0x18ec('0xe')]){output['note']({'title':a12_0x18ec('0xd')+_0xffb8d9[a12_0x18ec('0x13')]});}const _0x13f26e=_0x184992[a12_0x18ec('0x1')](_0x593a17=>_0xffb8d9[a12_0x18ec('0x13')]===_0x593a17['id']);if(!_0x13f26e){throw new Error(a12_0x18ec('0xa')+_0xffb8d9[a12_0x18ec('0x13')]);}const _0x28d425=yield _0xc7cc3d[a12_0x18ec('0x5')](_0xffb8d9['hash'],_0xffb8d9[a12_0x18ec('0x8')]);output[a12_0x18ec('0x7')](getCommand(_0x13f26e));process[a12_0x18ec('0x3')]['write'](_0x28d425);output['addVerticalSeparator']();});}exports['processTask']=processTask;function getCommand(_0x963770){const _0x3b1a2d=_0x963770[a12_0x18ec('0x10')][a12_0x18ec('0x4')]?':'+_0x963770[a12_0x18ec('0x10')][a12_0x18ec('0x4')]:'';return['nx',a12_0x18ec('0xf'),_0x963770['target'][a12_0x18ec('0x2')]+':'+_0x963770[a12_0x18ec('0x10')][a12_0x18ec('0x10')]+_0x3b1a2d,(0x0,serializer_overrides_1[a12_0x18ec('0x6')])(_0x963770)][a12_0x18ec('0x9')]('\x20');}
+const a12_0xad9c=['done','addVerticalSeparator','target','Processing\x20task\x20','../../../utilities/environment','project','join','run','next','find','logCommand','retrieveAndExtract','../../../utilities/nx-imports','serializeOverrides','Found\x20unknown\x20task:\x20','defineProperty','__awaiter','note','processTask','throw','taskId','then','url','value','../../../utilities/serializer-overrides'];(function(_0x54bd11,_0xad9c46){const _0x2a965d=function(_0x176642){while(--_0x176642){_0x54bd11['push'](_0x54bd11['shift']());}};_0x2a965d(++_0xad9c46);}(a12_0xad9c,0x1c8));const a12_0x2a96=function(_0x54bd11,_0xad9c46){_0x54bd11=_0x54bd11-0x0;let _0x2a965d=a12_0xad9c[_0x54bd11];return _0x2a965d;};'use strict';var __awaiter=this&&this[a12_0x2a96('0xa')]||function(_0x430577,_0x234090,_0x131912,_0x316f97){function _0x56e0df(_0x1c8371){return _0x1c8371 instanceof _0x131912?_0x1c8371:new _0x131912(function(_0x52a847){_0x52a847(_0x1c8371);});}return new(_0x131912||(_0x131912=Promise))(function(_0x548461,_0x35a895){function _0x219594(_0x2906ca){try{_0x268bcf(_0x316f97[a12_0x2a96('0x2')](_0x2906ca));}catch(_0x250558){_0x35a895(_0x250558);}}function _0x14d1d1(_0xcf0350){try{_0x268bcf(_0x316f97[a12_0x2a96('0xd')](_0xcf0350));}catch(_0x57dc55){_0x35a895(_0x57dc55);}}function _0x268bcf(_0x304a1a){_0x304a1a[a12_0x2a96('0x13')]?_0x548461(_0x304a1a['value']):_0x56e0df(_0x304a1a[a12_0x2a96('0x11')])[a12_0x2a96('0xf')](_0x219594,_0x14d1d1);}_0x268bcf((_0x316f97=_0x316f97['apply'](_0x430577,_0x234090||[]))['next']());});};Object[a12_0x2a96('0x9')](exports,'__esModule',{'value':!![]});exports[a12_0x2a96('0xc')]=void 0x0;const environment_1=require(a12_0x2a96('0x17'));const serializer_overrides_1=require(a12_0x2a96('0x12'));const {output}=require(a12_0x2a96('0x6'));function processTask(_0x476f10,_0x2e9396,_0x18627c){return __awaiter(this,void 0x0,void 0x0,function*(){if(environment_1['VERBOSE_LOGGING']){output[a12_0x2a96('0xb')]({'title':a12_0x2a96('0x16')+_0x18627c['taskId']});}const _0x3ef5f2=_0x2e9396[a12_0x2a96('0x3')](_0x3ad68f=>_0x18627c[a12_0x2a96('0xe')]===_0x3ad68f['id']);if(!_0x3ef5f2){throw new Error(a12_0x2a96('0x8')+_0x18627c[a12_0x2a96('0xe')]);}const _0x5d4d69=yield _0x476f10[a12_0x2a96('0x5')](_0x18627c['hash'],_0x18627c[a12_0x2a96('0x10')]);output[a12_0x2a96('0x4')](getCommand(_0x3ef5f2));process['stdout']['write'](_0x5d4d69);output[a12_0x2a96('0x14')]();});}exports[a12_0x2a96('0xc')]=processTask;function getCommand(_0x2d262e){const _0x11b616=_0x2d262e[a12_0x2a96('0x15')]['configuration']?':'+_0x2d262e[a12_0x2a96('0x15')]['configuration']:'';return['nx',a12_0x2a96('0x1'),_0x2d262e[a12_0x2a96('0x15')][a12_0x2a96('0x18')]+':'+_0x2d262e[a12_0x2a96('0x15')][a12_0x2a96('0x15')]+_0x11b616,(0x0,serializer_overrides_1[a12_0x2a96('0x7')])(_0x2d262e)][a12_0x2a96('0x0')]('\x20');}

lib/core/runners/distributed-execution/process-tasks.js

@@ -1,1 +0,1 @@
-const a13_0x5eb7=['Error:','commandStatus','completedTasks','Waiter','Waiting...','COMPLETED','No\x20new\x20completed\x20tasks\x20after\x20','then','done','wait','createUnchangedValueTimeout','value','./process-task','status','__awaiter','criticalErrorMessage','length','runUrl','NO_COMPLETED_TASKS_TIMEOUT','executionStatus','note','../../../utilities/waiter','../../../utilities/environment','processTask','apply','next','executionStatus:\x20','VERBOSE_LOGGING','reset','error:\x20','Status\x20update','processTasks','../../../utilities/create-unchanged-value-timeout','taskId','__esModule','exit'];(function(_0x57b922,_0x5eb7e4){const _0x2558be=function(_0x1da044){while(--_0x1da044){_0x57b922['push'](_0x57b922['shift']());}};_0x2558be(++_0x5eb7e4);}(a13_0x5eb7,0x1d4));const a13_0x2558=function(_0x57b922,_0x5eb7e4){_0x57b922=_0x57b922-0x0;let _0x2558be=a13_0x5eb7[_0x57b922];return _0x2558be;};'use strict';var __awaiter=this&&this[a13_0x2558('0xe')]||function(_0xd7d2e3,_0x8d653d,_0x1e6688,_0x2ccb12){function _0xdfc6f3(_0x50b241){return _0x50b241 instanceof _0x1e6688?_0x50b241:new _0x1e6688(function(_0x340537){_0x340537(_0x50b241);});}return new(_0x1e6688||(_0x1e6688=Promise))(function(_0x4f1005,_0x572d77){function _0x39a84f(_0x2b4832){try{_0x56578d(_0x2ccb12[a13_0x2558('0x19')](_0x2b4832));}catch(_0x4571ae){_0x572d77(_0x4571ae);}}function _0xd901dc(_0x451406){try{_0x56578d(_0x2ccb12['throw'](_0x451406));}catch(_0x14c166){_0x572d77(_0x14c166);}}function _0x56578d(_0x3b7572){_0x3b7572[a13_0x2558('0x8')]?_0x4f1005(_0x3b7572[a13_0x2558('0xb')]):_0xdfc6f3(_0x3b7572[a13_0x2558('0xb')])[a13_0x2558('0x7')](_0x39a84f,_0xd901dc);}_0x56578d((_0x2ccb12=_0x2ccb12[a13_0x2558('0x18')](_0xd7d2e3,_0x8d653d||[]))[a13_0x2558('0x19')]());});};Object['defineProperty'](exports,a13_0x2558('0x22'),{'value':!![]});exports[a13_0x2558('0x1f')]=void 0x0;const create_unchanged_value_timeout_1=require(a13_0x2558('0x20'));const environment_1=require(a13_0x2558('0x16'));const waiter_1=require(a13_0x2558('0x15'));const process_task_1=require(a13_0x2558('0xc'));const {output}=require('../../../utilities/nx-imports');function processTasks(_0x114e51,_0x13752f,_0x2a0703,_0x4280e3){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x6acd82={};const _0x231508=(0x0,create_unchanged_value_timeout_1[a13_0x2558('0xa')])({'title':a13_0x2558('0x6')+environment_1[a13_0x2558('0x12')]/0x3e8+'\x20seconds.','timeout':environment_1[a13_0x2558('0x12')]});const _0x577d91=new waiter_1[(a13_0x2558('0x3'))]();while(!![]){if(environment_1[a13_0x2558('0x1b')]){output[a13_0x2558('0x14')]({'title':a13_0x2558('0x4')});}yield _0x577d91[a13_0x2558('0x9')]();const _0x162863=yield _0x114e51[a13_0x2558('0xd')](_0x2a0703);if(environment_1[a13_0x2558('0x1b')]){output[a13_0x2558('0x14')]({'title':a13_0x2558('0x1e'),'bodyLines':['executionId:\x20'+_0x2a0703,a13_0x2558('0x1a')+_0x162863[a13_0x2558('0x13')],'number\x20of\x20completed\x20tasks:\x20'+_0x162863[a13_0x2558('0x2')][a13_0x2558('0x10')],a13_0x2558('0x1d')+_0x162863[a13_0x2558('0xf')]]});}if(_0x162863[a13_0x2558('0xf')]){output['error']({'title':'Distributed\x20Execution\x20Terminated','bodyLines':[a13_0x2558('0x0'),_0x162863['criticalErrorMessage']]});process[a13_0x2558('0x23')](0x1);}_0x231508(_0x162863[a13_0x2558('0x2')][a13_0x2558('0x10')]);for(const _0x2929ac of _0x162863[a13_0x2558('0x2')]){if(_0x6acd82[_0x2929ac['taskId']])continue;yield(0x0,process_task_1[a13_0x2558('0x17')])(_0x13752f,_0x4280e3,_0x2929ac);_0x577d91[a13_0x2558('0x1c')]();_0x6acd82[_0x2929ac[a13_0x2558('0x21')]]=!![];}if(_0x162863['executionStatus']===a13_0x2558('0x5')){return{'commandStatus':_0x162863[a13_0x2558('0x1')],'runUrl':_0x162863[a13_0x2558('0x11')]};}}});}exports[a13_0x2558('0x1f')]=processTasks;
+const a13_0x48a4=['reset','error:\x20','processTasks','length','Waiting...','../../../utilities/waiter','then','criticalErrorMessage','next','completedTasks','__awaiter','__esModule','note','Distributed\x20Execution\x20Terminated','done','taskId','executionStatus:\x20','Waiter','VERBOSE_LOGGING','wait','No\x20new\x20completed\x20tasks\x20after\x20','number\x20of\x20completed\x20tasks:\x20','defineProperty','Status\x20update','apply','runUrl','processTask','../../../utilities/nx-imports','value','executionStatus','createUnchangedValueTimeout','executionId:\x20','NO_COMPLETED_TASKS_TIMEOUT','Error:'];(function(_0x202828,_0x48a44d){const _0x2f4d27=function(_0x261209){while(--_0x261209){_0x202828['push'](_0x202828['shift']());}};_0x2f4d27(++_0x48a44d);}(a13_0x48a4,0xeb));const a13_0x2f4d=function(_0x202828,_0x48a44d){_0x202828=_0x202828-0x0;let _0x2f4d27=a13_0x48a4[_0x202828];return _0x2f4d27;};'use strict';var __awaiter=this&&this[a13_0x2f4d('0xd')]||function(_0x12fc61,_0x24fb30,_0x363a15,_0x175dde){function _0x4c0ea0(_0x5d407b){return _0x5d407b instanceof _0x363a15?_0x5d407b:new _0x363a15(function(_0x420f17){_0x420f17(_0x5d407b);});}return new(_0x363a15||(_0x363a15=Promise))(function(_0x4deb68,_0x611482){function _0x2b1364(_0x4a1b28){try{_0x34e1a6(_0x175dde[a13_0x2f4d('0xb')](_0x4a1b28));}catch(_0x3c8712){_0x611482(_0x3c8712);}}function _0x4e3e23(_0x394669){try{_0x34e1a6(_0x175dde['throw'](_0x394669));}catch(_0x316a33){_0x611482(_0x316a33);}}function _0x34e1a6(_0x20a82d){_0x20a82d[a13_0x2f4d('0x11')]?_0x4deb68(_0x20a82d[a13_0x2f4d('0x1f')]):_0x4c0ea0(_0x20a82d[a13_0x2f4d('0x1f')])[a13_0x2f4d('0x9')](_0x2b1364,_0x4e3e23);}_0x34e1a6((_0x175dde=_0x175dde[a13_0x2f4d('0x1b')](_0x12fc61,_0x24fb30||[]))[a13_0x2f4d('0xb')]());});};Object[a13_0x2f4d('0x19')](exports,a13_0x2f4d('0xe'),{'value':!![]});exports['processTasks']=void 0x0;const create_unchanged_value_timeout_1=require('../../../utilities/create-unchanged-value-timeout');const environment_1=require('../../../utilities/environment');const waiter_1=require(a13_0x2f4d('0x8'));const process_task_1=require('./process-task');const {output}=require(a13_0x2f4d('0x1e'));function processTasks(_0x3df5cc,_0x4f007c,_0x4a9a39,_0x2a4da8){return __awaiter(this,void 0x0,void 0x0,function*(){const _0x1bcf61={};const _0x5c3a84=(0x0,create_unchanged_value_timeout_1[a13_0x2f4d('0x21')])({'title':a13_0x2f4d('0x17')+environment_1['NO_COMPLETED_TASKS_TIMEOUT']/0x3e8+'\x20seconds.','timeout':environment_1[a13_0x2f4d('0x1')]});const _0x4ea133=new waiter_1[(a13_0x2f4d('0x14'))]();while(!![]){if(environment_1[a13_0x2f4d('0x15')]){output['note']({'title':a13_0x2f4d('0x7')});}yield _0x4ea133[a13_0x2f4d('0x16')]();const _0x1eb9a1=yield _0x3df5cc['status'](_0x4a9a39);if(environment_1['VERBOSE_LOGGING']){output[a13_0x2f4d('0xf')]({'title':a13_0x2f4d('0x1a'),'bodyLines':[a13_0x2f4d('0x0')+_0x4a9a39,a13_0x2f4d('0x13')+_0x1eb9a1['executionStatus'],a13_0x2f4d('0x18')+_0x1eb9a1[a13_0x2f4d('0xc')][a13_0x2f4d('0x6')],a13_0x2f4d('0x4')+_0x1eb9a1[a13_0x2f4d('0xa')]]});}if(_0x1eb9a1['criticalErrorMessage']){output['error']({'title':a13_0x2f4d('0x10'),'bodyLines':[a13_0x2f4d('0x2'),_0x1eb9a1[a13_0x2f4d('0xa')]]});process['exit'](0x1);}_0x5c3a84(_0x1eb9a1[a13_0x2f4d('0xc')]['length']);for(const _0x938916 of _0x1eb9a1[a13_0x2f4d('0xc')]){if(_0x1bcf61[_0x938916[a13_0x2f4d('0x12')]])continue;yield(0x0,process_task_1[a13_0x2f4d('0x1d')])(_0x4f007c,_0x2a4da8,_0x938916);_0x4ea133[a13_0x2f4d('0x3')]();_0x1bcf61[_0x938916[a13_0x2f4d('0x12')]]=!![];}if(_0x1eb9a1[a13_0x2f4d('0x20')]==='COMPLETED'){return{'commandStatus':_0x1eb9a1['commandStatus'],'runUrl':_0x1eb9a1[a13_0x2f4d('0x1c')]};}}});}exports[a13_0x2f4d('0x5')]=processTasks;

lib/core/runners/distributed-execution/split-task-graph-into-stages.js

@@ -1,1 +0,1 @@
-const a14_0x2d5d=['values','delete','push','has','size'];(function(_0x591fcb,_0x2d5d01){const _0x3643ca=function(_0x5049b4){while(--_0x5049b4){_0x591fcb['push'](_0x591fcb['shift']());}};_0x3643ca(++_0x2d5d01);}(a14_0x2d5d,0x1da));const a14_0x3643=function(_0x591fcb,_0x2d5d01){_0x591fcb=_0x591fcb-0x0;let _0x3643ca=a14_0x2d5d[_0x591fcb];return _0x3643ca;};'use strict';Object['defineProperty'](exports,'__esModule',{'value':!![]});exports['splitTasksIntoStages']=void 0x0;function splitTasksIntoStages(_0x55ec1d){const _0x478b59=[];const _0x545598=new Set(Object[a14_0x3643('0x1')](_0x55ec1d['tasks'])['map'](_0x434aeb=>_0x434aeb['id']));let _0x482b1f=0x0;while(_0x545598[a14_0x3643('0x0')]>0x0){const _0x4eafbb=_0x478b59[_0x482b1f]=[];for(const _0x4622e9 of _0x545598){let _0x2c2ff6=!![];for(const _0x2857dd of _0x55ec1d['dependencies'][_0x4622e9]){if(_0x545598[a14_0x3643('0x4')](_0x2857dd)){_0x2c2ff6=![];break;}}if(!_0x2c2ff6){continue;}const _0x281d7a=_0x55ec1d['tasks'][_0x4622e9];_0x4eafbb[a14_0x3643('0x3')](_0x281d7a);}for(const _0x4c07c8 of _0x4eafbb){_0x545598[a14_0x3643('0x2')](_0x4c07c8['id']);}_0x482b1f++;}return _0x478b59;}exports['splitTasksIntoStages']=splitTasksIntoStages;
+const a14_0x2fee=['size','splitTasksIntoStages','tasks','push','dependencies','delete','values','__esModule','map'];(function(_0x1b066f,_0x2fee2f){const _0x285be0=function(_0x5c8b10){while(--_0x5c8b10){_0x1b066f['push'](_0x1b066f['shift']());}};_0x285be0(++_0x2fee2f);}(a14_0x2fee,0x6b));const a14_0x285b=function(_0x1b066f,_0x2fee2f){_0x1b066f=_0x1b066f-0x0;let _0x285be0=a14_0x2fee[_0x1b066f];return _0x285be0;};'use strict';Object['defineProperty'](exports,a14_0x285b('0x8'),{'value':!![]});exports[a14_0x285b('0x2')]=void 0x0;function splitTasksIntoStages(_0x3d71d9){const _0x17e206=[];const _0x167229=new Set(Object[a14_0x285b('0x7')](_0x3d71d9['tasks'])[a14_0x285b('0x0')](_0x16d244=>_0x16d244['id']));let _0x104528=0x0;while(_0x167229[a14_0x285b('0x1')]>0x0){const _0x4f619b=_0x17e206[_0x104528]=[];for(const _0x591e74 of _0x167229){let _0x37dc55=!![];for(const _0x3f8e59 of _0x3d71d9[a14_0x285b('0x5')][_0x591e74]){if(_0x167229['has'](_0x3f8e59)){_0x37dc55=![];break;}}if(!_0x37dc55){continue;}const _0x1c6b2b=_0x3d71d9[a14_0x285b('0x3')][_0x591e74];_0x4f619b[a14_0x285b('0x4')](_0x1c6b2b);}for(const _0x1426d8 of _0x4f619b){_0x167229[a14_0x285b('0x6')](_0x1426d8['id']);}_0x104528++;}return _0x17e206;}exports['splitTasksIntoStages']=splitTasksIntoStages;

lib/core/runners/distributed-execution/task-graph-creator.js

@@ -1,1 +0,1 @@
-const a15_0xebc3=['projects','findTask','strictlyOrderedTargets','defineProperty','dependencies','project','parse','toString','targetDependencies','addTaskDependencies','addDependencies','indexOf','find','createTaskGraph','createTaskGraphCompat','strip-json-comments','add','/nx.json','__esModule','projectGraph','push','defaultTargetDependencies','filter','tasks','build','self','map','TaskGraphCreator','has','target','../../../utilities/nx-imports'];(function(_0x2dc35a,_0xebc3a7){const _0x50cd8e=function(_0x24ee8e){while(--_0x24ee8e){_0x2dc35a['push'](_0x2dc35a['shift']());}};_0x50cd8e(++_0xebc3a7);}(a15_0xebc3,0x124));const a15_0x50cd=function(_0x2dc35a,_0xebc3a7){_0x2dc35a=_0x2dc35a-0x0;let _0x50cd8e=a15_0xebc3[_0x2dc35a];return _0x50cd8e;};'use strict';Object[a15_0x50cd('0x15')](exports,a15_0x50cd('0x5'),{'value':!![]});exports[a15_0x50cd('0xe')]=exports[a15_0x50cd('0x1')]=void 0x0;const stripJsonComments=require(a15_0x50cd('0x2'));const fs_1=require('fs');const {getDependencyConfigs,workspaceRoot}=require(a15_0x50cd('0x11'));function createTaskGraphCompat(_0x9d5baf,_0xadc9e7,_0x1c7c15){const _0x5db65d=JSON[a15_0x50cd('0x18')](stripJsonComments((0x0,fs_1['readFileSync'])(workspaceRoot+a15_0x50cd('0x4'))[a15_0x50cd('0x19')]()));return new TaskGraphCreator(_0xadc9e7,getDefaultDependencyConfigs(_0x5db65d,_0x9d5baf))['createTaskGraph'](_0x1c7c15);}exports[a15_0x50cd('0x1')]=createTaskGraphCompat;function getDefaultDependencyConfigs(_0x527cdc,_0x484d89){var _0x1bee45,_0x4fc3d2;const _0x2eeaac=(_0x1bee45=_0x527cdc[a15_0x50cd('0x1a')])!==null&&_0x1bee45!==void 0x0?_0x1bee45:{};const _0x1d29fe=_0x484d89?(_0x4fc3d2=_0x484d89[a15_0x50cd('0x14')])!==null&&_0x4fc3d2!==void 0x0?_0x4fc3d2:[a15_0x50cd('0xb')]:[];for(const _0x41ac8f of _0x1d29fe){_0x2eeaac[_0x41ac8f]=_0x2eeaac[_0x41ac8f]||[];_0x2eeaac[_0x41ac8f]['push']({'target':_0x41ac8f,'projects':a15_0x50cd('0x16')});}return _0x2eeaac;}class TaskGraphCreator{constructor(_0x20d483,_0x33156d){this[a15_0x50cd('0x6')]=_0x20d483;this['defaultTargetDependencies']=_0x33156d;}[a15_0x50cd('0x0')](_0x101970){const _0xb203cc={'roots':[],'tasks':{},'dependencies':{}};for(const _0x123be6 of _0x101970){this['addTaskToGraph'](_0x123be6,_0xb203cc);const _0x74f53e=getDependencyConfigs(_0x123be6[a15_0x50cd('0x10')],this[a15_0x50cd('0x8')],this[a15_0x50cd('0x6')]);if(!_0x74f53e){continue;}this[a15_0x50cd('0x1b')](_0x123be6,_0x74f53e,_0x101970,_0xb203cc);}_0xb203cc['roots']=Object['keys'](_0xb203cc[a15_0x50cd('0x16')])[a15_0x50cd('0x9')](_0x1a3200=>_0xb203cc[a15_0x50cd('0x16')][_0x1a3200]['length']===0x0);return _0xb203cc;}[a15_0x50cd('0x1b')](_0x36ac15,_0x2967ee,_0x59d297,_0x1d3ba8){for(const _0x46dc8d of _0x2967ee){if(_0x46dc8d[a15_0x50cd('0x12')]===a15_0x50cd('0xc')){for(const _0x59315b of _0x59d297){if(_0x59315b[a15_0x50cd('0x10')][a15_0x50cd('0x17')]===_0x36ac15[a15_0x50cd('0x10')]['project']&&_0x59315b[a15_0x50cd('0x10')][a15_0x50cd('0x10')]===_0x46dc8d['target']){_0x1d3ba8[a15_0x50cd('0x16')][_0x36ac15['id']]['push'](_0x59315b['id']);}}}else if(_0x46dc8d[a15_0x50cd('0x12')]===a15_0x50cd('0x16')){const _0x5fd3b9=new Set();this[a15_0x50cd('0x1c')](_0x36ac15[a15_0x50cd('0x10')][a15_0x50cd('0x17')],_0x46dc8d[a15_0x50cd('0x10')],_0x59d297,_0x1d3ba8,_0x36ac15['id'],_0x5fd3b9);}}}['addDependencies'](_0x5d1efc,_0x2ebfa9,_0x2dcb66,_0x4d4237,_0xdaebd6,_0x121f04){_0x121f04[a15_0x50cd('0x3')](_0x5d1efc);const _0xf2f63=this[a15_0x50cd('0x6')]['dependencies'][_0x5d1efc];if(_0xf2f63){const _0x13da85=_0xf2f63[a15_0x50cd('0xd')](_0x332a49=>_0x332a49[a15_0x50cd('0x10')]);for(const _0x599f96 of _0x13da85){if(_0x121f04[a15_0x50cd('0xf')](_0x599f96)){continue;}const _0x537bfa=this[a15_0x50cd('0x13')]({'project':_0x599f96,'target':_0x2ebfa9},_0x2dcb66);if(_0x537bfa){if(_0x4d4237[a15_0x50cd('0x16')][_0xdaebd6][a15_0x50cd('0x1d')](_0x537bfa['id'])===-0x1){_0x4d4237['dependencies'][_0xdaebd6][a15_0x50cd('0x7')](_0x537bfa['id']);}}else{this[a15_0x50cd('0x1c')](_0x599f96,_0x2ebfa9,_0x2dcb66,_0x4d4237,_0xdaebd6,_0x121f04);}}}}[a15_0x50cd('0x13')]({project,target},_0x4a17fb){return _0x4a17fb[a15_0x50cd('0x1e')](_0x1f8223=>_0x1f8223[a15_0x50cd('0x10')][a15_0x50cd('0x17')]===project&&_0x1f8223['target'][a15_0x50cd('0x10')]===target);}['addTaskToGraph'](_0x111c10,_0x377756){_0x377756[a15_0x50cd('0xa')][_0x111c10['id']]=_0x111c10;_0x377756[a15_0x50cd('0x16')][_0x111c10['id']]=[];}}exports['TaskGraphCreator']=TaskGraphCreator;
+const a15_0x66df=['findTask','addTaskDependencies','indexOf','readFileSync','defaultTargetDependencies','projectGraph','/nx.json','map','dependencies','self','tasks','targetDependencies','strip-json-comments','push','has','projects','createTaskGraphCompat','../../../utilities/nx-imports','project','addDependencies','parse','keys','addTaskToGraph','toString','add','roots','build','TaskGraphCreator','length','filter','createTaskGraph','target'];(function(_0x85b9e9,_0x66df46){const _0x4a35c6=function(_0x48059c){while(--_0x48059c){_0x85b9e9['push'](_0x85b9e9['shift']());}};_0x4a35c6(++_0x66df46);}(a15_0x66df,0x87));const a15_0x4a35=function(_0x85b9e9,_0x66df46){_0x85b9e9=_0x85b9e9-0x0;let _0x4a35c6=a15_0x66df[_0x85b9e9];return _0x4a35c6;};'use strict';Object['defineProperty'](exports,'__esModule',{'value':!![]});exports[a15_0x4a35('0x14')]=exports[a15_0x4a35('0x9')]=void 0x0;const stripJsonComments=require(a15_0x4a35('0x5'));const fs_1=require('fs');const {getDependencyConfigs,workspaceRoot}=require(a15_0x4a35('0xa'));function createTaskGraphCompat(_0x3fac3b,_0xa8f4fc,_0x494aa4){const _0x337f59=JSON[a15_0x4a35('0xd')](stripJsonComments((0x0,fs_1[a15_0x4a35('0x1c')])(workspaceRoot+a15_0x4a35('0x1f'))[a15_0x4a35('0x10')]()));return new TaskGraphCreator(_0xa8f4fc,getDefaultDependencyConfigs(_0x337f59,_0x3fac3b))[a15_0x4a35('0x17')](_0x494aa4);}exports[a15_0x4a35('0x9')]=createTaskGraphCompat;function getDefaultDependencyConfigs(_0x35aac8,_0x15c627){var _0x3431fa,_0x16c50f;const _0x176682=(_0x3431fa=_0x35aac8[a15_0x4a35('0x4')])!==null&&_0x3431fa!==void 0x0?_0x3431fa:{};const _0x38810f=_0x15c627?(_0x16c50f=_0x15c627['strictlyOrderedTargets'])!==null&&_0x16c50f!==void 0x0?_0x16c50f:[a15_0x4a35('0x13')]:[];for(const _0x52cc15 of _0x38810f){_0x176682[_0x52cc15]=_0x176682[_0x52cc15]||[];_0x176682[_0x52cc15]['push']({'target':_0x52cc15,'projects':a15_0x4a35('0x1')});}return _0x176682;}class TaskGraphCreator{constructor(_0x57fb52,_0x56cbfe){this['projectGraph']=_0x57fb52;this[a15_0x4a35('0x1d')]=_0x56cbfe;}[a15_0x4a35('0x17')](_0x5db8ec){const _0x3e4e53={'roots':[],'tasks':{},'dependencies':{}};for(const _0x3d2841 of _0x5db8ec){this[a15_0x4a35('0xf')](_0x3d2841,_0x3e4e53);const _0x326a22=getDependencyConfigs(_0x3d2841[a15_0x4a35('0x18')],this['defaultTargetDependencies'],this[a15_0x4a35('0x1e')]);if(!_0x326a22){continue;}this[a15_0x4a35('0x1a')](_0x3d2841,_0x326a22,_0x5db8ec,_0x3e4e53);}_0x3e4e53[a15_0x4a35('0x12')]=Object[a15_0x4a35('0xe')](_0x3e4e53[a15_0x4a35('0x1')])[a15_0x4a35('0x16')](_0x367771=>_0x3e4e53['dependencies'][_0x367771][a15_0x4a35('0x15')]===0x0);return _0x3e4e53;}[a15_0x4a35('0x1a')](_0x22e170,_0x3984d1,_0x372c36,_0x98bfd){for(const _0x20ec7c of _0x3984d1){if(_0x20ec7c[a15_0x4a35('0x8')]===a15_0x4a35('0x2')){for(const _0x33e7e4 of _0x372c36){if(_0x33e7e4[a15_0x4a35('0x18')][a15_0x4a35('0xb')]===_0x22e170[a15_0x4a35('0x18')]['project']&&_0x33e7e4[a15_0x4a35('0x18')]['target']===_0x20ec7c[a15_0x4a35('0x18')]){_0x98bfd[a15_0x4a35('0x1')][_0x22e170['id']][a15_0x4a35('0x6')](_0x33e7e4['id']);}}}else if(_0x20ec7c[a15_0x4a35('0x8')]==='dependencies'){const _0x161899=new Set();this['addDependencies'](_0x22e170['target'][a15_0x4a35('0xb')],_0x20ec7c[a15_0x4a35('0x18')],_0x372c36,_0x98bfd,_0x22e170['id'],_0x161899);}}}['addDependencies'](_0x413df3,_0x15ffcd,_0x545a11,_0x4e1a46,_0x1f6705,_0x1f79a2){_0x1f79a2[a15_0x4a35('0x11')](_0x413df3);const _0x1420dd=this['projectGraph'][a15_0x4a35('0x1')][_0x413df3];if(_0x1420dd){const _0x182d9e=_0x1420dd[a15_0x4a35('0x0')](_0x383f67=>_0x383f67['target']);for(const _0xfff4f of _0x182d9e){if(_0x1f79a2[a15_0x4a35('0x7')](_0xfff4f)){continue;}const _0x562a04=this[a15_0x4a35('0x19')]({'project':_0xfff4f,'target':_0x15ffcd},_0x545a11);if(_0x562a04){if(_0x4e1a46[a15_0x4a35('0x1')][_0x1f6705][a15_0x4a35('0x1b')](_0x562a04['id'])===-0x1){_0x4e1a46['dependencies'][_0x1f6705][a15_0x4a35('0x6')](_0x562a04['id']);}}else{this[a15_0x4a35('0xc')](_0xfff4f,_0x15ffcd,_0x545a11,_0x4e1a46,_0x1f6705,_0x1f79a2);}}}}[a15_0x4a35('0x19')]({project,target},_0x7e57fa){return _0x7e57fa['find'](_0x3fd36b=>_0x3fd36b['target'][a15_0x4a35('0xb')]===project&&_0x3fd36b['target'][a15_0x4a35('0x18')]===target);}[a15_0x4a35('0xf')](_0x52d3ee,_0x203218){_0x203218[a15_0x4a35('0x3')][_0x52d3ee['id']]=_0x52d3ee;_0x203218[a15_0x4a35('0x1')][_0x52d3ee['id']]=[];}}exports[a15_0x4a35('0x14')]=TaskGraphCreator;

lib/generators/init/init.js

@@ -14,2 +14,3 @@ "use strict";
 const fs_1 = require("fs");
+const print_cloud_connection_disabled_message_1 = require("../../utilities/print-cloud-connection-disabled-message");
 function updateNxJson(json, token) {
@@ -113,15 +114,2 @@ var _a, _b, _c;
 }
-function printCloudConnectionDisabledMessage() {
-    const { output } = require('../../utilities/nx-imports');
-    output.error({
-        title: `Connections to Nx Cloud are disabled for this workspace`,
-        bodyLines: [
-            `This was an intentional decision by someone on your team.`,
-            `Nx Cloud cannot and will not be enabled.`,
-            ``,
-            `To allow connections to Nx Cloud again, remove the 'neverConnectToCloud'`,
-            `property in nx.json.`,
-        ],
-    });
-}
 function generator(host, schema) {
@@ -131,5 +119,5 @@ return __awaiter(this, void 0, void 0, function* () {
         if (nxJson.neverConnectToCloud) {
-            printCloudConnectionDisabledMessage();
-            process.exit(1);
-            return () => { };
+            return () => {
+                (0, print_cloud_connection_disabled_message_1.printCloudConnectionDisabledMessage)();
+            };
         }
@@ -136,0 +124,0 @@ else {

package.json

 {
   "name": "nx-cloud",
-  "version": "16.0.3",
+  "version": "16.0.4",
   "description": "Distributed caching and task execution for Lerna and Nx",
@@ -32,4 +32,4 @@ "keywords": [
     "open": "~8.4.0",
-    "@nrwl/nx-cloud": "16.0.3"
+    "@nrwl/nx-cloud": "16.0.4"
   }
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Dynamic require

Supply chain risk

Dynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Dynamic require

Supply chain risk

Dynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

362281

increased by0.34%

Number of package files

196

increased by1.55%

Lines of code

2914

increased by0.52%

Number of low supply chain risk alerts

179

decreased by-0.56%

Dependency changes

• + Added@nrwl/nx-cloud@16.0.4(transitive)

• - Removed@nrwl/nx-cloud@16.0.3(transitive)

• Updated@nrwl/nx-cloud@16.0.4