메시지 전송 요청 모델의 스키마를 개선하고, 전화번호 형식을 정규화하는 phoneNumberSchema를 추가함. 또한, 빈 배열 검증을 위한 재사용 가능한 필터를 도입하고, 에이전트 스키마의 기본값을 설정하여 코드의 재사용성을 높임. 메시지 서비스에서 스키마 검증을 비동기적으로 처리하도록 변경하고, 에러 처리를 개선하여 안정성을 강화함. 새로운 테스트 케이스를 추가하여 다양한 메시지 전송 시나리오를 검증함.

Author: Palbahngmiyine

src/models/requests/messages/sendMessage.ts

@@ -2,6 +2,21 @@ import {messageSchema} from '@models/base/messages/message';
 import {Schema} from 'effect';
 import {defaultAgentTypeSchema} from './requestConfig';
 
+export const phoneNumberSchema = Schema.String.pipe(
+  Schema.transform(Schema.String, {
+    decode: s => s.replace(/-/g, ''),
+    encode: s => s,
+  }),
+);
+
+// 빈 배열 검증을 위한 재사용 가능한 필터
+const nonEmptyArrayFilter = <A>(schema: Schema.Schema<A>) =>
+  Schema.Array(schema).pipe(
+    Schema.filter(arr => arr.length > 0, {
+      message: () => '데이터가 반드시 1건 이상 기입되어 있어야 합니다.',
+    }),
+  );
+
 /**
  * 단건 메시지 발송 요청 모델
  * @description 단건 메시지 발송 요청 모델
@@ -14,7 +29,15 @@ import {defaultAgentTypeSchema} from './requestConfig';
  * };
  * ```
  */
-export const requestSendOneMessageSchema = messageSchema;
+export const requestSendOneMessageSchema = messageSchema.pipe(
+  Schema.omit('to', 'from'),
+  Schema.extend(
+    Schema.Struct({
+      to: Schema.Union(phoneNumberSchema, Schema.Array(phoneNumberSchema)),
+      from: Schema.optional(phoneNumberSchema),
+    }),
+  ),
+);
 
 /**
  * 메시지 발송 요청 모델
@@ -39,7 +62,7 @@ export const requestSendOneMessageSchema = messageSchema;
  */
 export const requestSendMessageSchema = Schema.Union(
   requestSendOneMessageSchema,
-  Schema.Array(requestSendOneMessageSchema),
+  nonEmptyArrayFilter(requestSendOneMessageSchema),
 );
 
 export type RequestSendOneMessageSchema = Schema.Schema.Type<
@@ -53,21 +76,21 @@ export type RequestSendMessagesSchema = Schema.Schema.Type<
 // 기본 Agent 객체 (sdkVersion, osPlatform 값 포함) – 빈 객체 디코딩으로 생성
 const defaultAgentValue = Schema.decodeSync(defaultAgentTypeSchema)({});
 
