refactor: 쓸모없는 Slack 라우터 제거

Author: six-standard

src/configs/db.config.ts

@@ -16,13 +16,17 @@ const poolConfig: pg.PoolConfig = {
   max: 10, // 최대 연결 수
   idleTimeoutMillis: 30000, // 연결 유휴 시간 (30초)
   connectionTimeoutMillis: 5000, // 연결 시간 초과 (5초)
+  ssl: false,
+  // ssl: {
+  //   rejectUnauthorized: false,
+  // },
 };
 
-if (process.env.NODE_ENV === 'production') {
-  poolConfig.ssl = {
-    rejectUnauthorized: false,
-  };
-}
+// if (process.env.NODE_ENV === 'production') {
+//   poolConfig.ssl = {
+//     rejectUnauthorized: false,
+//   };
+// }
 
 const pool = new Pool(poolConfig);
 

src/controllers/slack.controller.ts

@@ -2,8 +2,10 @@ import { NextFunction, Request, RequestHandler, Response } from 'express';
 import { SlackService } from '@/services/slack.service';
 import { SentryService } from '@/services/sentry.service';
 import { SentryWebhookData, SlackMessage } from '@/types';
+import { SentryActionData, SentryApiAction } from '@/types/models/Sentry.type';
 import logger from '@/configs/logger.config';
 import { formatSentryIssueForSlack, createStatusUpdateMessage } from '@/utils/slack.util';
+import { getNewStatusFromAction } from '@/utils/sentry.util';
 
 export class WebhookController {
   constructor(
@@ -37,6 +39,51 @@ export class WebhookController {
     }
   };
 
+  handleSlackInteractive: RequestHandler = async (
+    req: Request,
+    res: Response,
+    next: NextFunction,
+  ): Promise<void> => {
+    try {
+      const payload = JSON.parse(req.body.payload);
+      
+      if (payload.type === 'interactive_message' && payload.actions && payload.actions[0]) {
+        const action = payload.actions[0];
+        
+        if (action.name === 'sentry_action') {
+          const [actionType, issueId, organizationSlug, projectSlug] = action.value.split(':');
+          
+          const actionData: SentryActionData = {
+            action: actionType as SentryApiAction,
+            issueId,
+            organizationSlug,
+            projectSlug,
+          };
+
+          if (actionData.issueId && actionData.organizationSlug && actionData.projectSlug) {
+            logger.info('Processing Sentry action:', actionData);
+
+            const result = await this.sentryService.handleIssueAction(actionData);
+            
+            if (result.success) {
+              const updatedMessage = this.createSuccessMessage(actionData, payload.original_message || {});
+              res.json(updatedMessage);
+            } else {
+              const errorMessage = this.createErrorMessage(result.error || 'Unknown error', payload.original_message || {});
+              res.json(errorMessage);
+            }
+            return;
+          }
+        }
+      }
+
+      res.json({ text: '❌ 잘못된 요청입니다.' });
+    } catch (error) {
+      logger.error('Slack Interactive 처리 실패:', error instanceof Error ? error.message : '알 수 없는 오류');
+      next(error);
+    }
+  };
+
   private async formatSentryDataForSlack(sentryData: SentryWebhookData): Promise<SlackMessage | null> {
     const { action, data } = sentryData;
 
@@ -106,4 +153,52 @@ export class WebhookController {
 
     return formatSentryIssueForSlack(sentryData, this.sentryService.hasSentryToken());
   }
+
+  private createSuccessMessage(actionData: SentryActionData, originalMessage: unknown): unknown {
+    const { action } = actionData;
+
+    const updatedMessage = JSON.parse(JSON.stringify(originalMessage));
+    
+    if (updatedMessage.attachments && updatedMessage.attachments[0]) {
+      const newStatus = getNewStatusFromAction(action);
+      const statusColors = {
+        'resolved': 'good',
+        'ignored': 'warning',
+        'archived': '#808080',
+        'unresolved': 'danger',
+      };
+      
+      updatedMessage.attachments[0].color = statusColors[newStatus as keyof typeof statusColors] || 'good';
+      
+      const statusMapping = {
+        'resolved': 'RESOLVED',
+        'ignored': 'IGNORED',
+        'archived': 'ARCHIVED',
+        'unresolved': 'UNRESOLVED',
+      };
+      
+      const statusText = statusMapping[newStatus as keyof typeof statusMapping] || newStatus.toUpperCase();
+      updatedMessage.attachments[0].footer = `✅ ${statusText} | 처리 완료: ${new Date().toLocaleString('ko-KR', { timeZone: 'Asia/Seoul' })}`;
+      
+      delete updatedMessage.attachments[0].actions;
+    }
+
+    return updatedMessage;
+  }
+
+  private createErrorMessage(error: string, originalMessage: unknown): unknown {
+    const updatedMessage = JSON.parse(JSON.stringify(originalMessage));
+    
+    if (updatedMessage.attachments && updatedMessage.attachments[0]) {
+      updatedMessage.attachments[0].fields.push({
+        title: '❌ 오류 발생',
+        value: error,
+        short: false,
+      });
+
+      updatedMessage.attachments[0].color = 'danger';
+    }
+
+    return updatedMessage;
+  }
 } 

src/controllers/webhook.controller.ts

@@ -5,7 +5,6 @@ import NotiRouter from './noti.router';
 import LeaderboardRouter from './leaderboard.router';
 import TotalStatsRouter from './totalStats.router';
 import WebhookRouter from './webhook.router';
-import SlackRouter from './slack.router';
 
 
 const router: Router = express.Router();
@@ -20,7 +19,5 @@ router.use('/', NotiRouter);
 router.use('/', LeaderboardRouter);
 router.use('/', TotalStatsRouter);
 router.use('/', WebhookRouter);
-router.use('/', SlackRouter);
-
 
 export default router;