Initial commit

ktor-client-brotli/.gitignore

@@ -0,0 +1 @@
+/build

ktor-client-brotli/build.gradle.kts

@@ -0,0 +1,12 @@
+plugins {
+    kotlin("jvm")
+}
+
+sourceSets.all {
+    java.srcDir("src/$name/kotlin")
+}
+
+dependencies {
+    implementation(libs.ktor.client.encoding)
+    implementation(libs.brotli)
+}

ktor-client-brotli/src/main/kotlin/io/ktor/client/plugins/compression/BrotliEncoder.kt

@@ -0,0 +1,16 @@
+package io.ktor.client.plugins.compression
+
+import io.ktor.utils.io.*
+import io.ktor.utils.io.jvm.javaio.*
+import kotlinx.coroutines.CoroutineScope
+import org.brotli.dec.BrotliInputStream
+
+internal object BrotliEncoder : ContentEncoder {
+    override val name: String = "br"
+
+    override fun CoroutineScope.encode(source: ByteReadChannel) =
+        error("BrotliOutputStream not available (https://github.com/google/brotli/issues/715)")
+
+    override fun CoroutineScope.decode(source: ByteReadChannel): ByteReadChannel =
+        BrotliInputStream(source.toInputStream()).toByteReadChannel()
+}

ktor-client-brotli/src/main/kotlin/io/ktor/client/plugins/compression/brotli.kt

@@ -0,0 +1,5 @@
+package io.ktor.client.plugins.compression
+
+fun ContentEncoding.Config.brotli(quality: Float? = null) {
+    customEncoder(BrotliEncoder, quality)
+}