[FEATURE] 테넌트 격리 정책 서비스

pom.xml

@@ -182,6 +182,13 @@
             <artifactId>h2</artifactId>
             <scope>test</scope>
         </dependency>
+
+        <!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-openfeign -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+            <version>4.1.3</version>
+        </dependency>
 
         <!-- Awaitility for async testing -->
         <dependency>

src/main/java/com/agenticcp/core/AgenticCpCoreApplication.java

@@ -4,12 +4,10 @@
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
 import org.springframework.scheduling.annotation.EnableAsync;
-import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @EnableJpaRepositories
 @EnableAsync
-@EnableScheduling
 public class AgenticCpCoreApplication {
 
     public static void main(String[] args) {

src/main/java/com/agenticcp/core/domain/tenant/adapter/TenantIsolationAdapter.java

@@ -0,0 +1,51 @@
+package com.agenticcp.core.domain.tenant.adapter;
+
+import com.agenticcp.core.domain.tenant.entity.TenantIsolation;
+import com.agenticcp.core.domain.tenant.adapter.dto.IsolationResult;
+import com.agenticcp.core.domain.tenant.adapter.dto.IsolationStatus;
+
+/**
+ * 테넌트 격리 정책을 적용하는 핵심 인터페이스
+ * Adapter 패턴의 Target Interface 역할
+ */
+public interface TenantIsolationAdapter {
+
+    /**
+     * 테넌트에 격리 정책을 적용합니다.
+     * 
+     * @param tenantKey 테넌트 키
+     * @param isolation 격리 정책 정보
+     * @return 격리 정책 적용 결과
+     */
+    IsolationResult applyIsolationPolicy(String tenantKey, TenantIsolation isolation);
+
+    /**
+     * 테넌트의 격리 정책을 제거합니다.
+     * 
+     * @param tenantKey 테넌트 키
+     */
+    void removeIsolationPolicy(String tenantKey);
+
+    /**
+     * 테넌트의 현재 격리 상태를 조회합니다.
+     * 
+     * @param tenantKey 테넌트 키
+     * @return 격리 상태 정보
+     */
+    IsolationStatus getIsolationStatus(String tenantKey);
+
+    /**
+     * 특정 격리 레벨을 지원하는지 확인합니다.
+     * 
+     * @param isolationLevel 격리 레벨
+     * @return 지원 여부
+     */
+    boolean supportsIsolationLevel(TenantIsolation.IsolationLevel isolationLevel);
+
+    /**
+     * 이 Adapter가 지원하는 클라우드 프로바이더 타입을 반환합니다.
+     * 
+     * @return 클라우드 프로바이더 타입
+     */
+    String getSupportedCloudProvider();
+}

src/main/java/com/agenticcp/core/domain/tenant/adapter/TenantIsolationAdapterFactory.java

@@ -0,0 +1,64 @@
+package com.agenticcp.core.domain.tenant.adapter;
+
+import com.agenticcp.core.domain.tenant.controller.cloud.CloudProviderType;
+import com.agenticcp.core.domain.tenant.entity.TenantIsolation;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+/**
+ * TenantIsolationAdapter 인스턴스를 생성하는 Factory
+ * Adapter 패턴의 Factory 역할
+ */
+@Component
+public class TenantIsolationAdapterFactory {
+
+    private final Map<CloudProviderType, TenantIsolationAdapter> adapters;
+
+    public TenantIsolationAdapterFactory(List<TenantIsolationAdapter> adapterList) {
+        this.adapters = adapterList.stream()
+                .collect(Collectors.toMap(
+                        adapter -> CloudProviderType.valueOf(adapter.getSupportedCloudProvider()),
+                        Function.identity()
+                ));
+    }
+
+    /**
+     * 클라우드 프로바이더 타입에 해당하는 Adapter를 반환합니다.
+     * 
+     * @param providerType 클라우드 프로바이더 타입
+     * @return 해당하는 Adapter 인스턴스
+     * @throws IllegalArgumentException 지원하지 않는 프로바이더 타입인 경우
+     */
+    public TenantIsolationAdapter getAdapter(CloudProviderType providerType) {
+        TenantIsolationAdapter adapter = adapters.get(providerType);
+        if (adapter == null) {
+            throw new IllegalArgumentException("Unsupported cloud provider type: " + providerType);
+        }
+        return adapter;
+    }
+
+    /**
+     * 특정 격리 레벨을 지원하는 Adapter 목록을 반환합니다.
+     * 
+     * @param isolationLevel 격리 레벨
+     * @return 해당 격리 레벨을 지원하는 Adapter 목록
+     */
+    public List<TenantIsolationAdapter> getAdaptersSupporting(TenantIsolation.IsolationLevel isolationLevel) {
+        return adapters.values().stream()
+                .filter(adapter -> adapter.supportsIsolationLevel(isolationLevel))
+                .toList();
+    }
+
+    /**
+     * 사용 가능한 모든 Adapter 목록을 반환합니다.
+     * 
+     * @return 모든 Adapter 목록
+     */
+    public List<TenantIsolationAdapter> getAllAdapters() {
+        return List.copyOf(adapters.values());
+    }
+}

src/main/java/com/agenticcp/core/domain/tenant/adapter/dto/IsolationResult.java

@@ -0,0 +1,44 @@
+package com.agenticcp.core.domain.tenant.adapter.dto;
+
+import com.agenticcp.core.domain.tenant.entity.TenantIsolation;
+import lombok.Builder;
+
+import java.time.LocalDateTime;
+import java.util.Map;
+
+/**
+ * 격리 정책 적용 결과를 담는 DTO
+ */
+@Builder
+public record IsolationResult(
+        boolean success,
+        String message,
+        String tenantKey,
+        TenantIsolation.IsolationLevel isolationLevel,
+        LocalDateTime appliedAt,
+        Map<String, Object> resourceDetails, // CSP별 생성된 리소스 정보
+        Map<String, String> errors // 오류 정보
+) {
+
+    public static IsolationResult success(String tenantKey, TenantIsolation.IsolationLevel level, 
+                                        Map<String, Object> resourceDetails) {
+        return IsolationResult.builder()
+                .success(true)
+                .message("Isolation policy applied successfully")
+                .tenantKey(tenantKey)
+                .isolationLevel(level)
+                .appliedAt(LocalDateTime.now())
+                .resourceDetails(resourceDetails)
+                .build();
+    }
+
+    public static IsolationResult failure(String tenantKey, String message, Map<String, String> errors) {
+        return IsolationResult.builder()
+                .success(false)
+                .message(message)
+                .tenantKey(tenantKey)
+                .appliedAt(LocalDateTime.now())
+                .errors(errors)
+                .build();
+    }
+}

src/main/java/com/agenticcp/core/domain/tenant/adapter/dto/IsolationStatus.java

@@ -0,0 +1,29 @@
+package com.agenticcp.core.domain.tenant.adapter.dto;
+
+import com.agenticcp.core.domain.tenant.entity.TenantIsolation;
+import lombok.Builder;
+
+import java.time.LocalDateTime;
+import java.util.Map;
+
+/**
+ * 테넌트의 격리 상태 정보를 담는 DTO
+ */
+@Builder
+public record IsolationStatus(
+        String tenantKey,
+        TenantIsolation.IsolationLevel isolationLevel,
+        boolean isActive,
+        LocalDateTime lastUpdated,
+        Map<String, Object> resourceStatus, // CSP별 리소스 상태
+        Map<String, String> configuration // 현재 설정 정보
+) {
+
+    public static IsolationStatus inactive(String tenantKey) {
+        return IsolationStatus.builder()
+                .tenantKey(tenantKey)
+                .isActive(false)
+                .lastUpdated(LocalDateTime.now())
+                .build();
+    }
+}

src/main/java/com/agenticcp/core/domain/tenant/controller/cloud/CloudProviderType.java

@@ -0,0 +1,11 @@
+package com.agenticcp.core.domain.tenant.controller.cloud;
+
+import lombok.Getter;
+
+@Getter
+public enum CloudProviderType {
+    AWS,
+    AZURE,
+    GCP,
+    OTHER
+}

src/main/java/com/agenticcp/core/domain/tenant/controller/cloud/SampleClient.java

@@ -0,0 +1,20 @@
+package com.agenticcp.core.domain.tenant.controller.cloud;
+
+import com.agenticcp.core.domain.tenant.controller.cloud.dto.CloudResourceResult;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(
+        name = "",
+        url = ""
+)
+public interface SampleClient {
+
+    @PostMapping("/api/{samplePathVariable}")
+    CloudResourceResult createVpc(
+            @PathVariable String samplePathVariable,
+            @RequestBody String sampleRequestBody
+    );
+}

src/main/java/com/agenticcp/core/domain/tenant/controller/cloud/dto/CloudResourceResult.java

@@ -0,0 +1,12 @@
+package com.agenticcp.core.domain.tenant.controller.cloud.dto;
+
+import lombok.Builder;
+
+import java.util.Map;
+
+@Builder
+public record CloudResourceResult(
+        String resourceId,
+        Map<String, Object> metadata
+) {
+}

src/main/java/com/agenticcp/core/domain/tenant/controller/cloud/dto/SecurityGroupRequest.java

@@ -0,0 +1,19 @@
+package com.agenticcp.core.domain.tenant.controller.cloud.dto;
+
+import lombok.Builder;
+
+import java.util.List;
+
+@Builder
+public record SecurityGroupRequest(
+        String vpcId,
+        String name,
+        List<SecurityGroupRule> securityGroupRules
+) {
+    public record SecurityGroupRule(
+            String protocol,
+            String portRange,
+            String cidrIp
+    ) {
+    }
+}

src/main/java/com/agenticcp/core/domain/tenant/controller/cloud/dto/SubnetRequest.java

@@ -0,0 +1,17 @@
+package com.agenticcp.core.domain.tenant.controller.cloud.dto;
+
+import lombok.Builder;
+
+import java.util.List;
+
+@Builder
+public record SubnetRequest(
+        String vpcId,
+        List<SubnetConfig> subnets
+) {
+    public record SubnetConfig(
+            String subnetId,
+            String availabilityZone
+    ) {
+    }
+}

src/main/java/com/agenticcp/core/domain/tenant/controller/cloud/dto/VpcRequest.java

@@ -0,0 +1,10 @@
+package com.agenticcp.core.domain.tenant.controller.cloud.dto;
+
+import java.util.Map;
+
+public record VpcRequest(
+        String cidrBlock,
+        String region,
+        Map<String, String> tags
+) {
+}

src/main/java/com/agenticcp/core/domain/tenant/controller/cloud/service/CloudProviderService.java

@@ -0,0 +1,24 @@
+package com.agenticcp.core.domain.tenant.controller.cloud.service;
+
+
+import com.agenticcp.core.domain.tenant.controller.cloud.CloudProviderType;
+import com.agenticcp.core.domain.tenant.controller.cloud.dto.CloudResourceResult;
+import com.agenticcp.core.domain.tenant.controller.cloud.dto.SecurityGroupRequest;
+import com.agenticcp.core.domain.tenant.controller.cloud.dto.SubnetRequest;
+import com.agenticcp.core.domain.tenant.controller.cloud.dto.VpcRequest;
+
+public interface CloudProviderService {
+
+    CloudProviderType getCloudProviderType();
+
+    CloudResourceResult createVpc(String tenantKey, VpcRequest vpcRequest);
+
+    CloudResourceResult createSubnets(String tenantKey, SubnetRequest subnetRequest);
+
+    CloudResourceResult createSecurityGroups(String tenantKey, SecurityGroupRequest securityGroupRequest);
+
+
+
+
+
+}