Socket
Socket
Sign inDemoInstall

nx-cloud

Package Overview
Dependencies
35
Maintainers
2
Versions
149
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 16.3.0-beta.2 to 16.3.0-beta.3

lib/utilities/nx-imports-light.d.ts

34

bin/nx-cloud.js

@@ -13,13 +13,5 @@ #!/usr/bin/env node

Object.defineProperty(exports, "__esModule", { value: true });
const clean_up_agents_1 = require("../lib/core/commands/clean-up-agents");
const record_output_1 = require("../lib/core/commands/record-output");
const start_ci_run_1 = require("../lib/core/commands/start-ci-run");
const stop_all_agents_1 = require("../lib/core/commands/stop-all-agents");
const distributed_agent_impl_1 = require("../lib/core/runners/distributed-agent/distributed-agent.impl");
const upload_and_show_run_details_1 = require("../lib/core/commands/upload-and-show-run-details");
const update_manager_1 = require("../lib/light-client/update-manager");
const path_1 = require("path");
const stripJsonComments = require("strip-json-comments");
const fs_1 = require("fs");
const debug_logger_1 = require("../lib/light-client/debug-logger");
const command = process.argv[2];

@@ -35,5 +27,7 @@ const options = JSON.parse(stripJsonComments((0, fs_1.readFileSync)(`nx.json`).toString())).tasksRunnerOptions.default.options;

