[RELEASE] - Bump version

- add NodesController
  - add NodesEndpoint
  - add NodesControllerTest
  - add NodesController
  - add nodes.http

- add NodeEntity toNodesResponse in Mapping.kt

- add getNodes to NodeService

- add findAll to NodeRepository

gradle.properties

@@ -1,4 +1,4 @@
 kotlin.code.style=official
-version=0.6.0
-catalog=0.11.0
+version=0.8.0-SNAPSHOT
+catalog=0.12.0
 container.port.host=9010

http/devices.http

@@ -0,0 +1,17 @@
+### get all types
+GET {{hostname}}/devices
+
+### get all types
+GET {{hostname}}/devices/page-1
+
+### get all types
+GET {{hostname}}/devices/page-1/show-2
+
+### get all types
+GET {{hostname}}/devices/type-00000000-0000-0000-0000-000000000000
+
+### get all types
+GET {{hostname}}/devices/type-00000000-0000-0000-0000-000000000000/page-1
+
+### get all types
+GET {{hostname}}/devices/type-00000000-0000-0000-0000-000000000000/page-1/show-2

http/nodes.http

@@ -0,0 +1,8 @@
+### get all types
+GET {{hostname}}/nodes
+
+### get all types
+GET {{hostname}}/nodes/page-1
+
+### get all types
+GET {{hostname}}/nodes/page-1/show-2

src/main/kotlin/ltd/hlaeja/controller/DevicesController.kt

@@ -0,0 +1,43 @@
+package ltd.hlaeja.controller
+
+import jakarta.validation.constraints.Min
+import java.util.UUID
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.map
+import ltd.hlaeja.library.deviceRegistry.Devices
+import ltd.hlaeja.service.DeviceService
+import ltd.hlaeja.util.Pagination.DEFAULT_PAGE
+import ltd.hlaeja.util.Pagination.DEFAULT_SIZE
+import ltd.hlaeja.util.toDevicesResponse
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PathVariable
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+class DevicesController(
+    private val deviceService: DeviceService,
+) {
+
+    @GetMapping(
+        "/devices",
+        "/devices/page-{page}",
+        "/devices/page-{page}/show-{show}",
+    )
+    suspend fun getDevices(
+        @PathVariable(required = false) @Min(1) page: Int = DEFAULT_PAGE,
+        @PathVariable(required = false) @Min(1) show: Int = DEFAULT_SIZE,
+    ): Flow<Devices.Response> = deviceService.getDevices((page - 1) * show, show)
+        .map { it.toDevicesResponse() }
+
+    @GetMapping(
+        "/devices/type-{type}",
+        "/devices/type-{type}/page-{page}",
+        "/devices/type-{type}/page-{page}/show-{show}",
+    )
+    suspend fun getDevicesByType(
+        @PathVariable type: UUID,
+        @PathVariable(required = false) @Min(1) page: Int = DEFAULT_PAGE,
+        @PathVariable(required = false) @Min(1) show: Int = DEFAULT_SIZE,
+    ): Flow<Devices.Response> = deviceService.getDevicesByType(type, (page - 1) * show, show)
+        .map { it.toDevicesResponse() }
+}

src/main/kotlin/ltd/hlaeja/controller/NodesController.kt

@@ -0,0 +1,30 @@
+package ltd.hlaeja.controller
+
+import jakarta.validation.constraints.Min
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.map
+import ltd.hlaeja.library.deviceRegistry.Nodes
+import ltd.hlaeja.service.NodeService
+import ltd.hlaeja.util.Pagination.DEFAULT_PAGE
+import ltd.hlaeja.util.Pagination.DEFAULT_SIZE
+import ltd.hlaeja.util.toNodesResponse
+import org.springframework.web.bind.annotation.GetMapping
+import org.springframework.web.bind.annotation.PathVariable
+import org.springframework.web.bind.annotation.RestController
+
+@RestController
+class NodesController(
+    private val service: NodeService,
+) {
+
+    @GetMapping(
+        "/nodes",
+        "/nodes/page-{page}",
+        "/nodes/page-{page}/show-{show}",
+    )
+    suspend fun getNodes(
+        @PathVariable(required = false) @Min(1) page: Int = DEFAULT_PAGE,
+        @PathVariable(required = false) @Min(1) show: Int = DEFAULT_SIZE,
+    ): Flow<Nodes.Response> = service.getNodes((page - 1) * show, show)
+        .map { it.toNodesResponse() }
+}

src/main/kotlin/ltd/hlaeja/controller/TypesController.kt