+// Agent 스키마의 재사용 가능한 정의
+const agentWithDefaultSchema = Schema.optional(defaultAgentTypeSchema).pipe(
+  Schema.withDecodingDefault(() => defaultAgentValue),
+  Schema.withConstructorDefault(() => defaultAgentValue),
+);
+
 export const singleMessageSendingRequestSchema = Schema.Struct({
   message: requestSendOneMessageSchema,
-  agent: Schema.optional(defaultAgentTypeSchema).pipe(
-    Schema.withDecodingDefault(() => defaultAgentValue),
-    Schema.withConstructorDefault(() => defaultAgentValue),
-  ),
+  agent: agentWithDefaultSchema,
 });
 
 export const multipleMessageSendingRequestSchema = Schema.Struct({
   allowDuplicates: Schema.optional(Schema.Boolean),
-  agent: Schema.optional(defaultAgentTypeSchema).pipe(
-    Schema.withDecodingDefault(() => defaultAgentValue),
-    Schema.withConstructorDefault(() => defaultAgentValue),
-  ),
-  messages: Schema.Array(requestSendOneMessageSchema),
+  agent: agentWithDefaultSchema,
+  messages: nonEmptyArrayFilter(requestSendOneMessageSchema),
   scheduledDate: Schema.optional(
     Schema.Union(Schema.DateFromSelf, Schema.DateFromString),
   ),

src/services/messages/messageService.ts

@@ -1,3 +1,4 @@
+import {toCompatibleError} from '@lib/effectErrorHandler';
 import stringifyQuery from '@lib/stringifyQuery';
 import {
   GetMessagesFinalizeRequest,
@@ -26,9 +27,8 @@ import {
   SingleMessageSentResponse,
 } from '@models/responses/messageResponses';
 import {DetailGroupMessageResponse} from '@models/responses/sendManyDetailResponse';
-import {Schema} from 'effect';
+import {Cause, Exit, Schema} from 'effect';
 import * as Effect from 'effect/Effect';
-import {defaultRuntime, runPromise as runtimeRunPromise} from 'effect/Runtime';
 import {
   BadRequestError,
   MessageNotReceivedError,
@@ -76,18 +76,29 @@ export default class MessageService extends DefaultService {
    * @throws MessageNotReceivedError 모든 메시지 접수건이 실패건으로 진행되는 경우 반환되는 에러
    * @throws BadRequestError 잘못된 파라미터를 기입했거나, 데이터가 아예 없는 경우 반환되는 에러
    */
-  send(
+  async send(
     messages: RequestSendMessagesSchema,
     requestConfigParameter?: SendRequestConfigSchema,
   ): Promise<DetailGroupMessageResponse> {
     const request = this.request.bind(this);
-    const messageSchema = Schema.encodeUnknownSync(requestSendMessageSchema)(
-      messages,
-    );
 
     const effect = Effect.gen(function* (_) {
       /**
-       * 1. MessageParameter → Message 변환 및 기본 검증
+       * 1. 스키마 검증 - Effect 내부에서 실행하여 에러를 안전하게 처리
+       */
+      const messageSchema = yield* _(
+        Effect.try({
+          try: () =>
+            Schema.encodeUnknownSync(requestSendMessageSchema)(messages),
+          catch: error =>
+            new BadRequestError({
+              message: error instanceof Error ? error.message : String(error),
+            }),
+        }),
+      );
+
+      /**
+       * 2. MessageParameter → Message 변환 및 기본 검증
        */
       const messageParameters = Array.isArray(messageSchema)
         ? messageSchema
@@ -103,8 +114,17 @@ export default class MessageService extends DefaultService {
         );
       }
 
-      const decodedConfig = Schema.encodeUnknownSync(sendRequestConfigSchema)(
-        requestConfigParameter ?? {},
+      const decodedConfig = yield* _(
+        Effect.try({
+          try: () =>
+            Schema.encodeUnknownSync(sendRequestConfigSchema)(
+              requestConfigParameter ?? {},
+            ),
+          catch: error =>
+            new BadRequestError({
+              message: error instanceof Error ? error.message : String(error),
+            }),
+        }),
       );
 
       const parameterObject = {
@@ -116,8 +136,17 @@ export default class MessageService extends DefaultService {
       };
 
       // 스키마 검증 및 파라미터 확정
-      const parameter = Schema.decodeSync(multipleMessageSendingRequestSchema)(
-        parameterObject,
+      const parameter = yield* _(
+        Effect.try({
+          try: () =>
+            Schema.decodeSync(multipleMessageSendingRequestSchema)(
+              parameterObject,
+            ),
+          catch: error =>
+            new BadRequestError({
+              message: error instanceof Error ? error.message : String(error),
+            }),
+        }),
       );
 
       /**
@@ -158,7 +187,20 @@ export default class MessageService extends DefaultService {
       return response;
     });
 
-    return runtimeRunPromise(defaultRuntime, effect);
+    // Effect를 Promise로 변환하되 에러를 표준 Error 객체로 변환
+    const exit = await Effect.runPromiseExit(effect);
+
+    return Exit.match(exit, {
+      onFailure: cause => {
+        // Effect 에러를 표준 JavaScript Error로 변환
+        const failure = Cause.failureOption(cause);
+        if (failure._tag === 'Some') {
+          throw toCompatibleError(failure.value);
+        }
+        throw new Error('Unknown error occurred');
+      },
+      onSuccess: value => value,
+    });
   }
 
   /**