У меня есть проект Scala, в котором я использую Circe для обработки json. У меня проблемы с декодированием из JSON в подклассы иерархии.
Код, с которым у меня возникли проблемы, - это следующий тест:
test("FailingResponse - Conversion between case object and Json works") {
val caseObject = FailingResponse("Some Error", StatusCodes.INTERNAL_ERROR)
val jsonString = caseObject
.asJson
.printWith(Printer.noSpaces)
decode[ValuationResponse](jsonString) must be(Right(caseObject))
}
Я хочу иметь возможность декодировать любой из подклассов ValuationResponse, поскольку в момент декодирования я не могу точно знать, является ли ответ FailingResponse или SuccessfulResponse. Я хотел бы, чтобы декодер мог определять, какой это тип ValuationReponse, декодировать его и делать доступным как «общий» ValuationResponse. Затем я мог бы манипулировать им, используя регистр совпадений или что-то в этом роде, чтобы получить конкретный тип.
Вместо этого в этом тесте я получаю ошибку DecodingFailure. Что я делаю неправильно?
Это код иерархии:
sealed trait ValuationResponse {
def statusCode: StatusCode
}
case class SuccessfulResponse(values: List[StockValuation], symbol: String, function: TimeSeriesType, statusCode: StatusCode) extends ValuationResponse
case class FailingResponse(reason: String, statusCode: StatusCode) extends ValuationResponse
case class ValuationRequest(function: TimeSeriesType = TIME_SERIES_INTRADAY, symbol: String, interval: IntraDayInterval = IntraDayIntervals.MIN_5)
object derivation {
implicit val encodeResponse: Encoder[ValuationResponse] = Encoder.instance {
case response@SuccessfulResponse(_, _, _, _) => response.asJson
case response@FailingResponse(_, _) => response.asJson
}
implicit val decodeResponse: Decoder[ValuationResponse] =
List[Decoder[ValuationResponse]](
Decoder[SuccessfulResponse].widen,
Decoder[FailingResponse].widen
).reduceLeft(_ or _)
implicit val encodeRequest: Encoder[ValuationRequest] = Encoder.instance {
case response@ValuationRequest(_, _, _) => response.asJson
}
implicit val decodeRequest: Decoder[ValuationRequest] =
List[Decoder[ValuationRequest]](
Decoder[ValuationRequest].widen
).reduceLeft(_ or _)
}
Это перечисления, которые он использует (да, я знаю, что перечисление для кодов состояния глупо, ах):
sealed abstract class TimeSeriesType(val text: String) extends EnumEntry {}
sealed abstract class IntraDayInterval(val text: String) extends EnumEntry {}
object TimeSeriesFunctions extends Enum[TimeSeriesType] with CirceEnum[TimeSeriesType] {
val values: immutable.IndexedSeq[TimeSeriesType] = findValues
case object TIME_SERIES_INTRADAY extends TimeSeriesType("TIME_SERIES_INTRADAY")
case object TIME_SERIES_DAILY extends TimeSeriesType("TIME_SERIES_DAILY")
case object TIME_SERIES_WEEKLY extends TimeSeriesType("TIME_SERIES_WEEKLY")
case object TIME_SERIES_MONTHLY extends TimeSeriesType("TIME_SERIES_MONTHLY")
}
object IntraDayIntervals extends Enum[IntraDayInterval] with CirceEnum[IntraDayInterval] {
val values: immutable.IndexedSeq[IntraDayInterval] = findValues
case object MIN_1 extends IntraDayInterval("1min")
case object MIN_5 extends IntraDayInterval("5min")
case object MIN_15 extends IntraDayInterval("15min")
case object MIN_30 extends IntraDayInterval("30min")
case object MIN_60 extends IntraDayInterval("60min")
}
object StatusCodes extends Enum[StatusCode] with CirceEnum[StatusCode] {
val values: immutable.IndexedSeq[StatusCode] = findValues
case object SUCCESS extends StatusCode(200)
case object INTERNAL_ERROR extends StatusCode(500)
case object REQUESTER_ERROR extends StatusCode(400)
}
