blob: 35dc16fc30600258fbf0529674a6fee4056b8dd1 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
package kotlinx.serialization.json
import kotlinx.serialization.*
import kotlinx.serialization.Serializable
import kotlinx.serialization.descriptors.*
import kotlinx.serialization.encoding.*
import kotlinx.serialization.test.assertFailsWithMessage
import org.junit.Test
import java.io.*
import java.util.*
import kotlin.random.Random
import kotlin.test.*
@Serializable(with = LargeBase64StringSerializer::class)
data class LargeBinaryData(val binaryData: ByteArray) {
override fun equals(other: Any?): Boolean {
if (this === other) return true
if (javaClass != other?.javaClass) return false
other as LargeBinaryData
if (!binaryData.contentEquals(other.binaryData)) return false
return true
}
override fun hashCode(): Int {
return binaryData.contentHashCode()
}
}
@Serializable
data class ClassWithBinaryDataField(val binaryField: LargeBinaryData)
object LargeBase64StringSerializer : KSerializer<LargeBinaryData> {
private val b64Decoder: Base64.Decoder = Base64.getDecoder()
override val descriptor: SerialDescriptor = PrimitiveSerialDescriptor("LargeStringContent", PrimitiveKind.STRING)
override fun deserialize(decoder: Decoder): LargeBinaryData {
require(decoder is ChunkedDecoder) { "Only chunked decoder supported" }
var reminder = ""
val decodedBytes = ByteArrayOutputStream().use { bos ->
decoder.decodeStringChunked {
val actualChunk = reminder + it
val reminderLength = actualChunk.length % 4
val alignedLength = actualChunk.length - reminderLength
val alignedChunk = actualChunk.take(alignedLength)
reminder = actualChunk.takeLast(reminderLength)
bos.write(b64Decoder.decode(alignedChunk))
}
bos.toByteArray()
}
return LargeBinaryData(decodedBytes)
}
override fun serialize(encoder: Encoder, value: LargeBinaryData) {
encoder.encodeString(Base64.getEncoder().encodeToString(value.binaryData))
}
}
class JsonChunkedBase64DecoderTest : JsonTestBase() {
@Test
fun decodeBase64String() {
val sourceObject =
ClassWithBinaryDataField(LargeBinaryData(Random.nextBytes(16 * 1024))) // After encoding to Base64 will be larger than 16k (JsonLexer#BATCH_SIZE)
val serializedObject = Json.encodeToString(sourceObject)
JsonTestingMode.values().forEach { mode ->
if (mode == JsonTestingMode.TREE) {
assertFailsWithMessage<IllegalArgumentException>(
"Only chunked decoder supported", "Shouldn't decode JSON in TREE mode"
) {
Json.decodeFromString<ClassWithBinaryDataField>(serializedObject, mode)
}
} else {
val deserializedObject = Json.decodeFromString<ClassWithBinaryDataField>(serializedObject, mode)
assertEquals(sourceObject.binaryField, deserializedObject.binaryField)
}
}
}
}
|
