Coverage Summary for Class: ApiUserEventSerializer (com.ghost.serialization.integration.model)
| Class |
Class, %
|
Method, %
|
Branch, %
|
Line, %
|
Instruction, %
|
| ApiUserEventSerializer |
100%
(1/1)
|
88.9%
(8/9)
|
59.3%
(32/54)
|
66.5%
(111/167)
|
68.3%
(439/643)
|
@file:OptIn(InternalGhostApi::class)
package com.ghost.serialization.integration.model
import com.ghost.serialization.InternalGhostApi
import com.ghost.serialization.contract.GhostSerializer
import com.ghost.serialization.parser.GhostJsonFlatReader
import com.ghost.serialization.parser.GhostJsonReader
import com.ghost.serialization.parser.JsonReaderOptions
import com.ghost.serialization.parser.beginObject
import com.ghost.serialization.parser.endObject
import com.ghost.serialization.parser.nextBoolean
import com.ghost.serialization.parser.nextInt
import com.ghost.serialization.parser.nextString
import com.ghost.serialization.parser.selectNameAndConsume
import com.ghost.serialization.parser.skipValue
import com.ghost.serialization.writer.GhostJsonFlatWriter
import com.ghost.serialization.writer.GhostJsonWriter
import okio.ByteString
import okio.ByteString.Companion.encodeUtf8
/**
* High-performance serializer for [ApiUserEvent].
* Generated by GhostSerialization. Do not modify manually.
*/
public object ApiUserEventSerializer : GhostSerializer<ApiUserEvent> {
override val typeName: String = "ApiUserEvent"
private val OPTIONS: JsonReaderOptions =
JsonReaderOptions.of(0, 31, 128, false, "userId", "eventType", "version", "retryCount", "isProcessed")
private val H_EVENTTYPE: ByteString = "\"eventType\":".encodeUtf8()
private val H_ISPROCESSED: ByteString = "\"isProcessed\":".encodeUtf8()
private val H_RETRYCOUNT: ByteString = "\"retryCount\":".encodeUtf8()
private val H_USERID: ByteString = "\"userId\":".encodeUtf8()
private val H_VERSION: ByteString = "\"version\":".encodeUtf8()
private const val MASK_USERID: Long = 1L
private const val MASK_EVENTTYPE: Long = 2L
private const val MASK_VERSION: Long = 4L
private const val MASK_RETRYCOUNT: Long = 8L
private const val MASK_ISPROCESSED: Long = 16L
private const val MASK_REQUIRED_0: Long = 3L
private const val MASK_OPTS_ISPROCESSED_RETRYCOUNT_VERSION: Long = 28L
private const val MASK_OPTS_RETRYCOUNT_VERSION: Long = 12L
private const val MASK_OPTS_ISPROCESSED_VERSION: Long = 20L
private const val MASK_OPTS_ISPROCESSED_RETRYCOUNT: Long = 24L
private const val MASK_OPTS_VERSION: Long = 4L
private const val MASK_OPTS_RETRYCOUNT: Long = 8L
private const val MASK_OPTS_ISPROCESSED: Long = 16L
private fun validateRequiredFields(mask0: Long, reader: GhostJsonReader) {
if ((mask0 and MASK_REQUIRED_0) != MASK_REQUIRED_0) {
if ((mask0 and MASK_USERID) == 0L) {
reader.throwError("Required field 'userId' missing in JSON")
} else if ((mask0 and MASK_EVENTTYPE) == 0L) {
reader.throwError("Required field 'eventType' missing in JSON")
}
}
}
/**
* Robust deserialization for [ApiUserEvent].
*/
override fun deserialize(reader: GhostJsonReader): ApiUserEvent {
var userIdValue: Int = 0
var eventTypeValue: String? = null
var versionValue: Int = 0
var retryCountValue: Int = 0
var isProcessedValue: Boolean = false
var mask0 = 0L
reader.beginObject()
while (true) {
val index = reader.selectNameAndConsume(OPTIONS)
when (index) {
0 -> {
userIdValue = reader.nextInt()
mask0 = mask0 or MASK_USERID
}
1 -> {
eventTypeValue = reader.nextString()
mask0 = mask0 or MASK_EVENTTYPE
}
2 -> {
versionValue = reader.nextInt()
mask0 = mask0 or MASK_VERSION
}
3 -> {
retryCountValue = reader.nextInt()
mask0 = mask0 or MASK_RETRYCOUNT
}
4 -> {
isProcessedValue = reader.nextBoolean()
mask0 = mask0 or MASK_ISPROCESSED
}
-1 -> break
-2 -> {
reader.skipValue()
}
}
}
reader.endObject()
validateRequiredFields(mask0, reader)
if ((mask0 and MASK_OPTS_ISPROCESSED_RETRYCOUNT_VERSION) == MASK_OPTS_ISPROCESSED_RETRYCOUNT_VERSION) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
version = versionValue,
retryCount = retryCountValue,
isProcessed = isProcessedValue,
)
}
if ((mask0 and MASK_OPTS_RETRYCOUNT_VERSION) == MASK_OPTS_RETRYCOUNT_VERSION) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
version = versionValue,
retryCount = retryCountValue,
)
}
if ((mask0 and MASK_OPTS_ISPROCESSED_VERSION) == MASK_OPTS_ISPROCESSED_VERSION) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
version = versionValue,
isProcessed = isProcessedValue,
)
}
if ((mask0 and MASK_OPTS_ISPROCESSED_RETRYCOUNT) == MASK_OPTS_ISPROCESSED_RETRYCOUNT) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
retryCount = retryCountValue,
isProcessed = isProcessedValue,
)
}
if ((mask0 and MASK_OPTS_VERSION) == MASK_OPTS_VERSION) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
version = versionValue,
)
}
if ((mask0 and MASK_OPTS_RETRYCOUNT) == MASK_OPTS_RETRYCOUNT) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
retryCount = retryCountValue,
)
}
if ((mask0 and MASK_OPTS_ISPROCESSED) == MASK_OPTS_ISPROCESSED) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
isProcessed = isProcessedValue,
)
}
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
)
}
private fun validateRequiredFields(mask0: Long, reader: GhostJsonFlatReader) {
if ((mask0 and MASK_REQUIRED_0) != MASK_REQUIRED_0) {
if ((mask0 and MASK_USERID) == 0L) {
reader.throwError("Required field 'userId' missing in JSON")
} else if ((mask0 and MASK_EVENTTYPE) == 0L) {
reader.throwError("Required field 'eventType' missing in JSON")
}
}
}
/**
* Robust deserialization for [ApiUserEvent].
*/
override fun deserialize(reader: GhostJsonFlatReader): ApiUserEvent {
var userIdValue: Int = 0
var eventTypeValue: String? = null
var versionValue: Int = 0
var retryCountValue: Int = 0
var isProcessedValue: Boolean = false
var mask0 = 0L
reader.beginObject()
while (true) {
val index = reader.selectNameAndConsume(OPTIONS)
when (index) {
0 -> {
userIdValue = reader.nextInt()
mask0 = mask0 or MASK_USERID
}
1 -> {
eventTypeValue = reader.nextString()
mask0 = mask0 or MASK_EVENTTYPE
}
2 -> {
versionValue = reader.nextInt()
mask0 = mask0 or MASK_VERSION
}
3 -> {
retryCountValue = reader.nextInt()
mask0 = mask0 or MASK_RETRYCOUNT
}
4 -> {
isProcessedValue = reader.nextBoolean()
mask0 = mask0 or MASK_ISPROCESSED
}
-1 -> break
-2 -> {
reader.skipValue()
}
}
}
reader.endObject()
validateRequiredFields(mask0, reader)
if ((mask0 and MASK_OPTS_ISPROCESSED_RETRYCOUNT_VERSION) == MASK_OPTS_ISPROCESSED_RETRYCOUNT_VERSION) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
version = versionValue,
retryCount = retryCountValue,
isProcessed = isProcessedValue,
)
}
if ((mask0 and MASK_OPTS_RETRYCOUNT_VERSION) == MASK_OPTS_RETRYCOUNT_VERSION) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
version = versionValue,
retryCount = retryCountValue,
)
}
if ((mask0 and MASK_OPTS_ISPROCESSED_VERSION) == MASK_OPTS_ISPROCESSED_VERSION) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
version = versionValue,
isProcessed = isProcessedValue,
)
}
if ((mask0 and MASK_OPTS_ISPROCESSED_RETRYCOUNT) == MASK_OPTS_ISPROCESSED_RETRYCOUNT) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
retryCount = retryCountValue,
isProcessed = isProcessedValue,
)
}
if ((mask0 and MASK_OPTS_VERSION) == MASK_OPTS_VERSION) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
version = versionValue,
)
}
if ((mask0 and MASK_OPTS_RETRYCOUNT) == MASK_OPTS_RETRYCOUNT) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
retryCount = retryCountValue,
)
}
if ((mask0 and MASK_OPTS_ISPROCESSED) == MASK_OPTS_ISPROCESSED) {
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
isProcessed = isProcessedValue,
)
}
return ApiUserEvent(
userId = userIdValue,
eventType = eventTypeValue!!,
)
}
override fun serialize(writer: GhostJsonWriter, `value`: ApiUserEvent) {
writer.beginObject()
writer.writeField(H_USERID, value.userId)
writer.writeField(H_EVENTTYPE, value.eventType)
writer.writeField(H_VERSION, value.version)
writer.writeField(H_RETRYCOUNT, value.retryCount)
writer.writeField(H_ISPROCESSED, value.isProcessed)
writer.endObject()
}
override fun serialize(writer: GhostJsonFlatWriter, `value`: ApiUserEvent) {
writer.beginObject()
writer.writeField(H_USERID, value.userId)
writer.writeField(H_EVENTTYPE, value.eventType)
writer.writeField(H_VERSION, value.version)
writer.writeField(H_RETRYCOUNT, value.retryCount)
writer.writeField(H_ISPROCESSED, value.isProcessed)
writer.endObject()
}
override fun warmUp() {
try {
val reader1 = GhostJsonReader("{\"userId\":0,\"eventType\":\"\"}".encodeToByteArray())
deserialize(reader1)
} catch (_: Exception) {
}
try {
val reader2 = GhostJsonFlatReader("{\"userId\":0,\"eventType\":\"\"}".encodeToByteArray())
deserialize(reader2)
} catch (_: Exception) {
}
}
}