moving publish action into a lambda

src/main/java/gov/cabinetoffice/gap/adminbackend/config/OpenSearchConfig.java → src/main/java/gov/cabinetoffice/gap/adminbackend/config/OpenSearchSqsProperties.java

@@ -11,11 +11,8 @@
 @Builder
 @AllArgsConstructor
 @NoArgsConstructor
-@Configuration
-@ConfigurationProperties(prefix = "open-search")
-public class OpenSearchConfig {
-        private String url;
-        private String domain;
-        private String username;
-        private String password;
+@Configuration("openSearchSqsProperties")
+@ConfigurationProperties(prefix = "open-search-sqs")
+public class OpenSearchSqsProperties {
+    private String queueUrl;
 }

src/main/java/gov/cabinetoffice/gap/adminbackend/dtos/SendAdvertToSqsDto.java

@@ -0,0 +1,4 @@
+package gov.cabinetoffice.gap.adminbackend.dtos;
+
+public record SendAdvertToSqsDto(String contentfulEntryId, String type) {
+}

src/main/java/gov/cabinetoffice/gap/adminbackend/services/GrantAdvertService.java

@@ -1,14 +1,19 @@
 package gov.cabinetoffice.gap.adminbackend.services;
 
+import com.amazonaws.services.sqs.AmazonSQS;
+import com.amazonaws.services.sqs.model.SendMessageRequest;
 import com.contentful.java.cda.CDAArray;
 import com.contentful.java.cda.CDAClient;
 import com.contentful.java.cda.CDAEntry;
 import com.contentful.java.cda.QueryOperation;
 import com.contentful.java.cma.CMAClient;
 import com.contentful.java.cma.model.CMAEntry;
 import com.contentful.java.cma.model.rich.CMARichDocument;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import gov.cabinetoffice.gap.adminbackend.config.ContentfulConfigProperties;
 import gov.cabinetoffice.gap.adminbackend.config.FeatureFlagsConfigurationProperties;
+import gov.cabinetoffice.gap.adminbackend.config.OpenSearchSqsProperties;
+import gov.cabinetoffice.gap.adminbackend.dtos.SendAdvertToSqsDto;
 import gov.cabinetoffice.gap.adminbackend.dtos.grantadvert.GetGrantAdvertPageResponseDTO;
 import gov.cabinetoffice.gap.adminbackend.dtos.grantadvert.GetGrantAdvertPublishingInformationResponseDTO;
 import gov.cabinetoffice.gap.adminbackend.dtos.grantadvert.GetGrantAdvertStatusResponseDTO;
@@ -62,14 +67,15 @@ public class GrantAdvertService {
     private final CMAClient contentfulManagementClient;
     private final CDAClient contentfulDeliveryClient;
     private final UserService userService;
-    private final OpenSearchService openSearchService;
     private final WebClient.Builder webClientBuilder;
-
-    private final WebClient webClient;
+    private final AmazonSQS amazonSqs;
+    private final ObjectMapper mapper;
     private final Clock clock;
     private final ContentfulConfigProperties contentfulProperties;
     private final FeatureFlagsConfigurationProperties featureFlagsProperties;
 
+    private final OpenSearchSqsProperties openSearchSqsProperties;
+
     public GrantAdvert save(GrantAdvert advert) {
         final Authentication auth = SecurityContextHolder.getContext().getAuthentication();
         Optional.ofNullable(auth)
@@ -320,7 +326,7 @@ public GrantAdvert publishAdvert(UUID advertId) {
 
         if (Boolean.FALSE.equals(contentfulAdvert.isPublished())) {
             final CMAEntry publishedAdvert = contentfulManagementClient.entries().publish(contentfulAdvert);
-            openSearchService.indexEntry(publishedAdvert);
+            sendMessageToQueue(new SendAdvertToSqsDto(publishedAdvert.getId(), "ADD"));
         }
 
         updateGrantAdvertApplicationDates(advert);
@@ -333,7 +339,7 @@ public void unpublishAdvert(UUID advertId) {
 
         if (Boolean.TRUE.equals(contentfulAdvert.isPublished())) {
             final CMAEntry unpublishedAd = contentfulManagementClient.entries().unPublish(contentfulAdvert);
-            openSearchService.removeIndexEntry(unpublishedAd);
+            sendMessageToQueue(new SendAdvertToSqsDto(unpublishedAd.getId(), "REMOVE"));
         }
 
         advert.setStatus(GrantAdvertStatus.DRAFT);
@@ -343,6 +349,19 @@ public void unpublishAdvert(UUID advertId) {
         save(advert);
     }
 
+    public void sendMessageToQueue(final SendAdvertToSqsDto advertDto) {
+        final UUID messageId = UUID.randomUUID();
+        final String messageBody = mapper.valueToTree(advertDto).toString();
+        final SendMessageRequest messageRequest = new SendMessageRequest()
+                .withQueueUrl(openSearchSqsProperties.getQueueUrl())
+                .withMessageGroupId(messageId.toString())
+                .withMessageBody(messageBody)
+                .withMessageDeduplicationId(messageId.toString());
+
+        amazonSqs.sendMessage(messageRequest);
+        log.info("Message sent to queue for advert with contentful ID {}");
+    }
+
     private CMAEntry createAdvertInContentful(final GrantAdvert grantAdvert) {
         final CMAEntry contentfulAdvert = new CMAEntry();
 
@@ -438,7 +457,8 @@ private void createRichTextQuestionsInContentful(final GrantAdvert advert, final
         }
 
         final Instant now = Instant.now();
-        webClient.patch()
+        webClientBuilder.build()
+                .patch()
                 .uri(contentfulUrl)
                 .headers(h -> {
                     h.set("Authorization", String.format("Bearer %s", contentfulProperties.getAccessToken()));

src/main/resources/application.properties

@@ -78,7 +78,4 @@ aws.kms.stage=stage
 
 spring.jpa.properties.hibernate.order_by.default_null_ordering=last
 
-open-search.url=https://search-url
-open-search.domain=domain
-open-search.username=username
-open-search.password=password
+open-search-sqs.queueUrl=an-sqs-url