fix customEndpointAddress parsing in browsers

sdk/eventhub/event-hubs/package.json

@@ -29,8 +29,7 @@
     }
   },
   "browser": {
-    "./dist-esm/src/util/runtimeInfo.js": "./dist-esm/src/util/runtimeInfo.browser.js",
-    "./dist-esm/src/util/url.js": "./dist-esm/src/util/url.browser.js"
+    "./dist-esm/src/util/runtimeInfo.js": "./dist-esm/src/util/runtimeInfo.browser.js"
   },
   "engine": {
     "node": ">=8.0.0"

sdk/eventhub/event-hubs/src/eventhubConnectionConfig.ts

@@ -3,7 +3,7 @@
 /* eslint-disable eqeqeq */
 
 import { ConnectionConfig } from "@azure/core-amqp";
-import { URL } from "./util/url";
+import { parseEndpoint } from "./util/parseEndpoint";
 
 /**
  * Describes the connection config object that is created after parsing an EventHub connection
@@ -153,7 +153,7 @@ export const EventHubConnectionConfig = {
   setCustomEndpointAddress(config: EventHubConnectionConfig, customEndpointAddress: string): void {
     // The amqpHostname should match the host prior to using the custom endpoint.
     config.amqpHostname = config.host;
-    const { hostname, port } = new URL(customEndpointAddress);
+    const { hostname, port } = parseEndpoint(customEndpointAddress);
     // Since we specify the port separately, set host to the customEndpointAddress hostname.
     config.host = hostname;
     if (port) {

sdk/eventhub/event-hubs/src/util/parseEndpoint.ts

@@ -0,0 +1,20 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT license.
+
+/**
+ * Parses the host, hostname, and port from an endpoint.
+ * @param endpoint And endpoint to parse.
+ * @hidden
+ * @internal
+ */
+export function parseEndpoint(endpoint: string): { host: string; hostname: string; port?: string } {
+  const hostMatch = endpoint.match(/.*:\/\/([^\/]*)/i);
+  if (!hostMatch) {
+    throw new TypeError(`Invalid endpoint missing host: ${endpoint}`);
+  }
+
+  const [, host] = hostMatch;
+  const [hostname, port] = host.split(":");
+
+  return { host, hostname, port };
+}

sdk/eventhub/event-hubs/test/impl/parseEndpoint.spec.ts

@@ -0,0 +1,40 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT license.
+
+import { parseEndpoint } from "../../src/util/parseEndpoint";
+import chai from "chai";
+const should = chai.should();
+
+describe("parseEndpoint", () => {
+  it("throws an error for invalid inputs", () => {
+    should.throw(() => parseEndpoint(""), /Invalid endpoint/);
+    should.throw(() => parseEndpoint("missing-protocol"), /Invalid endpoint/);
+    should.throw(() => parseEndpoint("//missing-protocol"), /Invalid endpoint/);
+  });
+
+  it("extracts host, hostname, and port", () => {
+    parseEndpoint("sb://test.servicebus.windows.net:5671").should.eql({
+      host: "test.servicebus.windows.net:5671",
+      hostname: "test.servicebus.windows.net",
+      port: "5671"
+    } as ReturnType<typeof parseEndpoint>);
+
+    parseEndpoint("https://127.0.0.1:5671").should.eql({
+      host: "127.0.0.1:5671",
+      hostname: "127.0.0.1",
+      port: "5671"
+    } as ReturnType<typeof parseEndpoint>);
+
+    parseEndpoint("amqps://127.0.0.1:5671/path/?query=foo").should.eql({
+      host: "127.0.0.1:5671",
+      hostname: "127.0.0.1",
+      port: "5671"
+    } as ReturnType<typeof parseEndpoint>);
+
+    parseEndpoint("wss://127.0.0.1/path/?query=foo").should.eql({
+      host: "127.0.0.1",
+      hostname: "127.0.0.1",
+      port: undefined
+    } as ReturnType<typeof parseEndpoint>);
+  });
+});