Commit @568476b306773ae88961a0f22435d729357fd729

ITN Dev 07-22

fix: 채널 프로비저닝 DB 저장 실패가 전파되지 않도록 예외 범위 확장

MattermostException만 catch하던 ensure()를 RuntimeException으로 넓혀,
채널 생성 직후 mapper 저장이 DataAccessException 계열로 실패해도
반대쪽 채널 시도를 막지 않고 FAILED로 강등되도록 수정. applyChannelId는
exhaustive switch 식으로 바꿔 컬럼 오기입 방지 주장을 실제로 컴파일
타임에 보장하고, 첫 채널 실패/양쪽 실패/DB 저장 실패 회귀 테스트를
추가했다.

Co-Authored-By: Claude Opus 4.8 (1M context)

@568476b306773ae88961a0f22435d729357fd729

ffa4d32

568476b

src/main/java/kr/itn/itnhub/provision/ChannelProvisionService.java

--- src/main/java/kr/itn/itnhub/provision/ChannelProvisionService.java

+++ src/main/java/kr/itn/itnhub/provision/ChannelProvisionService.java


 
 import kr.itn.itnhub.config.MattermostProperties;
 import kr.itn.itnhub.mattermost.MattermostClient;
-import kr.itn.itnhub.mattermost.MattermostException;
 import kr.itn.itnhub.org.Organization;
 import kr.itn.itnhub.org.OrganizationMapper;
 import org.slf4j.Logger;

             applyChannelId(org.getId(), kind, created);
             return ProvisionOutcome.CREATED;
 
-        } catch (MattermostException e) {
+        } catch (RuntimeException e) {
+            // MattermostException(서버 API 실패)뿐 아니라, 채널 생성/복구 직후 ID를 저장하는
+            // mapper 호출이 던지는 DataAccessException 등도 여기서 잡는다. Error나 checked
+            // exception은 의도적으로 넓히지 않는다 - 이 두 경우는 채널 하나만 FAILED로
+            // 강등시키고 메시지에 남긴 뒤, 나머지 채널은 계속 시도되게 해야 한다.
             log.warn("채널 처리 실패 org={} channel={}", org.getOrgName(), displayName, e);
             messages.append("[").append(label).append("] ")
                     .append(e.getMessage()).append(System.lineSeparator());

 
     /**
      * Channel ID를 저장할 컬럼(mj/law)을 결정하는 유일한 지점.
-     * 문자열 키 기반 동적 분기 대신 정적 타입(ChannelKind)으로만 분기하여,
-     * 잘못된 컬럼에 쓰는 실수를 컴파일 타임에 막는다.
+     * switch 식(expression)으로 작성해 ChannelKind에 값이 추가되고도 분기를
+     * 채우지 않으면 컴파일이 실패하도록 강제한다 - if/else였다면 새 값이
+     * 조용히 else(법률검토) 분기로 흘러 들어가는 것을 막지 못했을 것이다.
      */
     private void applyChannelId(Long orgId, ChannelKind kind, String channelId) {
-        if (kind == ChannelKind.MJ) {
-            mapper.updateChannelIdMj(orgId, channelId);
-        } else {
-            mapper.updateChannelIdLaw(orgId, channelId);
-        }
+        // 반환값(영향받은 행 수)은 쓰지 않지만, switch를 식으로 유지해야
+        // 컴파일러가 exhaustiveness를 검사한다 - 문(statement) 형태의
+        // switch/if-else는 이 검사를 강제하지 않는다.
+        var ignored = switch (kind) {
+            case MJ -> mapper.updateChannelIdMj(orgId, channelId);
+            case LAW -> mapper.updateChannelIdLaw(orgId, channelId);
+        };
     }
 }

ffa4d32

568476b

src/test/java/kr/itn/itnhub/provision/ChannelProvisionServiceTest.java

--- src/test/java/kr/itn/itnhub/provision/ChannelProvisionServiceTest.java

+++ src/test/java/kr/itn/itnhub/provision/ChannelProvisionServiceTest.java


 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.mock.mockito.MockBean;
+import org.springframework.boot.test.mock.mockito.SpyBean;
+import org.springframework.dao.DataIntegrityViolationException;
 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.doThrow;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;

     @Autowired
     ChannelProvisionService service;
 