@@ -5,6 +5,8 @@ import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.map
 import ltd.hlaeja.library.deviceRegistry.Types
 import ltd.hlaeja.service.TypeService
+import ltd.hlaeja.util.Pagination.DEFAULT_PAGE
+import ltd.hlaeja.util.Pagination.DEFAULT_SIZE
 import ltd.hlaeja.util.toTypesResponse
 import org.springframework.web.bind.annotation.GetMapping
 import org.springframework.web.bind.annotation.PathVariable
@@ -14,10 +16,6 @@ import org.springframework.web.bind.annotation.RestController
 class TypesController(
     private val service: TypeService,
 ) {
-    companion object {
-        const val DEFAULT_PAGE: Int = 1
-        const val DEFAULT_SIZE: Int = 25
-    }
 
     @GetMapping(
         "/types",
@@ -27,7 +25,7 @@ class TypesController(
         "/types/filter-{filter}/page-{page}",
         "/types/filter-{filter}/page-{page}/show-{show}",
     )
-    fun getTypes(
+    suspend fun getTypes(
         @PathVariable(required = false) @Min(1) page: Int = DEFAULT_PAGE,
         @PathVariable(required = false) @Min(1) show: Int = DEFAULT_SIZE,
         @PathVariable(required = false) filter: String? = null,

src/main/kotlin/ltd/hlaeja/repository/DeviceRepository.kt

@@ -1,9 +1,26 @@
 package ltd.hlaeja.repository
 
 import java.util.UUID
+import kotlinx.coroutines.flow.Flow
 import ltd.hlaeja.entity.DeviceEntity
+import org.springframework.data.r2dbc.repository.Query
 import org.springframework.data.repository.kotlin.CoroutineCrudRepository
+import org.springframework.data.repository.query.Param
 import org.springframework.stereotype.Repository
 
 @Repository
-interface DeviceRepository : CoroutineCrudRepository<DeviceEntity, UUID>
+interface DeviceRepository : CoroutineCrudRepository<DeviceEntity, UUID> {
+
+    @Query("SELECT * FROM devices LIMIT :limit OFFSET :offset")
+    fun findAll(
+        @Param("offset") offset: Int,
+        @Param("limit") limit: Int,
+    ): Flow<DeviceEntity>
+
+    @Query("SELECT * FROM devices WHERE type = :type LIMIT :limit OFFSET :offset")
+    fun findAllByType(
+        @Param("type") type: UUID,
+        @Param("offset") offset: Int,
+        @Param("limit") limit: Int,
+    ): Flow<DeviceEntity>
+}

src/main/kotlin/ltd/hlaeja/repository/NodeRepository.kt

@@ -1,9 +1,11 @@
 package ltd.hlaeja.repository
 
 import java.util.UUID
+import kotlinx.coroutines.flow.Flow
 import ltd.hlaeja.entity.NodeEntity
 import org.springframework.data.r2dbc.repository.Query
 import org.springframework.data.repository.kotlin.CoroutineCrudRepository
+import org.springframework.data.repository.query.Param
 import org.springframework.stereotype.Repository
 
 @Repository
@@ -11,4 +13,10 @@ interface NodeRepository : CoroutineCrudRepository<NodeEntity, UUID> {
 
     @Query("SELECT * FROM nodes WHERE device = :device")
     suspend fun findByDevice(device: UUID): NodeEntity?
+
+    @Query("SELECT * FROM nodes LIMIT :limit OFFSET :offset")
+    suspend fun findAll(
+        @Param("offset") offset: Int,
+        @Param("limit") limit: Int,
+    ): Flow<NodeEntity>
 }

src/main/kotlin/ltd/hlaeja/repository/TypeRepository.kt

@@ -13,13 +13,13 @@ import org.springframework.stereotype.Repository
 interface TypeRepository : CoroutineCrudRepository<TypeEntity, UUID> {
 
     @Query("SELECT * FROM types ORDER BY name LIMIT :limit OFFSET :offset")
-    fun findAll(
+    suspend fun findAll(
         @Param("offset") offset: Int,
         @Param("limit") limit: Int,
     ): Flow<TypeEntity>
 
     @Query("SELECT * FROM types WHERE name ILIKE :filter ORDER BY name LIMIT :limit OFFSET :offset")
-    fun findAllContaining(
+    suspend fun findAllContaining(
         @Param("filter") filter: String,
         @Param("offset") offset: Int,
         @Param("limit") limit: Int,

src/main/kotlin/ltd/hlaeja/service/DeviceService.kt

@@ -3,6 +3,7 @@ package ltd.hlaeja.service
 import io.github.oshai.kotlinlogging.KotlinLogging
 import java.time.ZonedDateTime
 import java.util.UUID
+import kotlinx.coroutines.flow.Flow
 import ltd.hlaeja.entity.DeviceEntity
 import ltd.hlaeja.repository.DeviceRepository
 import org.springframework.dao.DataIntegrityViolationException
@@ -31,4 +32,15 @@ class DeviceService(
     suspend fun getDevice(device: UUID): DeviceEntity = deviceRepository.findById(device)
         ?.also { log.debug { "Get device ${it.id}" } }
         ?: throw ResponseStatusException(NOT_FOUND)
+
+    suspend fun getDevices(
+        page: Int,
+        show: Int,
+    ): Flow<DeviceEntity> = deviceRepository.findAll(page, show)
+
+    suspend fun getDevicesByType(
+        type: UUID,
+        page: Int,
+        show: Int,
+    ): Flow<DeviceEntity> = deviceRepository.findAllByType(type, page, show)
 }

src/main/kotlin/ltd/hlaeja/service/NodeService.kt

@@ -2,6 +2,7 @@ package ltd.hlaeja.service
 
 import io.github.oshai.kotlinlogging.KotlinLogging
 import java.util.UUID
+import kotlinx.coroutines.flow.Flow
 import ltd.hlaeja.entity.NodeEntity
 import ltd.hlaeja.repository.NodeRepository
 import org.springframework.dao.DataIntegrityViolationException
@@ -29,4 +30,9 @@ class NodeService(
         device: UUID,
     ): NodeEntity = nodeRepository.findByDevice(device)
         ?: throw ResponseStatusException(NOT_FOUND)
+
+    suspend fun getNodes(
+        page: Int,
+        show: Int,
+    ): Flow<NodeEntity> = nodeRepository.findAll(page, show)
 }

src/main/kotlin/ltd/hlaeja/service/TypeService.kt

@@ -26,7 +26,7 @@ class TypeService(
     private val typeDescriptionRepository: TypeDescriptionRepository,
 ) {
 
-    fun getTypes(
+    suspend fun getTypes(
         page: Int,
         show: Int,
         filter: String?,

src/main/kotlin/ltd/hlaeja/util/Mapping.kt

@@ -2,15 +2,17 @@ package ltd.hlaeja.util
 
 import java.time.ZonedDateTime
 import java.util.UUID
+import ltd.hlaeja.dto.TypeWithDescription
 import ltd.hlaeja.entity.DeviceEntity
 import ltd.hlaeja.entity.NodeEntity
-import ltd.hlaeja.entity.TypeEntity
-import ltd.hlaeja.dto.TypeWithDescription
 import ltd.hlaeja.entity.TypeDescriptionEntity
+import ltd.hlaeja.entity.TypeEntity
 import ltd.hlaeja.jwt.service.PrivateJwtService
 import ltd.hlaeja.library.deviceRegistry.Device
+import ltd.hlaeja.library.deviceRegistry.Devices
 import ltd.hlaeja.library.deviceRegistry.Identity
 import ltd.hlaeja.library.deviceRegistry.Node
+import ltd.hlaeja.library.deviceRegistry.Nodes
 import ltd.hlaeja.library.deviceRegistry.Type
 import ltd.hlaeja.library.deviceRegistry.Types
 import org.springframework.http.HttpStatus.EXPECTATION_FAILED
@@ -68,3 +70,17 @@ fun DeviceEntity.toDeviceResponse(
     type,
     jwtService.sign("device" to id),
 )
+
+fun DeviceEntity.toDevicesResponse(): Devices.Response = Devices.Response(
+    id ?: throw ResponseStatusException(EXPECTATION_FAILED),
+    type,
+    timestamp,
+)
+
+fun NodeEntity.toNodesResponse(): Nodes.Response = Nodes.Response(
+    id ?: throw ResponseStatusException(EXPECTATION_FAILED),
+    timestamp,
+    client,
+    device,
+    name,
+)

src/main/kotlin/ltd/hlaeja/util/Pagination.kt

@@ -0,0 +1,6 @@
+package ltd.hlaeja.util
+
+object Pagination {
+    const val DEFAULT_PAGE: Int = 1
+    const val DEFAULT_SIZE: Int = 25
+}

src/test-integration/kotlin/ltd/hlaeja/controller/DeviceEndpoint.kt

@@ -3,7 +3,7 @@ package ltd.hlaeja.controller
 import java.util.UUID
 import ltd.hlaeja.library.deviceRegistry.Device
 import ltd.hlaeja.test.compareToFile
-import ltd.hlaeja.test.container.PostgresContainer
+import ltd.hlaeja.test.container.PostgresTestContainer
 import ltd.hlaeja.test.isEqualToUuid
 import org.assertj.core.api.SoftAssertions
 import org.assertj.core.api.junit.jupiter.InjectSoftAssertions
@@ -18,7 +18,7 @@ import org.springframework.boot.test.web.server.LocalServerPort
 import org.springframework.test.web.reactive.server.WebTestClient
 import org.springframework.test.web.reactive.server.expectBody
 
-@PostgresContainer
+@PostgresTestContainer
 @SpringBootTest(webEnvironment = RANDOM_PORT)
 @ExtendWith(SoftAssertionsExtension::class)
 class DeviceEndpoint {

src/test-integration/kotlin/ltd/hlaeja/controller/DevicesEndpoint.kt

@@ -0,0 +1,201 @@
+package ltd.hlaeja.controller
+
+import java.util.UUID
+import ltd.hlaeja.library.deviceRegistry.Devices
+import ltd.hlaeja.test.container.PostgresTestContainer
+import org.assertj.core.api.Assertions.assertThat
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Nested
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.params.ParameterizedTest
+import org.junit.jupiter.params.provider.CsvSource
+import org.springframework.boot.test.context.SpringBootTest
+import org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT
+import org.springframework.boot.test.web.server.LocalServerPort
+import org.springframework.test.web.reactive.server.WebTestClient
+import org.springframework.test.web.reactive.server.expectBody
+
+@PostgresTestContainer
+@SpringBootTest(webEnvironment = RANDOM_PORT)
+class DevicesEndpoint {
+
+    @LocalServerPort
+    var port: Int = 0
+
+    lateinit var webClient: WebTestClient
+
+    @BeforeEach
+    fun setup() {
+        webClient = WebTestClient.bindToServer().baseUrl("http://localhost:$port").build()
+    }
+
+    @Nested
+    inner class GetDevices {
+
+        @Test
+        fun `get devices default - success`() {
+            // when
+            val result = webClient.get().uri("/devices").exchange()
+
+            // then
+            result.expectStatus().isOk()
+                .expectBody<List<Devices.Response>>()
+                .consumeWith {
+                    assertThat(it.responseBody?.size).isEqualTo(4)
+                }
+        }
+
+        @ParameterizedTest
+        @CsvSource(
+            value = [
+                "1,4",
+                "2,0",
+            ],
+        )
+        fun `get devices by page - success`(page: Int, expected: Int) {
+            // when
+            val result = webClient.get().uri("/devices/page-$page").exchange()
+
+            // then
+            result.expectStatus().isOk()
+                .expectBody<List<Devices.Response>>()
+                .consumeWith {
+                    assertThat(it.responseBody?.size).isEqualTo(expected)
+                }
+        }
+
+        @Test
+        fun `get devices by pages - fail`() {
+            // when
+            val result = webClient.get().uri("/devices/page-0").exchange()
+
+            // then
+            result.expectStatus().isBadRequest
+        }
+
+        @ParameterizedTest
+        @CsvSource(
+            value = [
+                "1,2,2",
+                "2,2,2",
+                "3,2,0",
+            ],
+        )
+        fun `get devices by page and show - success`(page: Int, show: Int, expected: Int) {
+            // when
+            val result = webClient.get().uri("/devices/page-$page/show-$show").exchange()
+
+            // then
+            result.expectStatus().isOk()
+                .expectBody<List<Devices.Response>>()
+                .consumeWith {
+                    assertThat(it.responseBody?.size).isEqualTo(expected)
+                }
+        }
+
+        @ParameterizedTest
+        @CsvSource(
+            value = [
+                "0,1",
+                "1,0",
+            ],
+        )
+        fun `get devices by page and show - fail`(page: Int, show: Int) {
+            // when
+            val result = webClient.get().uri("/devices/page-$page/show-$show").exchange()
+
+            // then
+            result.expectStatus().isBadRequest
+        }
+    }
+
+    @Nested
+    inner class GetDevicesByType {
+
+        @Test
+        fun `get devices for type default - success`() {
+            // when
+            val result = webClient.get()
+                .uri("/devices/type-00000000-0000-0000-0001-000000000001")
+                .exchange()
+
+            // then
+            result.expectStatus().isOk()
+                .expectBody<List<Devices.Response>>()
+                .consumeWith {
+                    assertThat(it.responseBody?.size).isEqualTo(2)
+                }
+        }
+
+        @ParameterizedTest
+        @CsvSource(
+            value = [
+                "00000000-0000-0000-0001-000000000001,1,2",
+                "00000000-0000-0000-0001-000000000001,2,0",
+            ],
+        )
+        fun `get devices for type by page - success`(type: UUID, page: Int, expected: Int) {
+            // when
+            val result = webClient.get()
+                .uri("/devices/type-$type/page-$page")
+                .exchange()
+
+            // then
+            result.expectStatus().isOk()
+                .expectBody<List<Devices.Response>>()
+                .consumeWith {
+                    assertThat(it.responseBody?.size).isEqualTo(expected)
+                }
+        }
+
+        @Test
+        fun `get devices for type by pages - fail`() {
+            // when
+            val result = webClient.get()
+                .uri("/devices/type-00000000-0000-0000-0001-000000000001/page-0")
+                .exchange()
+
+            // then
+            result.expectStatus().isBadRequest
+        }
+
+        @ParameterizedTest
+        @CsvSource(
+            value = [
+                "00000000-0000-0000-0001-000000000001,1,1,1",
+                "00000000-0000-0000-0001-000000000001,2,1,1",
+                "00000000-0000-0000-0001-000000000001,3,1,0",
+            ],
+        )
+        fun `get devices for type by page and show - success`(type: UUID, page: Int, show: Int, expected: Int) {
+            // when
+            val result = webClient.get()
+                .uri("/devices/type-$type/page-$page/show-$show")
+                .exchange()
+
+            // then
+            result.expectStatus().isOk()
+                .expectBody<List<Devices.Response>>()
+                .consumeWith {
+                    assertThat(it.responseBody?.size).isEqualTo(expected)
+                }
+        }
+
+        @ParameterizedTest
+        @CsvSource(
+            value = [
+                "0,1",
+                "1,0",
+            ],
+        )
+        fun `get devices for type by page and show - fail`(page: Int, show: Int) {
+            // when
+            val result = webClient.get()
+                .uri("/devices/type-00000000-0000-0000-0001-000000000001/page-$page/show-$show")
+                .exchange()
+
+            // then
+            result.expectStatus().isBadRequest
+        }
+    }
+}

src/test-integration/kotlin/ltd/hlaeja/controller/IdentityEndpoint.kt

@@ -2,7 +2,7 @@ package ltd.hlaeja.controller
 
 import java.util.UUID
 import ltd.hlaeja.library.deviceRegistry.Identity
-import ltd.hlaeja.test.container.PostgresContainer
+import ltd.hlaeja.test.container.PostgresTestContainer
 import ltd.hlaeja.test.isEqualToUuid
 import org.assertj.core.api.SoftAssertions
 import org.assertj.core.api.junit.jupiter.InjectSoftAssertions
@@ -16,7 +16,7 @@ import org.springframework.boot.test.web.server.LocalServerPort
 import org.springframework.test.web.reactive.server.WebTestClient
 import org.springframework.test.web.reactive.server.expectBody
 
-@PostgresContainer
+@PostgresTestContainer
 @SpringBootTest(webEnvironment = RANDOM_PORT)
 @ExtendWith(SoftAssertionsExtension::class)
 class IdentityEndpoint {

src/test-integration/kotlin/ltd/hlaeja/controller/NodeEndpoint.kt

@@ -2,7 +2,7 @@ package ltd.hlaeja.controller
 
 import java.util.UUID
 import ltd.hlaeja.library.deviceRegistry.Node
-import ltd.hlaeja.test.container.PostgresContainer
+import ltd.hlaeja.test.container.PostgresTestContainer
 import org.assertj.core.api.SoftAssertions
 import org.assertj.core.api.junit.jupiter.InjectSoftAssertions
 import org.assertj.core.api.junit.jupiter.SoftAssertionsExtension
@@ -17,7 +17,7 @@ import org.springframework.boot.test.web.server.LocalServerPort
 import org.springframework.test.web.reactive.server.WebTestClient
 import org.springframework.test.web.reactive.server.expectBody
 
-@PostgresContainer
+@PostgresTestContainer
 @SpringBootTest(webEnvironment = RANDOM_PORT)
 @ExtendWith(SoftAssertionsExtension::class)
 class NodeEndpoint {

src/test-integration/kotlin/ltd/hlaeja/controller/NodesEndpoint.kt

@@ -0,0 +1,113 @@
+package ltd.hlaeja.controller
+
+import ltd.hlaeja.library.deviceRegistry.Nodes
+import ltd.hlaeja.test.container.PostgresTestContainer
+import org.assertj.core.api.Assertions.assertThat
+import org.assertj.core.api.SoftAssertions
+import org.assertj.core.api.junit.jupiter.InjectSoftAssertions
+import org.assertj.core.api.junit.jupiter.SoftAssertionsExtension
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.extension.ExtendWith
+import org.junit.jupiter.params.ParameterizedTest
+import org.junit.jupiter.params.provider.CsvSource
+import org.springframework.boot.test.context.SpringBootTest
+import org.springframework.boot.test.context.SpringBootTest.WebEnvironment.RANDOM_PORT
+import org.springframework.boot.test.web.server.LocalServerPort
+import org.springframework.test.web.reactive.server.WebTestClient
+import org.springframework.test.web.reactive.server.expectBody
+
+@PostgresTestContainer
+@SpringBootTest(webEnvironment = RANDOM_PORT)
+@ExtendWith(SoftAssertionsExtension::class)
+class NodesEndpoint {
+
+    @InjectSoftAssertions
+    lateinit var softly: SoftAssertions
+
+    @LocalServerPort
+    var port: Int = 0
+
+    lateinit var webClient: WebTestClient
+
+    @BeforeEach
+    fun setup() {
+        webClient = WebTestClient.bindToServer().baseUrl("http://localhost:$port").build()
+    }
+
+    @Test
+    fun `get nodes default - success`() {
+        // when
+        val result = webClient.get().uri("/nodes").exchange()
+
+        // then
+        result.expectStatus().isOk()
+            .expectBody<List<Nodes.Response>>()
+            .consumeWith {
+                assertThat(it.responseBody?.size).isEqualTo(3)
+            }
+    }
+
+    @ParameterizedTest
+    @CsvSource(
+        value = [
+            "1,3",
+            "2,0",
+        ],
+    )
+    fun `get nodes by page - success`(page: Int, expected: Int) {
+        // when
+        val result = webClient.get().uri("/nodes/page-$page").exchange()
+
+        // then
+        result.expectStatus().isOk()
+            .expectBody<List<Nodes.Response>>()
+            .consumeWith {
+                assertThat(it.responseBody?.size).isEqualTo(expected)
+            }
+    }
+
+    @Test
+    fun `get nodes by pages - fail`() {
+        // when
+        val result = webClient.get().uri("/nodes/page-0").exchange()
+
+        // then
+        result.expectStatus().isBadRequest
+    }
+
+    @ParameterizedTest
+    @CsvSource(
+        value = [
+            "1,2,2",
+            "2,2,1",
+            "3,2,0",
+        ],
+    )
+    fun `get nodes by page and show - success`(page: Int, show: Int, expected: Int) {
+        // when
+        val result = webClient.get().uri("/nodes/page-$page/show-$show").exchange()
+
+        // then
+        result.expectStatus().isOk()
+            .expectBody<List<Nodes.Response>>()
+            .consumeWith {
+                assertThat(it.responseBody?.size).isEqualTo(expected)
+            }
+    }
+
+    @ParameterizedTest
+    @CsvSource(
+        value = [
+            "0,1",
+            "1,0",
+        ],
+    )
+    fun `get nodes by page and show - fail`(page: Int, show: Int) {
+        // when
+        val result = webClient.get().uri("/nodes/page-$page/show-$show").exchange()
+
+        // then
+        result.expectStatus().isBadRequest
+    }
+}

src/test-integration/kotlin/ltd/hlaeja/controller/TypeEndpoint.kt

@@ -1,7 +1,7 @@
 package ltd.hlaeja.controller
 
 import ltd.hlaeja.library.deviceRegistry.Type
-import ltd.hlaeja.test.container.PostgresContainer
+import ltd.hlaeja.test.container.PostgresTestContainer
 import ltd.hlaeja.test.isEqualToUuid
 import org.assertj.core.api.SoftAssertions
 import org.assertj.core.api.junit.jupiter.InjectSoftAssertions
@@ -21,7 +21,7 @@ import org.springframework.http.MediaType.APPLICATION_JSON
 import org.springframework.test.web.reactive.server.WebTestClient
 import org.springframework.test.web.reactive.server.expectBody
 
-@PostgresContainer
+@PostgresTestContainer
 @SpringBootTest(webEnvironment = RANDOM_PORT)
 @ExtendWith(SoftAssertionsExtension::class)
 class TypeEndpoint {

src/test-integration/kotlin/ltd/hlaeja/controller/TypesEndpoint.kt

@@ -1,11 +1,10 @@
 package ltd.hlaeja.controller
 
 import ltd.hlaeja.library.deviceRegistry.Types
-import ltd.hlaeja.test.container.PostgresContainer
+import ltd.hlaeja.test.container.PostgresTestContainer
 import org.assertj.core.api.Assertions.assertThat
 import org.junit.jupiter.api.BeforeEach
 import org.junit.jupiter.api.Test
-import org.junit.jupiter.api.TestInstance
 import org.junit.jupiter.params.ParameterizedTest
 import org.junit.jupiter.params.provider.CsvSource
 import org.springframework.boot.test.context.SpringBootTest
@@ -14,9 +13,8 @@ import org.springframework.boot.test.web.server.LocalServerPort
 import org.springframework.test.web.reactive.server.WebTestClient
 import org.springframework.test.web.reactive.server.expectBody
 
-@PostgresContainer
+@PostgresTestContainer
 @SpringBootTest(webEnvironment = RANDOM_PORT)
-@TestInstance(TestInstance.Lifecycle.PER_CLASS)
 class TypesEndpoint {
 
     @LocalServerPort

src/test-integration/resources/application.yml

@@ -6,10 +6,3 @@ spring:
     url: r2dbc:postgresql://placeholder
     username: placeholder
     password: placeholder
-
-container:
-  postgres:
-    version: postgres:17
-    init: postgres/schema.sql
-    before: postgres/data.sql
-    after: postgres/reset.sql

src/test/kotlin/ltd/hlaeja/controller/DevicesControllerTest.kt

@@ -0,0 +1,72 @@
+package ltd.hlaeja.controller
+
+import io.mockk.coEvery
+import io.mockk.coVerify
+import io.mockk.mockk
+import java.time.LocalDateTime
+import java.time.ZoneId
+import java.time.ZonedDateTime
+import java.util.UUID
+import kotlinx.coroutines.flow.flowOf
+import kotlinx.coroutines.flow.single
+import kotlinx.coroutines.test.runTest
+import ltd.hlaeja.entity.DeviceEntity
+import ltd.hlaeja.service.DeviceService
+import ltd.hlaeja.test.isEqualToUuid
+import org.assertj.core.api.Assertions.assertThat
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Test
+
+class DevicesControllerTest {
+    companion object {
+        const val NIL_UUID: String = "00000000-0000-0000-0000-000000000000"
+        val id: UUID = UUID.fromString(NIL_UUID)
+        val type: UUID = UUID.fromString(NIL_UUID)
+        val timestamp: ZonedDateTime = ZonedDateTime.of(LocalDateTime.of(2000, 1, 1, 0, 0, 0, 1), ZoneId.of("UTC"))
+    }
+
+    val service: DeviceService = mockk()
+
+    lateinit var controller: DevicesController
+
+    @BeforeEach
+    fun setUp() {
+        controller = DevicesController(service)
+    }
+
+    @Test
+    fun `get all devices`() = runTest {
+        // given
+        coEvery {
+            service.getDevices(any(), any())
+        } returns flowOf(DeviceEntity(id, timestamp, type))
+
+        // when
+        val response = controller.getDevices().single()
+
+        // then
+        coVerify(exactly = 1) { service.getDevices(0, 25) }
+
+        assertThat(response.id).isEqualToUuid(NIL_UUID)
+        assertThat(response.type).isEqualToUuid(NIL_UUID)
+        assertThat(response.timestamp).isEqualTo(timestamp)
+    }
+
+    @Test
+    fun `get all devices for type`() = runTest {
+        // given
+        coEvery {
+            service.getDevicesByType(any(), any(), any())
+        } returns flowOf(DeviceEntity(id, timestamp, type))
+
+        // when
+        val response = controller.getDevicesByType(type).single()
+
+        // then
+        coVerify(exactly = 1) { service.getDevicesByType(type, 0, 25) }
+
+        assertThat(response.id).isEqualToUuid(NIL_UUID)
+        assertThat(response.type).isEqualToUuid(NIL_UUID)
+        assertThat(response.timestamp).isEqualTo(timestamp)
+    }
+}

src/test/kotlin/ltd/hlaeja/controller/NodesControllerTest.kt

@@ -0,0 +1,58 @@
+package ltd.hlaeja.controller
+
+import io.mockk.coEvery
+import io.mockk.coVerify
+import io.mockk.mockk
+import java.time.LocalDateTime
+import java.time.ZoneId
+import java.time.ZonedDateTime
+import java.util.UUID
+import kotlinx.coroutines.flow.flowOf
+import kotlinx.coroutines.flow.single
+import kotlinx.coroutines.test.runTest
+import ltd.hlaeja.entity.NodeEntity
+import ltd.hlaeja.service.NodeService
+import ltd.hlaeja.test.isEqualToUuid
+import org.assertj.core.api.Assertions.assertThat
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Test
+
+class NodesControllerTest {
+    companion object {
+        const val NAME: String = "My Device"
+        const val NIL_UUID: String = "00000000-0000-0000-0000-000000000000"
+        val id: UUID = UUID.fromString(NIL_UUID)
+        val client: UUID = UUID.fromString(NIL_UUID)
+        val device: UUID = UUID.fromString(NIL_UUID)
+        val timestamp: ZonedDateTime = ZonedDateTime.of(LocalDateTime.of(2000, 1, 1, 0, 0, 0, 1), ZoneId.of("UTC"))
+    }
+
+    val service: NodeService = mockk()
+
+    lateinit var controller: NodesController
+
+    @BeforeEach
+    fun setUp() {
+        controller = NodesController(service)
+    }
+
+    @Test
+    fun `get all nodes`() = runTest {
+        // given
+        coEvery {
+            service.getNodes(any(), any())
+        } returns flowOf(NodeEntity(id, timestamp, client, device, NAME))
+
+        // when
+        val response = controller.getNodes().single()
+
+        // then
+        coVerify(exactly = 1) { service.getNodes(0, 25) }
+
+        assertThat(response.id).isEqualToUuid(NIL_UUID)
+        assertThat(response.timestamp).isEqualTo(timestamp)
+        assertThat(response.client).isEqualToUuid(NIL_UUID)
+        assertThat(response.device).isEqualToUuid(NIL_UUID)
+        assertThat(response.name).isEqualTo(NAME)
+    }
+}

src/test/kotlin/ltd/hlaeja/controller/TypesControllerTest.kt

@@ -1,8 +1,8 @@
 package ltd.hlaeja.controller
 
-import io.mockk.every
+import io.mockk.coEvery
+import io.mockk.coVerify
 import io.mockk.mockk
-import io.mockk.verify
 import java.time.LocalDateTime
 import java.time.ZoneId
 import java.time.ZonedDateTime
@@ -37,7 +37,7 @@ class TypesControllerTest {
     @Test
     fun `get all types`() = runTest {
         // given
-        every {
+        coEvery {
             service.getTypes(any(), any(), any())
         } returns flowOf(TypeEntity(id, timestamp, NAME))
 
@@ -45,7 +45,7 @@ class TypesControllerTest {
         val response = controller.getTypes().single()
 
         // then
-        verify(exactly = 1) { service.getTypes(0, 25, null) }
+        coVerify(exactly = 1) { service.getTypes(0, 25, null) }
 
         assertThat(response.id).isEqualToUuid(NIL_UUID)
         assertThat(response.name).isEqualTo(NAME)

src/test/kotlin/ltd/hlaeja/service/TypeServiceTest.kt

@@ -6,7 +6,6 @@ import io.mockk.every
 import io.mockk.mockk
 import io.mockk.mockkStatic
 import io.mockk.unmockkStatic
-import io.mockk.verify
 import java.time.LocalDateTime
 import java.time.ZoneId
 import java.time.ZonedDateTime
@@ -57,29 +56,29 @@ class TypeServiceTest {
     }
 
     @Test
-    fun `get all types`() {
+    fun `get all types`() = runTest {
         // given
-        every { typeRepository.findAll(any(), any()) } returns flowOf(mockk<TypeEntity>())
+        coEvery { typeRepository.findAll(any(), any()) } returns flowOf(mockk<TypeEntity>())
 
         // when
         service.getTypes(1, 10, null)
 
         // then
-        verify(exactly = 1) { typeRepository.findAll(1, 10) }
-        verify(exactly = 0) { typeRepository.findAllContaining(any(), any(), any()) }
+        coVerify(exactly = 1) { typeRepository.findAll(1, 10) }
+        coVerify(exactly = 0) { typeRepository.findAllContaining(any(), any(), any()) }
     }
 
     @Test
-    fun `get all types with filter`() {
+    fun `get all types with filter`() = runTest {
         // given
-        every { typeRepository.findAllContaining(any(), any(), any()) } returns flowOf(mockk<TypeEntity>())
+        coEvery { typeRepository.findAllContaining(any(), any(), any()) } returns flowOf(mockk<TypeEntity>())
 
         // when
         service.getTypes(1, 10, "abc")
 
         // then
-        verify(exactly = 1) { typeRepository.findAllContaining("%abc%", 1, 10) }
-        verify(exactly = 0) { typeRepository.findAll(any(), any()) }
+        coVerify(exactly = 1) { typeRepository.findAllContaining("%abc%", 1, 10) }
+        coVerify(exactly = 0) { typeRepository.findAll(any(), any()) }
     }
 
     @Test