Merge pull request #1 from lukasroegner/master

Error handling for socket write
stickpin · May 10, 2020 · f0ba30d · f0ba30d
2 parents cfcf0f6 + a1882e8
commit f0ba30d
Showing 1 changed file with 14 additions and 2 deletions.
diff --git a/dist/lib/connection.js b/dist/lib/connection.js
@@ -149,13 +149,25 @@ class Connection extends typed_events_1.default {
                 that.emit('debug', "DEBUG: >>>> Send Protobuf=" + JSON.stringify(message.toJSON(), null, 2));
                 let messageLength = Buffer.from(varint.encode(encrypted.length));
                 let bytes = Buffer.concat([messageLength, encrypted]);
-                that.socket.write(bytes);
+                try {
+                    that.socket.write(bytes);
+                } catch (e) {
+                    that.emit('debug', "DEBUG: >>>> Error while writing to socket");
+                    reject();
+                    return;
+                }
             }
             else {
                 that.emit('debug', "DEBUG: >>>> Send Protobuf=" + JSON.stringify(message.toJSON(), null, 2));
                 let messageLength = Buffer.from(varint.encode(data.length));
                 let bytes = Buffer.concat([messageLength, data]);
-                that.socket.write(bytes);
+                try {
+                    that.socket.write(bytes);
+                } catch (e) {
+                    that.emit('debug', "DEBUG: >>>> Error while writing to socket");
+                    reject();
+                    return;
+                }
             }
             if (!waitForResponse) {
                 resolve(new message_1.Message(message));