Merge branch 'main' into feature/group_dependencies

# Conflicts:
#	gradle/libs.versions.toml

Author: ashtanko

.github/workflows/build.yml

@@ -65,13 +65,6 @@ jobs:
       - name: Generate Test Coverage Xml Report
         run: ./gradlew koverXmlReport
 
-      - name: Upload test coverage to qlty
-        uses: qltysh/qlty-action/coverage@v2
-        with:
-          oidc: true
-          files: build/reports/jacoco/test/jacocoTestReport.xml
-          add-prefix: src/main/kotlin
-
       - name: Run codacy-coverage-reporter
         uses: codacy/codacy-coverage-reporter-action@v1
         with:

README.md

@@ -3,10 +3,8 @@
 <p align="center">
   <a href="https://github.com/ashtanko/kotlab/actions/workflows/build.yml"><img alt="Build" src="https://github.com/ashtanko/kotlab/actions/workflows/build.yml/badge.svg?branch=main"/></a>
   <a href="https://codecov.io/gh/ashtanko/kotlab"><img alt="Codecov" src="https://codecov.io/gh/ashtanko/kotlab/branch/main/graph/badge.svg?token=JEU9EIJMHA"/></a>
-  <a href="https://qlty.sh/gh/ashtanko/projects/kotlab"><img alt="Test Coverage" src="https://qlty.sh/gh/ashtanko/projects/kotlab/coverage.svg"/></a>
   <a href="https://app.codacy.com/gh/ashtanko/kotlab/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_coverage"><img alt="Codacy Coverage Badge" src="https://app.codacy.com/project/badge/Coverage/74cad08184b34038bb5c64c317384367"/></a>
   <a href="https://www.codefactor.io/repository/github/ashtanko/kotlin-lab"><img alt="CodeFactor" src="https://www.codefactor.io/repository/github/ashtanko/kotlin-lab/badge"/></a>
-  <a href="https://qlty.sh/gh/ashtanko/projects/kotlab"><img alt="Maintainability" src="https://qlty.sh/gh/ashtanko/projects/kotlab/maintainability.svg"/></a>
   <a href="https://app.codacy.com/gh/ashtanko/kotlab/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_grade"><img alt="Codacy Grade Badge" src="https://app.codacy.com/project/badge/Grade/74cad08184b34038bb5c64c317384367"/></a>
   <a href="https://codebeat.co/projects/github-com-ashtanko-kotlab-main"><img alt="Codebeat Badge" src="https://codebeat.co/badges/b5a26fee-b6d2-46f2-b121-c3d98cb13c9f"/></a>
   <a href="https://hitsofcode.com/github/ashtanko/kotlab/view?branch=main"><img alt="Hits-of-Code" src="https://hitsofcode.com/github/ashtanko/kotlab?branch=main"/></a>
