Update exception handling

Author: seriousme

lib/connect/index.js

@@ -58,6 +58,9 @@ function connect (brokerUrl, opts) {
   opts = opts || {}
 
   if (brokerUrl) {
+    if (opts.protocol === null) {
+      throw new Error('Missing protocol')
+    }
     var parsed = new URL(brokerUrl)
     // the URL object is a bit special, so copy individual
     // items to the opts object
@@ -68,10 +71,6 @@ function connect (brokerUrl, opts) {
     opts.username = parsed.username
     opts.password = parsed.password
     opts.searchParams = parsed.searchParams
-
-    if (opts.protocol === null) {
-      throw new Error('Missing protocol')
-    }
     opts.protocol = opts.protocol.replace(/:$/, '')
   }
 

test/mqtt.js

@@ -18,7 +18,7 @@ describe('mqtt', function () {
       (function () {
         var c = mqtt.connect('foo.bar.com')
         c.end()
-      }).should.throw('Missing protocol')
+      }).should.throw('Invalid URL: foo.bar.com')
     })
 
     it('should throw an error when called with no protocol specified - with options', function () {