-    @Autowired
+    @SpyBean
     OrganizationMapper mapper;
 
     @Autowired

 
         verify(mattermost, never()).createPrivateChannel(anyString(), anyString());
     }
+
+    @Test
+    void 문정원이_실패해도_법률검토는_시도된다() {
+        when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
+        when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
+        when(mattermost.createPrivateChannel(eq("org-001-mj"), anyString()))
+                .thenThrow(new MattermostException("문정원 서버 오류"));
+        when(mattermost.createPrivateChannel(eq("org-001-law"), anyString()))
+                .thenReturn("id-law");
+
+        ProvisionResult result = service.provision(orgId);
+
+        assertThat(result.mj()).isEqualTo(ProvisionOutcome.FAILED);
+        assertThat(result.law()).isEqualTo(ProvisionOutcome.CREATED);
+        assertThat(result.message()).contains("문정원");
+
+        Organization after = mapper.findById(orgId);
+        assertThat(after.getChannelIdMj()).isNull();
+        assertThat(after.getChannelIdLaw()).isEqualTo("id-law");
+        assertThat(after.getStatus()).isEqualTo(OrgStatus.PARTIAL);
+    }
+
+    @Test
+    void 양쪽_다_실패하면_메시지에_두_채널_라벨이_모두_누적된다() {
+        when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
+        when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
+        when(mattermost.createPrivateChannel(eq("org-001-mj"), anyString()))
+                .thenThrow(new MattermostException("문정원 서버 오류"));
+        when(mattermost.createPrivateChannel(eq("org-001-law"), anyString()))
+                .thenThrow(new MattermostException("법률검토 서버 오류"));
+
+        ProvisionResult result = service.provision(orgId);
+
+        assertThat(result.mj()).isEqualTo(ProvisionOutcome.FAILED);
+        assertThat(result.law()).isEqualTo(ProvisionOutcome.FAILED);
+        assertThat(result.message()).contains("문정원").contains("법률검토");
+
+        Organization after = mapper.findById(orgId);
+        assertThat(after.getChannelIdMj()).isNull();
+        assertThat(after.getChannelIdLaw()).isNull();
+    }
+
+    /**
+     * Finding 1 회귀 테스트: MattermostClient 호출은 성공했는데 그 직후 DB 기록(mapper)이
+     * DataAccessException 계열로 실패하는 경우. 수정 전에는 ensure()가 MattermostException만
+     * catch 하므로 이 예외가 provision() 밖으로 전파되어 두 번째(법률검토) 채널은 시도조차
+     * 되지 않고 호출자는 ProvisionResult를 받지 못한다. 수정 후에는 해당 채널만 FAILED로
+     * 강등되고 나머지 채널은 정상적으로 계속 시도되어야 한다.
+     */
+    @Test
+    void 채널_생성_성공_직후_DB_저장_실패는_예외로_전파되지_않고_FAILED로_처리된다() {
+        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()))
+                .thenReturn("id-law");
+
+        doThrow(new DataIntegrityViolationException("DB 저장 실패"))
+                .when(mapper).updateChannelIdMj(eq(orgId), anyString());
+
+        ProvisionResult result = service.provision(orgId);
+
+        assertThat(result.mj()).isEqualTo(ProvisionOutcome.FAILED);
+        assertThat(result.law()).isEqualTo(ProvisionOutcome.CREATED);
+        assertThat(result.message()).contains("문정원");
+
+        Organization after = mapper.findById(orgId);
+        assertThat(after.getChannelIdMj()).isNull();
+        assertThat(after.getChannelIdLaw()).isEqualTo("id-law");
+    }
 }

Add a comment

Open 0
Closed 0

List

