Coverage Summary for Class: WebhookEnvelopeSerializer (com.ghost.serialization.integration.model)
| Class |
Class, %
|
Method, %
|
Branch, %
|
Line, %
|
Instruction, %
|
| WebhookEnvelopeSerializer |
100%
(1/1)
|
81.8%
(9/11)
|
44.1%
(15/34)
|
62%
(49/79)
|
63.1%
(243/385)
|
@file:OptIn(InternalGhostApi::class)
package com.ghost.serialization.integration.model
import com.ghost.serialization.Ghost
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.captureRawJson
import com.ghost.serialization.parser.consumeNull
import com.ghost.serialization.parser.endObject
import com.ghost.serialization.parser.isNextNullValue
import com.ghost.serialization.parser.nextString
import com.ghost.serialization.parser.selectNameAndConsume
import com.ghost.serialization.parser.skipValue
import com.ghost.serialization.types.RawJson
import com.ghost.serialization.types.RawJsonDecode
import com.ghost.serialization.writer.GhostJsonFlatWriter
import com.ghost.serialization.writer.GhostJsonWriter
import kotlin.ByteArray
import okio.ByteString
import okio.ByteString.Companion.encodeUtf8
/**
* High-performance serializer for [WebhookEnvelope].
* Generated by GhostSerialization. Do not modify manually.
*/
public object WebhookEnvelopeSerializer : GhostSerializer<WebhookEnvelope> {
override val typeName: String = "WebhookEnvelope"
private val OPTIONS: JsonReaderOptions = JsonReaderOptions.of(0, 31, 128, false, "type", "data")
private val H_DATA: ByteString = "\"data\":".encodeUtf8()
private val H_TYPE: ByteString = "\"type\":".encodeUtf8()
private const val MASK_TYPE: Long = 1L
private const val MASK_DATA: Long = 2L
private const val MASK_OPTS_DATA_TYPE: Long = 3L
private const val MASK_OPTS_TYPE: Long = 1L
private const val MASK_OPTS_DATA: Long = 2L
private val dataTargetSerializer: GhostSerializer<InvoicePaidPayload> =
Ghost.getSerializer(InvoicePaidPayload::class)!!
/**
* Robust deserialization for [WebhookEnvelope].
*/
override fun deserialize(reader: GhostJsonReader): WebhookEnvelope {
var typeValue: String? = null
var dataValue: RawJson? = null
var mask0 = 0L
reader.beginObject()
while (true) {
val index = reader.selectNameAndConsume(OPTIONS)
when (index) {
0 -> {
typeValue = reader.nextString()
mask0 = mask0 or MASK_TYPE
}
1 -> {
dataValue = if (reader.isNextNullValue()) { reader.consumeNull(); null } else reader.captureRawJson()
mask0 = mask0 or MASK_DATA
}
-1 -> break
-2 -> {
reader.skipValue()
}
}
}
reader.endObject()
if ((mask0 and MASK_OPTS_DATA_TYPE) == MASK_OPTS_DATA_TYPE) {
return WebhookEnvelope(
type = typeValue!!,
`data` = dataValue,
)
}
if ((mask0 and MASK_OPTS_TYPE) == MASK_OPTS_TYPE) {
return WebhookEnvelope(
type = typeValue!!,
)
}
if ((mask0 and MASK_OPTS_DATA) == MASK_OPTS_DATA) {
return WebhookEnvelope(
`data` = dataValue,
)
}
return WebhookEnvelope(
)
}
/**
* Robust deserialization for [WebhookEnvelope].
*/
override fun deserialize(reader: GhostJsonFlatReader): WebhookEnvelope {
var typeValue: String? = null
var dataValue: RawJson? = null
var mask0 = 0L
reader.beginObject()
while (true) {
val index = reader.selectNameAndConsume(OPTIONS)
when (index) {
0 -> {
typeValue = reader.nextString()
mask0 = mask0 or MASK_TYPE
}
1 -> {
dataValue = if (reader.isNextNullValue()) { reader.consumeNull(); null } else reader.captureRawJson()
mask0 = mask0 or MASK_DATA
}
-1 -> break
-2 -> {
reader.skipValue()
}
}
}
reader.endObject()
if ((mask0 and MASK_OPTS_DATA_TYPE) == MASK_OPTS_DATA_TYPE) {
return WebhookEnvelope(
type = typeValue!!,
`data` = dataValue,
)
}
if ((mask0 and MASK_OPTS_TYPE) == MASK_OPTS_TYPE) {
return WebhookEnvelope(
type = typeValue!!,
)
}
if ((mask0 and MASK_OPTS_DATA) == MASK_OPTS_DATA) {
return WebhookEnvelope(
`data` = dataValue,
)
}
return WebhookEnvelope(
)
}
/**
* Routes [WebhookEnvelope] to its matching opaque JSON payload without re-parsing.
*/
public fun routePayload(envelope: WebhookEnvelope): RawJson? = when (envelope.type) {
"invoice.paid" -> envelope.data
else -> envelope.data
}
/**
* Deserializes [WebhookEnvelope] from bytes and routes to payload (zero-copy RawJson slice on flat reader).
*/
public fun parsePayload(bytes: ByteArray): RawJson? {
val envelope = deserialize(GhostJsonFlatReader(bytes))
return routePayload(envelope)
}
/**
* Routes [WebhookEnvelope] and decodes annotated payload targets.
*/
public fun routeTyped(envelope: WebhookEnvelope): Any? = when (envelope.type) {
"invoice.paid" -> envelope.data?.let { RawJsonDecode.decode(it, dataTargetSerializer) }
else -> envelope.data
}
/**
* Deserializes [WebhookEnvelope] from bytes and returns typed payload when configured.
*/
public fun parseTyped(bytes: ByteArray): Any? {
val envelope = deserialize(GhostJsonFlatReader(bytes))
return routeTyped(envelope)
}
override fun serialize(writer: GhostJsonWriter, `value`: WebhookEnvelope) {
writer.beginObject()
writer.writeField(H_TYPE, value.type)
if (value.`data` != null) {
writer.writeNameRaw(H_DATA)
writer.rawValue(value.`data`.storage, value.`data`.storageOffset, value.`data`.storageLength)
}
writer.endObject()
}
override fun serialize(writer: GhostJsonFlatWriter, `value`: WebhookEnvelope) {
writer.beginObject()
writer.writeField(H_TYPE, value.type)
if (value.`data` != null) {
writer.writeNameRaw(H_DATA)
writer.rawValue(value.`data`.storage, value.`data`.storageOffset, value.`data`.storageLength)
}
writer.endObject()
}
override fun warmUp() {
try {
val reader1 = GhostJsonReader("{}".encodeToByteArray())
deserialize(reader1)
} catch (_: Exception) {
}
try {
val reader2 = GhostJsonFlatReader("{}".encodeToByteArray())
deserialize(reader2)
} catch (_: Exception) {
}
}
}