def serializeToBytes()

in src/main/scala/com/gu/thrift/serializer/ThriftSerializer.scala [13:43]

• 20 lines of code
• 5 McCabe index (conditional complexity)

  def serializeToBytes(struct: ThriftStruct, userCompressionType: Option[CompressionType],
    thriftBufferInitialSize: Option[Int], withSettings: Boolean=false): ByteBuffer = {

    val bufferSize = thriftBufferInitialSize.getOrElse(initialBufferDefault)
    val buffer = new TMemoryBuffer(bufferSize)
    val protocol = new TCompactProtocol(buffer)

    struct.write(protocol)

    if (!withSettings) {
      val compressionType = userCompressionType.getOrElse(compressionDefault)

      val compression: Byte = {
        compressionType match {
          case NoneType => 0x00.toByte
          case GzipType => 0x01.toByte
          case ZstdType => 0x02.toByte
        }
      }

      val other: Byte = 0x07.toByte

      /*
      Ox00000XXX - used for compression type
      OxXXXXX000 - kept for the future
      */
     val settings: Byte = (other & compression).toByte

     ByteBuffer.wrap(settings +: payload(buffer.getArray, compressionType))
    } else ByteBuffer.wrap(buffer.getArray)
  }