これは、 Cats (circe が依存するライブラリ)の状態モナド トランスフォーマーを使用して比較的簡単に実現できます。
import cats.data.StateT
import cats.std.option._
import cats.std.list._
import cats.syntax.traverse._
import io.circe.{ Json, JsonObject }
import java.util.UUID
def update(j: Json): StateT[Option, Map[UUID, Long], Json] = j.arrayOrObject(
StateT.pure[Option, Map[UUID, Long], Json](j),
_.traverseU(update).map(Json.fromValues),
_.toList.traverseU {
case ("id", value) => StateT { (ids: Map[UUID, Long]) =>
value.as[UUID].toOption.map { uuid =>
val next = if (ids.isEmpty) 1L else ids.values.max + 1L
(ids.updated(uuid, next), "id" -> Json.fromString(s"$next"))
}
}
case (other, value) => value.as[UUID].toOption match {
case Some(uuid) => StateT { (ids: Map[UUID, Long]) =>
ids.get(uuid).map(id => (ids, other -> Json.fromString(s"ref:$id")))
}
case None => update(value).map(other -> _)
}
}.map(Json.fromFields)
)
その後:
import io.circe.literal._
val doc: Json = json"""
{
"places": [{
"id": "dadcc0d9-0615-4e46-9df4-2619f49930a0"
}, {
"id": "21d02f4b-7e88-47d7-bf2b-48e50761b6c3"
}],
"transitions": [{
"id": "10a3aee5-541b-4d04-bb45-cb1dbbfe2128",
"startPlaceId": "dadcc0d9-0615-4e46-9df4-2619f49930a0",
"endPlaceId": "21d02f4b-7e88-47d7-bf2b-48e50761b6c3"
}],
"routes": [{
"id": "6ded1763-86c0-44ce-b94b-f05934976a3b",
"transitionId": "10a3aee5-541b-4d04-bb45-cb1dbbfe2128"
}]
}
"""
そして最後に:
scala> import cats.std.long._
import cats.std.long._
scala> import cats.std.map._
import cats.std.map._
scala> update(doc).runEmptyA
res0: Option[io.circe.Json] =
Some({
"places" : [
{
"id" : "1"
},
{
"id" : "2"
}
],
"transitions" : [
{
"id" : "3",
"startPlaceId" : "ref:1",
"endPlaceId" : "ref:2"
}
],
"routes" : [
{
"id" : "4",
"transitionId" : "ref:3"
}
]
})
いずれかid
のフィールドが正当な UUID でない場合、または他のフィールドに不明な UUID への参照が含まれている場合、計算は で失敗しNone
ます。この動作は、必要に応じて少し改良できます。エラーが発生した場所に関するより具体的な情報が必要な場合は、JSON 値の代わりにカーソルを使用するように実装を調整できます (ただし、これはもう少し複雑になります)。