✅ test: rabbitMQ 테스트 컨테이너 설정 및 정리 로직 추가

Author: CodeVac513

server/test/integration-test-global-setup.ts

@@ -1,11 +1,17 @@
 import { MySqlContainer, StartedMySqlContainer } from '@testcontainers/mysql';
 import { RedisContainer, StartedRedisContainer } from '@testcontainers/redis';
+import {
+  RabbitMQContainer,
+  StartedRabbitMQContainer,
+} from '@testcontainers/rabbitmq';
+
 const globalAny: any = global;
 
 export default async () => {
   console.log('Starting global setup...');
   await createMysqlContainer();
   await createRedisContainer();
+  await createRabbitMQContainer();
   jwtEnvSetup();
   console.log('Global setup completed.');
 };
@@ -40,6 +46,18 @@ const createRedisContainer = async () => {
   process.env.REDIS_PASSWORD = '';
 };
 
+const createRabbitMQContainer = async () => {
+  console.log('Starting RabbitMQ container...');
+  const rabbitMQContainer: StartedRabbitMQContainer =
+    await new RabbitMQContainer('rabbitmq:4.1-management').start();
+  globalAny.__RABBITMQ_CONTAINER__ = rabbitMQContainer;
+
+  process.env.RABBITMQ_HOST = rabbitMQContainer.getHost();
+  process.env.RABBITMQ_PORT = rabbitMQContainer.getMappedPort(5672).toString();
+  process.env.RABBITMQ_DEFAULT_USER = 'guest';
+  process.env.RABBITMQ_DEFAULT_PASS = 'guest';
+};
+
 const jwtEnvSetup = () => {
   console.log('Starting Jwt Environment...');
   process.env.JWT_ACCESS_SECRET = 'temp';

server/test/integration-test-global-teardown.ts

@@ -13,5 +13,11 @@ export default async () => {
     delete globalAny.__REDIS_CONTAINER__;
   }
 
+  console.log('Stopping RabbitMQ container...');
+  if (globalAny.__RABBITMQ_CONTAINER__) {
+    await globalAny.__RABBITMQ_CONTAINER__.stop();
+    delete globalAny.__RABBITMQ_CONTAINER__;
+  }
+
   console.log('Global teardown completed.');
 };

server/test/jest.setup.ts

@@ -7,6 +7,7 @@ import { HttpExceptionsFilter } from '../src/common/filters/http.exception.filte
 import * as cookieParser from 'cookie-parser';
 import { TestService } from '../src/common/test/test.service';
 import { RedisService } from '../src/common/redis/redis.service';
+import { RabbitMQService } from '../src/common/rabbitmq/rabbitmq.service';
 
 const globalAny: any = global;
 
@@ -39,6 +40,8 @@ afterAll(async () => {
   await redisService.flushall();
   redisService.disconnect();
 
+  await cleanupRabbitMQ();
+
   console.log('Closing NestJS application...');
   if (globalAny.testApp) {
     await globalAny.testApp.close();
@@ -47,6 +50,20 @@ afterAll(async () => {
   console.log('NestJS application closed.');
 });
 
+async function cleanupRabbitMQ() {
+  try {
+    const rabbitMQService: RabbitMQService =
+      globalAny.testApp.get(RabbitMQService);
+
+    if (rabbitMQService.connection) {
+      await rabbitMQService.connection.close();
+      console.log('RabbitMQ connection closed.');
+    }
+  } catch (error) {
+    console.error('Error cleaning up RabbitMQ:', error);
+  }
+}
+
 beforeEach(() => {
   jest.resetAllMocks();
 });