⌚ Handle socket timeout

package.json

@@ -1,6 +1,6 @@
 {
   "name": "vitrea-client",
-  "version": "0.0.5",
+  "version": "0.0.6",
   "description": "Vitrea Smart Home API Client",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/VitreaClient.spec.ts

@@ -93,7 +93,7 @@ describe('VitreaClient', () => {
         expect(mock).toHaveBeenCalledTimes(1)
     })
 
-    it('[handleDisconnect] will not attempt to reconnect by default', async () => {
+    it('[handleDisconnect] will not attempt to reconnect', async () => {
         const socket = new Socket()
 
         const mock = jest.spyOn(socket, 'connect')

src/socket/AbstractSocket.ts

@@ -25,13 +25,14 @@ export abstract class AbstractSocket extends EventEmitter implements WritableSoc
         this.socket = this.socketConfigs.socketSupplier()
 
         return this.socket
+            .setTimeout(this.socketConfigs.requestTimeout * 10)
             .on('connect', this.handleConnect.bind(this))
             .on('data', this.handleData.bind(this))
             .on('end', this.handleDisconnect.bind(this))
             .on('error', this.handleError.bind(this))
     }
 
-    public async connect() :Promise<void> {
+    public async connect(): Promise<void> {
         this.log.debug('Attempting to make a connection')
 
         if (this.socket) {
@@ -68,7 +69,7 @@ export abstract class AbstractSocket extends EventEmitter implements WritableSoc
     }
 
     public async write(data: Buffer): Promise<void> {
-        if (!this.socket) {
+        if (!this.socket || this.socket.destroyed) {
             throw new Exceptions.NoConnectionException()
         }
 
@@ -103,6 +104,7 @@ export abstract class AbstractSocket extends EventEmitter implements WritableSoc
 
     protected handleError(error: Error) {
         this.socketConfigs.shouldReconnect = false
+
         this.log.error(`An error occurred - ${error.message}`)
     }