add remote object count and ref/unref events

Author: arcticnotes

lib/node/node-wsh.js

@@ -1,3 +1,4 @@
+import EventEmitter from 'node:events';
 import PATH from 'node:path';
 import { Syncline} from "@arcticnotes/syncline";
 
@@ -7,7 +8,7 @@ const SCRIPT_FILE = PATH.join( PATH.dirname( import.meta.dirname), 'wsh', 'host.
 const PROXY = Symbol();
 const TRACE_REF = 1;
 
-export class WindowsScriptingHost {
+export class WindowsScriptingHost extends EventEmitter {
 
 	static async connect( options = {}) {
 		const command = options.command || COMMAND;
@@ -24,15 +25,25 @@ export class WindowsScriptingHost {
 	#Enumerator;
 
 	constructor( syncline, options) {
+		super();
 		this.#syncline = syncline;
 		this.#syncline.on( 'stderr', line => console.log( 'wsh:', line));
 		this.#syncline.on( 'stdout', line => console.log( 'wsh:', line));
-		this.#proxies = new Proxies( syncline, options);
+		this.#proxies = new Proxies( syncline, options, this);
 		this.#WScript = this.#proxies.getOrCreateObject( 0);
 		this.#GetObject = this.#proxies.getOrCreateFunction( 1);
 		this.#Enumerator = this.#proxies.getOrCreateFunction( 2);
 	}
 
+	get remoteObjects() {
+		const proxies = this.#proxies;
+		return {
+			get count() {
+				proxies.count;
+			},
+		};
+	}
+
 	get WScript() {
 		return this.#WScript;
 	}
@@ -54,6 +65,7 @@ class Proxies {
 
 	#syncline;
 	#trace;
+	#eventEmitter;
 	#finalizer = new FinalizationRegistry( this.#finalized.bind( this));
 	#ref2proxy = new Map();
 	#proxy2ref = new Map();
@@ -110,9 +122,14 @@ class Proxies {
 		},
 	};
 
-	constructor( syncline, options) {
+	constructor( syncline, options, eventEmitter) {
 		this.#syncline = syncline;
 		this.#trace = options.trace;
+		this.#eventEmitter = eventEmitter;
+	}
+
+	get count() {
+		return this.#ref2proxy.size;
 	}
 
 	getOrCreateObject( ref) {
@@ -134,6 +151,7 @@ class Proxies {
 		this.#ref2proxy.set( ref, newProxy);
 		this.#proxy2ref.set( newProxy, ref);
 		this.#finalizer.register( newProxy, ref);
+		this.#eventEmitter.emit( 'ref', ref, newProxy);
 		return newProxy;
 	}
 
@@ -150,6 +168,7 @@ class Proxies {
 				default:
 					console.log( `unknown response: ${ output[ 0]}`);
 			}
+		this.#eventEmitter.emit( 'unref', ref);
 	}
 
 	#encode( decoded) {

package-lock.json

@@ -1,6 +1,6 @@
 {
 	"name": "@arcticnotes/node-wsh",
-	"version": "0.0.7",
+	"version": "0.0.8",
 	"description": "A Node.js package that runs Windows Scripting Host (WSH) as a child process and exposes the resources from the WSH world to the Node.js world",
 	"author": "Paul <paul@arcticnotes.com>",
 	"license": "MIT",

package.json

@@ -4,6 +4,8 @@ import { WindowsScriptingHost} from '@arcticnotes/node-wsh';
 
 TEST( 'smoke-test', async() => {
 	const wsh = await WindowsScriptingHost.connect();
+	wsh.on( 'ref', ( ref, obj) => console.log( 'ref', ref, obj));
+	wsh.on( 'unref', ref => console.log( 'unref', ref));
 	try {
 		const { WScript, GetObject, Enumerator} = wsh;
 		console.log( WScript.Version);
@@ -14,6 +16,7 @@ TEST( 'smoke-test', async() => {
 			ASSERT.equal( typeof enumerator.item().ProcessId, 'number');
 			ASSERT.equal( typeof enumerator.item().Name, 'string');
 		}
+		console.log( 'remote objects:', wsh.remoteObjects.count);
 	} finally {
 		await wsh.disconnect();
 	}