Fixed #4: TCP sockets for connection

src/connection/inet-socket-connection.ts

@@ -0,0 +1,43 @@
+import * as net from 'net';
+import BaseConnection from './base-connection';
+
+export default class InetSocketConnection extends BaseConnection {
+	client?: net.Socket;
+	host: string;
+	port: number;
+
+	constructor(host: string, port: number) {
+		super();
+		this.host = host;
+		this.port = port;
+	}
+
+	setupConnection(): Promise<void> {
+		return new Promise(resolve => {
+			this.client = net.createConnection(this.port, this.host);
+			this.client.on('data', (data) => {
+				const dataLines = data.toString().split(/\r?\n/);
+				dataLines.map((data) => {
+					if (data) {
+						this.onData(Buffer.from(data))
+					}
+				});
+			});
+			this.client.on('connect', () => {
+				resolve();
+			});
+		});
+	}
+
+	async closeConnection() {
+		this.client?.destroy();
+	}
+
+	send(message: Buffer): Promise<void> {
+		return new Promise(resolve => {
+			this.client?.write(message, () => {
+				resolve();
+			});
+		});
+	}
+}

src/connection/unix-socket-connection.ts

@@ -1,7 +1,7 @@
 import * as net from 'net';
 import BaseConnection from './base-connection';
 
-export default class SocketConnection extends BaseConnection {
+export default class UnixSocketConnection extends BaseConnection {
 	client?: net.Socket;
 	sockPath: string;
 

src/juno-node.ts

@@ -1,3 +1,5 @@
+import * as net from 'net';
+import * as fs from 'fs';
 import { BaseProtocol } from './protocol/base-protocol';
 import BaseConnection from './connection/base-connection';
 import { JsonProtocol } from './protocol/json-protocol';
@@ -8,7 +10,8 @@ import {
 	TriggerHookRequest,
 	JunoMessage
 } from './models/messages';
-import SocketConnection from './connection/unix-socket-connection';
+import UnixSocketConnection from './connection/unix-socket-connection';
+import InetSocketConnection from './connection/inet-socket-connection';
 
 export default class JunoModule {
 
@@ -27,8 +30,30 @@ export default class JunoModule {
 		// this.connection.setOnDataListener(this.onDataHandler);
 	}
 
-	public static default(socketPath: string): JunoModule {
-		return new JunoModule(new SocketConnection(socketPath), new JsonProtocol());
+	public static async default(socketPath: string) {
+		const [ host, port ] = socketPath.split(':');
+
+		if (net.isIP(host) && typeof Number(port) === 'number') {
+			return this.fromInetSocket(host, Number(port));
+		}
+		if ( (await fs.promises.lstat(socketPath)).isSocket() ) {
+			return this.fromUnixSocket(socketPath);
+		}
+
+		throw new Error('Invalid socket object');
+
+	}
+
+	public static fromUnixSocket(path: string) {
+		// Return Error if invoked from windows
+		if (process.platform == 'win32') {
+			throw new Error('Unix sockets are not supported on windows');
+		}
+		return new JunoModule(new UnixSocketConnection(path), new JsonProtocol());
+	}
+
+	public static fromInetSocket(host: string, port: number) {
+		return new JunoModule(new InetSocketConnection(host, port), new JsonProtocol());
 	}
 
 	public async initialize(