feat(core): add method to obtain system info and remove debugging lifecycle

Author: leosvelperez

packages/nx/src/native/index.d.ts

@@ -110,6 +110,11 @@ export declare class ProcessMetricsCollector {
    * Returns true if collection was stopped, false if not running
    */
   stopCollection(): boolean
+  /**
+   * Get system information (CPU cores and total memory)
+   * This is separate from the collection interval and meant to be called imperatively
+   */
+  getSystemInfo(): SystemInfo
   /** Register the main CLI process for metrics collection */
   registerMainCliProcess(pid: number): void
   /** Register the daemon process for metrics collection */
@@ -415,6 +420,12 @@ export declare const enum SupportedEditor {
   Unknown = 5
 }
 
+/** System information (static system-level data) */
+export interface SystemInfo {
+  cpuCores: number
+  totalMemory: number
+}
+
 export interface Target {
   executor?: string
   inputs?: Array<JsInputs>

packages/nx/src/native/metrics/collector.rs

@@ -11,7 +11,7 @@ use sysinfo::{Pid, ProcessRefreshKind, System, UpdateKind};
 use crate::native::metrics::types::{
     BatchMetricsSnapshot, BatchRegistration, CollectorConfig, DaemonMetrics,
     IndividualTaskRegistration, MetricsError, MetricsUpdate, ProcessMetadata, ProcessMetrics,
-    ProcessMetricsSnapshot,
+    ProcessMetricsSnapshot, SystemInfo,
 };
 use napi::threadsafe_function::{
     ErrorStrategy::CalleeHandled, ThreadsafeFunction, ThreadsafeFunctionCallMode,
@@ -200,6 +200,15 @@ impl MetricsCollector {
         self.is_collecting.load(Ordering::Acquire)
     }
 
+    /// Get system information (CPU cores and total memory)
+    pub fn get_system_info(&self) -> SystemInfo {
+        let sys = self.system.lock();
+        SystemInfo {
+            cpu_cores: sys.cpus().len() as u32,
+            total_memory: sys.total_memory() as i64,
+        }
+    }
+
     /// Register the main CLI process
     /// Idempotent - safe to call multiple times with same PID
     /// No validation at registration time - validation happens during collection

packages/nx/src/native/metrics/napi_bindings.rs

@@ -9,7 +9,7 @@ use parking_lot::RwLock;
 use tracing::error;
 
 use crate::native::metrics::collector::MetricsCollector;
-use crate::native::metrics::types::MetricsUpdate;
+use crate::native::metrics::types::{MetricsUpdate, SystemInfo};
 
 /// NAPI wrapper for the process metrics collector
 /// Provides a JavaScript-friendly interface for metrics collection
@@ -57,6 +57,14 @@ impl ProcessMetricsCollector {
         }
     }
 
+    /// Get system information (CPU cores and total memory)
+    /// This is separate from the collection interval and meant to be called imperatively
+    #[napi]
+    pub fn get_system_info(&self) -> SystemInfo {
+        let collector = self.collector.read();
+        collector.get_system_info()
+    }
+
     /// Register the main CLI process for metrics collection
     #[napi]
     pub fn register_main_cli_process(&self, pid: i32) {

packages/nx/src/native/metrics/types.rs

@@ -168,3 +168,11 @@ pub struct MetricsUpdate {
     pub metrics: Arc<ProcessMetricsSnapshot>,
     pub metadata: Option<Arc<HashMap<String, ProcessMetadata>>>,
 }
+
+/// System information (static system-level data)
+#[napi(object)]
+#[derive(Debug, Clone)]
+pub struct SystemInfo {
+    pub cpu_cores: u32,
+    pub total_memory: i64,
+}

packages/nx/src/tasks-runner/life-cycles/process-metrics-life-cycle.ts

@@ -6,6 +6,7 @@ import {
   ProcessMetricsSnapshot,
   BatchMetricsSnapshot,
   MetricsUpdate,
+  SystemInfo,
 } from '../native';
 import { getDaemonProcessIdSync } from '../daemon/cache';
 
@@ -16,6 +17,7 @@ export type {
   ProcessMetricsSnapshot,
   BatchMetricsSnapshot,
   MetricsUpdate,
+  SystemInfo,
 };
 
 export type MetricsCallback = (event: MetricsUpdate) => void;
@@ -134,6 +136,18 @@ class ProcessMetricsService {
     }
   }
 
+  /**
+   * Get system information (CPU cores and total memory)
+   */
+  getSystemInfo(): SystemInfo | null {
+    try {
+      return this.collector?.getSystemInfo();
+    } catch {
+      // Silent failure - metrics collection is optional
+      return null;
+    }
+  }
+
   /**
    * Stop collection and cleanup
    */

packages/nx/src/tasks-runner/process-metrics-service.ts

@@ -57,7 +57,6 @@ import { TaskProfilingLifeCycle } from './life-cycles/task-profiling-life-cycle'
 import { TaskResultsLifeCycle } from './life-cycles/task-results-life-cycle';
 import { TaskTimingsLifeCycle } from './life-cycles/task-timings-life-cycle';
 import { getTuiTerminalSummaryLifeCycle } from './life-cycles/tui-summary-life-cycle';
-import { ProcessMetricsLifeCycle } from './life-cycles/process-metrics-life-cycle';
 import {
   assertTaskGraphDoesNotContainInvalidTargets,
   findCycle,
@@ -1056,10 +1055,6 @@ export async function invokeTasksRunner({
 export function constructLifeCycles(lifeCycle: LifeCycle): LifeCycle[] {
   const lifeCycles = [] as LifeCycle[];
   lifeCycles.push(new StoreRunInformationLifeCycle());
-  if (process.env.NX_DEBUG_PROCESS_METRICS === 'true') {
-    // Temporary throwaway life cycle only used for debugging purposes
-    lifeCycles.push(new ProcessMetricsLifeCycle());
-  }
   lifeCycles.push(lifeCycle);
   if (process.env.NX_PERF_LOGGING === 'true') {
     lifeCycles.push(new TaskTimingsLifeCycle());