@nxtedition/common - npm Package Compare versions

Comparing version 1.0.2 to 1.0.3

lib/threads.d.ts

+export declare const APP_STATS_CHANNEL = "nxt:app:stats";
+export type ThreadMemoryUsage = {
+    rss: number;
+    heapTotal: number;
+    heapUsed: number;
+    external: number;
+    arrayBuffers: number;
+};
+export type ThreadHeapStatistics = {
+    total_heap_size: number;
+    total_heap_size_executable: number;
+    total_physical_size: number;
+    total_available_size: number;
+    used_heap_size: number;
+    heap_size_limit: number;
+    malloced_memory: number;
+    peak_malloced_memory: number;
+    does_zap_garbage: number;
+    number_of_native_contexts: number;
+    number_of_detached_contexts: number;
+    total_global_handles_size: number;
+    used_global_handles_size: number;
+    external_memory: number;
+};
+export type ThreadEventLoopUtilization = {
+    idle: number;
+    active: number;
+    utilization: number;
+};
+export type ThreadCpuUsage = {
+    user: number;
+    system: number;
+};
+export type ThreadResourceLimits = {
+    maxYoungGenerationSizeMb?: number;
+    maxOldGenerationSizeMb?: number;
+    codeRangeSizeMb?: number;
+    stackSizeMb?: number;
+};
+export type ThreadDsStats = {
+    connected: boolean;
+    record: {
+        records: number;
+        pruning: number;
+        updating: number;
+        patching: number;
+    };
+};
+export type ThreadHttpStats = {
+    userAgent?: string;
+    pending?: number;
+};
+export type ThreadUndiciStats = {
+    sockets?: number;
+    pending?: number;
+};
+export type ThreadLagHistogram = {
+    p50: number;
+    p95: number;
+    p99: number;
+    max: number;
+};
+export type ThreadRuntimeStats = {
+    memoryUsage?: ThreadMemoryUsage;
+    heapStatistics?: ThreadHeapStatistics;
+    eventLoopUtilization?: ThreadEventLoopUtilization;
+};
+export type ThreadStatsWire = ThreadRuntimeStats & {
+    id: number;
+    name: string;
+    module: string;
+    version?: string;
+    uptime?: number;
+    timestamp?: number;
+    ds?: ThreadDsStats;
+    lag?: ThreadLagHistogram | null;
+    busyCount?: number | null;
+    cpuUsage?: ThreadCpuUsage;
+    threadCpuUsage?: ThreadCpuUsage;
+    affinity?: string | null;
+    resourceLimits?: ThreadResourceLimits;
+    http?: ThreadHttpStats;
+    undici?: ThreadUndiciStats;
+} & Record<string, unknown>;
+export type ThreadStatsBroadcastMessage<T = ThreadStatsWire> = {
+    id: number;
+    data: T | undefined;
+};
+export type BroadcastChannelMessageEvent<T> = {
+    data: T;
+};
+export type TypedBroadcastChannel<T> = Omit<BroadcastChannel, 'onmessage' | 'postMessage'> & {
+    onmessage: ((this: BroadcastChannel, event: BroadcastChannelMessageEvent<T>) => unknown) | null;
+    postMessage(message: T): void;
+};
+export type StatsBroadcastChannel<T = ThreadStatsWire> = TypedBroadcastChannel<ThreadStatsBroadcastMessage<T>>;
+export declare function isThreadStatsWire(value: unknown): value is ThreadStatsWire;
+//# sourceMappingURL=threads.d.ts.map

lib/threads.d.ts.map