...	...	@@ -2,7 +2,6 @@
2	2
3	3	import kr.itn.itnhub.config.MattermostProperties;
4	4	import kr.itn.itnhub.mattermost.MattermostClient;
5		-import kr.itn.itnhub.mattermost.MattermostException;
6	5	import kr.itn.itnhub.org.Organization;
7	6	import kr.itn.itnhub.org.OrganizationMapper;
8	7	import org.slf4j.Logger;
...	...	@@ -95,7 +94,11 @@
95	94	applyChannelId(org.getId(), kind, created);
96	95	return ProvisionOutcome.CREATED;
97	96
98		- } catch (MattermostException e) {
	97	+ } catch (RuntimeException e) {
	98	+ // MattermostException(서버 API 실패)뿐 아니라, 채널 생성/복구 직후 ID를 저장하는
	99	+ // mapper 호출이 던지는 DataAccessException 등도 여기서 잡는다. Error나 checked
	100	+ // exception은 의도적으로 넓히지 않는다 - 이 두 경우는 채널 하나만 FAILED로
	101	+ // 강등시키고 메시지에 남긴 뒤, 나머지 채널은 계속 시도되게 해야 한다.
99	102	log.warn("채널 처리 실패 org={} channel={}", org.getOrgName(), displayName, e);
100	103	messages.append("[").append(label).append("] ")
101	104	.append(e.getMessage()).append(System.lineSeparator());
...	...	@@ -105,14 +108,17 @@
105	108
106	109	/**
107	110	* Channel ID를 저장할 컬럼(mj/law)을 결정하는 유일한 지점.
108		- * 문자열 키 기반 동적 분기 대신 정적 타입(ChannelKind)으로만 분기하여,
109		- * 잘못된 컬럼에 쓰는 실수를 컴파일 타임에 막는다.
	111	+ * switch 식(expression)으로 작성해 ChannelKind에 값이 추가되고도 분기를
	112	+ * 채우지 않으면 컴파일이 실패하도록 강제한다 - if/else였다면 새 값이
	113	+ * 조용히 else(법률검토) 분기로 흘러 들어가는 것을 막지 못했을 것이다.
110	114	*/
111	115	private void applyChannelId(Long orgId, ChannelKind kind, String channelId) {
112		- if (kind == ChannelKind.MJ) {
113		- mapper.updateChannelIdMj(orgId, channelId);
114		- } else {
115		- mapper.updateChannelIdLaw(orgId, channelId);
116		- }
	116	+ // 반환값(영향받은 행 수)은 쓰지 않지만, switch를 식으로 유지해야
	117	+ // 컴파일러가 exhaustiveness를 검사한다 - 문(statement) 형태의
	118	+ // switch/if-else는 이 검사를 강제하지 않는다.
	119	+ var ignored = switch (kind) {
	120	+ case MJ -> mapper.updateChannelIdMj(orgId, channelId);
	121	+ case LAW -> mapper.updateChannelIdLaw(orgId, channelId);
	122	+ };
117	123	}
118	124	}

...	...	@@ -10,14 +10,16 @@
10	10	import org.junit.jupiter.api.Test;
11	11	import org.springframework.beans.factory.annotation.Autowired;
12	12	import org.springframework.boot.test.mock.mockito.MockBean;
	13	+import org.springframework.boot.test.mock.mockito.SpyBean;
	14	+import org.springframework.dao.DataIntegrityViolationException;
13	15	import org.springframework.jdbc.core.JdbcTemplate;
14	16
15	17	import java.util.Optional;
16	18
17	19	import static org.assertj.core.api.Assertions.assertThat;
18		-import static org.mockito.ArgumentMatchers.any;
19	20	import static org.mockito.ArgumentMatchers.anyString;
20	21	import static org.mockito.ArgumentMatchers.eq;
	22	+import static org.mockito.Mockito.doThrow;
21	23	import static org.mockito.Mockito.never;
22	24	import static org.mockito.Mockito.verify;
23	25	import static org.mockito.Mockito.when;
...	...	@@ -27,7 +29,7 @@
27	29	@Autowired
28	30	ChannelProvisionService service;
29	31
30		- @Autowired
	32	+ @SpyBean
