added flux endpoint

ksidelta · Dec 21, 2023 · 750fb6b · 750fb6b
1 parent 5dfefbf
commit 750fb6b
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/README.md b/README.md
@@ -14,3 +14,7 @@
 
 Frontend is available at [http://localhost:3000/](http://localhost:3000/)
 Backend is available at [http://localhost:8080/](http://localhost:8080/)
+
+## SWAGGER
+
+http://localhost:8080/swagger-ui.html
diff --git a/backend/src/main/kotlin/com/ksidelta/libruch/modules/organisation/OrganisationController.kt b/backend/src/main/kotlin/com/ksidelta/libruch/modules/organisation/OrganisationController.kt
@@ -11,11 +11,14 @@ import org.axonframework.messaging.MetaData
 import org.axonframework.messaging.responsetypes.ResponseType
 import org.axonframework.messaging.responsetypes.ResponseTypes
 import org.axonframework.queryhandling.QueryGateway
+import org.springframework.http.MediaType
 import org.springframework.web.bind.annotation.GetMapping
 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 java.time.Duration
 import java.util.*
 import kotlin.reflect.KClass
 
@@ -47,6 +50,12 @@ class OrganisationController(
         )
             .await()
             .let { UserOrganisationViewModel(it) }
+
+    @GetMapping(path = ["/stream"], produces = [MediaType.TEXT_EVENT_STREAM_VALUE])
+    fun testServerSentEvents(user: Party.User): Flux<UserOrganisationViewModel> {
+        return Flux.interval(Duration.ofMillis(1000))
+            .map { UserOrganisationViewModel(listOf(UserOrganisationsView(UUID.randomUUID(), "xD"))) }
+    }
 }
 
 suspend fun EventBus.awaitingEvent(eventType: KClass<*>, block: suspend (correlationId: String) -> Unit) {