feat: introduce timeout

README.md

@@ -121,7 +121,8 @@ var client = new RPCclient({
     user: 'dash',
     pass: 'local321', 
     host: '127.0.0.1', 
-    port: 19998
+    port: 19998,
+    timeout: 1000
 });
 
 var cb = function (err, data) {

lib/index.js

@@ -10,6 +10,7 @@ function RpcClient(opts) {
   this.port = opts.port || 9998;
   this.user = opts.user || 'user';
   this.pass = opts.pass || 'pass';
+  this.timeout = opts.timeout || undefined;
   this.protocol = opts.protocol === 'http' ? http : https;
   this.batchedCalls = null;
   this.disableAgent = opts.disableAgent || false;
@@ -74,6 +75,7 @@ function innerRpc(request, callback) {
     port: self.port,
     rejectUnauthorized: self.rejectUnauthorized,
     agent: self.disableAgent ? false : undefined,
+    timeout: self.timeout ? self.timeout : undefined,
   };
 
   if (self.httpOptions) {
@@ -142,6 +144,11 @@ function innerRpc(request, callback) {
     }
   });
 
+  req.on('timeout', () => {
+    const err = new Error(`Timeout Error: ${options.timeout}ms exceeded`);
+    req.destroy(err);
+  });
+
   req.setHeader('Content-Length', request.length);
   req.setHeader('Content-Type', 'application/json');
   req.setHeader('Authorization', `Basic ${auth}`);
@@ -156,6 +163,10 @@ RpcClient.prototype.batch = function (batchCallback, resultCallback) {
   this.batchedCalls = null;
 };
 
+RpcClient.prototype.setTimeout = function (timeout) {
+  this.timeout = timeout;
+}
+
 // For definitions of RPC calls, see various files in: https://github.com/dashpay/dash/tree/master/src
 RpcClient.callspec = {
   abandonTransaction: 'str',

test/index.js

@@ -526,3 +526,23 @@ describe('RpcClient', function() {
   });
 
 });
+
+it('should throw error when timeout is triggered', (done) => {
+  var client = new RpcClient({
+    user: 'user',
+    pass: 'pass',
+    host: '127.0.0.1',
+    port: 1000,
+  });
+
+  client.httpOptions = {
+    timeout: 100
+  };
+
+  client.getDifficulty((error, parsedBuf) => {
+    should.exist(error);
+    should.not.exist(parsedBuf);
+    error.message.should.equal('Timeout Error: 100ms exceeded')
+    done();
+  })
+});