added mailtrap.io configs

Author: nipun-das

.idea/uiDesigner.xml

@@ -38,7 +38,10 @@
 			<groupId>org.springframework.kafka</groupId>
 			<artifactId>spring-kafka</artifactId>
 		</dependency>
-
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

notification-service/pom.xml

@@ -0,0 +1,11 @@
+//{
+//  "type": "record",
+//  "name": "OrderPlacedEvent",
+//  "namespace": "com.nipundas.order.event",
+//  "fields": [
+//    { "name": "orderNumber", "type": "string" },
+//    { "name": "email", "type": "string" },
+//    { "name": "firstName", "type": "string" },
+//    { "name": "lastName", "type": "string" }
+//  ]
+//}

notification-service/src/main/java/com/nipundas/notification_service/avro.order-placed.avsc

@@ -0,0 +1,54 @@
+package com.nipundas.notification_service.notification.service;
+
+
+
+import com.nipundas.notification_service.order.event.OrderPlacedEvent;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.kafka.annotation.KafkaListener;
+import org.springframework.mail.MailException;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.mail.javamail.MimeMessageHelper;
+import org.springframework.mail.javamail.MimeMessagePreparator;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class NotificationService {
+
+    private final JavaMailSender javaMailSender;
+
+    @KafkaListener(topics="order-placed")
+    public void listen(OrderPlacedEvent orderPlacedEvent){
+        log.info("Got message from order-placed kafkaTopic ",orderPlacedEvent);
+
+        //sending mail
+
+        MimeMessagePreparator messagePreparator = mimeMessage -> {
+            MimeMessageHelper messageHelper = new MimeMessageHelper(mimeMessage);
+            messageHelper.setFrom("productshop@email.com");
+            messageHelper.setTo(orderPlacedEvent.getEmail().toString());
+            messageHelper.setSubject(String.format("Your Order with OrderNumber %s is placed successfully",
+                    orderPlacedEvent.getOrderNumber()));
+
+            messageHelper.setText(String.format("""
+                            Hi,
+                            Your order with order number %s is now placed successfully.
+
+                            Best Regards
+                            Product Shop
+                            """,
+//                    orderPlacedEvent.getFirstName().toString(),
+//                    orderPlacedEvent.getLastName().toString(),
+                    orderPlacedEvent.getOrderNumber()));
+        };
+        try {
+            javaMailSender.send(messagePreparator);
+            log.info("Order Notification email sent!!");
+        } catch (MailException e) {
+            log.error("Exception occurred when sending mail", e);
+            throw new RuntimeException("Exception occurred when sending mail to springshop@email.com", e);
+        }
+    }
+}

notification-service/src/main/java/com/nipundas/notification_service/notification/service/NotificationService.java

@@ -1,4 +1,4 @@
-package com.nipundas.notification_service.order;
+package com.nipundas.notification_service.order.event;
 
 import lombok.AllArgsConstructor;
 import lombok.Data;

notification-service/src/main/java/com/nipundas/notification_service/order/OrderPlacedEvent.java renamed to notification-service/src/main/java/com/nipundas/notification_service/order/event/OrderPlacedEvent.java

@@ -1,10 +1,19 @@
 spring.application.name=notification-service
+server.port=8087
 
 # Kafka Consumer Properties
-spring.kafka.bootstrap-servers=localhost:9200
+spring.kafka.bootstrap-servers=localhost:9092
 spring.kafka.consumer.group-id=notification-service
 spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
-spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonSerializer
-spring.kafka.consumer.properties.schema.registry.url=http://127.0.0.1:8085
-spring.kafka.consumer.properties.specific.avro.reader=true
+spring.kafka.consumer.value-deserializer=org.springframework.kafka.support.serializer.JsonDeserializer
+#spring.kafka.consumer.properties.spring.json.type.mapping=event:com.nipundas.notification_service.order.event.OrderPlacedEvent
 