+{"version":3,"file":"threads.d.ts","sourceRoot":"","sources":["../src/threads.ts"],"names":[],"mappings":"AAEA,eAAO,MAAM,iBAAiB,kBAAkB,CAAA;AAEhD,MAAM,MAAM,iBAAiB,GAAG;IAC9B,GAAG,EAAE,MAAM,CAAA;IACX,SAAS,EAAE,MAAM,CAAA;IACjB,QAAQ,EAAE,MAAM,CAAA;IAChB,QAAQ,EAAE,MAAM,CAAA;IAChB,YAAY,EAAE,MAAM,CAAA;CACrB,CAAA;AAED,MAAM,MAAM,oBAAoB,GAAG;IACjC,eAAe,EAAE,MAAM,CAAA;IACvB,0BAA0B,EAAE,MAAM,CAAA;IAClC,mBAAmB,EAAE,MAAM,CAAA;IAC3B,oBAAoB,EAAE,MAAM,CAAA;IAC5B,cAAc,EAAE,MAAM,CAAA;IACtB,eAAe,EAAE,MAAM,CAAA;IACvB,eAAe,EAAE,MAAM,CAAA;IACvB,oBAAoB,EAAE,MAAM,CAAA;IAC5B,gBAAgB,EAAE,MAAM,CAAA;IACxB,yBAAyB,EAAE,MAAM,CAAA;IACjC,2BAA2B,EAAE,MAAM,CAAA;IACnC,yBAAyB,EAAE,MAAM,CAAA;IACjC,wBAAwB,EAAE,MAAM,CAAA;IAChC,eAAe,EAAE,MAAM,CAAA;CACxB,CAAA;AAED,MAAM,MAAM,0BAA0B,GAAG;IACvC,IAAI,EAAE,MAAM,CAAA;IACZ,MAAM,EAAE,MAAM,CAAA;IACd,WAAW,EAAE,MAAM,CAAA;CACpB,CAAA;AAED,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,MAAM,CAAA;IACZ,MAAM,EAAE,MAAM,CAAA;CACf,CAAA;AAED,MAAM,MAAM,oBAAoB,GAAG;IACjC,wBAAwB,CAAC,EAAE,MAAM,CAAA;IACjC,sBAAsB,CAAC,EAAE,MAAM,CAAA;IAC/B,eAAe,CAAC,EAAE,MAAM,CAAA;IACxB,WAAW,CAAC,EAAE,MAAM,CAAA;CACrB,CAAA;AAED,MAAM,MAAM,aAAa,GAAG;IAC1B,SAAS,EAAE,OAAO,CAAA;IAClB,MAAM,EAAE;QACN,OAAO,EAAE,MAAM,CAAA;QACf,OAAO,EAAE,MAAM,CAAA;QACf,QAAQ,EAAE,MAAM,CAAA;QAChB,QAAQ,EAAE,MAAM,CAAA;KACjB,CAAA;CACF,CAAA;AAED,MAAM,MAAM,eAAe,GAAG;IAC5B,SAAS,CAAC,EAAE,MAAM,CAAA;IAClB,OAAO,CAAC,EAAE,MAAM,CAAA;CACjB,CAAA;AAED,MAAM,MAAM,iBAAiB,GAAG;IAC9B,OAAO,CAAC,EAAE,MAAM,CAAA;IAChB,OAAO,CAAC,EAAE,MAAM,CAAA;CACjB,CAAA;AAED,MAAM,MAAM,kBAAkB,GAAG;IAC/B,GAAG,EAAE,MAAM,CAAA;IACX,GAAG,EAAE,MAAM,CAAA;IACX,GAAG,EAAE,MAAM,CAAA;IACX,GAAG,EAAE,MAAM,CAAA;CACZ,CAAA;AAED,MAAM,MAAM,kBAAkB,GAAG;IAM/B,WAAW,CAAC,EAAE,iBAAiB,CAAA;IAC/B,cAAc,CAAC,EAAE,oBAAoB,CAAA;IACrC,oBAAoB,CAAC,EAAE,0BAA0B,CAAA;CAClD,CAAA;AAED,MAAM,MAAM,eAAe,GAAG,kBAAkB,GAAG;IACjD,EAAE,EAAE,MAAM,CAAA;IACV,IAAI,EAAE,MAAM,CAAA;IACZ,MAAM,EAAE,MAAM,CAAA;IACd,OAAO,CAAC,EAAE,MAAM,CAAA;IAChB,MAAM,CAAC,EAAE,MAAM,CAAA;IACf,SAAS,CAAC,EAAE,MAAM,CAAA;IAClB,EAAE,CAAC,EAAE,aAAa,CAAA;IAClB,GAAG,CAAC,EAAE,kBAAkB,GAAG,IAAI,CAAA;IAC/B,SAAS,CAAC,EAAE,MAAM,GAAG,IAAI,CAAA;IACzB,QAAQ,CAAC,EAAE,cAAc,CAAA;IACzB,cAAc,CAAC,EAAE,cAAc,CAAA;IAC/B,QAAQ,CAAC,EAAE,MAAM,GAAG,IAAI,CAAA;IACxB,cAAc,CAAC,EAAE,oBAAoB,CAAA;IACrC,IAAI,CAAC,EAAE,eAAe,CAAA;IACtB,MAAM,CAAC,EAAE,iBAAiB,CAAA;CAC3B,GAAG,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;AAE3B,MAAM,MAAM,2BAA2B,CAAC,CAAC,GAAG,eAAe,IAAI;IAC7D,EAAE,EAAE,MAAM,CAAA;IACV,IAAI,EAAE,CAAC,GAAG,SAAS,CAAA;CACpB,CAAA;AAED,MAAM,MAAM,4BAA4B,CAAC,CAAC,IAAI;IAC5C,IAAI,EAAE,CAAC,CAAA;CACR,CAAA;AAED,MAAM,MAAM,qBAAqB,CAAC,CAAC,IAAI,IAAI,CAAC,gBAAgB,EAAE,WAAW,GAAG,aAAa,CAAC,GAAG;IAC3F,SAAS,EAAE,CAAC,CAAC,IAAI,EAAE,gBAAgB,EAAE,KAAK,EAAE,4BAA4B,CAAC,CAAC,CAAC,KAAK,OAAO,CAAC,GAAG,IAAI,CAAA;IAC/F,WAAW,CAAC,OAAO,EAAE,CAAC,GAAG,IAAI,CAAA;CAC9B,CAAA;AAED,MAAM,MAAM,qBAAqB,CAAC,CAAC,GAAG,eAAe,IAAI,qBAAqB,CAC5E,2BAA2B,CAAC,CAAC,CAAC,CAC/B,CAAA;AAED,wBAAgB,iBAAiB,CAAC,KAAK,EAAE,OAAO,GAAG,KAAK,IAAI,eAAe,CA8C1E"}

