Push build

.gitignore

@@ -3,7 +3,6 @@ node_modules
 
 # output
 out
-dist
 *.tgz
 
 # code coverage

dist/index.js

@@ -0,0 +1,85 @@
+import EventEmitter from 'node:events';
+import IPCModule from 'node-ipc';
+/**
+ * Handles Inter-Process Communication (IPC) via. server/socket
+ *
+ * @example
+ * // Simple echo example
+ * const ipc = new IPC('echo');
+ *
+ * ipc.on('connect', () => {
+ *   console.log('Connected');
+ *   ipc.send(ipc.name, { hello: 'world!' });
+ * });
+ *
+ * ipc.on('disconnect', () => console.log('Disconnected'));
+ *
+ * ipc.on('message', (message: Message) => {
+ *   console.log(`Message:`, message);
+ * });
+ */
+export default class IPC extends EventEmitter {
+    name;
+    ready;
+    ipc;
+    constructor(name, debug = false) {
+        super();
+        this.name = name;
+        this.ready = false;
+        this.ipc = IPCModule;
+        this.ipc.config.appspace = 'hop.';
+        this.ipc.config.id = name;
+        this.ipc.config.retry = 2500;
+        this.ipc.config.maxRetries = 5;
+        this.ipc.config.logger = debug ? console.log.bind(this) : () => null;
+    }
+    /**
+     * Connect to the IPC server/socket
+     */
+    connect() {
+        this.ipc.connectTo('ipc', () => {
+            this.ipc.of.ipc?.on('connect', () => this.onConnect());
+            this.ipc.of.ipc?.on('disconnect', () => this.onDisconnect());
+            this.ipc.of.ipc?.on('ready', () => this.onReady());
+            this.ipc.of.ipc?.on('message', (raw) => {
+                const data = JSON.parse(raw);
+                this.onMessage(data);
+            });
+        });
+    }
+    /**
+     * Send a message to another process via. IPC
+     * @param to Who to send the message to
+     * @param data JSON data to send to the process
+     */
+    send(to, data) {
+        if (!this.ready)
+            return;
+        const message = {
+            from: this.name,
+            to,
+            payload: JSON.stringify(data)
+        };
+        this.ipc.of.ipc?.emit('message', message);
+    }
+    onConnect() {
+        this.ipc.of.ipc?.emit('identify', {
+            from: this.name
+        });
+    }
+    onDisconnect() {
+        this.emit('disconnect');
+    }
+    onReady() {
+        this.emit('connect');
+        this.ready = true;
+    }
+    onMessage(raw) {
+        const message = {
+            from: raw.from,
+            to: raw.to,
+            payload: JSON.parse(raw.payload)
+        };
+        this.emit('message', message);
+    }
+}