Scala - JSON 对象在字段类型上是多态的

Question

我正在尝试解码一些非常糟糕的 JSON。每个对象的类型信息都编码在标记为 type 的字段中。 ，即"type": "event"等等。我正在使用 Circe用于 JSON 编码/解码。该库使用类型类，其中相关类型类是 def apply(c: HCursor): Decoder.Result[A] 。问题是任何解码器对于输入都是不变的，A 。这是一个具体的例子

sealed trait MotherEvent {
  val id: UUID
  val timestamp: DateTime
}
implicit val decodeJson: Decoder[MotherEvent] = new Decoder[MotherEvent] { 
def apply(c: HCursor) = {
  c.downField("type").focus match {
    case Some(x) => x.asString match {
      case Some(string) if string == "flight" => FlightEvent.decodeJson(c)
      case Some(string) if string == "hotel"  => // etc 
      // like a bunch of these
      case None => Xor.Left(DecodingFailure("type is not a string", c.history))
    }
    case None    => Xor.Left(DecodingFailure("not type found", c.history))
  }
}

sealed trait FlightEvents(id: UUID, timestamp: DateTime, flightId: Int)
case class Arrival(id: UUID, timestamp: DateTime, flightId: Int) extends Event // a metric ton of additional fields
case class Departure(id: UUID, timestamp: DateTime, flightId: Int) extends Event // samsies as Arrival

解码工作正常，但是MotherEvent总是返回

val jsonString = // from wherevs, where the json string is flightevent
val x = decode[MotherEvent](jsonString)
println(x) // prints (cats.data.Xor[io.circe.Error, MotherEvent] = Right(FlightEvent)
println(x.flightId) // ERROR- flightId is not a member of MotherEvent

当然，我想要一个 FlightEvent 而不是母事件。一种可能的解决方案是创建一个具有 60 或 70 个字段的“母亲”类型，但我已经讨厌自己了，并且想停止编程，只考虑 70 Option[A]根据 type 填写的字段字段。

谁能想到一个好的解决方案吗？

Answer 1

所以，我最终接受了一个不变量 A并依靠 Shapeless 获得 Coproduct 。这会导致一些额外的代码重复，但它极大地简化了我对问题的思考方式以及Decoder[A]的方式。被处理了。由于这是简单数据摄取程序的一部分，因此将额外工作映射到 Coproduct 相对容易。并对数据库所表示的数据具有更清晰的类型。这是一个简单的示例，说明了它们是如何组合在一起的:

import shapeless._
import io.circe._, io.circe.Decoder.instance 

case class FlightEvent(id: UUID, departureTime: DateTime, arrivalTime: DateTime)
case class HotelEvent(id: UUID, city: String)
case class CarEvent(id: UUID, carrier: String)
// assume valid Decoder typeclasses in each companion object

type FHC = FlightEvent :+: HotelEvent :+: CarEvent :+: CNil
type FHCs = List[FHC]

implicit val decodeFHC: Decoder[FHC] = instance { c => 
  c.downField("type".focus match {
    case Some(t) => t.asString match {
      case Some(string) if string == "flight" => FlightEvent.decodeJson(c) map { Coproduct[FHC](_) }
      case Some(string) if string == "hotel"  => HotelEvent.decodeJson(c) map { Coproduct[FHC](_) }
      case Some(string) if string == "car"    => CarEvent.decodeJson(c) map { Coproduct[FHC](_) }
      case Some(string) => Xor.Left(DecodingFailure(s"unkown type $string", c.history))
      case None =>  Xor.Left(DecodingFailure("json field \"type\", string expected", c.history))
    }
    case None => Xor.Left(DecodingFailure("json field \"type\" not found", c.history))
  }
}

这是我第一次使用 Shapeless，所以很有可能有一种更简洁的方法来实现这一点。我确实很喜欢正交Coproduct做了这个。