lib/threads.js

+import { isPlainObject } from './utils.js';
+export const APP_STATS_CHANNEL = 'nxt:app:stats';
+export function isThreadStatsWire(value) {
+    if (!isPlainObject(value)) {
+        return false;
+    }
+    if (typeof value.id !== 'number' ||
+        typeof value.name !== 'string' ||
+        typeof value.module !== 'string') {
+        return false;
+    }
+    if (value.lag != null &&
+        (!isPlainObject(value.lag) ||
+            typeof value.lag.p50 !== 'number' ||
+            typeof value.lag.p95 !== 'number' ||
+            typeof value.lag.p99 !== 'number' ||
+            typeof value.lag.max !== 'number')) {
+        return false;
+    }
+    if (value.memoryUsage !== undefined &&
+        (!isPlainObject(value.memoryUsage) ||
+            typeof value.memoryUsage.rss !== 'number' ||
+            typeof value.memoryUsage.heapTotal !== 'number' ||
+            typeof value.memoryUsage.heapUsed !== 'number' ||
+            typeof value.memoryUsage.external !== 'number' ||
+            typeof value.memoryUsage.arrayBuffers !== 'number')) {
+        return false;
+    }
+    if (value.heapStatistics !== undefined &&
+        (!isPlainObject(value.heapStatistics) ||
+            typeof value.heapStatistics.used_heap_size !== 'number' ||
+            typeof value.heapStatistics.heap_size_limit !== 'number')) {
+        return false;
+    }
+    return true;
+}
+//# sourceMappingURL=threads.js.map

lib/threads.js.map

