add timeouts to rpcs

Author: rashfael

src/index.js

@@ -52,14 +52,25 @@ export default class RohrpostClient extends EventEmitter {
 		return promise
 	}
 
-	call (name, data) {
+	call (name, data, opts) {
+		const options = {
+			timeout: 2000
+		}
+		Object.assign(options, opts)
+
 		const {id, promise} = this._createRequest()
 		const payload = {
 			type: name,
 			id,
 			data
 		}
 		this._socket.send(JSON.stringify(payload))
+		setTimeout(() => {
+			if (this._openRequests[id]) {
+				const timeoutedRequest = this._popPendingRequest(id)
+				timeoutedRequest.deferred.reject(new Error('call timed out'))
+			}
+		}, options.timeout)
 		return promise
 	}
 

test/all.test.js

@@ -66,6 +66,11 @@ describe('Rohrpost Client', () => {
 			done()
 		}).catch(() => { done('should not error') })
 	})
+	it('should handle custom call timeouts', (done) => {
+		client.call('my-little-timeouter', {number: 4}, {timeout: 500}).then(() => {
+			done('should not resolve')
+		}).catch(() => { done() })
+	})
 	it('should detect timeouts', (done) => {
 		client.once('closed', done)
 		server.drop = true

test/mock-server.js

@@ -51,7 +51,8 @@ const mock = {
 			ping: mock.handlePing,
 			subscribe: mock.handleSubscribe,
 			unsubscribe: mock.handleUnsubscribe,
-			'my-little-incrementer': mock.handleIncrement
+			'my-little-incrementer': mock.handleIncrement,
+			'my-little-timeouter': mock.handleTimeout
 		}
 		handlers[message.type](socket, message)
 	},
@@ -100,6 +101,9 @@ const mock = {
 		}
 		socket.send(JSON.stringify(response))
 	},
+	handleTimeout (socket, message) {
+		// just let it rot
+	},
 	checkAuth (message) {
 		return message.auth_jwt === 'hunter2'
 	}