added tests, prepublish scripts

Author: fed135

.gitignore

@@ -50,3 +50,18 @@ packages/tcp/bin
 packages/udp/bin
 packages/ws/bin
 packages/webrtc/bin
+
+# publish-only files
+packages/kalm/LICENSE
+packages/ipc/LICENSE
+packages/tcp/LICENSE
+packages/udp/LICENSE
+packages/ws/LICENSE
+packages/webrtc/LICENSE
+
+packages/kalm/CHANGELOG.md
+packages/ipc/CHANGELOG.md
+packages/tcp/CHANGELOG.md
+packages/udp/CHANGELOG.md
+packages/ws/CHANGELOG.md
+packages/webrtc/CHANGELOG.md

packages/ipc/CHANGELOG.md

@@ -6,7 +6,8 @@
   "scripts": {
     "build": "../../scripts/build.sh ipc",
     "clean": "../../scripts/cleanup.sh",
-    "test": "jest ./tests"
+    "test": "jest ./tests",
+    "prepublish": "cp ../../LICENSE ./LICENSE && cp ../../CHANGELOG.md ./CHANGELOG.md"
   },
   "funding": {
     "type": "Open Collective",

packages/ipc/LICENSE

@@ -13,7 +13,7 @@ interface IPCSocket extends net.Socket {
   }
 }
 
-export function ipc({ socketTimeout = 30000, path = '/tmp/app.socket-' }: IPCConfig = {}): KalmTransport {
+function ipc({ socketTimeout = 30000, path = '/tmp/app.socket-' }: IPCConfig = {}): KalmTransport {
   return function socket(params: ClientConfig, emitter: NodeJS.EventEmitter): Socket {
     let listener: net.Server;
 
@@ -25,8 +25,8 @@ export function ipc({ socketTimeout = 30000, path = '/tmp/app.socket-' }: IPCCon
 
     function remote(handle: IPCSocket): Remote {
       return {
-        host: handle._server._pipeName,
-        port: handle._handle.fd,
+        host: handle && handle._server && handle._server._pipeName || null,
+        port: handle && handle._handle && handle._handle.fd || null,
       };
     }
 

packages/ipc/package.json

@@ -1,5 +1,40 @@
+import { EventEmitter } from 'events';
 import * as ipc from '../../src/ipc';
 
 describe('IPC transport', () => {
-  it('TODO', () => { expect(ipc).not.toBeUndefined(); });
+  it('basic setup', () => {
+    expect(typeof ipc.default).toBe('function');
+    const transport = ipc.default();
+    expect(typeof transport).toBe('function');
+    const socket = transport({}, new EventEmitter());
+
+    expect(socket).toHaveProperty('bind', expect.any(Function));
+    expect(socket).toHaveProperty('connect', expect.any(Function));
+    expect(socket).toHaveProperty('disconnect', expect.any(Function));
+    expect(socket).toHaveProperty('remote', expect.any(Function));
+    expect(socket).toHaveProperty('stop', expect.any(Function));
+    expect(socket).toHaveProperty('send', expect.any(Function));
+  });
+
+  describe('Given an empty handle reference and no configs', () => {
+    const transport = ipc.default();
+    const socket = transport({}, new EventEmitter());
+
+    describe('when fetching remote', () => {
+      it('should return null values', () => {
+        expect(socket.remote()).toEqual({ host: null, port: null });
+      });
+    });
+  });
+
+  describe('Given a handle reference and no configs', () => {
+    const transport = ipc.default();
+    const socket = transport({}, new EventEmitter());
+
+    describe('when fetching remote', () => {
+      it('should return handle\'s values', () => {
+        expect(socket.remote({ _server: { _pipeName: '/foo' }, _handle: { fd: 12345 } })).toEqual({ host: '/foo', port: 12345 });
+      });
+    });
+  });
 });

packages/ipc/src/ipc.ts

@@ -6,7 +6,8 @@
   "scripts": {
     "build": "../../scripts/build.sh kalm",
     "clean": "../../scripts/cleanup.sh",
-    "test": "jest ./tests"
+    "test": "jest ./tests",
+    "prepublish": "cp ../../LICENSE ./LICENSE && cp ../../CHANGELOG.md ./CHANGELOG.md"
   },
   "funding": {
     "type": "Open Collective",