chore: Configure publishmq in emulator for local dev & local publishmq helper

Author: alexluong

build/dev/azure/config.json

@@ -32,6 +32,15 @@
               }
             ]
           },
+          // publishmq
+          {
+            "Name": "outpost-publish",
+            "Subscriptions": [
+              {
+                "Name": "outpost-publish-sub"
+              }
+            ]
+          },
 
           // tests
           {

cmd/publish/declare_handler.go

@@ -10,6 +10,8 @@ func handleDeclare(w http.ResponseWriter, r *http.Request) {
 	switch r.URL.Query().Get("method") {
 	case "aws_sqs":
 		err = declareAWS()
+	case "azure_servicebus":
+		err = declareAzureServiceBus()
 	case "gcp_pubsub":
 		err = declareGCP()
 	case "rabbitmq":

cmd/publish/publish_azure.go

@@ -0,0 +1,58 @@
+package main
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"log"
+
+	"github.com/Azure/azure-sdk-for-go/sdk/messaging/azservicebus"
+)
+
+const (
+	AzureServiceBusConnectionString = "Endpoint=sb://localhost;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;"
+	AzureServiceBusTopic            = "outpost-publish"
+	AzureServiceBusSubscription     = "outpost-publish-sub"
+)
+
+func publishAzureServiceBus(body map[string]interface{}) error {
+	log.Printf("[x] Publishing Azure Service Bus")
+
+	ctx := context.Background()
+	client, err := azservicebus.NewClientFromConnectionString(AzureServiceBusConnectionString, nil)
+	if err != nil {
+		return fmt.Errorf("failed to create Azure Service Bus client: %w", err)
+	}
+	defer client.Close(ctx)
+
+	sender, err := client.NewSender(AzureServiceBusTopic, nil)
+	if err != nil {
+		return fmt.Errorf("failed to create sender: %w", err)
+	}
+	defer sender.Close(ctx)
+
+	messageBody, err := json.Marshal(body)
+	if err != nil {
+		return err
+	}
+
+	message := &azservicebus.Message{
+		Body: messageBody,
+		ApplicationProperties: map[string]interface{}{
+			"source": "outpost-publish",
+		},
+	}
+
+	err = sender.SendMessage(ctx, message, nil)
+	if err != nil {
+		return fmt.Errorf("failed to send message: %w", err)
+	}
+
+	log.Printf("[x] Published message to Azure Service Bus topic %s", AzureServiceBusTopic)
+	return nil
+}
+
+func declareAzureServiceBus() error {
+	log.Printf("[*] Declaring Azure Service Bus Publish infra")
+	return fmt.Errorf("azure sb emulator does not support declaring topics and subscriptions. Use `%s` and `%s` for the publishmq topic and subscription", AzureServiceBusTopic, AzureServiceBusSubscription)
+}

cmd/publish/publish_handler.go

@@ -17,6 +17,8 @@ func handlePublish(w http.ResponseWriter, r *http.Request) {
 	switch r.URL.Query().Get("method") {
 	case "aws_sqs":
 		err = publishAWS(body)
+	case "azure_servicebus":
+		err = publishAzureServiceBus(body)
 	case "gcp_pubsub":
 		err = publishGCP(body)
 	case "rabbitmq":