sync: health check api

Author: manyb2ns

src/main/java/com/catcher/datasource/config/DBConfiguration.java

@@ -1,29 +1,13 @@
-/*
-        데이터베이스 연결 및 SSH 터널링 설정 파일으로 보임.
- */
-
 package com.catcher.datasource.config;
-
 import com.catcher.infrastructure.KmsService;
-
-/* for SSH Session */
 import com.jcraft.jsch.JSch;
 import com.jcraft.jsch.Session;
-
-/* 생성자 자동 설정 */
 import lombok.RequiredArgsConstructor;
 import org.springframework.beans.factory.annotation.Value;
-
-/* DataSource 빌드 (DB 연결 정보 구성 및 DataSource 객체 생성) */
 import org.springframework.boot.jdbc.DataSourceBuilder;
-
-/* bean(?)을 정의하기 위한 어노테이션 */
 import org.springframework.context.annotation.Bean;
-
-/* Spring 어플리케이션의 구성 설정 및 구성요소 생성 .. */
 import org.springframework.context.annotation.Configuration;
 
-/* 데이터베이스 연결 관리 */
 import javax.sql.DataSource;
 
 @Configuration
@@ -66,30 +50,30 @@ public class DBConfiguration {
     @Value("${ssh.local-port}")
     private int localPort;
 
-//     @Bean
-//     public DataSource dataSource() throws Exception {
-
-//         JSch jsch = new JSch();
-//         Session session = jsch.getSession(
-//                 kmsService.decrypt(sshUsername),
-//                 kmsService.decrypt(sshHost),
-//                 sshPort
-//         );
-//         session.setPassword(kmsService.decrypt(sshPassword));
-//         session.setConfig("StrictHostKeyChecking", "no");
-//         session.connect();
-
-//         int assignedPort = session.setPortForwardingL(0,
-//                 kmsService.decrypt(originUrl),
-//                 localPort
-//         );
-
-//         return DataSourceBuilder.create()
-//                 .url(kmsService.decrypt(databaseUrl).replace(Integer.toString(localPort), Integer.toString(assignedPort)))
-//                 .username(kmsService.decrypt(databaseUsername))
-//                 .password(kmsService.decrypt(databasePassword))
-//                 .build();
-//     }
+    @Bean
+    public DataSource dataSource() throws Exception {
+
+        JSch jsch = new JSch();
+        Session session = jsch.getSession(
+                kmsService.decrypt(sshUsername),
+                kmsService.decrypt(sshHost),
+                sshPort
+        );
+        session.setPassword(kmsService.decrypt(sshPassword));
+        session.setConfig("StrictHostKeyChecking", "no");
+        session.connect();
+
+        int assignedPort = session.setPortForwardingL(0,
+                kmsService.decrypt(originUrl),
+                localPort
+        );
+
+        return DataSourceBuilder.create()
+                .url(kmsService.decrypt(databaseUrl).replace(Integer.toString(localPort), Integer.toString(assignedPort)))
+                .username(kmsService.decrypt(databaseUsername))
+                .password(kmsService.decrypt(databasePassword))
+                .build();
+    }
 
     @Bean
     public DataSource dataSource() {

src/main/java/com/catcher/infrastructure/KmsService.java

@@ -25,10 +25,10 @@ public class KmsService {
     // private static String PROFILE;
 
     public String encrypt(String text) {
-        // AWSKMS kmsClient = AWSKMSClientBuilder.standard()
-        //         .withCredentials(new ProfileCredentialsProvider(PROFILE))
-        //         .withRegion(Regions.AP_NORTHEAST_2)
-        //         .build();
+    //     AWSKMS kmsClient = AWSKMSClientBuilder.standard()
+    //             .withCredentials(new ProfileCredentialsProvider(PROFILE))
+    //             .withRegion(Regions.AP_NORTHEAST_2)
+    //             .build();
         AWSKMS kmsClient = AWSKMSClientBuilder.standard()
                 .withRegion(Regions.AP_NORTHEAST_2)
                 .build();
@@ -59,4 +59,4 @@ public String decrypt(String cipherBase64) {
         byte[] textBytes = kmsClient.decrypt(request).getPlaintext().array();
         return new String(textBytes);
     }
-}
+}