[WIP]GenericRecordConverter.scala

/**
  * [WIP]
  *
  * The goal is to recursively convert a genericRecord to have lower case field names.
  */

import org.apache.avro.{Schema, SchemaBuilder}

import scala.collection.JavaConverters._

object GenericRecordConverter {

  def converter(schema: Schema): Schema = {
    val builder: SchemaBuilder.FieldAssembler[Schema] = SchemaBuilder.record(schema.getNamespace).fields()
    schema.getFields.asScala.foreach { field =>
      if (field.schema().getType != Schema.Type.RECORD) {
        builder.name(field.name().toLowerCase).`type`(field.schema())
      } else {
        builder.name(field.name().toLowerCase).`type`(converter(field.schema()))
      }
    }

    builder.endRecord()
  }

}