ObjectBlockService.java

package clap.server.adapter.outbound.api;

import clap.server.adapter.outbound.api.dto.SendWebhookRequest;
import clap.server.adapter.outbound.persistense.repository.notification.NotificationRepository;
import clap.server.application.port.outbound.webhook.MakeObjectBlockPort;
import clap.server.common.annotation.architecture.PersistenceAdapter;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.RequiredArgsConstructor;

import java.util.Map;

@PersistenceAdapter
@RequiredArgsConstructor
public class ObjectBlockService implements MakeObjectBlockPort {

    private final ObjectMapper objectMapper;
    private final NotificationRepository notificationRepository;

    @Override
    public String makeTaskRequestBlock(SendWebhookRequest request) {
        // Blocks 데이터 생성
        Object[] blocks = new Object[]{
                // Header 블록
                Map.of(
                        "type", "header",
                        "text", "TaskFlow 작업 요청 알림",
                        "style", "blue"
                ),
                // Text 블록 1
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 작업 요청 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", "새로운 작업이 요청되었습니다.",
                                        "bold", true
                                )
                        }
                ),
                // Text 블록 2: 제목 변수 사용
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 작업 요청 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - Task 제목 : " + request.taskName(),
                                        "bold", false
                                )
                        }
                ),
                // Text 블록 3: 요청자 변수 사용
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 작업 요청 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - 요청자 : " + request.senderName(),
                                        "bold", false
                                )
                        }
                ),
                // Button 블록
                Map.of(
                        "type", "button",
                        "text", "확인하기",
                        "style", "default",
                        "action", Map.of(
                                "type", "open_system_browser",
                                "name", "button1",
                                "value", "http://example.com/details/999"
                        )
                )
        };

        String payload;
        try {
            payload = "{" +
                    "\"email\":\"" + request.email() + "\"," +
                    "\"text\": \"신규 작업 요청 알림\"," + // fallback 메시지
                    "\"blocks\":" + objectMapper.writeValueAsString(blocks) +
                    "}";
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }

        return payload;
    }

    @Override
    public String makeNewProcessorBlock(SendWebhookRequest request) {
        Object[] blocks = new Object[]{
                Map.of(
                        "type", "header",
                        "text", "TaskFlow 알림 서비스",
                        "style", "blue"
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 담당자 선정 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", "TaskFlow 담당자 선정 알림",
                                        "bold", true
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 담당자 선정 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - Task 제목 : " + request.taskName(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 담당자 선정 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - 담당자 : " + request.message(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "button",
                        "text", "확인하기",
                        "style", "default",
                        "action", Map.of(
                                "type", "open_system_browser",
                                "name", "button1",
                                "value", "http://example.com/details/999"
                        )
                )
        };

        String payload;
        try {
            payload = "{" +
                        "\"email\":\"" + request.email() + "\"," +
                        "\"text\":\"작업 담당자 선정 알림\"," + // fallback 메시지
                        "\"blocks\":" + objectMapper.writeValueAsString(blocks) +
                        "}";
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }

        return payload;
    }

    @Override
    public String makeProcessorChangeBlock(SendWebhookRequest request) {
        Object[] blocks = new Object[]{
                Map.of(
                        "type", "header",
                        "text", "TaskFlow 알림 서비스",
                        "style", "blue"
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 담당자 변경 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", "TaskFlow 담당자 변경 알림",
                                        "bold", true
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 담당자 변경 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - Task 제목 : " + request.taskName(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 담당자 변경 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - 담당자 : " + request.message(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "button",
                        "text", "확인하기",
                        "style", "default",
                        "action", Map.of(
                                "type", "open_system_browser",
                                "name", "button1",
                                "value", "http://example.com/details/999"
                        )
                )
        };

        String payload;
        try {
            payload = "{" +
                    "\"email\":\"" + request.email() + "\"," +
                    "\"text\":\"작업 담당자 변경 알림\"," + // fallback 메시지
                    "\"blocks\":" + objectMapper.writeValueAsString(blocks) +
                    "}";
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }


        return payload;
    }

    @Override
    public String makeCommentBlock(SendWebhookRequest request) {
        Object[] blocks = new Object[]{
                Map.of(
                        "type", "header",
                        "text", "TaskFlow 알림 서비스",
                        "style", "blue"
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 댓글 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", "TaskFlow 댓글 알림",
                                        "bold", true
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 댓글 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - Task Title : " + request.taskName(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 댓글 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - 작성자 : " + request.commenterName(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 댓글 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - 내용 : " + request.message(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "button",
                        "text", "확인하기",
                        "style", "default",
                        "action", Map.of(
                                "type", "open_system_browser",
                                "name", "button1",
                                "value", "http://example.com/details/999"
                        )
                )
        };

        String payload;
        try {
            payload = "{" +
                    "\"email\":\"" + request.email() + "\"," +
                    "\"text\":\"댓글 알림\"," + // fallback 메시지
                    "\"blocks\":" + objectMapper.writeValueAsString(blocks) +
                    "}";
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }

        return payload;
    }

    @Override
    public String makeTaskStatusBlock(SendWebhookRequest request) {
        Object[] blocks = new Object[]{
                Map.of(
                        "type", "header",
                        "text", "TaskFlow 알림 서비스",
                        "style", "blue"
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 작업 상태 변경 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", "TaskFlow 작업 상태 변경 알림",
                                        "bold", true
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 상태 변경 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - Task Title : " + request.taskName(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "text",
                        "text", "TaskFlow 작업 상태 변경 알림",
                        "inlines", new Object[]{
                                Map.of(
                                        "type", "styled",
                                        "text", " - 상태 : " + request.message(),
                                        "bold", false
                                )
                        }
                ),
                Map.of(
                        "type", "button",
                        "text", "확인하기",
                        "style", "default",
                        "action", Map.of(
                                "type", "open_system_browser",
                                "name", "button1",
                                "value", "http://example.com/details/999"
                        )
                )
        };

        String payload;
        try {
            payload = "{" +
                    "\"email\":\"" + request.email() + "\"," +
                    "\"text\":\"작업 상태 변경 알림\"," + // fallback 메시지
                    "\"blocks\":" + objectMapper.writeValueAsString(blocks) +
                    "}";
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }

        return payload;
    }
}