/**
 * Generated by API Builder - https://www.apibuilder.io
 * Service version: 0.0.1
 * User agent: apibuilder app.apibuilder.io/nccloud/reporting-crds/0.0.1/anorm_2_8_parsers
 */
import anorm._

package de.nccloud.reporting.crds.v0.anorm.parsers {

  import de.nccloud.reporting.crds.v0.anorm.conversions.Standard._

  import de.nccloud.reporting.api.v0.anorm.conversions.Types._
  import de.nccloud.reporting.crds.v0.anorm.conversions.Types._

  object ReportStream {

    def parserWithPrefix(prefix: String, sep: String = "_"): RowParser[de.nccloud.reporting.crds.v0.models.ReportStream] = parser(prefixOpt = Some(s"$prefix$sep"))

    def parser(
      topic: String = "topic",
      description: String = "description",
      service: String = "service",
      schema: String = "schema",
      prefixOpt: Option[String] = None
    ): RowParser[de.nccloud.reporting.crds.v0.models.ReportStream] = {
      SqlParser.str(prefixOpt.getOrElse("") + topic) ~
      SqlParser.str(prefixOpt.getOrElse("") + description) ~
      SqlParser.str(prefixOpt.getOrElse("") + service) ~
      SqlParser.get[Map[String, de.nccloud.reporting.api.v0.models.Field]](prefixOpt.getOrElse("") + schema) map {
        case topic ~ description ~ service ~ schema => {
          de.nccloud.reporting.crds.v0.models.ReportStream(
            topic = topic,
            description = description,
            service = service,
            schema = schema
          )
        }
      }
    }

  }

}