Ping connection for net-sync client

package.json

@@ -19,7 +19,7 @@
     "test:cov": "jest --config jest.json --runInBand --coverage",
     "lint": "eslint 'src/**/*.ts'",
     "lint:fix": "eslint --fix 'src/**/*.ts'",
-    "link": "npm link",
+    "link": "npm run build:release && npm link",
     "unlink": "npm unlink iola -g",
     "demo:iola": "terminalizer render ./demo/iola-demo.yml -o ./demo/iola-demo.gif",
     "ws": "ts-node ./test/server/main/ws.ts",

src/api/cli/cli/cli.interactive.ts

@@ -14,23 +14,21 @@ export class CliInteractive implements ICliInteractive {
   ) {}
 
   async listen(server: IHttpServer, client: ISocketClient): Promise<void> {
-    if (!this.config.netSync) {
-      const spinner = ora('Connecting').start()
-
-      const stopSpinner = (delay: number): Promise<ora.Ora> => new Promise(
-        resolve => setTimeout(() => resolve(spinner.stop()), delay)
-      )
-
-      try {
-        await client.connect()
-        await stopSpinner(500)
-      }
-      catch (err) {
-        spinner.color = 'red'
-        await stopSpinner(500)
-
-        throw err
-      }
+    const spinner = ora('Connecting').start()
+
+    const stopSpinner = (delay: number): Promise<ora.Ora> => new Promise(
+      resolve => setTimeout(() => resolve(spinner.stop()), delay)
+    )
+
+    try {
+      await client.connect()
+      await stopSpinner(500)
+    }
+    catch (err) {
+      spinner.color = 'red'
+      await stopSpinner(500)
+
+      throw err
     }
 
     const address = await server

src/core/socket/client/net-socket.sync.client.ts

@@ -26,7 +26,19 @@ export class NetSocketSyncClient implements ISocketClient {
   }
 
   async connect(): Promise<void> {
-    return undefined
+    const socket = createConnection(this.netOptions())
+
+    const connect$ = fromEvent(socket, 'connect').pipe(
+      RxJSUtil.timeout(1000, `connection to ${this._options.address} is timed out`),
+    )
+
+    try {
+      await firstValueFrom(connect$)
+    } catch (e) {
+      throw e
+    } finally {
+      socket.destroy()
+    }
   }
 
   async sendData<TData>(data: TData): Promise<SocketSendReply> {