package kr.itn.itnhub.provision;

import kr.itn.itnhub.AbstractDbTest;
import kr.itn.itnhub.mattermost.MattermostClient;
import kr.itn.itnhub.mattermost.MattermostException;
import kr.itn.itnhub.org.OrgStatus;
import kr.itn.itnhub.org.Organization;
import kr.itn.itnhub.org.OrganizationMapper;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.mock.mockito.MockBean;
import org.springframework.jdbc.core.JdbcTemplate;

import java.util.Optional;

import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.when;

class ChannelProvisionServiceTest extends AbstractDbTest {

    @Autowired
    ChannelProvisionService service;

    @Autowired
    OrganizationMapper mapper;

    @Autowired
    JdbcTemplate jdbc;

    @MockBean
    MattermostClient mattermost;

    private Long orgId;

    @BeforeEach
    void setUp() {
        jdbc.update("delete from organization");

        Organization org = new Organization();
        org.setOrgNo("001");
        org.setOrgName("국제방송교류재단");
        org.setChannelSlug("001");
        org.setDeptName("데이터정보화팀");
        org.setManagerName("송민지");
        org.setManagerPhone("02-3475-5434");
        org.setManagerEmail("ming@arirang.com");
        mapper.upsertBySeed(org);

        orgId = mapper.findAll().get(0).getId();
    }

    @Test
    void 채널이_없으면_두_개를_생성하고_ID를_저장한다() {
        when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
        when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
        when(mattermost.createPrivateChannel("org-001-mj", "001_국제방송교류재단 (문정원)"))
                .thenReturn("id-mj");
        when(mattermost.createPrivateChannel("org-001-law", "001_국제방송교류재단 (법률검토)"))
                .thenReturn("id-law");

        ProvisionResult result = service.provision(orgId);

        assertThat(result.mj()).isEqualTo(ProvisionOutcome.CREATED);
        assertThat(result.law()).isEqualTo(ProvisionOutcome.CREATED);

        Organization after = mapper.findById(orgId);
        assertThat(after.getChannelIdMj()).isEqualTo("id-mj");
        assertThat(after.getChannelIdLaw()).isEqualTo("id-law");
        assertThat(after.getStatus()).isEqualTo(OrgStatus.ACTIVE);
    }

    @Test
    void 이미_ID가_있으면_아무것도_생성하지_않는다() {
        mapper.updateChannelIdMj(orgId, "id-mj");
        mapper.updateChannelIdLaw(orgId, "id-law");

        ProvisionResult result = service.provision(orgId);

        assertThat(result.mj()).isEqualTo(ProvisionOutcome.CACHED);
        assertThat(result.law()).isEqualTo(ProvisionOutcome.CACHED);

        verify(mattermost, never()).createPrivateChannel(anyString(), anyString());
        verify(mattermost, never()).findChannelIdByInternalName(anyString());
    }

    @Test
    void DB에는_없고_서버에_내부명이_있으면_ID를_복구한다() {
        when(mattermost.findChannelIdByInternalName("org-001-mj"))
                .thenReturn(Optional.of("recovered-mj"));
        when(mattermost.findChannelIdByInternalName("org-001-law"))
                .thenReturn(Optional.of("recovered-law"));

        ProvisionResult result = service.provision(orgId);

        assertThat(result.mj()).isEqualTo(ProvisionOutcome.RECOVERED);
        assertThat(result.law()).isEqualTo(ProvisionOutcome.RECOVERED);

        verify(mattermost, never()).createPrivateChannel(anyString(), anyString());

        Organization after = mapper.findById(orgId);
        assertThat(after.getChannelIdMj()).isEqualTo("recovered-mj");
        assertThat(after.getChannelIdLaw()).isEqualTo("recovered-law");
    }