+{"version":3,"file":"threads.js","sourceRoot":"","sources":["../src/threads.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,aAAa,EAAE,MAAM,YAAY,CAAA;AAE1C,MAAM,CAAC,MAAM,iBAAiB,GAAG,eAAe,CAAA;AAuHhD,MAAM,UAAU,iBAAiB,CAAC,KAAc;IAC9C,IAAI,CAAC,aAAa,CAAC,KAAK,CAAC,EAAE,CAAC;QAC1B,OAAO,KAAK,CAAA;IACd,CAAC;IAED,IACE,OAAO,KAAK,CAAC,EAAE,KAAK,QAAQ;QAC5B,OAAO,KAAK,CAAC,IAAI,KAAK,QAAQ;QAC9B,OAAO,KAAK,CAAC,MAAM,KAAK,QAAQ,EAChC,CAAC;QACD,OAAO,KAAK,CAAA;IACd,CAAC;IAED,IACE,KAAK,CAAC,GAAG,IAAI,IAAI;QACjB,CAAC,CAAC,aAAa,CAAC,KAAK,CAAC,GAAG,CAAC;YACxB,OAAO,KAAK,CAAC,GAAG,CAAC,GAAG,KAAK,QAAQ;YACjC,OAAO,KAAK,CAAC,GAAG,CAAC,GAAG,KAAK,QAAQ;YACjC,OAAO,KAAK,CAAC,GAAG,CAAC,GAAG,KAAK,QAAQ;YACjC,OAAO,KAAK,CAAC,GAAG,CAAC,GAAG,KAAK,QAAQ,CAAC,EACpC,CAAC;QACD,OAAO,KAAK,CAAA;IACd,CAAC;IAED,IACE,KAAK,CAAC,WAAW,KAAK,SAAS;QAC/B,CAAC,CAAC,aAAa,CAAC,KAAK,CAAC,WAAW,CAAC;YAChC,OAAO,KAAK,CAAC,WAAW,CAAC,GAAG,KAAK,QAAQ;YACzC,OAAO,KAAK,CAAC,WAAW,CAAC,SAAS,KAAK,QAAQ;YAC/C,OAAO,KAAK,CAAC,WAAW,CAAC,QAAQ,KAAK,QAAQ;YAC9C,OAAO,KAAK,CAAC,WAAW,CAAC,QAAQ,KAAK,QAAQ;YAC9C,OAAO,KAAK,CAAC,WAAW,CAAC,YAAY,KAAK,QAAQ,CAAC,EACrD,CAAC;QACD,OAAO,KAAK,CAAA;IACd,CAAC;IAED,IACE,KAAK,CAAC,cAAc,KAAK,SAAS;QAClC,CAAC,CAAC,aAAa,CAAC,KAAK,CAAC,cAAc,CAAC;YACnC,OAAO,KAAK,CAAC,cAAc,CAAC,cAAc,KAAK,QAAQ;YACvD,OAAO,KAAK,CAAC,cAAc,CAAC,eAAe,KAAK,QAAQ,CAAC,EAC3D,CAAC;QACD,OAAO,KAAK,CAAA;IACd,CAAC;IAED,OAAO,IAAI,CAAA;AACb,CAAC"}

lib/utils.d.ts

+export declare function isPlainObject(value: unknown): value is Record<string, unknown>;
+//# sourceMappingURL=utils.d.ts.map

lib/utils.d.ts.map

+{"version":3,"file":"utils.d.ts","sourceRoot":"","sources":["../src/utils.ts"],"names":[],"mappings":"AAAA,wBAAgB,aAAa,CAAC,KAAK,EAAE,OAAO,GAAG,KAAK,IAAI,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAQ9E"}

lib/utils.js

+export function isPlainObject(value) {
+    if (typeof value !== 'object' || value === null || Array.isArray(value)) {
+        return false;
+    }
+    const prototype = Object.getPrototypeOf(value);
+    return prototype === Object.prototype || prototype === null;
+}
+//# sourceMappingURL=utils.js.map

lib/utils.js.map

+{"version":3,"file":"utils.js","sourceRoot":"","sources":["../src/utils.ts"],"names":[],"mappings":"AAAA,MAAM,UAAU,aAAa,CAAC,KAAc;IAC1C,IAAI,OAAO,KAAK,KAAK,QAAQ,IAAI,KAAK,KAAK,IAAI,IAAI,KAAK,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE,CAAC;QACxE,OAAO,KAAK,CAAA;IACd,CAAC;IAED,MAAM,SAAS,GAAG,MAAM,CAAC,cAAc,CAAC,KAAK,CAAC,CAAA;IAE9C,OAAO,SAAS,KAAK,MAAM,CAAC,SAAS,IAAI,SAAS,KAAK,IAAI,CAAA;AAC7D,CAAC"}

lib/virtual-id.d.ts

+export type VirtualId = {
+    type: string;
+    parentId: string;
+    id: string;
+};
+export declare function createVirtualId({ type, parentId, id }: VirtualId): string;
+export declare function parseVirtualId(value: string | null | undefined): VirtualId | null;
+//# sourceMappingURL=virtual-id.d.ts.map

lib/virtual-id.d.ts.map

+{"version":3,"file":"virtual-id.d.ts","sourceRoot":"","sources":["../src/virtual-id.ts"],"names":[],"mappings":"AAAA,MAAM,MAAM,SAAS,GAAG;IACtB,IAAI,EAAE,MAAM,CAAA;IACZ,QAAQ,EAAE,MAAM,CAAA;IAChB,EAAE,EAAE,MAAM,CAAA;CACX,CAAA;AAED,wBAAgB,eAAe,CAAC,EAAE,IAAI,EAAE,QAAQ,EAAE,EAAE,EAAE,EAAE,SAAS,UAEhE;AAED,wBAAgB,cAAc,CAAC,KAAK,EAAE,MAAM,GAAG,IAAI,GAAG,SAAS,GAAG,SAAS,GAAG,IAAI,CAcjF"}

lib/virtual-id.js

+export function createVirtualId({ type, parentId, id }) {
+    return [type, parentId, id].map((x) => encodeURIComponent(x)).join('@');
+}
+export function parseVirtualId(value) {
+    if (typeof value !== 'string') {
+        return null;
+    }
+    const parsed = value.match(/^([^@]+)@([^@]+)@([^@]+)$/);
+    return parsed
+        ? {
+            type: decodeURIComponent(parsed[1]),
+            parentId: decodeURIComponent(parsed[2]),
+            id: decodeURIComponent(parsed[3]),
+        }
+        : null;
+}
+//# sourceMappingURL=virtual-id.js.map

lib/virtual-id.js.map

+{"version":3,"file":"virtual-id.js","sourceRoot":"","sources":["../src/virtual-id.ts"],"names":[],"mappings":"AAMA,MAAM,UAAU,eAAe,CAAC,EAAE,IAAI,EAAE,QAAQ,EAAE,EAAE,EAAa;IAC/D,OAAO,CAAC,IAAI,EAAE,QAAQ,EAAE,EAAE,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,kBAAkB,CAAC,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAA;AACzE,CAAC;AAED,MAAM,UAAU,cAAc,CAAC,KAAgC;IAC7D,IAAI,OAAO,KAAK,KAAK,QAAQ,EAAE,CAAC;QAC9B,OAAO,IAAI,CAAA;IACb,CAAC;IAED,MAAM,MAAM,GAAG,KAAK,CAAC,KAAK,CAAC,2BAA2B,CAAC,CAAA;IAEvD,OAAO,MAAM;QACX,CAAC,CAAC;YACE,IAAI,EAAE,kBAAkB,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC;YACnC,QAAQ,EAAE,kBAAkB,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC;YACvC,EAAE,EAAE,kBAAkB,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC;SAClC;QACH,CAAC,CAAC,IAAI,CAAA;AACV,CAAC"}

lib/index.d.ts

@@ -1,99 +0,4 @@
-export declare const APP_STATS_CHANNEL = "nxt:app:stats";
-export type ThreadMemoryUsage = {
-    rss: number;
-    heapTotal: number;
-    heapUsed: number;
-    external: number;
-    arrayBuffers: number;
-};
-export type ThreadHeapStatistics = {
-    total_heap_size: number;
-    total_heap_size_executable: number;
-    total_physical_size: number;
-    total_available_size: number;
-    used_heap_size: number;
-    heap_size_limit: number;
-    malloced_memory: number;
-    peak_malloced_memory: number;
-    does_zap_garbage: number;
-    number_of_native_contexts: number;
-    number_of_detached_contexts: number;
-    total_global_handles_size: number;
-    used_global_handles_size: number;
-    external_memory: number;
-};
-export type ThreadEventLoopUtilization = {
-    idle: number;
-    active: number;
-    utilization: number;
-};
-export type ThreadCpuUsage = {
-    user: number;
-    system: number;
-};
-export type ThreadResourceLimits = {
-    maxYoungGenerationSizeMb?: number;
-    maxOldGenerationSizeMb?: number;
-    codeRangeSizeMb?: number;
-    stackSizeMb?: number;
-};
-export type ThreadDsStats = {
-    connected: boolean;
-    record: {
-        records: number;
-        pruning: number;
-        updating: number;
-        patching: number;
-    };
-};
-export type ThreadHttpStats = {
-    userAgent?: string;
-    pending?: number;
-};
-export type ThreadUndiciStats = {
-    sockets?: number;
-    pending?: number;
-};
-export type ThreadLagHistogram = {
-    p50: number;
-    p95: number;
-    p99: number;
-    max: number;
-};
-export type ThreadRuntimeStats = {
-    memoryUsage?: ThreadMemoryUsage;
-    heapStatistics?: ThreadHeapStatistics;
-    eventLoopUtilization?: ThreadEventLoopUtilization;
-};
-export type ThreadStatsWire = ThreadRuntimeStats & {
-    id: number;
-    name: string;
-    module: string;
-    version?: string;
-    uptime?: number;
-    timestamp?: number;
-    ds?: ThreadDsStats;
-    lag?: ThreadLagHistogram | null;
-    busyCount?: number | null;
-    cpuUsage?: ThreadCpuUsage;
-    threadCpuUsage?: ThreadCpuUsage;
-    affinity?: string | null;
-    resourceLimits?: ThreadResourceLimits;
-    http?: ThreadHttpStats;
-    undici?: ThreadUndiciStats;
-} & Record<string, unknown>;
-export type ThreadStatsBroadcastMessage<T = ThreadStatsWire> = {
-    id: number;
-    data: T | undefined;
-};
-export type BroadcastChannelMessageEvent<T> = {
-    data: T;
-};
-export type TypedBroadcastChannel<T> = Omit<BroadcastChannel, 'onmessage' | 'postMessage'> & {
-    onmessage: ((this: BroadcastChannel, event: BroadcastChannelMessageEvent<T>) => unknown) | null;
-    postMessage(message: T): void;
-};
-export type StatsBroadcastChannel<T = ThreadStatsWire> = TypedBroadcastChannel<ThreadStatsBroadcastMessage<T>>;
-export declare function isPlainObject(value: unknown): value is Record<string, unknown>;
-export declare function isThreadStatsWire(value: unknown): value is ThreadStatsWire;
+export * from './virtual-id.js';
+export * from './threads.js';
+export * from './utils.js';
 //# sourceMappingURL=index.d.ts.map

lib/index.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,eAAO,MAAM,iBAAiB,kBAAkB,CAAA;AAEhD,MAAM,MAAM,iBAAiB,GAAG;IAC9B,GAAG,EAAE,MAAM,CAAA;IACX,SAAS,EAAE,MAAM,CAAA;IACjB,QAAQ,EAAE,MAAM,CAAA;IAChB,QAAQ,EAAE,MAAM,CAAA;IAChB,YAAY,EAAE,MAAM,CAAA;CACrB,CAAA;AAED,MAAM,MAAM,oBAAoB,GAAG;IACjC,eAAe,EAAE,MAAM,CAAA;IACvB,0BAA0B,EAAE,MAAM,CAAA;IAClC,mBAAmB,EAAE,MAAM,CAAA;IAC3B,oBAAoB,EAAE,MAAM,CAAA;IAC5B,cAAc,EAAE,MAAM,CAAA;IACtB,eAAe,EAAE,MAAM,CAAA;IACvB,eAAe,EAAE,MAAM,CAAA;IACvB,oBAAoB,EAAE,MAAM,CAAA;IAC5B,gBAAgB,EAAE,MAAM,CAAA;IACxB,yBAAyB,EAAE,MAAM,CAAA;IACjC,2BAA2B,EAAE,MAAM,CAAA;IACnC,yBAAyB,EAAE,MAAM,CAAA;IACjC,wBAAwB,EAAE,MAAM,CAAA;IAChC,eAAe,EAAE,MAAM,CAAA;CACxB,CAAA;AAED,MAAM,MAAM,0BAA0B,GAAG;IACvC,IAAI,EAAE,MAAM,CAAA;IACZ,MAAM,EAAE,MAAM,CAAA;IACd,WAAW,EAAE,MAAM,CAAA;CACpB,CAAA;AAED,MAAM,MAAM,cAAc,GAAG;IAC3B,IAAI,EAAE,MAAM,CAAA;IACZ,MAAM,EAAE,MAAM,CAAA;CACf,CAAA;AAED,MAAM,MAAM,oBAAoB,GAAG;IACjC,wBAAwB,CAAC,EAAE,MAAM,CAAA;IACjC,sBAAsB,CAAC,EAAE,MAAM,CAAA;IAC/B,eAAe,CAAC,EAAE,MAAM,CAAA;IACxB,WAAW,CAAC,EAAE,MAAM,CAAA;CACrB,CAAA;AAED,MAAM,MAAM,aAAa,GAAG;IAC1B,SAAS,EAAE,OAAO,CAAA;IAClB,MAAM,EAAE;QACN,OAAO,EAAE,MAAM,CAAA;QACf,OAAO,EAAE,MAAM,CAAA;QACf,QAAQ,EAAE,MAAM,CAAA;QAChB,QAAQ,EAAE,MAAM,CAAA;KACjB,CAAA;CACF,CAAA;AAED,MAAM,MAAM,eAAe,GAAG;IAC5B,SAAS,CAAC,EAAE,MAAM,CAAA;IAClB,OAAO,CAAC,EAAE,MAAM,CAAA;CACjB,CAAA;AAED,MAAM,MAAM,iBAAiB,GAAG;IAC9B,OAAO,CAAC,EAAE,MAAM,CAAA;IAChB,OAAO,CAAC,EAAE,MAAM,CAAA;CACjB,CAAA;AAED,MAAM,MAAM,kBAAkB,GAAG;IAC/B,GAAG,EAAE,MAAM,CAAA;IACX,GAAG,EAAE,MAAM,CAAA;IACX,GAAG,EAAE,MAAM,CAAA;IACX,GAAG,EAAE,MAAM,CAAA;CACZ,CAAA;AAED,MAAM,MAAM,kBAAkB,GAAG;IAM/B,WAAW,CAAC,EAAE,iBAAiB,CAAA;IAC/B,cAAc,CAAC,EAAE,oBAAoB,CAAA;IACrC,oBAAoB,CAAC,EAAE,0BAA0B,CAAA;CAClD,CAAA;AAED,MAAM,MAAM,eAAe,GAAG,kBAAkB,GAAG;IACjD,EAAE,EAAE,MAAM,CAAA;IACV,IAAI,EAAE,MAAM,CAAA;IACZ,MAAM,EAAE,MAAM,CAAA;IACd,OAAO,CAAC,EAAE,MAAM,CAAA;IAChB,MAAM,CAAC,EAAE,MAAM,CAAA;IACf,SAAS,CAAC,EAAE,MAAM,CAAA;IAClB,EAAE,CAAC,EAAE,aAAa,CAAA;IAClB,GAAG,CAAC,EAAE,kBAAkB,GAAG,IAAI,CAAA;IAC/B,SAAS,CAAC,EAAE,MAAM,GAAG,IAAI,CAAA;IACzB,QAAQ,CAAC,EAAE,cAAc,CAAA;IACzB,cAAc,CAAC,EAAE,cAAc,CAAA;IAC/B,QAAQ,CAAC,EAAE,MAAM,GAAG,IAAI,CAAA;IACxB,cAAc,CAAC,EAAE,oBAAoB,CAAA;IACrC,IAAI,CAAC,EAAE,eAAe,CAAA;IACtB,MAAM,CAAC,EAAE,iBAAiB,CAAA;CAC3B,GAAG,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAAA;AAE3B,MAAM,MAAM,2BAA2B,CAAC,CAAC,GAAG,eAAe,IAAI;IAC7D,EAAE,EAAE,MAAM,CAAA;IACV,IAAI,EAAE,CAAC,GAAG,SAAS,CAAA;CACpB,CAAA;AAED,MAAM,MAAM,4BAA4B,CAAC,CAAC,IAAI;IAC5C,IAAI,EAAE,CAAC,CAAA;CACR,CAAA;AAED,MAAM,MAAM,qBAAqB,CAAC,CAAC,IAAI,IAAI,CAAC,gBAAgB,EAAE,WAAW,GAAG,aAAa,CAAC,GAAG;IAC3F,SAAS,EAAE,CAAC,CAAC,IAAI,EAAE,gBAAgB,EAAE,KAAK,EAAE,4BAA4B,CAAC,CAAC,CAAC,KAAK,OAAO,CAAC,GAAG,IAAI,CAAA;IAC/F,WAAW,CAAC,OAAO,EAAE,CAAC,GAAG,IAAI,CAAA;CAC9B,CAAA;AAED,MAAM,MAAM,qBAAqB,CAAC,CAAC,GAAG,eAAe,IAAI,qBAAqB,CAC5E,2BAA2B,CAAC,CAAC,CAAC,CAC/B,CAAA;AAED,wBAAgB,aAAa,CAAC,KAAK,EAAE,OAAO,GAAG,KAAK,IAAI,MAAM,CAAC,MAAM,EAAE,OAAO,CAAC,CAQ9E;AAED,wBAAgB,iBAAiB,CAAC,KAAK,EAAE,OAAO,GAAG,KAAK,IAAI,eAAe,CA8C1E"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,cAAc,iBAAiB,CAAA;AAC/B,cAAc,cAAc,CAAA;AAC5B,cAAc,YAAY,CAAA"}

