| Server IP : 167.235.224.122 / Your IP : 216.73.216.110 Web Server : Apache/2.4.58 (Ubuntu) System : Linux newplayground 6.8.0-136-generic #136-Ubuntu SMP PREEMPT_DYNAMIC Wed Jul 1 21:33:11 UTC 2026 aarch64 User : deploy ( 1000) PHP Version : 8.4.23 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /var/www/html/emajiwallet/node_modules/nx/src/daemon/server/ |
Upload File : |
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.watchWorkspace = watchWorkspace;
exports.watchOutputFiles = watchOutputFiles;
exports.convertChangeEventsToLogMessage = convertChangeEventsToLogMessage;
const workspace_root_1 = require("../../utils/workspace-root");
const path_1 = require("path");
const shutdown_utils_1 = require("./shutdown-utils");
const path_2 = require("../../utils/path");
const cache_1 = require("../cache");
const server_1 = require("./server");
async function watchWorkspace(server, cb) {
const { Watcher } = await Promise.resolve().then(() => require('../../native'));
const watcher = new Watcher(workspace_root_1.workspaceRoot);
watcher.watch((err, events) => {
if (err) {
return cb(err, null);
}
for (const event of events) {
if (event.path.endsWith('.gitignore') || event.path === '.nxignore') {
// If the ignore files themselves have changed we need to dynamically update our cached ignoreGlobs
(0, shutdown_utils_1.handleServerProcessTermination)({
server,
reason: 'Stopping the daemon the set of ignored files changed (native)',
sockets: server_1.openSockets,
});
}
}
cb(null, events);
});
return watcher;
}
async function watchOutputFiles(server, cb) {
const { Watcher } = await Promise.resolve().then(() => require('../../native'));
const relativeServerProcess = (0, path_2.normalizePath)((0, path_1.relative)(workspace_root_1.workspaceRoot, cache_1.serverProcessJsonPath));
const watcher = new Watcher(workspace_root_1.workspaceRoot, [`!${relativeServerProcess}`], false);
watcher.watch((err, events) => {
if (err) {
return cb(err, null);
}
for (const event of events) {
if (event.path == relativeServerProcess &&
(0, cache_1.getDaemonProcessIdSync)() !== process.pid) {
return (0, shutdown_utils_1.handleServerProcessTermination)({
server,
reason: 'this process is no longer the current daemon (native)',
sockets: server_1.openSockets,
});
}
}
if (events.length !== 0) {
cb(null, events);
}
});
return watcher;
}
/**
* NOTE: An event type of "create" will also apply to the case where the user has restored
* an original version of a file after modifying/deleting it by using git, so we adjust
* our log language accordingly.
*/
function convertChangeEventsToLogMessage(changeEvents) {
// If only a single file was changed, show the information inline
if (changeEvents.length === 1) {
const { path, type } = changeEvents[0];
let typeLog = 'updated';
switch (type) {
case 'create':
typeLog = 'created or restored';
break;
case 'update':
typeLog = 'modified';
break;
case 'delete':
typeLog = 'deleted';
break;
}
return `${path} was ${typeLog}`;
}
let numCreatedOrRestoredFiles = 0;
let numModifiedFiles = 0;
let numDeletedFiles = 0;
for (const event of changeEvents) {
switch (event.type) {
case 'create':
numCreatedOrRestoredFiles++;
break;
case 'update':
numModifiedFiles++;
break;
case 'delete':
numDeletedFiles++;
break;
}
}
return `${numCreatedOrRestoredFiles} file(s) created or restored, ${numModifiedFiles} file(s) modified, ${numDeletedFiles} file(s) deleted`;
}