31	33	OrganizationMapper mapper;
32	34
33	35	@Autowired
...	...	@@ -213,4 +215,75 @@
213	215
214	216	verify(mattermost, never()).createPrivateChannel(anyString(), anyString());
215	217	}
	218	+
	219	+ @Test
	220	+ void 문정원이_실패해도_법률검토는_시도된다() {
	221	+ when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
	222	+ when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
	223	+ when(mattermost.createPrivateChannel(eq("org-001-mj"), anyString()))
	224	+ .thenThrow(new MattermostException("문정원 서버 오류"));
	225	+ when(mattermost.createPrivateChannel(eq("org-001-law"), anyString()))
	226	+ .thenReturn("id-law");
	227	+
	228	+ ProvisionResult result = service.provision(orgId);
	229	+
	230	+ assertThat(result.mj()).isEqualTo(ProvisionOutcome.FAILED);
	231	+ assertThat(result.law()).isEqualTo(ProvisionOutcome.CREATED);
	232	+ assertThat(result.message()).contains("문정원");
	233	+
	234	+ Organization after = mapper.findById(orgId);
	235	+ assertThat(after.getChannelIdMj()).isNull();
	236	+ assertThat(after.getChannelIdLaw()).isEqualTo("id-law");
	237	+ assertThat(after.getStatus()).isEqualTo(OrgStatus.PARTIAL);
	238	+ }
	239	+
	240	+ @Test
	241	+ void 양쪽_다_실패하면_메시지에_두_채널_라벨이_모두_누적된다() {
	242	+ when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
	243	+ when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
	244	+ when(mattermost.createPrivateChannel(eq("org-001-mj"), anyString()))
	245	+ .thenThrow(new MattermostException("문정원 서버 오류"));
	246	+ when(mattermost.createPrivateChannel(eq("org-001-law"), anyString()))
	247	+ .thenThrow(new MattermostException("법률검토 서버 오류"));
	248	+
	249	+ ProvisionResult result = service.provision(orgId);
	250	+
	251	+ assertThat(result.mj()).isEqualTo(ProvisionOutcome.FAILED);
	252	+ assertThat(result.law()).isEqualTo(ProvisionOutcome.FAILED);
	253	+ assertThat(result.message()).contains("문정원").contains("법률검토");
	254	+
	255	+ Organization after = mapper.findById(orgId);
	256	+ assertThat(after.getChannelIdMj()).isNull();
	257	+ assertThat(after.getChannelIdLaw()).isNull();
	258	+ }
	259	+
	260	+ /**
	261	+ * Finding 1 회귀 테스트: MattermostClient 호출은 성공했는데 그 직후 DB 기록(mapper)이
	262	+ * DataAccessException 계열로 실패하는 경우. 수정 전에는 ensure()가 MattermostException만
	263	+ * catch 하므로 이 예외가 provision() 밖으로 전파되어 두 번째(법률검토) 채널은 시도조차
	264	+ * 되지 않고 호출자는 ProvisionResult를 받지 못한다. 수정 후에는 해당 채널만 FAILED로
	265	+ * 강등되고 나머지 채널은 정상적으로 계속 시도되어야 한다.
	266	+ */
	267	+ @Test
	268	+ void 채널_생성_성공_직후_DB_저장_실패는_예외로_전파되지_않고_FAILED로_처리된다() {
	269	+ when(mattermost.findChannelIdByInternalName(anyString())).thenReturn(Optional.empty());
	270	+ when(mattermost.findChannelIdByDisplayName(anyString())).thenReturn(Optional.empty());
	271	+ when(mattermost.createPrivateChannel(eq("org-001-mj"), anyString()))
	272	+ .thenReturn("id-mj");
	273	+ when(mattermost.createPrivateChannel(eq("org-001-law"), anyString()))
	274	+ .thenReturn("id-law");
	275	+
	276	+ doThrow(new DataIntegrityViolationException("DB 저장 실패"))
	277	+ .when(mapper).updateChannelIdMj(eq(orgId), anyString());
	278	+
	279	+ ProvisionResult result = service.provision(orgId);
	280	+
	281	+ assertThat(result.mj()).isEqualTo(ProvisionOutcome.FAILED);
	282	+ assertThat(result.law()).isEqualTo(ProvisionOutcome.CREATED);
	283	+ assertThat(result.message()).contains("문정원");
	284	+
	285	+ Organization after = mapper.findById(orgId);
	286	+ assertThat(after.getChannelIdMj()).isNull();
	287	+ assertThat(after.getChannelIdLaw()).isEqualTo("id-law");
	288	+ }
216	289	}

Delete comment