Merge pull request #19 from IvanKondrashkov/homework-11

feat: Добавлены нагрузочные тесты, модуль hw09-back

build.gradle

@@ -30,6 +30,7 @@ allprojects {
         dependencies {
             imports {
                 //mavenBom("io.micronaut:micronaut-bom:3.10.4")
+                mavenBom("org.apache.jmeter:ApacheJMeter_bom:5.6.3")
             }
             dependency("com.google.guava:guava:${Versions.guava}")
             dependency("org.junit.jupiter:junit-jupiter:${Versions.junit_jupiter}")
@@ -38,6 +39,8 @@ allprojects {
             dependency("com.zaxxer:HikariCP:${Versions.hikari}")
             dependency("org.postgresql:postgresql:${Versions.postgres}")
             dependency("org.flywaydb:flyway-core:${Versions.flyway}")
+            dependency("com.google.code.gson:gson:${Versions.gson}")
+            dependency("us.abstracta.jmeter:jmeter-java-dsl:${Versions.jmeter_java_dsl}")
         }
     }
 

buildSrc/src/main/groovy/Versions.groovy

@@ -5,4 +5,6 @@ interface Versions {
     String hikari = '5.0.1'
     String postgres = '42.5.1'
     String flyway = '9.12.0'
+    String gson = '2.11.0'
+    String jmeter_java_dsl = '1.29.1'
 }

hw09-back/.micronaut/test-resources/test-resources-port.txt

@@ -1 +1 @@
-62748
+57245

hw09-back/build.gradle

@@ -22,6 +22,7 @@ dependencies {
     implementation 'io.micronaut.serde:micronaut-serde-jackson'
     implementation 'io.micronaut.sql:micronaut-hibernate-jpa'
     implementation 'io.micronaut.sql:micronaut-jdbc-hikari'
+    implementation 'com.google.code.gson:gson:2.11.0'
 
     compileOnly 'io.micronaut.data:micronaut-data-processor'
     compileOnly 'io.micronaut:micronaut-http-client'
@@ -34,6 +35,7 @@ dependencies {
     testImplementation 'org.testcontainers:postgresql'
     testImplementation 'org.testcontainers:testcontainers'
     testImplementation 'io.micronaut:micronaut-http-client'
+    testImplementation 'us.abstracta.jmeter:jmeter-java-dsl'
 
     testRuntimeOnly 'org.postgresql:postgresql'
 }

hw09-back/src/main/groovy/ru/otus/homework/util/LocalDateTimeAdapter.groovy

@@ -0,0 +1,30 @@
+package ru.otus.homework.util
+
+import java.time.LocalDateTime
+import com.google.gson.TypeAdapter
+import com.google.gson.stream.JsonToken
+import com.google.gson.stream.JsonReader
+import com.google.gson.stream.JsonWriter
+import java.time.format.DateTimeFormatter
+
+class LocalDateTimeAdapter extends TypeAdapter<LocalDateTime> {
+    private final DateTimeFormatter formatter = DateTimeFormatter.ISO_LOCAL_DATE_TIME
+
+    @Override
+    void write(JsonWriter jsonWriter, LocalDateTime date) throws IOException {
+        if (date == null) {
+            jsonWriter.nullValue()
+            return
+        }
+        jsonWriter.value(date.format(formatter))
+    }
+
+    @Override
+    LocalDateTime read(JsonReader jsonReader) throws IOException {
+        if (jsonReader.peek() == JsonToken.NULL) {
+            jsonReader.nextNull()
+            return null
+        }
+        return LocalDateTime.parse(jsonReader.nextString(), formatter)
+    }
+}

hw09-back/src/test/groovy/ru/otus/homework/perfomans/PerfomansTest.groovy

@@ -0,0 +1,133 @@
+package ru.otus.homework.perfomans
+
+import com.google.gson.Gson
+import com.google.gson.GsonBuilder
+import io.micronaut.context.annotation.Property
+import io.micronaut.test.extensions.spock.annotation.MicronautTest
+import java.time.Duration
+import java.time.LocalDateTime
+import spock.lang.Specification
+import ru.otus.homework.model.Task
+import ru.otus.homework.model.Action
+import org.apache.http.entity.ContentType
+import ru.otus.homework.util.LocalDateTimeAdapter
+import us.abstracta.jmeter.javadsl.core.TestPlanStats
+import static us.abstracta.jmeter.javadsl.JmeterDsl.*;
+
+@MicronautTest
+@Property(name = "datasources.default.driver-class-name", value = "org.testcontainers.jdbc.ContainerDatabaseDriver")
+@Property(name = "datasources.default.url", value = "jdbc:tc:postgresql:///db")
+class PerfomansTest extends Specification {
+    Task task
+    Action action
+    Gson gson
+
+    String taskId
+    String actionId
+
+    static final String BASE_URL = "http://localhost:9090"
+
+    def setup() {
+        task = new Task(
+                name: "learning",
+                description: "read book",
+                startDate: LocalDateTime.of(2024, 11, 1, 0, 0),
+                endDate: LocalDateTime.of(2024, 11, 10, 0, 0),
+        )
+        action = new Action(
+                name: "read",
+                description: "read math",
+                startDate: LocalDateTime.of(2024, 11, 2, 0, 0),
+                endDate: LocalDateTime.of(2024, 11, 3, 0, 0),
+                task: task
+        )
+        gson = new GsonBuilder()
+                .registerTypeAdapter(LocalDateTime.class, new LocalDateTimeAdapter())
+                .serializeNulls()
+                .create()
+    }
+
+    void cleanup() {
+        task = null
+        action = null
+        gson = null
+    }
+
+    def "saveTask"() {
+        when:
+        TestPlanStats stats = testPlan(
+                threadGroup(10, 20,
+                        httpSampler(BASE_URL + "/tasks")
+                                .post(gson.toJson(task), ContentType.APPLICATION_JSON)
+                                .children(
+                                        jsr223PostProcessor(
+                                                "if (prev.responseCode == '400') { prev.successful = true }")
+                                )
+                ),
+                jtlWriter("build/jtls"),
+                htmlReporter("build/reports/jmeter")
+        ).run()
+
+        then:
+        stats.overall().sampleTimePercentile99() <= Duration.ofSeconds(1)
+    }
+
+    def "saveAction"() {
+        when:
+        TestPlanStats stats = testPlan(
+                threadGroup(10, 20,
+                        httpSampler(BASE_URL + "/actions")
+                                .post(gson.toJson(action), ContentType.APPLICATION_JSON)
+                                .children(
+                                        jsr223PostProcessor(
+                                                "if (prev.responseCode == '400') { prev.successful = true }")
+                                )
+                ),
+                jtlWriter("build/jtls"),
+                htmlReporter("build/reports/jmeter")
+        ).run()
+
+        then:
+        stats.overall().sampleTimePercentile99() <= Duration.ofSeconds(1)
+    }
+
+    def "findByIdTask"() {
+        when:
+        TestPlanStats stats = testPlan(
+                threadGroup(10, 20,
+                        httpSampler(BASE_URL + "/tasks")
+                                .post(gson.toJson(task), ContentType.APPLICATION_JSON)
+                                .children(
+                                        jsonExtractor(taskId, "[].id"),
+                                        debugPostProcessor()
+                                ),
+                        httpSampler(BASE_URL + "/tasks/${taskId}")
+                ),
+                jtlWriter("build/jtls"),
+                htmlReporter("build/reports/jmeter")
+        ).run()
+
+        then:
+        stats.overall().sampleTimePercentile99() <= Duration.ofSeconds(1)
+    }
+
+    def "findByIdAction"() {
+        when:
+        TestPlanStats stats = testPlan(
+                threadGroup(10, 20,
+                        httpSampler(BASE_URL + "/actions")
+                                .post(gson.toJson(action), ContentType.APPLICATION_JSON)
+                                .children(
+                                        jsonExtractor(actionId, "[].id"),
+                                        debugPostProcessor()
+                                ),
+                        httpSampler(BASE_URL + "/actions/${actionId}")
+                ),
+                jtlWriter("build/jtls"),
+                htmlReporter("build/reports/jmeter")
+        ).run()
+
+        then:
+        stats.overall().sampleTimePercentile99() <= Duration.ofSeconds(1)
+    }
+}