lib/index.js

@@ -1,43 +0,4 @@
-export const APP_STATS_CHANNEL = 'nxt:app:stats';
-export function isPlainObject(value) {
-    if (typeof value !== 'object' || value === null || Array.isArray(value)) {
-        return false;
-    }
-    const prototype = Object.getPrototypeOf(value);
-    return prototype === Object.prototype || prototype === null;
-}
-export function isThreadStatsWire(value) {
-    if (!isPlainObject(value)) {
-        return false;
-    }
-    if (typeof value.id !== 'number' ||
-        typeof value.name !== 'string' ||
-        typeof value.module !== 'string') {
-        return false;
-    }
-    if (value.lag != null &&
-        (!isPlainObject(value.lag) ||
-            typeof value.lag.p50 !== 'number' ||
-            typeof value.lag.p95 !== 'number' ||
-            typeof value.lag.p99 !== 'number' ||
-            typeof value.lag.max !== 'number')) {
-        return false;
-    }
-    if (value.memoryUsage !== undefined &&
-        (!isPlainObject(value.memoryUsage) ||
-            typeof value.memoryUsage.rss !== 'number' ||
-            typeof value.memoryUsage.heapTotal !== 'number' ||
-            typeof value.memoryUsage.heapUsed !== 'number' ||
-            typeof value.memoryUsage.external !== 'number' ||
-            typeof value.memoryUsage.arrayBuffers !== 'number')) {
-        return false;
-    }
-    if (value.heapStatistics !== undefined &&
-        (!isPlainObject(value.heapStatistics) ||
-            typeof value.heapStatistics.used_heap_size !== 'number' ||
-            typeof value.heapStatistics.heap_size_limit !== 'number')) {
-        return false;
-    }
-    return true;
-}
+export * from './virtual-id.js';
+export * from './threads.js';
+export * from './utils.js';
 //# sourceMappingURL=index.js.map