@@ -22,23 +20,23 @@
 
 ### Metrics
 ```text
-15199 number of properties
-10523 number of functions
-8940 number of classes
-239 number of packages
-3531 number of kt files
+15288 number of properties
+10573 number of functions
+8954 number of classes
+240 number of packages
+3543 number of kt files
 ```
 
 
 ### Complexity Report
 ```text
-266642 lines of code (loc)
-165721 source lines of code (sloc)
-121060 logical lines of code (lloc)
-72547 comment lines of code (cloc)
-25022 cyclomatic complexity (mcc)
-20410 cognitive complexity
+267458 lines of code (loc)
+166374 source lines of code (sloc)
+121548 logical lines of code (lloc)
+72562 comment lines of code (cloc)
+25100 cyclomatic complexity (mcc)
+20431 cognitive complexity
 0 number of total code smells
 43 comment source ratio
 206 mcc per 1,000 lloc
-```
+```

api/Kotlin-Lab.api

@@ -19686,6 +19686,17 @@ public final class dev/shtanko/concurrency/coroutines/actors/ExampleKt {
 	public static synthetic fun main ([Ljava/lang/String;)V
 }
 
+public final class dev/shtanko/concurrency/coroutines/examples/AdvancedImageProcessingKt {
+	public static final fun applyRegionSpecificFilter (Ljava/awt/image/BufferedImage;)Ljava/awt/image/BufferedImage;
+	public static final fun blendSegment (Ljava/awt/image/BufferedImage;Ljava/awt/image/BufferedImage;)Ljava/awt/image/BufferedImage;
+	public static final fun detectEdges (Ljava/awt/image/BufferedImage;)Ljava/awt/image/BufferedImage;
+	public static final fun main ()V
+	public static synthetic fun main ([Ljava/lang/String;)V
+	public static final fun mergeSegments (Ljava/util/List;II)Ljava/awt/image/BufferedImage;
+	public static final fun processImageParallel (Ljava/awt/image/BufferedImage;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
+	public static final fun segmentImage (Ljava/awt/image/BufferedImage;I)Ljava/util/List;
+}
+
 public final class dev/shtanko/concurrency/coroutines/examples/AtomicBankTransfer : dev/shtanko/concurrency/coroutines/examples/IAtomicBankTransfer {
 	public static final field Companion Ldev/shtanko/concurrency/coroutines/examples/AtomicBankTransfer$Companion;
 	public fun <init> ()V
@@ -19733,6 +19744,8 @@ public abstract interface class dev/shtanko/concurrency/coroutines/examples/IAto
 }
 
 public final class dev/shtanko/concurrency/coroutines/examples/ImageProcessingKt {
+	public static final field MAX_COLOR I
+	public static final field MAX_COLOR_VALUE I
 	public static final fun adjustBrightness (Ljava/awt/image/BufferedImage;I)Ljava/awt/image/BufferedImage;
 	public static synthetic fun adjustBrightness$default (Ljava/awt/image/BufferedImage;IILjava/lang/Object;)Ljava/awt/image/BufferedImage;
 	public static final fun applySepia (Ljava/awt/image/BufferedImage;)Ljava/awt/image/BufferedImage;
@@ -21427,6 +21440,96 @@ public final class dev/shtanko/grasp/polymorphism/example1/Triangle : dev/shtank
 public final class dev/shtanko/grasp/polymorphism/example1/Triangle$Companion {
 }
 
+public abstract interface class dev/shtanko/http/ConnectionFactory {
+	public abstract fun invoke ()Ljava/sql/Connection;
+}
+
+public final class dev/shtanko/http/CustomInterceptor : okhttp3/Interceptor {
+	public static final field Companion Ldev/shtanko/http/CustomInterceptor$Companion;
+	public synthetic fun <init> (Ldev/shtanko/http/HttpLogger;Lkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public fun intercept (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
+}
+
+public final class dev/shtanko/http/CustomInterceptor$Companion {
+	public final fun create (Ldev/shtanko/http/HttpLogger;)Ldev/shtanko/http/CustomInterceptor;
+	public static synthetic fun create$default (Ldev/shtanko/http/CustomInterceptor$Companion;Ldev/shtanko/http/HttpLogger;ILjava/lang/Object;)Ldev/shtanko/http/CustomInterceptor;
+}
+
+public final class dev/shtanko/http/DbHttpLogger : dev/shtanko/http/HttpLogger {
+	public fun <init> (Ldev/shtanko/http/HttpLogRepository;)V
+	public fun logRequest (Lokhttp3/Request;)V
+	public fun logResponse (Lokhttp3/Response;D)V
+}
+
+public final class dev/shtanko/http/DefaultHttpLogger : dev/shtanko/http/HttpLogger {
+	public fun <init> ()V
+	public fun logRequest (Lokhttp3/Request;)V
+	public fun logResponse (Lokhttp3/Response;D)V
+}
+
+public final class dev/shtanko/http/FileSqliteConnectionFactory : dev/shtanko/http/ConnectionFactory {
+	public fun <init> ()V
+	public fun <init> (Ljava/lang/String;)V
+	public synthetic fun <init> (Ljava/lang/String;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public fun invoke ()Ljava/sql/Connection;
+}
+
+public final class dev/shtanko/http/HttpLogEntry {
+	public fun <init> (Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;DLjava/time/Instant;)V
+	public synthetic fun <init> (Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;DLjava/time/Instant;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
+	public final fun component1 ()Ljava/lang/Long;
+	public final fun component2 ()Ljava/lang/String;
+	public final fun component3 ()Ljava/lang/String;
+	public final fun component4 ()Ljava/lang/String;
+	public final fun component5 ()I
+	public final fun component6 ()Ljava/lang/String;
+	public final fun component7 ()D
+	public final fun component8 ()Ljava/time/Instant;
+	public final fun copy (Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;DLjava/time/Instant;)Ldev/shtanko/http/HttpLogEntry;
+	public static synthetic fun copy$default (Ldev/shtanko/http/HttpLogEntry;Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ILjava/lang/String;DLjava/time/Instant;ILjava/lang/Object;)Ldev/shtanko/http/HttpLogEntry;
+	public fun equals (Ljava/lang/Object;)Z
+	public final fun getDurationMs ()D
+	public final fun getId ()Ljava/lang/Long;
+	public final fun getMethod ()Ljava/lang/String;
+	public final fun getRequestHeaders ()Ljava/lang/String;
+	public final fun getResponseCode ()I
+	public final fun getResponseHeaders ()Ljava/lang/String;
+	public final fun getTimestamp ()Ljava/time/Instant;
+	public final fun getUrl ()Ljava/lang/String;
+	public fun hashCode ()I
+	public fun toString ()Ljava/lang/String;
+}
+
+public final class dev/shtanko/http/HttpLogRepository {
+	public static final field Companion Ldev/shtanko/http/HttpLogRepository$Companion;
+	public fun <init> (Ljava/sql/Connection;)V
+	public final fun count ()J
+	public final fun deleteOlderThan (Ljava/time/Instant;)I
+	public final fun getAll ()Ljava/util/List;
+	public final fun getById (J)Ldev/shtanko/http/HttpLogEntry;
+	public final fun getByUrlPattern (Ljava/lang/String;)Ljava/util/List;
+	public final fun init ()V
+	public final fun insert (Ldev/shtanko/http/HttpLogEntry;)V
+}
+
+public final class dev/shtanko/http/HttpLogRepository$Companion {
+}
+
+public abstract interface class dev/shtanko/http/HttpLogger {
+	public abstract fun logRequest (Lokhttp3/Request;)V
+	public abstract fun logResponse (Lokhttp3/Response;D)V
+}
+
+public final class dev/shtanko/http/InMemorySqliteConnectionFactory : dev/shtanko/http/ConnectionFactory {
+	public fun <init> ()V
+	public fun invoke ()Ljava/sql/Connection;
+}
+
+public final class dev/shtanko/http/Main {
+	public static final fun main ()V
+	public static synthetic fun main ([Ljava/lang/String;)V
+}
+
 public final class dev/shtanko/jmm/memory/ManualResourceManagementKt {
 	public static final fun readFromFile (Ljava/lang/String;)V
 }

build.gradle.kts

@@ -73,6 +73,14 @@ repositories {
 application {
     mainClass.set("link.kotlin.scripts.Application")
     mainClass.set("dev.shtanko.report.ReportParserKt")
+    mainClass.set("dev.shtanko.http.Main")
+}
+
+tasks.register<JavaExec>("dev.shtanko.http.Main.main()") {
+    mainClass.set("dev.shtanko.http.Main")
+    group = "application"
+    mainClass.set("dev.shtanko.http.Main")
+    classpath = sourceSets["main"].runtimeClasspath
 }
 
 pitest {
@@ -339,8 +347,8 @@ dependencies {
         implementation("org.openjdk.jol:jol-core:0.17")
         implementation("com.jakewharton.retrofit:retrofit2-kotlinx-serialization-converter:1.0.0")
         implementation(jsoup)
-        implementation("com.google.protobuf:protobuf-java:4.31.1")
-        implementation("com.google.protobuf:protobuf-kotlin-lite:4.31.1")
+        implementation("com.google.protobuf:protobuf-java:4.32.0")
+        implementation("com.google.protobuf:protobuf-kotlin-lite:4.32.0")
         implementation("io.grpc:grpc-stub:1.74.0")
         implementation("io.grpc:grpc-protobuf:1.74.0")
 
@@ -368,6 +376,7 @@ dependencies {
         testImplementation(turbine)
         testImplementation(truth)
     }
+    implementation("org.xerial:sqlite-jdbc:3.50.3.0")
     testImplementation("org.jetbrains.kotlin:kotlin-test-junit")
 }
 

config/main.md

@@ -3,10 +3,8 @@
 <p align="center">
   <a href="https://github.com/ashtanko/kotlab/actions/workflows/build.yml"><img alt="Build" src="https://github.com/ashtanko/kotlab/actions/workflows/build.yml/badge.svg?branch=main"/></a>
   <a href="https://codecov.io/gh/ashtanko/kotlab"><img alt="Codecov" src="https://codecov.io/gh/ashtanko/kotlab/branch/main/graph/badge.svg?token=JEU9EIJMHA"/></a>
-  <a href="https://qlty.sh/gh/ashtanko/projects/kotlab"><img alt="Test Coverage" src="https://qlty.sh/gh/ashtanko/projects/kotlab/coverage.svg"/></a>
   <a href="https://app.codacy.com/gh/ashtanko/kotlab/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_coverage"><img alt="Codacy Coverage Badge" src="https://app.codacy.com/project/badge/Coverage/74cad08184b34038bb5c64c317384367"/></a>
   <a href="https://www.codefactor.io/repository/github/ashtanko/kotlin-lab"><img alt="CodeFactor" src="https://www.codefactor.io/repository/github/ashtanko/kotlin-lab/badge"/></a>
-  <a href="https://qlty.sh/gh/ashtanko/projects/kotlab"><img alt="Maintainability" src="https://qlty.sh/gh/ashtanko/projects/kotlab/maintainability.svg"/></a>
   <a href="https://app.codacy.com/gh/ashtanko/kotlab/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_grade"><img alt="Codacy Grade Badge" src="https://app.codacy.com/project/badge/Grade/74cad08184b34038bb5c64c317384367"/></a>
   <a href="https://codebeat.co/projects/github-com-ashtanko-kotlab-main"><img alt="Codebeat Badge" src="https://codebeat.co/badges/b5a26fee-b6d2-46f2-b121-c3d98cb13c9f"/></a>
   <a href="https://hitsofcode.com/github/ashtanko/kotlab/view?branch=main"><img alt="Hits-of-Code" src="https://hitsofcode.com/github/ashtanko/kotlab?branch=main"/></a>

config/main.md.bak

@@ -3,10 +3,8 @@
 <p align="center">
   <a href="https://github.com/ashtanko/kotlab/actions/workflows/build.yml"><img alt="Build" src="https://github.com/ashtanko/kotlab/actions/workflows/build.yml/badge.svg?branch=main"/></a>
   <a href="https://codecov.io/gh/ashtanko/kotlab"><img alt="Codecov" src="https://codecov.io/gh/ashtanko/kotlab/branch/main/graph/badge.svg?token=JEU9EIJMHA"/></a>
-  <a href="https://qlty.sh/gh/ashtanko/projects/kotlab"><img alt="Test Coverage" src="https://qlty.sh/gh/ashtanko/projects/kotlab/coverage.svg"/></a>
   <a href="https://app.codacy.com/gh/ashtanko/kotlab/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_coverage"><img alt="Codacy Coverage Badge" src="https://app.codacy.com/project/badge/Coverage/74cad08184b34038bb5c64c317384367"/></a>
   <a href="https://www.codefactor.io/repository/github/ashtanko/kotlin-lab"><img alt="CodeFactor" src="https://www.codefactor.io/repository/github/ashtanko/kotlin-lab/badge"/></a>
-  <a href="https://qlty.sh/gh/ashtanko/projects/kotlab"><img alt="Maintainability" src="https://qlty.sh/gh/ashtanko/projects/kotlab/maintainability.svg"/></a>
   <a href="https://app.codacy.com/gh/ashtanko/kotlab/dashboard?utm_source=gh&utm_medium=referral&utm_content=&utm_campaign=Badge_grade"><img alt="Codacy Grade Badge" src="https://app.codacy.com/project/badge/Grade/74cad08184b34038bb5c64c317384367"/></a>
   <a href="https://codebeat.co/projects/github-com-ashtanko-kotlab-main"><img alt="Codebeat Badge" src="https://codebeat.co/badges/b5a26fee-b6d2-46f2-b121-c3d98cb13c9f"/></a>
   <a href="https://hitsofcode.com/github/ashtanko/kotlab/view?branch=main"><img alt="Hits-of-Code" src="https://hitsofcode.com/github/ashtanko/kotlab?branch=main"/></a>

gradle/libs.versions.toml

@@ -19,7 +19,7 @@ junit = "5.13.4"             # https://junit.org/junit5
 kotest = "5.9.1"             # https://kotest.io
 kotlintest = "3.4.2"         # https://mvnrepository.com/artifact/io.kotlintest/kotlintest-core
 assertj = "3.27.4"           # https://assertj.github.io/doc
-mockito = "5.18.0"           # https://mvnrepository.com/artifact/org.mockito/mockito-core
+mockito = "5.19.0"           # https://mvnrepository.com/artifact/org.mockito/mockito-core
 mockitoKotlin = "6.0.0"      # https://github.com/mockito/mockito-kotlin
 mockk = "1.14.5"             # https://mockk.io
 hamcrest = "3.0"             # https://hamcrest.org
@@ -39,8 +39,8 @@ retrofit = "3.0.0"           # https://github.com/square/retrofit
 okhttp = "5.1.0"             # https://square.github.io/okhttp/changelogs/changelog
 sandwich = "2.1.2"           # https://github.com/skydoves/sandwich
 protobufPlugin = "0.9.5"     # https://mvnrepository.com/artifact/com.google.protobuf/protobuf-gradle-plugin
-protobufKotlin = "4.31.1"    # https://mvnrepository.com/artifact/com.google.protobuf/protobuf-kotlin
-protoc = "4.31.1"            # https://mvnrepository.com/artifact/com.google.protobuf/protoc
+protobufKotlin = "4.32.0"    # https://mvnrepository.com/artifact/com.google.protobuf/protobuf-kotlin
+protoc = "4.32.0"            # https://mvnrepository.com/artifact/com.google.protobuf/protoc
 jsoup = "1.21.1"             # https://jsoup.org/
 
 # --- Dependency Injection ---

src/main/kotlin/dev/shtanko/concurrency/coroutines/examples/AdvancedImageProcessing.kt

@@ -0,0 +1,133 @@
+package dev.shtanko.concurrency.coroutines.examples
+
+import dev.shtanko.utils.ResourceFilePath
+import dev.shtanko.utils.readImageBytes
+import java.awt.Color
+import java.awt.image.BufferedImage
+import kotlin.math.sqrt
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.async
+import kotlinx.coroutines.awaitAll
+import kotlinx.coroutines.coroutineScope
+import kotlinx.coroutines.runBlocking
+
+private const val KERNEL_RADIUS = 1
+
+private val KERNEL_X = arrayOf(
+    intArrayOf(-1, 0, 1),
+    intArrayOf(-2, 0, 2),
+    intArrayOf(-1, 0, 1),
+)
+
+private val KERNEL_Y = arrayOf(
+    intArrayOf(-1, -2, -1),
+    intArrayOf(0, 0, 0),
+    intArrayOf(1, 2, 1),
+)
+
+suspend fun processImageParallel(image: BufferedImage): BufferedImage = coroutineScope {
+    val segments = segmentImage(image, numberOfSegments = 8)
+
+    val processedRegions = segments.map { segment ->
+        async(Dispatchers.Default) {
+            val edges = detectEdges(segment)
+            val filtered = applyRegionSpecificFilter(segment)
+            blendSegment(filtered, edges)
+        }
+    }
+
+    val finalImage = mergeSegments(processedRegions.awaitAll(), image.width, image.height)
+    return@coroutineScope finalImage
+}
+
+fun segmentImage(image: BufferedImage, numberOfSegments: Int): List<BufferedImage> {
+    val heightPerSegment = image.height / numberOfSegments
+    return List(numberOfSegments) { i ->
+        val y = i * heightPerSegment
+        val h = if (i == numberOfSegments - 1) image.height - y else heightPerSegment
+        image.getSubimage(0, y, image.width, h)
+    }
+}
+
+fun detectEdges(image: BufferedImage): BufferedImage {
+    val w = image.width
+    val h = image.height
+    val edgeImage = BufferedImage(w, h, BufferedImage.TYPE_INT_RGB)
+
+    for (y in KERNEL_RADIUS until h - KERNEL_RADIUS) {
+        for (x in KERNEL_RADIUS until w - KERNEL_RADIUS) {
+            var gx = 0
+            var gy = 0
+
+            for (ky in -KERNEL_RADIUS..KERNEL_RADIUS) {
+                for (kx in -KERNEL_RADIUS..KERNEL_RADIUS) {
+                    val pixel = Color(image.getRGB(x + kx, y + ky)).red
+                    gx += pixel * KERNEL_X[ky + KERNEL_RADIUS][kx + KERNEL_RADIUS]
+                    gy += pixel * KERNEL_Y[ky + KERNEL_RADIUS][kx + KERNEL_RADIUS]
+                }
+            }
+
+            val magnitude = sqrt((gx * gx + gy * gy).toDouble())
+                .toInt()
+                .coerceIn(0, MAX_COLOR_VALUE)
+            val gray = Color(magnitude, magnitude, magnitude)
+            edgeImage.setRGB(x, y, gray.rgb)
+        }
+    }
+
+    return edgeImage
+}
+
+fun applyRegionSpecificFilter(image: BufferedImage): BufferedImage {
+    val output = BufferedImage(image.width, image.height, BufferedImage.TYPE_INT_RGB)
+    for (y in 0 until image.height) {
+        for (x in 0 until image.width) {
+            val c = Color(image.getRGB(x, y))
+            val r = MAX_COLOR - c.red
+            val g = MAX_COLOR - c.green
+            val b = MAX_COLOR - c.blue
+            output.setRGB(x, y, Color(r, g, b).rgb)
+        }
+    }
+    return output
+}
+
+fun blendSegment(filtered: BufferedImage, edges: BufferedImage): BufferedImage {
+    val w = filtered.width
+    val h = filtered.height
+    val blended = BufferedImage(w, h, BufferedImage.TYPE_INT_RGB)
+
+    for (y in 0 until h) {
+        for (x in 0 until w) {
+            val c1 = Color(filtered.getRGB(x, y))
+            val c2 = Color(edges.getRGB(x, y))
+
+            val r = ((c1.red + c2.red) / 2).coerceIn(0, MAX_COLOR)
+            val g = ((c1.green + c2.green) / 2).coerceIn(0, MAX_COLOR)
+            val b = ((c1.blue + c2.blue) / 2).coerceIn(0, MAX_COLOR)
+
+            blended.setRGB(x, y, Color(r, g, b).rgb)
+        }
+    }
+
+    return blended
+}
+
+fun mergeSegments(segments: List<BufferedImage>, totalWidth: Int, totalHeight: Int): BufferedImage {
+    val result = BufferedImage(totalWidth, totalHeight, BufferedImage.TYPE_INT_RGB)
+    var currentY = 0
+    for (segment in segments) {
+        result.graphics.drawImage(segment, 0, currentY, null)
+        currentY += segment.height
+    }
+    return result
+}
+
+fun main() = runBlocking {
+    val path: ResourceFilePath = "images/bd.jpg"
+    val inputImage = decodeImage(path.readImageBytes())
+    val result = processImageParallel(inputImage)
+
+    val resultBytes = result.toByteArray()
+    display(resultBytes)
+}