return __awaiter(this, void 0, void 0, function* () {
(0, debug_logger_1.debugLog)('Verifying current cloud bundle');
const { version, fullPath } = yield (0, update_manager_1.verifyOrUpdateCloudBundle)(options);
(0, debug_logger_1.debugLog)('Done: ', fullPath);
const { debugLog } = require('../lib/light-client/debug-logger');
debugLog('Verifying current cloud bundle');
const { verifyOrUpdateCloudBundle, } = require('../lib/light-client/update-manager');
const { version, fullPath } = yield verifyOrUpdateCloudBundle(options);
debugLog('Done: ', fullPath);
const runner = require((0, path_1.join)(process.cwd(), fullPath, 'index.js'));

@@ -83,3 +77,4 @@ if (command === 'start-agent') {

if (command === 'start-agent') {
(0, distributed_agent_impl_1.startAgent)().catch((e) => {
const { startAgent, } = require('../lib/core/runners/distributed-agent/distributed-agent.impl');
startAgent().catch((e) => {
console.error(e);

@@ -90,3 +85,4 @@ process.exit(1);

else if (command === 'stop-all-agents') {
(0, stop_all_agents_1.stopAllAgents)().catch((e) => {
const { stopAllAgents } = require('../lib/core/commands/stop-all-agents');
stopAllAgents().catch((e) => {
console.error(e);

@@ -97,3 +93,4 @@ process.exit(1);

else if (command === 'start-ci-run') {
(0, start_ci_run_1.startCiRun)().catch((e) => {
const { startCiRun } = require('../lib/core/commands/start-ci-run');
startCiRun().catch((e) => {
console.error(e);

@@ -104,3 +101,4 @@ process.exit(1);

else if (command === 'clean-up-agents') {
(0, clean_up_agents_1.cleanUpAgents)().catch((e) => {
const { cleanUpAgents } = require('../lib/core/commands/clean-up-agents');
cleanUpAgents().catch((e) => {
console.error(e);

@@ -111,3 +109,4 @@ process.exit(1);

else if (command === 'record') {
(0, record_output_1.runCommandAndStoreInCloud)().catch((e) => {
const { runCommandAndStoreInCloud, } = require('../lib/core/commands/record-output');
runCommandAndStoreInCloud().catch((e) => {
console.error(e);

@@ -118,3 +117,4 @@ process.exit(1);

else if (command === 'upload-and-show-run-details') {
(0, upload_and_show_run_details_1.uploadAndShowRunDetails)().catch((e) => {
const { uploadAndShowRunDetails, } = require('../lib/core/commands/upload-and-show-run-details');
uploadAndShowRunDetails().catch((e) => {
console.error(e);

@@ -121,0 +121,0 @@ process.exit(1);

@@ -14,3 +14,3 @@ "use strict";

const axios_1 = require("../../utilities/axios");
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
class ErrorReporterApi {

@@ -17,0 +17,0 @@ constructor(options) {

@@ -15,3 +15,3 @@ "use strict";

const metric_logger_1 = require("../../utilities/metric-logger");
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
class RunGroupApi {

@@ -18,0 +18,0 @@ constructor(options) {

@@ -15,3 +15,4 @@ "use strict";

const fs_1 = require("fs");
const { output, cacheDirectory } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
const { cacheDirectory } = require('../../utilities/nx-imports');
function cleanUpAgents() {

@@ -18,0 +19,0 @@ return __awaiter(this, void 0, void 0, function* () {

@@ -21,3 +21,3 @@ "use strict";

const distributed_execution_api_1 = require("../runners/distributed-execution/distributed-execution.api");
const { output, workspaceRoot } = require('../../utilities/nx-imports');
const { output, workspaceRoot } = require('../../utilities/nx-imports-light');
const MAX_CHARACTERS_OUTPUT_CAPTURE = 200000;

@@ -24,0 +24,0 @@ function runCommandAndStoreInCloud() {

@@ -20,3 +20,3 @@ "use strict";

const distributed_task_execution_detection_1 = require("../../utilities/distributed-task-execution-detection");
const { output, workspaceRoot } = require('../../utilities/nx-imports');
const { output, workspaceRoot } = require('../../utilities/nx-imports-light');
const args = yargsParser(process.argv, {

@@ -23,0 +23,0 @@ boolean: ['stop-agents-on-failure', 'use-dte-by-default'],

@@ -18,3 +18,3 @@ "use strict";

const fs_1 = require("fs");
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
function stopAllAgents() {

@@ -21,0 +21,0 @@ return __awaiter(this, void 0, void 0, function* () {

@@ -25,3 +25,4 @@ "use strict";

const print_cloud_connection_disabled_message_1 = require("../../utilities/print-cloud-connection-disabled-message");
const { workspaceRoot, output, cacheDirectory, } = require('../../utilities/nx-imports');
const { output, workspaceRoot } = require('../../utilities/nx-imports-light');
const { cacheDirectory } = require('../../utilities/nx-imports');
function uploadRunDetails(options) {

@@ -28,0 +29,0 @@ return __awaiter(this, void 0, void 0, function* () {

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.printCacheableTargetsError = void 0;
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
function printCacheableTargetsError(wrongTargets) {

@@ -6,0 +6,0 @@ output.error({

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.printInvalidRunnerError = void 0;
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
function printInvalidRunnerError() {

@@ -6,0 +6,0 @@ output.error({

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.printRunGroupError = exports.canDetectRunGroup = void 0;
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
function canDetectRunGroup(runGroup, ciExecutionId) {

@@ -6,0 +6,0 @@ return !!runGroup || !!ciExecutionId;

@@ -23,3 +23,3 @@ "use strict";

const tar = require('tar');
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
class FileStorage {

@@ -26,0 +26,0 @@ constructor(encryption, errorReporter, options, context) {

@@ -30,3 +30,4 @@ "use strict";

const remove_trailing_slash_1 = require("../../../utilities/remove-trailing-slash");
const { tasksRunner, output, cacheDirectory, } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
const { tasksRunner, cacheDirectory, } = require('../../../utilities/nx-imports');
function createApi(errors, options, runContext) {

@@ -33,0 +34,0 @@ const machineInfo = (0, environment_1.getMachineInfo)();

@@ -14,3 +14,3 @@ "use strict";

const environment_1 = require("../../../utilities/environment");
const { output } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
class CloudRemoteCache {

@@ -17,0 +17,0 @@ constructor(messages, api, runContext, fileStorage, distributedExecutionId, storeInCurrentProcess) {

@@ -20,3 +20,3 @@ "use strict";

const is_private_cloud_1 = require("../../../utilities/is-private-cloud");
const { output } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
class CloudRunApi {

@@ -23,0 +23,0 @@ constructor(messages, runContext, options, machineInfo) {

@@ -16,3 +16,3 @@ "use strict";

const metric_logger_1 = require("../../../utilities/metric-logger");
const { output } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
class DistributedAgentApi {

@@ -19,0 +19,0 @@ constructor(options, branch, runGroup, ciExecutionId, ciExecutionEnv, agentName) {

@@ -30,3 +30,4 @@ "use strict";

const is_workspace_enabled_1 = require("../../../utilities/is-workspace-enabled");
const { output, initTasksRunner, workspaceRoot, cacheDirectory, } = require('../../../utilities/nx-imports');
const { output, workspaceRoot, } = require('../../../utilities/nx-imports-light');
const { initTasksRunner, cacheDirectory, } = require('../../../utilities/nx-imports');
const args = yargsParser(process.argv, {

@@ -33,0 +34,0 @@ array: ['targets'],

@@ -16,3 +16,3 @@ "use strict";

const waiter_1 = require("../../../utilities/waiter");
const { output } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
function executeTasks(agentName, api, dteArtifactStorage, invokeTasks, targets) {

@@ -19,0 +19,0 @@ return __awaiter(this, void 0, void 0, function* () {

@@ -16,3 +16,4 @@ "use strict";

const fs_1 = require("fs");
const { output, cacheDirectory } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
const { cacheDirectory } = require('../../../utilities/nx-imports');
function invokeTasksUsingRunMany() {

@@ -19,0 +20,0 @@ return __awaiter(this, void 0, void 0, function* () {

@@ -17,3 +17,3 @@ "use strict";

const serializer_overrides_1 = require("../../../utilities/serializer-overrides");
const { output } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
class DistributedExecutionApi {

@@ -20,0 +20,0 @@ constructor(options) {

@@ -24,3 +24,4 @@ "use strict";

const dte_artifact_storage_1 = require("../../../utilities/dte-artifact-storage");
const { output, cacheDirectory } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
const { cacheDirectory } = require('../../../utilities/nx-imports');
class NoopLifeCycle {

@@ -27,0 +28,0 @@ scheduleTask(task) { }

@@ -15,3 +15,3 @@ "use strict";

const serializer_overrides_1 = require("../../../utilities/serializer-overrides");
const { output } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
function processTask(dteArtifactStorage, tasks, completedTask) {

@@ -18,0 +18,0 @@ return __awaiter(this, void 0, void 0, function* () {

@@ -17,3 +17,3 @@ "use strict";

const process_task_1 = require("./process-task");
const { output } = require('../../../utilities/nx-imports');
const { output } = require('../../../utilities/nx-imports-light');
function processTasks(api, dteArtifactStorage, executionId, tasks) {

@@ -20,0 +20,0 @@ return __awaiter(this, void 0, void 0, function* () {

@@ -6,3 +6,4 @@ "use strict";

const fs_1 = require("fs");
const { getDependencyConfigs, workspaceRoot, } = require('../../../utilities/nx-imports');
const { workspaceRoot } = require('../../../utilities/nx-imports-light');
const { getDependencyConfigs } = require('../../../utilities/nx-imports');
function createTaskGraphCompat(options, projectGraph, tasks) {

@@ -9,0 +10,0 @@ const nxjson = JSON.parse(stripJsonComments((0, fs_1.readFileSync)(`${workspaceRoot}/nx.json`).toString()));

@@ -5,3 +5,3 @@ "use strict";

const print_message_1 = require("../../utilities/print-message");
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
class MessageReporter {

@@ -8,0 +8,0 @@ constructor(options) {

@@ -5,3 +5,3 @@ "use strict";

const path_1 = require("path");
const { workspaceRoot } = require('../../utilities/nx-imports');
const { workspaceRoot } = require('../../utilities/nx-imports-light');
const environment_1 = require("../../utilities/environment");

@@ -8,0 +8,0 @@ const fs_1 = require("fs");

@@ -94,3 +94,3 @@ "use strict";

function printSuccessMessage(url) {
const { output } = require('../../utilities/nx-imports');
const { output } = require('../../utilities/nx-imports-light');
let host = 'nx.app';

@@ -97,0 +97,0 @@ try {

@@ -24,3 +24,3 @@ "use strict";

const runner = require((0, path_1.join)(process.cwd(), fullPath, 'index.js'));
return runner.default(tasks, options, context);
return runner.nxCloudTasksRunner(tasks, options, context);
}

@@ -27,0 +27,0 @@ else {

@@ -16,3 +16,4 @@ "use strict";

const is_workspace_enabled_1 = require("./utilities/is-workspace-enabled");
const { tasksRunner, output, runnerReturnsPromise, } = require('./utilities/nx-imports');
const { output } = require('./utilities/nx-imports-light');
const { tasksRunner, runnerReturnsPromise } = require('./utilities/nx-imports');
const nxCloudTasksRunner = (tasks, options, context = {}) => {

@@ -19,0 +20,0 @@ const nxArgs = context.nxArgs || {};

@@ -16,3 +16,3 @@ "use strict";

const path_1 = require("path");
const { output } = require('./nx-imports');
const { output } = require('./nx-imports-light');
const axios = require('axios');

@@ -19,0 +19,0 @@ class AxiosException {

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.createUnchangedValueTimeout = void 0;
const { output } = require('./nx-imports');
const { output } = require('./nx-imports-light');
function createUnchangedValueTimeout(options) {

@@ -6,0 +6,0 @@ let value = new Object();

@@ -16,3 +16,3 @@ "use strict";

const path_1 = require("path");
const { output, workspaceRoot } = require('./nx-imports');
const { output, workspaceRoot } = require('./nx-imports-light');
class DteArtifactStorage {

@@ -19,0 +19,0 @@ constructor(fileStorage, cacheDirectory) {

@@ -12,3 +12,3 @@ "use strict";

const crypto_1 = require("crypto");
const { workspaceRoot } = require('./nx-imports');
const { workspaceRoot } = require('./nx-imports-light');
// Set once

@@ -15,0 +15,0 @@ exports.UNLIMITED_TIMEOUT = 9999999;

@@ -7,3 +7,3 @@ "use strict";

const path_1 = require("path");
const { workspaceRoot } = require('./nx-imports');
const { workspaceRoot } = require('./nx-imports-light');
function isConnectedToPrivateCloud() {

@@ -10,0 +10,0 @@ const options = readOptions();

@@ -6,3 +6,2 @@ "use strict";

try {
const { output } = require('nx/src/utils/output');
let workspaceRoot;

@@ -37,4 +36,2 @@ try {

exports.runnerReturnsPromise = true;
exports.output = output;
exports.workspaceRoot = workspaceRoot;
exports.tasksRunner = tasksRunner;

@@ -46,3 +43,2 @@ exports.CompositeLifeCycle = CompositeLifeCycle;

catch (e) {
const { output } = require('@nrwl/workspace/src/utilities/output');
const { appRootPath } = require('@nrwl/tao/src/utils/app-root');

@@ -59,4 +55,2 @@ const { getDependencyConfigs, } = require('@nrwl/workspace/src/tasks-runner/utils');

exports.runnerReturnsPromise = false;
exports.output = output;
exports.workspaceRoot = appRootPath;
exports.tasksRunner = tasksRunnerV2;

@@ -63,0 +57,0 @@ exports.CompositeLifeCycle = CompositeLifeCycle;

@@ -5,3 +5,3 @@ "use strict";

function printCloudConnectionDisabledMessage() {
const { output } = require('./nx-imports');
const { output } = require('./nx-imports-light');
output.error({

@@ -8,0 +8,0 @@ title: `Connections to Nx Cloud are disabled for this workspace`,

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.printMessage = void 0;
const { output } = require('./nx-imports');
const { output } = require('./nx-imports-light');
function printMessage(message) {

@@ -6,0 +6,0 @@ if (newTerminalOutput()) {

{
"name": "nx-cloud",
"version": "16.3.0-beta.2",
"version": "16.3.0-beta.3",
"description": "Distributed caching and task execution for Lerna and Nx",

@@ -32,4 +32,4 @@ "keywords": [

"open": "~8.4.0",
"@nrwl/nx-cloud": "16.3.0-beta.2"
"@nrwl/nx-cloud": "16.3.0-beta.3"
}
}

@@ -37,3 +37,4 @@ {

},
"implicitDependencies": ["!nx-packages-nrwl-nx-cloud"]
}

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc