Moved protocol under opts merge

mqttjs · Jan 31, 2025 · ea15651 · ea15651
1 parent ad78551
commit ea15651
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/lib/connect/index.ts b/src/lib/connect/index.ts
@@ -72,17 +72,17 @@ function connect(
 		parsedOptions.protocol = parsedUrl.protocol as MqttProtocol
 		parsedOptions.path = parsedUrl.path
 
-		parsedOptions.protocol = parsedOptions.protocol?.replace(
-			/:$/,
-			'',
-		) as MqttProtocol
-
 		opts = { ...parsedOptions, ...opts }
 
 		// when parsing an url expect the protocol to be set
 		if (!opts.protocol) {
 			throw new Error('Missing protocol')
 		}
+
+    opts.protocol = opts.protocol.replace(
+      /:$/,
+      '',
+    ) as MqttProtocol
 	}
 
 	opts.unixSocket = opts.unixSocket || opts.protocol?.includes('+unix')