Added view for all demo projects (#1860)

Author: nulls

save-backend/src/main/kotlin/com/saveourtool/save/backend/controllers/DemoManagerController.kt

@@ -271,7 +271,7 @@ class DemoManagerController(
         }
         .flatMap {
             webClientDemo.get()
-                .uri("/demo/internal/manager/$organizationName/$projectName/status")
+                .uri("/demo/api/manager/$organizationName/$projectName/status")
                 .retrieve()
                 .onStatus({ it == HttpStatus.NOT_FOUND }) {
                     Mono.error(
@@ -312,7 +312,7 @@ class DemoManagerController(
         }
         .flatMap {
             webClientDemo.get()
-                .uri("/demo/internal/manager/$organizationName/$projectName")
+                .uri("/demo/api/manager/$organizationName/$projectName")
                 .retrieve()
                 .onStatus({ it == HttpStatus.NOT_FOUND }) {
                     Mono.error(

save-demo/src/main/kotlin/com/saveourtool/save/demo/controller/DemoController.kt

@@ -1,19 +1,23 @@
 package com.saveourtool.save.demo.controller
 
 import com.saveourtool.save.configs.ApiSwaggerSupport
+import com.saveourtool.save.demo.DemoDto
 import com.saveourtool.save.demo.DemoResult
 import com.saveourtool.save.demo.DemoRunRequest
 import com.saveourtool.save.demo.runners.cli.CliRunnerFactory
 import com.saveourtool.save.demo.service.DemoService
 import com.saveourtool.save.demo.utils.KOTLIN_TEST_NAME
+import com.saveourtool.save.utils.blockingToFlux
 import com.saveourtool.save.utils.blockingToMono
 import io.swagger.v3.oas.annotations.tags.Tag
 import io.swagger.v3.oas.annotations.tags.Tags
+import org.springframework.web.bind.annotation.GetMapping
 import org.springframework.web.bind.annotation.PathVariable
 import org.springframework.web.bind.annotation.PostMapping
 import org.springframework.web.bind.annotation.RequestBody
 import org.springframework.web.bind.annotation.RequestMapping
 import org.springframework.web.bind.annotation.RestController
+import reactor.core.publisher.Flux
 import reactor.core.publisher.Mono
 import kotlin.io.path.createTempDirectory
 
@@ -25,20 +29,28 @@ import kotlin.io.path.createTempDirectory
     Tag(name = "demo"),
 )
 @RestController
-@RequestMapping("/demo/api/{organizationName}/{projectName}")
+@RequestMapping("/demo/api")
 class DemoController(
     private val demoService: DemoService,
     private val demoCliRunnerFactory: CliRunnerFactory,
 ) {
     private val tmpDir = createTempDirectory("demo-")
 
+    /**
+     * @return all [DemoDto]s as [Flux]
+     */
+    @GetMapping("/all")
+    fun all(): Flux<DemoDto> = blockingToFlux {
+        demoService.getAllDemos().map { it.toDto() }
+    }
+
     /**
      * @param organizationName
      * @param projectName
      * @param demoRunRequest request data class with all required additional info
      * @return [DemoResult]
      */
-    @PostMapping("/run")
+    @PostMapping("/{organizationName}/{projectName}/run")
     fun runCheckDemo(
         @PathVariable organizationName: String,
         @PathVariable projectName: String,

save-demo/src/main/kotlin/com/saveourtool/save/demo/controller/ManagementApiController.kt

@@ -0,0 +1,84 @@
+package com.saveourtool.save.demo.controller
+
+import com.saveourtool.save.demo.DemoInfo
+import com.saveourtool.save.demo.DemoStatus
+import com.saveourtool.save.demo.entity.*
+import com.saveourtool.save.demo.service.*
+import com.saveourtool.save.utils.*
+import io.swagger.v3.oas.annotations.tags.Tag
+import io.swagger.v3.oas.annotations.tags.Tags
+
+import org.springframework.web.bind.annotation.*
+import reactor.core.publisher.Mono
+import reactor.kotlin.core.util.function.component1
+import reactor.kotlin.core.util.function.component2
+
+/**
+ * Controller that allows to query management's api
+ */
+@Tags(
+    Tag(name = "demo"),
+    Tag(name = "management"),
+)
+@RestController
+@RequestMapping("/demo/api/manager")
+class ManagementApiController(
+    private val toolService: ToolService,
+    private val demoService: DemoService,
+) {
+    /**
+     * @param organizationName name of GitHub user/organization
+     * @param projectName name of GitHub repository
+     * @return [Mono] of [DemoStatus] of current demo
+     */
+    @GetMapping("/{organizationName}/{projectName}/status")
+    fun getDemoStatus(
+        @PathVariable organizationName: String,
+        @PathVariable projectName: String,
+    ): Mono<DemoStatus> = demoService.findBySaveourtoolProjectOrNotFound(organizationName, projectName) {
+        "Could not find demo for $organizationName/$projectName."
+    }
+        .map {
+            /*
+             * todo:
+             * kubernetesService.getStatus(it)
+             */
+            DemoStatus.STOPPED
+        }
+
+    /**
+     * @param organizationName name of GitHub user/organization
+     * @param projectName name of GitHub repository
+     * @return [Mono] of [DemoStatus] of current demo
+     */
+    @GetMapping("/{organizationName}/{projectName}")
+    fun getDemoInfo(
+        @PathVariable organizationName: String,
+        @PathVariable projectName: String,
+    ): Mono<DemoInfo> = demoService.findBySaveourtoolProjectOrNotFound(organizationName, projectName) {
+        "Could not find demo for $organizationName/$projectName."
+    }
+        .zipWith(getDemoStatus(organizationName, projectName))
+        .map { (demo, status) ->
+            DemoInfo(
+                demo.toDto().copy(vcsTagName = ""),
+                status,
+            )
+        }
+        .zipWhen { demoInfo ->
+            blockingToMono {
+                demoInfo.demoDto
+                    .githubProjectCoordinates
+                    ?.let { repo ->
+                        toolService.findCurrentVersion(repo)
+                    } ?: "manual"
+            }
+        }
+        .map { (demoInfo, currentVersion) ->
+            demoInfo.copy(
+                demoDto = demoInfo.demoDto.copy(
+                    vcsTagName = currentVersion
+                )
+            )
+        }
+}