v1.1.0

src/main/kotlin/com/dcd/server/core/common/error/ErrorCode.kt

@@ -22,6 +22,8 @@ enum class ErrorCode(
     ALREADY_EXISTS_DOMAIN("이미 존재하는 도메인", 400),
     ALREADY_CONNECTED_DOMAIN("이미 연결된 도메인", 400),
     NOT_CONNECTED_DOMAIN("도메인이 애플리케이션에 연결되어 있지 않음", 400),
+    ALREADY_EXISTS_VOLUME("이미 존재하는 볼륨", 400),
+    ALREADY_EXISTS_VOLUME_MOUNT("볼륨 마운트가 존재합니다.", 400),
 
     UNAUTHORIZED("권한이 없음", 401),
     EXPIRED_TOKEN("토큰이 만료됨", 401),
@@ -44,6 +46,8 @@ enum class ErrorCode(
     WORKSPACE_NOT_FOUND("해당 워크스페이스를 찾을 수 없음", 404),
     AUTH_CODE_NOT_FOUND("인증 코드를 찾을 수 없습니다. 코드를 다시 전송 해주세요.", 404),
     DOMAIN_NOT_FOUND("해당 도메인을 찾을 수 없음", 404),
+    VOLUME_NOT_FOUND("해당 볼륨을 찾을 수 없음", 404),
+    VOLUME_MOUNT_NOT_FOUND("해당 볼륨 마운트를 찾을 수 없음", 404),
 
     CONFLICT("해당 요청은 서버의 상태와 충돌됩니다.", 409),
     CAN_NOT_DEPLOY_APPLICATION("애플리케이션을 배포할 수 없습니다. 애플리케이션을 정지시킨 후 실행해주세요.", 409),
@@ -59,4 +63,7 @@ enum class ErrorCode(
     IMAGE_NOT_BUILT("해당 애플리케이션을 이미지로 빌드할 수 없음", 500),
     INTERNAL_ERROR("서버 내부 에러", 500),
     INVALID_PARSING_OBJECT_FIELD("파싱할 필드가 올바르게 설정되어있지 않는 객체임", 500),
+    FAILURE_VOLUME_CREATION("컨테이너 볼륨 생성에 실패했습니다.", 500),
+    FAILURE_VOLUME_DELETE("컨테이너 볼륨 삭제에 실패했습니다.", 500),
+    FAILURE_VOLUME_COPY("컨테이너 볼륨 복제에 실패했습니다.", 500),
 }

src/main/kotlin/com/dcd/server/core/common/file/FileContent.kt

@@ -47,12 +47,21 @@ object FileContent {
         ${getEnvString(env)}
        """.trimIndent()
 
-    fun getImageVersionShellScriptContent(imageName: String, minVersion: String): String =
+    fun getH2DBDockerFileContent(version: String, port: Int, env: Map<String, String>): String =
         """
+        FROM oscarfonts/h2:${version}
+        EXPOSE $port
+        ${getEnvString(env)}
+        """.trimIndent()
+
+    fun getImageVersionShellScriptContent(imageName: String, minVersion: String): String {
+        val imagePrefix = if (imageName.contains("/")) "" else "library/"
+
+        return """
         #!/bin/bash
 
         # 이미지, 페이지 사이즈, 최소 버전(threshold) 설정
-        IMAGE_NAME="library/$imageName"
+        IMAGE_NAME="${imagePrefix}$imageName"
         PAGE_SIZE=100
         MIN_VERSION="$minVersion"
 
@@ -100,6 +109,7 @@ object FileContent {
             echo "${'$'}sorted_numeric_tags"
         fi
         """.trimIndent()
+    }
 
     fun getApplicationHttpConfig(application: Application, domain: String): String =
         """
@@ -118,7 +128,7 @@ object FileContent {
             proxy_set_header X-Real-IP ${'$'}remote_addr;
             proxy_set_header X-Forwarded-For ${'$'}proxy_add_x_forwarded_for;
 
-            proxy_pass http://host.docker.internal:${application.externalPort};
+            proxy_pass http://${application.containerName}:${application.externalPort};
           }
         }
         """.trimIndent()

src/main/kotlin/com/dcd/server/core/domain/application/model/enums/ApplicationType.kt

@@ -5,5 +5,6 @@ enum class ApplicationType {
     NEST_JS,
     MYSQL,
     MARIA_DB,
-    REDIS
+    REDIS,
+    H2_DB
 }

src/main/kotlin/com/dcd/server/core/domain/application/service/impl/CreateContainerServiceImpl.kt

@@ -5,21 +5,34 @@ import com.dcd.server.core.domain.application.model.Application
 import com.dcd.server.core.domain.application.service.CreateContainerService
 import com.dcd.server.core.domain.application.spi.CheckExitValuePort
 import com.dcd.server.core.domain.application.util.FailureCase
+import com.dcd.server.core.domain.volume.spi.QueryVolumePort
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.withContext
 import org.springframework.stereotype.Service
 
 @Service
 class CreateContainerServiceImpl(
     private val commandPort: CommandPort,
+    private val queryVolumePort: QueryVolumePort,
     private val checkExitValuePort: CheckExitValuePort
 ) : CreateContainerService {
     override suspend fun createContainer(application: Application, externalPort: Int) {
         withContext(Dispatchers.IO) {
+            val volumeMountBuilder = StringBuilder()
+            queryVolumePort.findAllMountByApplication(application)
+                .forEach {
+                    val volume = it.volume
+                    volumeMountBuilder.append("-v ${volume.volumeName}:${it.mountPath}")
+                    if (it.readOnly)
+                        volumeMountBuilder.append(":ro")
+                    volumeMountBuilder.append(" ")
+                }
+            val volumeMountFlags = volumeMountBuilder.toString()
             val cmd =
                 "docker create --network ${application.workspace.networkName} " +
-                        "--name ${application.containerName} " +
-                        "-p ${externalPort}:${application.port} ${application.containerName}:latest"
+                "--name ${application.containerName} " +
+                volumeMountFlags +
+                "-p ${externalPort}:${application.port} ${application.containerName}:latest"
 
             commandPort.executeShellCommand(cmd)
                 .also {exitValue ->

src/main/kotlin/com/dcd/server/core/domain/application/service/impl/CreateDockerFileServiceImpl.kt

@@ -80,6 +80,9 @@ class CreateDockerFileServiceImpl(
 
             ApplicationType.NEST_JS ->
                 FileContent.getNestJsDockerFileContent(version, application.port, applicationEnv)
+
+            ApplicationType.H2_DB ->
+                FileContent.getH2DBDockerFileContent(version, application.port, applicationEnv)
         }
         try {
             if (!file.exists())

src/main/kotlin/com/dcd/server/core/domain/application/service/impl/GetApplicationVersionServiceImpl.kt

@@ -17,6 +17,7 @@ class GetApplicationVersionServiceImpl(
             ApplicationType.MARIA_DB -> "mariadb" to "10"
             ApplicationType.MYSQL -> "mysql" to "8"
             ApplicationType.REDIS -> "redis" to "6"
+            ApplicationType.H2_DB -> "oscarfonts/h2" to "0"
         }
         val getVersionScript = FileContent.getImageVersionShellScriptContent(baseImageName, minVersion)
         return commandPort.executeShellCommandWithResult(getVersionScript)

src/main/kotlin/com/dcd/server/core/domain/volume/dto/extension/VolumeDtoExtension.kt

@@ -0,0 +1,50 @@
+package com.dcd.server.core.domain.volume.dto.extension
+
+import com.dcd.server.core.domain.application.dto.extenstion.toProfileDto
+import com.dcd.server.core.domain.volume.dto.request.CreateVolumeReqDto
+import com.dcd.server.core.domain.volume.dto.request.UpdateVolumeReqDto
+import com.dcd.server.core.domain.volume.dto.response.VolumeDetailResDto
+import com.dcd.server.core.domain.volume.dto.response.VolumeMountResDto
+import com.dcd.server.core.domain.volume.dto.response.VolumeSimpleResDto
+import com.dcd.server.core.domain.volume.model.Volume
+import com.dcd.server.core.domain.volume.model.VolumeMount
+import com.dcd.server.core.domain.workspace.model.Workspace
+import java.util.UUID
+
+fun CreateVolumeReqDto.toEntity(workspace: Workspace): Volume =
+    Volume(
+        id = UUID.randomUUID(),
+        name = this.name,
+        description = this.description,
+        workspace = workspace,
+    )
+
+fun UpdateVolumeReqDto.toEntity(volume: Volume): Volume =
+    Volume(
+        id = volume.id,
+        name = this.name,
+        description = this.description,
+        workspace = volume.workspace,
+    )
+
+fun Volume.toResDto(): VolumeSimpleResDto =
+    VolumeSimpleResDto(
+        id = this.id,
+        name = this.name,
+        description = this.description
+    )
+
+fun Volume.toDetailResDto(volumeMountList: List<VolumeMount>): VolumeDetailResDto =
+    VolumeDetailResDto(
+        id = this.id,
+        name = this.name,
+        description = this.description,
+        mountList = volumeMountList.map { it.toResDto() }
+    )
+
+fun VolumeMount.toResDto(): VolumeMountResDto =
+    VolumeMountResDto(
+        mountPath = this.mountPath,
+        readOnly = this.readOnly,
+        applicationInfo = this.application.toProfileDto()
+    )

src/main/kotlin/com/dcd/server/core/domain/volume/dto/request/CreateVolumeReqDto.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.dto.request
+
+data class CreateVolumeReqDto(
+    val name: String,
+    val description: String
+)

src/main/kotlin/com/dcd/server/core/domain/volume/dto/request/MountVolumeReqDto.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.dto.request
+
+data class MountVolumeReqDto(
+    val mountPath: String,
+    val readOnly: Boolean,
+)

src/main/kotlin/com/dcd/server/core/domain/volume/dto/request/UpdateVolumeReqDto.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.dto.request
+
+data class UpdateVolumeReqDto(
+    val name: String,
+    val description: String
+)

src/main/kotlin/com/dcd/server/core/domain/volume/dto/response/VolumeDetailResDto.kt

@@ -0,0 +1,10 @@
+package com.dcd.server.core.domain.volume.dto.response
+
+import java.util.UUID
+
+data class VolumeDetailResDto(
+    val id: UUID,
+    val name: String,
+    val description: String,
+    val mountList: List<VolumeMountResDto>
+)

src/main/kotlin/com/dcd/server/core/domain/volume/dto/response/VolumeListResDto.kt

@@ -0,0 +1,5 @@
+package com.dcd.server.core.domain.volume.dto.response
+
+data class VolumeListResDto(
+    val list: List<VolumeSimpleResDto>
+)

src/main/kotlin/com/dcd/server/core/domain/volume/dto/response/VolumeMountResDto.kt

@@ -0,0 +1,9 @@
+package com.dcd.server.core.domain.volume.dto.response
+
+import com.dcd.server.core.domain.application.dto.response.ApplicationProfileResDto
+
+data class VolumeMountResDto(
+    val mountPath: String,
+    val readOnly: Boolean,
+    val applicationInfo: ApplicationProfileResDto
+)

src/main/kotlin/com/dcd/server/core/domain/volume/dto/response/VolumeSimpleResDto.kt

@@ -0,0 +1,9 @@
+package com.dcd.server.core.domain.volume.dto.response
+
+import java.util.UUID
+
+data class VolumeSimpleResDto(
+    val id: UUID,
+    val name: String,
+    val description: String
+)

src/main/kotlin/com/dcd/server/core/domain/volume/exception/AlreadyExistsVolumeException.kt

@@ -0,0 +1,8 @@
+package com.dcd.server.core.domain.volume.exception
+
+import com.dcd.server.core.common.error.BasicException
+import com.dcd.server.core.common.error.ErrorCode
+
+class AlreadyExistsVolumeException : BasicException(ErrorCode.ALREADY_EXISTS_VOLUME){
+
+}

src/main/kotlin/com/dcd/server/core/domain/volume/exception/AlreadyExistsVolumeMountException.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.exception
+
+import com.dcd.server.core.common.error.BasicException
+import com.dcd.server.core.common.error.ErrorCode
+
+class AlreadyExistsVolumeMountException : BasicException(ErrorCode.ALREADY_EXISTS_VOLUME_MOUNT)

src/main/kotlin/com/dcd/server/core/domain/volume/exception/VolumeCopyFailureException.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.exception
+
+import com.dcd.server.core.common.error.BasicException
+import com.dcd.server.core.common.error.ErrorCode
+
+class VolumeCopyFailureException : BasicException(ErrorCode.FAILURE_VOLUME_COPY)

src/main/kotlin/com/dcd/server/core/domain/volume/exception/VolumeCreationFailureException.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.exception
+
+import com.dcd.server.core.common.error.BasicException
+import com.dcd.server.core.common.error.ErrorCode
+
+class VolumeCreationFailureException : BasicException(ErrorCode.FAILURE_VOLUME_CREATION)

src/main/kotlin/com/dcd/server/core/domain/volume/exception/VolumeDeleteFailureException.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.exception
+
+import com.dcd.server.core.common.error.BasicException
+import com.dcd.server.core.common.error.ErrorCode
+
+class VolumeDeleteFailureException : BasicException(ErrorCode.FAILURE_VOLUME_DELETE)

src/main/kotlin/com/dcd/server/core/domain/volume/exception/VolumeMountNotFoundException.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.exception
+
+import com.dcd.server.core.common.error.BasicException
+import com.dcd.server.core.common.error.ErrorCode
+
+class VolumeMountNotFoundException : BasicException(ErrorCode.VOLUME_MOUNT_NOT_FOUND)

src/main/kotlin/com/dcd/server/core/domain/volume/exception/VolumeNotFoundException.kt

@@ -0,0 +1,6 @@
+package com.dcd.server.core.domain.volume.exception
+
+import com.dcd.server.core.common.error.BasicException
+import com.dcd.server.core.common.error.ErrorCode
+
+class VolumeNotFoundException : BasicException(ErrorCode.VOLUME_NOT_FOUND)

src/main/kotlin/com/dcd/server/core/domain/volume/model/Volume.kt

@@ -0,0 +1,13 @@
+package com.dcd.server.core.domain.volume.model
+
+import com.dcd.server.core.domain.workspace.model.Workspace
+import java.util.UUID
+
+class Volume(
+    val id: UUID,
+    val name: String,
+    val description: String,
+    val workspace: Workspace
+) {
+    val volumeName: String = "${name.replace(" ", "_")}-$id"
+}

src/main/kotlin/com/dcd/server/core/domain/volume/model/VolumeMount.kt

@@ -0,0 +1,11 @@
+package com.dcd.server.core.domain.volume.model
+
+import com.dcd.server.core.domain.application.model.Application
+import java.util.UUID
+
+class VolumeMount(
+    val application: Application,
+    val volume: Volume,
+    val mountPath: String,
+    val readOnly: Boolean
+)

src/main/kotlin/com/dcd/server/core/domain/volume/service/CopyVolumeService.kt

@@ -0,0 +1,7 @@
+package com.dcd.server.core.domain.volume.service
+
+import com.dcd.server.core.domain.volume.model.Volume
+
+interface CopyVolumeService {
+    fun copyVolumeContent(existingVolume: Volume, newVolume: Volume)
+}

src/main/kotlin/com/dcd/server/core/domain/volume/service/CreateVolumeService.kt

@@ -0,0 +1,7 @@
+package com.dcd.server.core.domain.volume.service
+
+import com.dcd.server.core.domain.volume.model.Volume
+
+interface CreateVolumeService {
+    fun create(volume: Volume)
+}

src/main/kotlin/com/dcd/server/core/domain/volume/service/DeleteVolumeService.kt

@@ -0,0 +1,7 @@
+package com.dcd.server.core.domain.volume.service
+
+import com.dcd.server.core.domain.volume.model.Volume
+
+interface DeleteVolumeService {
+    fun deleteVolume(volume: Volume)
+}

src/main/kotlin/com/dcd/server/core/domain/volume/service/impl/CopyDockerVolumeServiceImpl.kt

@@ -0,0 +1,30 @@
+package com.dcd.server.core.domain.volume.service.impl
+
+import com.dcd.server.core.common.command.CommandPort
+import com.dcd.server.core.domain.volume.exception.VolumeCopyFailureException
+import com.dcd.server.core.domain.volume.model.Volume
+import com.dcd.server.core.domain.volume.service.CopyVolumeService
+import com.dcd.server.core.domain.volume.service.DeleteVolumeService
+import org.springframework.stereotype.Service
+
+@Service
+class CopyDockerVolumeServiceImpl(
+    private val commandPort: CommandPort,
+    private val deleteVolumeService: DeleteVolumeService
+) : CopyVolumeService {
+    override fun copyVolumeContent(existingVolume: Volume, newVolume: Volume) {
+        val volumeCopyCmd =
+            """
+                docker run --rm -it \
+                    -v ${existingVolume.volumeName}:/from \
+                    -v ${newVolume.volumeName}:/to \
+                    alpine ash -c \"cp -a /from/. /to/\"
+            """.trimIndent()
+
+        val exitValue = commandPort.executeShellCommand(volumeCopyCmd)
+        if (exitValue != 0) {
+            deleteVolumeService.deleteVolume(newVolume)
+            throw VolumeCopyFailureException()
+        }
+    }
+}