T-39: add additional sink for reports

Author: whiskels

README.md

@@ -41,7 +41,7 @@ Then run docker-compose with environment variables
 ```console
 TELEGRAM_BOT_TOKEN=${YOUR_TOKEN} \                                     
 TELEGRAM_BOT_ADMIN=${YOUR_TELEGRAM_ID}  \
-SLACK_WEBHOOK=${SLACK_WEBHOOK} \
+WEBHOOK_URL=${WEBHOOK_URL} \
 docker-compose up
 ```
 
@@ -51,7 +51,7 @@ Adjust application-mock with report.parameters.schedule to send reports to slack
 Adjust SPRING_PROFILES_ACTIVE in docker-compose to "mock" and run docker-compose with your webhook
 
 ```console
-SLACK_WEBHOOK=${SLACK_WEBHOOK} \
+WEBHOOK_URL=${WEBHOOK_URL} \
 docker-compose up
 ```
 

docker-compose.yml

@@ -10,7 +10,7 @@ services:
       - db
     environment:
       - SPRING_PROFILES_ACTIVE=mock,telegram
-      - SLACK_WEBHOOK
+      - WEBHOOK_URL
       - TELEGRAM_BOT_ADMIN
       - TELEGRAM_BOT_TOKEN
       - SPRING_DATASOURCE_URL=jdbc:postgresql://db:5432/postgres
@@ -20,6 +20,8 @@ services:
   db:
     image: 'postgres:16.2'
     container_name: db
+    ports:
+      - "5432:5432"
     environment:
       - POSTGRES_USER=postgres
       - POSTGRES_PASSWORD=postgres

src/main/java/com/whiskels/notifier/App.java

@@ -2,6 +2,7 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.cloud.openfeign.EnableFeignClients;
 import org.springframework.context.annotation.Profile;
 import org.springframework.scheduling.annotation.EnableScheduling;
@@ -10,6 +11,7 @@
 @SpringBootApplication
 @EnableFeignClients
 @EnableScheduling
+@EnableConfigurationProperties
 public class App {
     public static void main(String[] args) {
         SpringApplication.run(App.class, args);

src/main/java/com/whiskels/notifier/infrastructure/config/clock/ClockConfiguration.java

@@ -6,13 +6,21 @@
 import org.springframework.context.annotation.Profile;
 
 import java.time.Clock;
+import java.time.Instant;
 import java.time.ZoneId;
 
 @Configuration
 @Profile("!test")
 class ClockConfiguration {
     @Bean
+    @Profile("!mock")
     Clock defaultClock(@Value("${common.timezone}") String timeZone) {
         return Clock.system(ZoneId.of(timeZone));
     }
+
+    @Bean
+    @Profile("mock")
+    Clock mockedClock() {
+        return Clock.fixed(Instant.parse("2025-01-01T10:15:30Z"), ZoneId.of("UTC"));
+    }
 }

src/main/java/com/whiskels/notifier/infrastructure/report/ReportExecutor.java

@@ -0,0 +1,8 @@
+package com.whiskels.notifier.infrastructure.report;
+
+import com.whiskels.notifier.reporting.ReportType;
+import com.whiskels.notifier.reporting.service.Report;
+
+public interface ReportExecutor {
+    void send(ReportType type, Report report);
+}

src/main/java/com/whiskels/notifier/infrastructure/slack/SlackClient.java renamed to src/main/java/com/whiskels/notifier/infrastructure/report/slack/SlackClient.java

@@ -1,4 +1,4 @@
-package com.whiskels.notifier.infrastructure.slack;
+package com.whiskels.notifier.infrastructure.report.slack;
 
 import com.slack.api.Slack;
 import com.slack.api.webhook.Payload;

src/main/java/com/whiskels/notifier/infrastructure/report/slack/SlackPayloadMapper.java

@@ -0,0 +1,33 @@
+package com.whiskels.notifier.infrastructure.report.slack;
+
+import com.slack.api.webhook.Payload;
+import com.whiskels.notifier.infrastructure.report.slack.builder.SlackPayloadBuilder;
+import com.whiskels.notifier.reporting.service.Report;
+import org.springframework.stereotype.Service;
+
+import static java.util.Objects.nonNull;
+
+@Service
+public class SlackPayloadMapper {
+    public Payload map(final Report report) {
+        var builder = SlackPayloadBuilder.builder()
+                .header(report.getHeader());
+        if (report.isNotifyChannel()) {
+            builder.notifyChannel();
+        }
+
+        if (nonNull(report.getBanner())) {
+            builder.header(report.getBanner());
+        }
+
+        report.getBody().forEach(block -> {
+            if (nonNull(block.mediaContentUrl())) {
+                builder.block(block.text(), block.mediaContentUrl());
+            } else {
+                builder.block(block.text());
+            }
+        });
+
+        return builder.build();
+    }
+}

src/main/java/com/whiskels/notifier/infrastructure/report/slack/SlackReportExecutor.java

@@ -0,0 +1,33 @@
+package com.whiskels.notifier.infrastructure.report.slack;
+
+import com.whiskels.notifier.infrastructure.report.ReportExecutor;
+import com.whiskels.notifier.reporting.ReportType;
+import com.whiskels.notifier.reporting.service.Report;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+import java.io.IOException;
+import java.util.Map;
+
+import static org.springframework.util.CollectionUtils.isEmpty;
+
+@Slf4j
+@AllArgsConstructor
+public class SlackReportExecutor implements ReportExecutor {
+    private final SlackClient slackClient;
+    private final SlackPayloadMapper slackPayloadMapper;
+    private final Map<ReportType, String> webhookMappings;
+
+    @Override
+    public void send(ReportType type, Report report) {
+        if (isEmpty(webhookMappings) || !webhookMappings.containsKey(type)) {
+            log.error("No webhook mapping for type {}", type);
+            return;
+        }
+        try {
+            slackClient.send(webhookMappings.get(type), slackPayloadMapper.map(report));
+        } catch (IOException e) {
+            throw new IllegalArgumentException(e);
+        }
+    }
+}

src/main/java/com/whiskels/notifier/infrastructure/slack/builder/AccessoryBlock.java renamed to src/main/java/com/whiskels/notifier/infrastructure/report/slack/builder/AccessoryBlock.java

@@ -1,4 +1,4 @@
-package com.whiskels.notifier.infrastructure.slack.builder;
+package com.whiskels.notifier.infrastructure.report.slack.builder;
 
 import com.slack.api.model.block.element.BlockElement;
 import lombok.Data;

src/main/java/com/whiskels/notifier/infrastructure/slack/builder/SlackPayloadBuilder.java renamed to src/main/java/com/whiskels/notifier/infrastructure/report/slack/builder/SlackPayloadBuilder.java

@@ -1,4 +1,4 @@
-package com.whiskels.notifier.infrastructure.slack.builder;
+package com.whiskels.notifier.infrastructure.report.slack.builder;
 
 import com.slack.api.model.block.HeaderBlock;
 import com.slack.api.model.block.LayoutBlock;
@@ -54,7 +54,7 @@ public SlackPayloadBuilder block(String text) {
         return this;
     }
 
-    public <T> SlackPayloadBuilder block(String text, String picUrl) {
+    public SlackPayloadBuilder block(String text, String picUrl) {
         MarkdownTextObject content = new MarkdownTextObject();
         content.setText(text);