lib/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,MAAM,CAAC,MAAM,iBAAiB,GAAG,eAAe,CAAA;AAuHhD,MAAM,UAAU,aAAa,CAAC,KAAc;IAC1C,IAAI,OAAO,KAAK,KAAK,QAAQ,IAAI,KAAK,KAAK,IAAI,IAAI,KAAK,CAAC,OAAO,CAAC,KAAK,CAAC,EAAE,CAAC;QACxE,OAAO,KAAK,CAAA;IACd,CAAC;IAED,MAAM,SAAS,GAAG,MAAM,CAAC,cAAc,CAAC,KAAK,CAAC,CAAA;IAE9C,OAAO,SAAS,KAAK,MAAM,CAAC,SAAS,IAAI,SAAS,KAAK,IAAI,CAAA;AAC7D,CAAC;AAED,MAAM,UAAU,iBAAiB,CAAC,KAAc;IAC9C,IAAI,CAAC,aAAa,CAAC,KAAK,CAAC,EAAE,CAAC;QAC1B,OAAO,KAAK,CAAA;IACd,CAAC;IAED,IACE,OAAO,KAAK,CAAC,EAAE,KAAK,QAAQ;QAC5B,OAAO,KAAK,CAAC,IAAI,KAAK,QAAQ;QAC9B,OAAO,KAAK,CAAC,MAAM,KAAK,QAAQ,EAChC,CAAC;QACD,OAAO,KAAK,CAAA;IACd,CAAC;IAED,IACE,KAAK,CAAC,GAAG,IAAI,IAAI;QACjB,CAAC,CAAC,aAAa,CAAC,KAAK,CAAC,GAAG,CAAC;YACxB,OAAO,KAAK,CAAC,GAAG,CAAC,GAAG,KAAK,QAAQ;YACjC,OAAO,KAAK,CAAC,GAAG,CAAC,GAAG,KAAK,QAAQ;YACjC,OAAO,KAAK,CAAC,GAAG,CAAC,GAAG,KAAK,QAAQ;YACjC,OAAO,KAAK,CAAC,GAAG,CAAC,GAAG,KAAK,QAAQ,CAAC,EACpC,CAAC;QACD,OAAO,KAAK,CAAA;IACd,CAAC;IAED,IACE,KAAK,CAAC,WAAW,KAAK,SAAS;QAC/B,CAAC,CAAC,aAAa,CAAC,KAAK,CAAC,WAAW,CAAC;YAChC,OAAO,KAAK,CAAC,WAAW,CAAC,GAAG,KAAK,QAAQ;YACzC,OAAO,KAAK,CAAC,WAAW,CAAC,SAAS,KAAK,QAAQ;YAC/C,OAAO,KAAK,CAAC,WAAW,CAAC,QAAQ,KAAK,QAAQ;YAC9C,OAAO,KAAK,CAAC,WAAW,CAAC,QAAQ,KAAK,QAAQ;YAC9C,OAAO,KAAK,CAAC,WAAW,CAAC,YAAY,KAAK,QAAQ,CAAC,EACrD,CAAC;QACD,OAAO,KAAK,CAAA;IACd,CAAC;IAED,IACE,KAAK,CAAC,cAAc,KAAK,SAAS;QAClC,CAAC,CAAC,aAAa,CAAC,KAAK,CAAC,cAAc,CAAC;YACnC,OAAO,KAAK,CAAC,cAAc,CAAC,cAAc,KAAK,QAAQ;YACvD,OAAO,KAAK,CAAC,cAAc,CAAC,eAAe,KAAK,QAAQ,CAAC,EAC3D,CAAC;QACD,OAAO,KAAK,CAAA;IACd,CAAC;IAED,OAAO,IAAI,CAAA;AACb,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,cAAc,iBAAiB,CAAA;AAC/B,cAAc,cAAc,CAAA;AAC5B,cAAc,YAAY,CAAA"}

package.json

 {
   "name": "@nxtedition/common",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "type": "module",
@@ -27,3 +27,4 @@ "main": "lib/index.js",
     "typescript": "^5.9.3"
-  }
+  },
+  "gitHead": "420b1a6e239958e010f6662fcd02c158c1fd3046"
 }

New alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Improved metrics

Total package byte prevSize

12672

30.37%

Number of package files

17

240%

Lines of code

170

21.43%

Worsened metrics

Number of medium supply chain risk alerts

2

Infinity%

No dependency changes