+#spring.kafka.consumer.properties.schema.registry.url=http://127.0.0.1:8085
+#spring.kafka.consumer.properties.specific.avro.reader=true
+
+# Mail Properties
+spring.mail.host=sandbox.smtp.mailtrap.io
+spring.mail.port=2525
+spring.mail.username=1ee0dd5771d659
+spring.mail.password=4f9eb34bacafd3
+#spring.mail.protocol=smtp

notification-service/src/main/java/com/nipundas/notification_service/service/NotificationService.java

@@ -3,4 +3,4 @@ WiredTiger 11.2.0: (November 10, 2022)
 WiredTiger version
 major=11,minor=2,patch=0
 file:WiredTiger.wt
-access_pattern_hint=none,allocation_size=4KB,app_metadata=,assert=(commit_timestamp=none,durable_timestamp=none,read_timestamp=none,write_timestamp=off),block_allocation=best,block_compressor=,cache_resident=false,checksum=on,collator=,columns=,dictionary=0,encryption=(keyid=,name=),format=btree,huffman_key=,huffman_value=,id=0,ignore_in_memory_cache_size=false,internal_item_max=0,internal_key_max=0,internal_key_truncate=true,internal_page_max=4KB,key_format=S,key_gap=10,leaf_item_max=0,leaf_key_max=0,leaf_page_max=32KB,leaf_value_max=0,log=(enabled=true),memory_page_image_max=0,memory_page_max=5MB,os_cache_dirty_max=0,os_cache_max=0,prefix_compression=false,prefix_compression_min=4,readonly=false,split_deepen_min_child=0,split_deepen_per_child=0,split_pct=90,tiered_object=false,tiered_storage=(auth_token=,bucket=,bucket_prefix=,cache_directory=,local_retention=300,name=,object_target_size=0),value_format=S,verbose=[],version=(major=1,minor=1),write_timestamp_usage=none,checkpoint=(WiredTigerCheckpoint.7404=(addr="018f81e4a486e6ea9081e431d46b5c9181e47128be4b808080e3010fc0e23fc0",order=7404,time=1724514517,size=28672,newest_start_durable_ts=0,oldest_start_ts=0,newest_txn=17,newest_stop_durable_ts=0,newest_stop_ts=-1,newest_stop_txn=-11,prepare=0,write_gen=22208,run_write_gen=22173)),checkpoint_backup_info=,checkpoint_lsn=(9,12672)
+access_pattern_hint=none,allocation_size=4KB,app_metadata=,assert=(commit_timestamp=none,durable_timestamp=none,read_timestamp=none,write_timestamp=off),block_allocation=best,block_compressor=,cache_resident=false,checksum=on,collator=,columns=,dictionary=0,encryption=(keyid=,name=),format=btree,huffman_key=,huffman_value=,id=0,ignore_in_memory_cache_size=false,internal_item_max=0,internal_key_max=0,internal_key_truncate=true,internal_page_max=4KB,key_format=S,key_gap=10,leaf_item_max=0,leaf_key_max=0,leaf_page_max=32KB,leaf_value_max=0,log=(enabled=true),memory_page_image_max=0,memory_page_max=5MB,os_cache_dirty_max=0,os_cache_max=0,prefix_compression=false,prefix_compression_min=4,readonly=false,split_deepen_min_child=0,split_deepen_per_child=0,split_pct=90,tiered_object=false,tiered_storage=(auth_token=,bucket=,bucket_prefix=,cache_directory=,local_retention=300,name=,object_target_size=0),value_format=S,verbose=[],version=(major=1,minor=1),write_timestamp_usage=none,checkpoint=(WiredTigerCheckpoint.7458=(addr="018f81e45428989d9081e431d46b5c9181e478a6625d808080e3010fc0e23fc0",order=7458,time=1724517761,size=28672,newest_start_durable_ts=0,oldest_start_ts=0,newest_txn=71,newest_stop_durable_ts=0,newest_stop_ts=-1,newest_stop_txn=-11,prepare=0,write_gen=22370,run_write_gen=22173)),checkpoint_backup_info=,checkpoint_lsn=(9,54144)