PHP WebShell

• .. (вверх)
• [DIR] ..
• [DIR] file-watching
• [FILE] handle-outputs-tracking.d.ts
• [FILE] handle-outputs-tracking.js
• [FILE] handle-outputs-tracking.js.map
• [FILE] handle-process-in-background.d.ts
• [FILE] handle-process-in-background.js
• [FILE] handle-process-in-background.js.map
• [FILE] handle-request-project-graph.d.ts
• [FILE] handle-request-project-graph.js
• [FILE] handle-request-project-graph.js.map
• [FILE] handle-request-shutdown.d.ts
• [FILE] handle-request-shutdown.js
• [FILE] handle-request-shutdown.js.map
• [FILE] logger.d.ts
• [FILE] logger.js
• [FILE] logger.js.map
• [FILE] outputs-tracking.d.ts
• [FILE] outputs-tracking.js
• [FILE] outputs-tracking.js.map
• [FILE] project-graph-incremental-recomputation.d.ts
• [FILE] project-graph-incremental-recomputation.js
• [FILE] project-graph-incremental-recomputation.js.map
• [FILE] server.d.ts
• [FILE] server.js
• [FILE] server.js.map
• [FILE] shutdown-utils.d.ts
• [FILE] shutdown-utils.js
• [FILE] shutdown-utils.js.map
• [FILE] start.d.ts
• [FILE] start.js
• [FILE] start.js.map
• [FILE] watcher.d.ts
• [FILE] watcher.js
• [FILE] watcher.js.map

Просмотр файла: shutdown-utils.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.respondWithErrorAndExit = exports.respondToClient = exports.resetInactivityTimeout = exports.handleServerProcessTermination = exports.storeProcessJsonSubscription = exports.storeOutputsWatcherSubscription = exports.getOutputsWatcherSubscription = exports.storeSourceWatcherSubscription = exports.getSourceWatcherSubscription = exports.SERVER_INACTIVITY_TIMEOUT_MS = void 0;
const tslib_1 = require("tslib");
const workspace_root_1 = require("../../utils/workspace-root");
const logger_1 = require("./logger");
const socket_utils_1 = require("../socket-utils");
const cache_1 = require("../cache");
exports.SERVER_INACTIVITY_TIMEOUT_MS = 10800000; // 10800000 ms = 3 hours
let sourceWatcherSubscription;
let outputsWatcherSubscription;
function getSourceWatcherSubscription() {
    return sourceWatcherSubscription;
}
exports.getSourceWatcherSubscription = getSourceWatcherSubscription;
function storeSourceWatcherSubscription(s) {
    sourceWatcherSubscription = s;
}
exports.storeSourceWatcherSubscription = storeSourceWatcherSubscription;
function getOutputsWatcherSubscription() {
    return outputsWatcherSubscription;
}
exports.getOutputsWatcherSubscription = getOutputsWatcherSubscription;
function storeOutputsWatcherSubscription(s) {
    outputsWatcherSubscription = s;
}
exports.storeOutputsWatcherSubscription = storeOutputsWatcherSubscription;
let processJsonSubscription;
function storeProcessJsonSubscription(s) {
    processJsonSubscription = s;
}
exports.storeProcessJsonSubscription = storeProcessJsonSubscription;
function handleServerProcessTermination({ server, reason, }) {
    return tslib_1.__awaiter(this, void 0, void 0, function* () {
        try {
            server.close();
            (0, cache_1.deleteDaemonJsonProcessCache)();
            if (sourceWatcherSubscription) {
                yield sourceWatcherSubscription.unsubscribe();
                logger_1.serverLogger.watcherLog(`Unsubscribed from changes within: ${workspace_root_1.workspaceRoot} (sources)`);
            }
            if (outputsWatcherSubscription) {
                yield outputsWatcherSubscription.unsubscribe();
                logger_1.serverLogger.watcherLog(`Unsubscribed from changes within: ${workspace_root_1.workspaceRoot} (outputs)`);
            }
            if (processJsonSubscription) {
                yield processJsonSubscription.unsubscribe();
                logger_1.serverLogger.watcherLog(`Unsubscribed from changes within: ${workspace_root_1.workspaceRoot} (server-process.json)`);
            }
            logger_1.serverLogger.log(`Server stopped because: "${reason}"`);
        }
        finally {
            process.exit(0);
        }
    });
}
exports.handleServerProcessTermination = handleServerProcessTermination;
let serverInactivityTimerId;
function resetInactivityTimeout(cb) {
    if (serverInactivityTimerId) {
        clearTimeout(serverInactivityTimerId);
    }
    serverInactivityTimerId = setTimeout(cb, exports.SERVER_INACTIVITY_TIMEOUT_MS);
}
exports.resetInactivityTimeout = resetInactivityTimeout;
function respondToClient(socket, response, description) {
    return new Promise((res) => tslib_1.__awaiter(this, void 0, void 0, function* () {
        if (description) {
            logger_1.serverLogger.requestLog(`Responding to the client.`, description);
        }
        socket.write(`${response}${String.fromCodePoint(4)}`, (err) => {
            if (err) {
                console.error(err);
            }
            logger_1.serverLogger.log(`Done responding to the client`, description);
            res(null);
        });
    }));
}
exports.respondToClient = respondToClient;
function respondWithErrorAndExit(socket, description, error) {
    return tslib_1.__awaiter(this, void 0, void 0, function* () {
        // print some extra stuff in the error message
        logger_1.serverLogger.requestLog(`Responding to the client with an error.`, description, error.message);
        console.error(error);
        error.message = `${error.message}\n\nBecause of the error the Nx daemon process has exited. The next Nx command is going to restart the daemon process.\nIf the error persists, please run "nx reset".`;
        yield respondToClient(socket, (0, socket_utils_1.serializeResult)(error, null), null);
        process.exit(1);
    });
}
exports.respondWithErrorAndExit = respondWithErrorAndExit;
//# sourceMappingURL=shutdown-utils.js.map

Выполнить команду