0.8.1 (#8)

* Try reconnecting when getting a DNS error on WS connect

* 0.8.1

Author: cakedan

package-lock.json

@@ -1,18 +1,18 @@
 {
   "name": "detritus-client-socket",
-  "version": "0.8.0",
+  "version": "0.8.1",
   "description": "A TypeScript NodeJS library to interact with Discord's Gateway",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",
   "files": [
     "lib/**/*"
   ],
   "dependencies": {
+    "@types/node": "^14.17.1",
     "detritus-utils": "^0.4.0",
     "ws": "^7.4.6"
   },
   "devDependencies": {
-    "@types/node": "^14.17.1",
     "typedoc": "^0.20.36",
     "typescript": "^4.2.4"
   },

package.json

@@ -1,6 +1,6 @@
 export const Package = Object.freeze({
   URL: 'https://github.com/detritusjs/client-socket',
-  VERSION: '0.8.0',
+  VERSION: '0.8.1',
 });
 
 

src/constants.ts

@@ -433,11 +433,26 @@ export class Socket extends EventSpewer {
       }; break;
     }
 
-    this.socket = new BaseSocket(this.url.href);
-    this.socket.on(SocketEventsBase.CLOSE, this.onClose.bind(this, this.socket));
-    this.socket.on(SocketEventsBase.ERROR, this.onError.bind(this, this.socket));
-    this.socket.on(SocketEventsBase.MESSAGE, this.onMessage.bind(this, this.socket));
-    this.socket.on(SocketEventsBase.OPEN, this.onOpen.bind(this, this.socket));
+    try {
+      this.socket = new BaseSocket(this.url.href);
+      this.socket.on(SocketEventsBase.CLOSE, this.onClose.bind(this, this.socket));
+      this.socket.on(SocketEventsBase.ERROR, this.onError.bind(this, this.socket));
+      this.socket.on(SocketEventsBase.MESSAGE, this.onMessage.bind(this, this.socket));
+      this.socket.on(SocketEventsBase.OPEN, this.onOpen.bind(this, this.socket));
+    } catch(error) {
+      this.socket = null;
+      if (this.autoReconnect && !this.killed) {
+        if (this.reconnectMax < this.reconnects) {
+          this.kill(new Error(`Tried reconnecting more than ${this.reconnectMax} times.`));
+        } else {
+          this.emit(SocketEvents.RECONNECTING);
+          setTimeout(() => {
+            this.connect(url);
+            this.reconnects++;
+          }, this.reconnectDelay);
+        }
+      }
+    }
 
     this.setState(SocketStates.CONNECTING);
     this.emit(SocketEvents.SOCKET, this.socket);