    @Test
    void 내부명으로_못_찾으면_표시명으로_복구를_시도한다() {
        when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
        when(mattermost.findChannelIdByDisplayName("001_국제방송교류재단 (문정원)"))
                .thenReturn(Optional.of("bydisplay-mj"));
        when(mattermost.findChannelIdByDisplayName("001_국제방송교류재단 (법률검토)"))
                .thenReturn(Optional.empty());
        when(mattermost.createPrivateChannel(eq("org-001-law"), anyString()))
                .thenReturn("new-law");

        ProvisionResult result = service.provision(orgId);

        assertThat(result.mj()).isEqualTo(ProvisionOutcome.RECOVERED);
        assertThat(result.law()).isEqualTo(ProvisionOutcome.CREATED);

        verify(mattermost, never()).createPrivateChannel(eq("org-001-mj"), anyString());
    }

    @Test
    void 법률검토가_실패해도_문정원_ID는_저장된다() {
        when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
        when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
        when(mattermost.createPrivateChannel(eq("org-001-mj"), anyString()))
                .thenReturn("id-mj");
        when(mattermost.createPrivateChannel(eq("org-001-law"), anyString()))
                .thenThrow(new MattermostException("서버 오류"));

        ProvisionResult result = service.provision(orgId);

        assertThat(result.mj()).isEqualTo(ProvisionOutcome.CREATED);
        assertThat(result.law()).isEqualTo(ProvisionOutcome.FAILED);
        assertThat(result.message()).contains("법률검토");

        Organization after = mapper.findById(orgId);
        assertThat(after.getChannelIdMj()).isEqualTo("id-mj");
        assertThat(after.getChannelIdLaw()).isNull();
        assertThat(after.getStatus()).isEqualTo(OrgStatus.PARTIAL);
    }

    @Test
    void 부분_실패_후_재시도는_없는_쪽만_생성한다() {
        mapper.updateChannelIdMj(orgId, "id-mj");

        when(mattermost.findChannelIdByInternalName("org-001-law")).thenReturn(Optional.empty());
        when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
        when(mattermost.createPrivateChannel(eq("org-001-law"), anyString()))
                .thenReturn("retry-law");

        ProvisionResult result = service.provision(orgId);

        assertThat(result.mj()).isEqualTo(ProvisionOutcome.CACHED);
        assertThat(result.law()).isEqualTo(ProvisionOutcome.CREATED);

        verify(mattermost, never()).createPrivateChannel(eq("org-001-mj"), anyString());
        assertThat(mapper.findById(orgId).getStatus()).isEqualTo(OrgStatus.ACTIVE);
    }

    @Test
    void 치안정책연구소는_policy_내부명으로_생성한다() {
        Organization special = new Organization();
        special.setOrgNo("008");
        special.setOrgName("경찰청_치안정책연구소");
        special.setChannelSlug("008-policy");
        special.setDeptName("연구지원과");
        special.setManagerName("담당자");
        special.setManagerPhone("02-0000-0000");
        special.setManagerEmail("a@police.go.kr");
        mapper.upsertBySeed(special);

        Long specialId = mapper.findAll().stream()
                .filter(o -> "경찰청_치안정책연구소".equals(o.getOrgName()))
                .findFirst().orElseThrow().getId();

        when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
        when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
        when(mattermost.createPrivateChannel(anyString(), anyString())).thenReturn("x");

        service.provision(specialId);

        verify(mattermost).createPrivateChannel(
                "org-008-policy-mj", "008_경찰청_치안정책연구소 (문정원)");
        verify(mattermost).createPrivateChannel(
                "org-008-policy-law", "008_경찰청_치안정책연구소 (법률검토)");
    }

    @Test
    void 담당자정보가_없으면_생성하지_않는다() {
        Organization pending = new Organization();
        pending.setOrgNo("099");
        pending.setOrgName("정보없는기관");
        pending.setChannelSlug("099");
        mapper.upsertBySeed(pending);

        Long pendingId = mapper.findAll().stream()
                .filter(o -> "정보없는기관".equals(o.getOrgName()))
                .findFirst().orElseThrow().getId();

        ProvisionResult result = service.provision(pendingId);

        assertThat(result.mj()).isEqualTo(ProvisionOutcome.FAILED);
        assertThat(result.law()).isEqualTo(ProvisionOutcome.FAILED);
        assertThat(result.message()).contains("담당자 정보");

        verify(mattermost, never()).createPrivateChannel(anyString(), anyString());
    }
}