Strangler fig (#6)

* Support guide CAMS

* Support guide config for different senders

* app service environment variable for email request service

* Spring Cloud Stream to send messages to Azure Service Bus

* send email request from CAMS

* Process email response in CAMS

* documentation

Author: nickdala

.vscode/launch.json

@@ -28,7 +28,8 @@
                 "AZURE_ACTIVE_DIRECTORY_CREDENTIAL_TENANT_ID": "",
                 "AZURE_SERVICEBUS_NAMESPACE": "",
                 "AZURE_SERVICEBUS_EMAIL_REQUEST_QUEUE_NAME": "",
-                "AZURE_SERVICEBUS_EMAIL_RESPONSE_QUEUE_NAME": ""
+                "AZURE_SERVICEBUS_EMAIL_RESPONSE_QUEUE_NAME": "",
+                "CONTOSO_SUPPORT_GUIDE_REQUEST_SERVICE": ""
             }
         },
         {

README.md

@@ -49,12 +49,6 @@ The environment name should be less than 18 characters and must be comprised of
 azd env new <pick_a_name>
 ```
 
-Enable the AZD Terraform provider:
-
-```shell
-azd config set alpha.terraform on
-```
-
 Select the subscription that will be used for the deployment:
 
 ```shell
@@ -67,6 +61,12 @@ Set the Azure region to be used:
 azd env set AZURE_LOCATION <pick_a_region>
 ```
 
+Optional: Set the App Registration Service management reference:
+
+```shell
+azd env set AZURE_SERVICE_MANAGEMENT_REFERENCE <service_management_reference>
+```
+
 ## Create the Azure resources and deploy the code
 
 Run the following command to create the Azure resources and deploy the code (about 15-minutes to complete):

apps/contoso-fiber/pom.xml

@@ -18,6 +18,10 @@
 	<description>Customer Account Management System</description>
 
 	<dependencies>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-stream</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-web</artifactId>
@@ -100,7 +104,6 @@
 		<dependency>
 			<groupId>com.fasterxml.jackson.core</groupId>
 			<artifactId>jackson-databind</artifactId>
-			<version>2.15.2</version>
 		</dependency>
 
 		<dependency>
@@ -123,11 +126,6 @@
             <artifactId>commons-lang3</artifactId>
         </dependency>
 
-		<dependency>
-            <groupId>com.azure</groupId>
-            <artifactId>azure-messaging-servicebus</artifactId>
-        </dependency>
-
 		<dependency>
 			<groupId>com.azure.spring</groupId>
 			<artifactId>spring-cloud-azure-stream-binder-servicebus</artifactId>
@@ -141,12 +139,6 @@
 
 	</dependencies>
 
-	<dependencyManagement>
-		<dependencies>
-
-		</dependencies>
-	</dependencyManagement>
-
 	<build>
 		<finalName>cams</finalName>
 		<plugins>

apps/contoso-fiber/src/main/java/com/contoso/cams/CamsApplication.java

@@ -18,6 +18,7 @@
 @SpringBootApplication
 @EnableCaching
 public class CamsApplication {
+
 	public static void main(String[] args) {
 		SpringApplication.run(CamsApplication.class, args);
 	}

apps/contoso-fiber/src/main/java/com/contoso/cams/config/SupportGuideSenderConfig.java

@@ -0,0 +1,40 @@
+package com.contoso.cams.config;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.cloud.stream.function.StreamBridge;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import com.contoso.cams.services.SupportGuideQueueLoadDemo;
+import com.contoso.cams.services.SuportGuideDeadLetterDemo;
+import com.contoso.cams.services.SupportGuideEmailSender;
+import com.contoso.cams.services.SupportGuideQueueSender;
+import com.contoso.cams.services.SupportGuideSender;
+
+@Configuration
+public class SupportGuideSenderConfig {
+
+    @Bean
+    @ConditionalOnProperty(prefix = "contoso.suport-guide.request", name = "service", havingValue = "queue")
+    SupportGuideSender supportGuideQueueSender(StreamBridge streamBridge) {
+        return new SupportGuideQueueSender(streamBridge);
+    }
+
+    @Bean
+    @ConditionalOnProperty(prefix = "contoso.suport-guide.request", name = "service", havingValue = "email")
+    SupportGuideSender supportGuideEmailSender() {
+        return new SupportGuideEmailSender();
+    }
+
+    @Bean
+    @ConditionalOnProperty(prefix = "contoso.suport-guide.request", name = "service", havingValue = "demo-load")
+    SupportGuideSender supportGuideQueueLoadDemo(StreamBridge streamBridge) {
+        return new SupportGuideQueueLoadDemo(streamBridge);
+    }
+
+    @Bean
+    @ConditionalOnProperty(prefix = "contoso.suport-guide.request", name = "service", havingValue = "demo-dead-letter")
+    SupportGuideSender suportGuideDeadLetterDemo(StreamBridge streamBridge) {
+        return new SuportGuideDeadLetterDemo(streamBridge);
+    }
+}

apps/contoso-fiber/src/main/java/com/contoso/cams/serviceplan/ServicePlanController.java

@@ -63,5 +63,4 @@ public String updateServicePlan(Model model, @ModelAttribute("servicePlan") Serv
             return "pages/plans/notfound";
         }
     }
-
 }

apps/contoso-fiber/src/main/java/com/contoso/cams/services/SuportGuideDeadLetterDemo.java

@@ -0,0 +1,28 @@
+package com.contoso.cams.services;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.stream.function.StreamBridge;
+
+public class SuportGuideDeadLetterDemo implements SupportGuideSender {
+
+    private static final Logger log = LoggerFactory.getLogger(SuportGuideDeadLetterDemo.class);
+    private static final String EMAIL_REQUEST_QUEUE = "produceemailrequest-out-0";
+
+    private final StreamBridge streamBridge;
+
+    public SuportGuideDeadLetterDemo(StreamBridge streamBridge) {
+        this.streamBridge = streamBridge;
+    }
+
+    @Override
+    public void send(String to, String guideUrl, Long requestId) {
+        final String bogusMessage = "This is a bogus message for request id " + requestId;
+
+        log.info("EmailRequest: {}", bogusMessage);
+
+        streamBridge.send(EMAIL_REQUEST_QUEUE, bogusMessage);
+
+        log.info("Message sent to the queue");
+    }
+}

apps/contoso-fiber/src/main/java/com/contoso/cams/services/SupportGuideEmailSender.java

@@ -0,0 +1,14 @@
+package com.contoso.cams.services;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class SupportGuideEmailSender implements SupportGuideSender {
+
+    private static final Logger log = LoggerFactory.getLogger(SupportGuideEmailSender.class);
+
+    @Override
+    public void send(String to, String guideUrl, Long requestId) {
+        log.info("Sending guide to {} with url {} by email for request id {}", to, guideUrl, requestId);
+    }
+}

apps/contoso-fiber/src/main/java/com/contoso/cams/services/SupportGuideQueueLoadDemo.java

@@ -0,0 +1,38 @@
+package com.contoso.cams.services;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.stream.function.StreamBridge;
+
+import com.contoso.cams.protobuf.email.v1.EmailRequest;
+
+public class SupportGuideQueueLoadDemo implements SupportGuideSender {
+
+    private static final Logger log = LoggerFactory.getLogger(SupportGuideQueueLoadDemo.class);
+    private static final String EMAIL_REQUEST_QUEUE = "produceemailrequest-out-0";
+
+    private final StreamBridge streamBridge;
+
+    public SupportGuideQueueLoadDemo(StreamBridge streamBridge) {
+        this.streamBridge = streamBridge;
+    }
+
+    @Override
+    public void send(String to, String guideUrl, Long requestId) {
+        EmailRequest emailRequest = EmailRequest.newBuilder()
+                .setRequestId(requestId)
+                .setEmailAddress(to)
+                .setUrlToManual(guideUrl)
+                .build();
+
+        log.info("EmailRequest: {}", emailRequest);
+
+        var message = emailRequest.toByteArray();
+
+        for (int i = 0; i < 1_000; i++) {
+            streamBridge.send(EMAIL_REQUEST_QUEUE, message);
+        }
+
+        log.info("Messages sent to the queue");
+    }
+}

apps/contoso-fiber/src/main/java/com/contoso/cams/services/SupportGuideQueueSender.java

@@ -0,0 +1,35 @@
+package com.contoso.cams.services;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.stream.function.StreamBridge;
+
+import com.contoso.cams.protobuf.email.v1.EmailRequest;
+
+public class SupportGuideQueueSender implements SupportGuideSender {
+
+    private static final Logger log = LoggerFactory.getLogger(SupportGuideQueueSender.class);
+    private static final String EMAIL_REQUEST_QUEUE = "produceemailrequest-out-0";
+
+    private final StreamBridge streamBridge;
+
+    public SupportGuideQueueSender(StreamBridge streamBridge) {
+        this.streamBridge = streamBridge;
+    }
+
+    @Override
+    public void send(String to, String guideUrl, Long requestId) {
+        EmailRequest emailRequest = EmailRequest.newBuilder()
+                .setRequestId(requestId)
+                .setEmailAddress(to)
+                .setUrlToManual(guideUrl)
+                .build();
+
+        log.info("EmailRequest: {}", emailRequest);
+
+        var message = emailRequest.toByteArray();
+        streamBridge.send(EMAIL_REQUEST_QUEUE, message);
+
+        log.info("Message sent to the queue");
+    }
+}