fix: Helper functions for Service Bus namespace ingredient (#64)

ingredient/ingredient-service-bus-namespace/package.json

@@ -34,7 +34,8 @@
     "@types/node": "^10.12.18"
   },
   "dependencies": {
-    "@azbake/arm-helper": "^0.1.47"
+    "@azbake/arm-helper": "^0.1.47",
+    "@azure/arm-servicebus": "^3.2.0"
   },
   "publishConfig": {
     "access": "public"

ingredient/ingredient-service-bus-namespace/src/functions.ts

@@ -1,10 +1,72 @@
 import {BaseUtility, IngredientManager} from '@azbake/core'
+import { ServiceBusManagementClient } from "@azure/arm-servicebus";
 
 export class ServiceBusNamespaceUtils extends BaseUtility {
 
     public create_resource_name(): string {
-        let util = IngredientManager.getIngredientFunction("coreutils", this.context)
+        let util = IngredientManager.getIngredientFunction("coreutils", this.context);
         const name = util.create_resource_name("sbn", null, false);
         return name;
     }
+
+    public async get_endpoint(nsName: string, rg: string | null = null): Promise<string> {
+
+        let util = IngredientManager.getIngredientFunction("coreutils", this.context);
+        let resource_group = rg || await util.resource_group();
+
+        const client = new ServiceBusManagementClient(this.context.AuthToken, this.context.Environment.authentication.subscriptionId);
+
+        let response = await client.namespaces.get(resource_group, nsName);
+        // client.namespaces.listKeys(resource_group,)
+
+        return response.serviceBusEndpoint || "";
+    }
+
+    public async get_primary_key(nsName: string, authRuleName: string, rg: string | null = null) : Promise<string> {
+
+        let util = IngredientManager.getIngredientFunction("coreutils", this.context);
+        let resource_group = rg || await util.resource_group();
+
+        const client = new ServiceBusManagementClient(this.context.AuthToken, this.context.Environment.authentication.subscriptionId);
+
+        let response = await client.namespaces.listKeys(resource_group, nsName, authRuleName);
+
+        return response.primaryKey || "";
+    }
+
+    public async get_secondary_key(nsName: string, authRuleName: string, rg: string | null = null) : Promise<string> {
+
+        let util = IngredientManager.getIngredientFunction("coreutils", this.context);
+        let resource_group = rg || await util.resource_group();
+
+        const client = new ServiceBusManagementClient(this.context.AuthToken, this.context.Environment.authentication.subscriptionId);
+
+        let response = await client.namespaces.listKeys(resource_group, nsName, authRuleName);
+
+        return response.secondaryKey || "";
+    }
+
+    public async get_primary_connection_string(nsName: string, authRuleName: string, rg: string | null = null) : Promise<string> {
+
+        let util = IngredientManager.getIngredientFunction("coreutils", this.context);
+        let resource_group = rg || await util.resource_group();
+
+        const client = new ServiceBusManagementClient(this.context.AuthToken, this.context.Environment.authentication.subscriptionId);
+
+        let response = await client.namespaces.listKeys(resource_group, nsName, authRuleName);
+
+        return response.primaryConnectionString || "";
+    }
+
+    public async get_secondary_connection_string(nsName: string, authRuleName: string, rg: string | null = null) : Promise<string> {
+
+        let util = IngredientManager.getIngredientFunction("coreutils", this.context);
+        let resource_group = rg || await util.resource_group();
+
+        const client = new ServiceBusManagementClient(this.context.AuthToken, this.context.Environment.authentication.subscriptionId);
+
+        let response = await client.namespaces.listKeys(resource_group, nsName, authRuleName);
+
+        return response.secondaryConnectionString || "";
+    }
 }