Allow configurable timeout on Connection

packages/client/README.md

@@ -104,6 +104,7 @@ See [jid package](/packages/jid)
   - `resource` `<string`> Optional resource for [resource binding](/packages/resource-binding)
   - `username` `<string>` Optional username for [sasl](/packages/sasl)
   - `password` `<string>` Optional password for [sasl](/packages/sasl)
+  - `timeout` `<number` Number of miliseconds to wait before timing out (default is `2000`)
 
 Returns an [xmpp](#xmpp) object.
 

packages/component/README.md

@@ -70,6 +70,7 @@ See [jid package](/packages/jid)
   - `service` `<string>` The service to connect to, accepts an URI. eg. `xmpp://localhost:5347`
   - `domain` `<string>` Domain of the component. eg. `component.localhost`
   - `password` `<string>` Password to use to authenticate with the service.
+  - `timeout` `<number` Number of miliseconds to wait before timing out (default is `2000`)
 
 Returns an [xmpp](#xmpp) object.
 

packages/connection/index.js

@@ -13,8 +13,13 @@ class Connection extends EventEmitter {
 
   constructor(options = {}) {
     super();
+
+    if (typeof options === "string") {
+      options = { domain: options };
+    }
+
     this.jid = null;
-    this.timeout = 2000;
+    this.timeout = options.timeout || 2000;
     this.options = options;
     this.status = "offline";
     this.socket = null;
@@ -251,11 +256,7 @@ class Connection extends EventEmitter {
   async open(options) {
     this._status("opening");
 
-    if (typeof options === "string") {
-      options = { domain: options };
-    }
-
-    const { domain, lang, timeout = this.timeout } = options;
+    const { domain, lang } = options;
 
     const headerElement = this.headerElement();
     headerElement.attrs.to = domain;
@@ -265,7 +266,7 @@ class Connection extends EventEmitter {
     this._attachParser(new this.Parser());
 
     await this.write(this.header(headerElement));
-    return promise(this, "open", "error", timeout);
+    return promise(this, "open", "error", this.timeout);
   }
 
   /**

packages/connection/test/test.js

@@ -9,6 +9,20 @@ test("new Connection()", () => {
   expect(conn instanceof EventEmitter).toBe(true);
 });
 
+test("new Connection() with custom timeout", () => {
+  const conn = new Connection({timeout:1234});
+  expect(conn.jid).toBe(null);
+  expect(conn.timeout).toBe(1234);
+  expect(conn instanceof EventEmitter).toBe(true);
+});
+
+test("new Connection() with unexpected input", () => {
+  const conn = new Connection(1234);
+  expect(conn.jid).toBe(null);
+  expect(conn.timeout).toBe(2000);
+  expect(conn instanceof EventEmitter).toBe(true);
+});
+
 test("isStanza()", () => {
   const conn = new Connection();