From ea1565129dbe66cd3b1493fc0dbb82932165a011 Mon Sep 17 00:00:00 2001
From: mmoriani <mmoriani95@gmail.com>
Date: Fri, 31 Jan 2025 20:46:42 +0100
Subject: [PATCH] Moved protocol under opts merge

---
 src/lib/connect/index.ts | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/lib/connect/index.ts b/src/lib/connect/index.ts
index a25863f78..ef8bef0ed 100644
--- 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')