System creation module

Dockerfile

@@ -5,7 +5,7 @@ FROM gradle:7.4.2-jdk17 AS dependencies
 
 WORKDIR /home/gradle/usvision
 
-RUN mkdir app-analyses app-model app-persistence app-reports app-web \
+RUN mkdir app-analyses app-model app-persistence app-reports app-web app-creation \
     && chown gradle:gradle . -R
 
 USER gradle
@@ -20,6 +20,7 @@ COPY --chown=gradle:gradle  app-model/build.gradle.kts          app-model/gradle
 COPY --chown=gradle:gradle  app-persistence/build.gradle.kts    app-persistence/gradle.properties   ./app-persistence/
 COPY --chown=gradle:gradle  app-reports/build.gradle.kts        app-reports/gradle.properties       ./app-reports/
 COPY --chown=gradle:gradle  app-web/build.gradle.kts            app-web/gradle.properties           ./app-web/
+COPY --chown=gradle:gradle  app-creation/build.gradle.kts       app-creation/gradle.properties      ./app-creation
 
 
 # PRE-INSTALL JUST THE DEPENDENCIES -- THIS SHALL SPEEDUP FUTURE BUILDS

app-creation/build.gradle.kts

@@ -0,0 +1,24 @@
+val mockk_version: String by project
+
+plugins {
+    `java-library`
+    kotlin("jvm")
+    kotlin("plugin.serialization")
+}
+
+group = "com.usvision.reports"
+version = "0.0.1"
+
+repositories {
+    mavenCentral()
+}
+
+tasks.test {
+    useJUnitPlatform()
+}
+
+dependencies {
+    implementation(project(":app-model"))
+    testImplementation("io.mockk:mockk:${mockk_version}")
+    testImplementation(kotlin("test"))
+}

app-creation/gradle.properties

@@ -0,0 +1,2 @@
+mockk_version=1.12.3
+kotlin.code.style=official

app-creation/src/main/kotlin/com/usvision/creation/SystemAggregateStorage.kt

@@ -0,0 +1,13 @@
+package com.usvision.creation
+
+import com.usvision.model.domain.CompanySystem
+import com.usvision.model.domain.Microservice
+import com.usvision.model.systemcomposite.System
+
+interface SystemAggregateStorage {
+    fun getSystem(name: String): System?
+    fun save(microservice: Microservice): Microservice
+    fun save(companySystem: CompanySystem): CompanySystem
+    fun getCompanySystem(name: String): CompanySystem?
+    fun getMicroservice(name: String): Microservice?
+}

app-creation/src/main/kotlin/com/usvision/creation/SystemCreator.kt

@@ -0,0 +1,99 @@
+package com.usvision.creation
+
+import com.usvision.model.domain.CompanySystem
+import com.usvision.model.domain.MessageChannel
+import com.usvision.model.domain.Microservice
+import com.usvision.model.domain.databases.Database
+import com.usvision.model.domain.operations.Operation
+import com.usvision.model.systemcomposite.System
+
+typealias CompanySystemDTO = CompanySystem
+typealias SystemDTO = System
+typealias MicroserviceDTO = Microservice
+typealias DatabaseDTO = Database
+
+class SystemCreator(
+    private val systemAggregateStorage: SystemAggregateStorage
+) {
+
+    fun createCompanySystem(companySystem: CompanySystemDTO, fatherSystemName: String? = null): CompanySystemDTO {
+        checkIfSystemAlreadyExists(companySystem.name)
+
+        fatherSystemName?.also {
+            val fatherSystem = systemAggregateStorage.getCompanySystem(fatherSystemName)
+
+            return@createCompanySystem fatherSystem?.let {
+                fatherSystem.addSubsystem(companySystem)
+                systemAggregateStorage.save(fatherSystem)
+            } ?: throw Exception("A System Of Systems with name $fatherSystemName does not exist")
+        }
+
+        return systemAggregateStorage.save(companySystem)
+    }
+
+    fun createMicroservice(microservice: MicroserviceDTO, fatherSystemName: String? = null): SystemDTO {
+        checkIfSystemAlreadyExists(microservice.name)
+
+        fatherSystemName?.also {
+            val fatherSystem = systemAggregateStorage.getCompanySystem(fatherSystemName)
+
+            return@createMicroservice fatherSystem?.let {
+                fatherSystem.addSubsystem(microservice)
+                systemAggregateStorage.save(fatherSystem)
+            } ?: throw Exception("A System Of Systems with name $fatherSystemName does not exist")
+        }
+
+        return systemAggregateStorage.save(microservice)
+    }
+
+    fun addNewDatabaseConnectionToMicroservice(
+        database: DatabaseDTO,
+        microserviceName: String
+    ) = getExistingMicroservice(microserviceName).let {
+        it.addDatabaseConnection(database)
+        systemAggregateStorage.save(it)
+    }
+
+    fun addOperationsToMicroservice(
+        exposedOperations: List<Operation>,
+        consumedOperations: List<Operation>,
+        microserviceName: String
+    ) = getExistingMicroservice(microserviceName).let {
+        exposedOperations.forEach {
+            operation ->  it.exposeOperation(operation)
+        }
+
+        consumedOperations.forEach {
+            operation -> it.consumeOperation(operation)
+        }
+
+        systemAggregateStorage.save(it)
+    }
+
+    fun addMessageChannelsToMicroservice(
+        publishMessageChannels: List<MessageChannel>,
+        subscribedMessageChannels: List<MessageChannel>,
+        microserviceName: String
+    ) = getExistingMicroservice(microserviceName).let {
+        publishMessageChannels.forEach {
+            operation ->  it.addPublishChannel(operation)
+        }
+
+        subscribedMessageChannels.forEach {
+            operation ->  it.addSubscribedChannel(operation)
+        }
+
+        systemAggregateStorage.save(it)
+    }
+
+    private fun getExistingMicroservice(
+        microserviceName: String
+    ) = systemAggregateStorage.getMicroservice(microserviceName)
+        ?: throw Exception("A Microservice with name $microserviceName does not exist")
+
+    private fun checkIfSystemAlreadyExists(name: String) {
+        systemAggregateStorage.getSystem(name)?.also {
+            throw Exception("A system with name $name already exists")
+        }
+    }
+}