diff --git a/src/main/scala/coop/rchain/rabbit2rho/gentran/IdocSchemaParser.scala b/src/main/scala/coop/rchain/rabbit2rho/gentran/IdocSchemaParser.scala index 7ef8f02..6180154 100644 --- a/src/main/scala/coop/rchain/rabbit2rho/gentran/IdocSchemaParser.scala +++ b/src/main/scala/coop/rchain/rabbit2rho/gentran/IdocSchemaParser.scala @@ -25,7 +25,7 @@ object ParseInput extends IOApp { .map(idoc2RhoList(_, schema._2, schema._1)) .compile .toList - _ = println(parsed.head) + _ = println(s"[${parsed.head.mkString(", ")}]") } yield ExitCode.Success } } diff --git a/src/main/scala/coop/rchain/rabbit2rho/gentran/IdocTools.scala b/src/main/scala/coop/rchain/rabbit2rho/gentran/IdocTools.scala index 8505df4..4c9767e 100644 --- a/src/main/scala/coop/rchain/rabbit2rho/gentran/IdocTools.scala +++ b/src/main/scala/coop/rchain/rabbit2rho/gentran/IdocTools.scala @@ -58,8 +58,12 @@ object IdocTools { id2Tag: String => String ): List[String] = parseIdoc(idoc, schema, id2Tag).compile.toList - .map { case (k, v) => (k, v) } - .map(json.writeValueAsString) + .map { + case (recName, fields) => + val strFields = fields.toList.map { case (k, v) => s""""${rhoName(k)}":"$v"""" } + s"""("${rhoName(recName)}",{${strFields.mkString(", ")}})""" + } + def rhoName(name: String): String = name.replace(":", "_colon_") def idoc2RhoMap( idoc: String,