package firrtl package annotations import scala.util.{Try, Failure} import org.json4s._ import org.json4s.native.JsonMethods._ import org.json4s.native.Serialization import org.json4s.native.Serialization.{read, writePretty} trait HasSerializationHints { // For serialization of complicated constructor arguments, let the annotation // writer specify additional type hints for relevant classes that might be // contained within def typeHints: Seq[Class[_]] } object JsonProtocol { class TransformClassSerializer extends CustomSerializer[Class[_ <: Transform]](format => ( { case JString(s) => Class.forName(s).asInstanceOf[Class[_ <: Transform]] }, { case x: Class[_] => JString(x.getName) } )) // TODO Reduce boilerplate? class NamedSerializer extends CustomSerializer[Named](format => ( { case JString(s) => AnnotationUtils.toNamed(s) }, { case named: Named => JString(named.serialize) } )) class CircuitNameSerializer extends CustomSerializer[CircuitName](format => ( { case JString(s) => AnnotationUtils.toNamed(s).asInstanceOf[CircuitName] }, { case named: CircuitName => JString(named.serialize) } )) class ModuleNameSerializer extends CustomSerializer[ModuleName](format => ( { case JString(s) => AnnotationUtils.toNamed(s).asInstanceOf[ModuleName] }, { case named: ModuleName => JString(named.serialize) } )) class ComponentNameSerializer extends CustomSerializer[ComponentName](format => ( { case JString(s) => AnnotationUtils.toNamed(s).asInstanceOf[ComponentName] }, { case named: ComponentName => JString(named.serialize) } )) class TransformSerializer extends CustomSerializer[Transform](format => ( { case JString(s) => try { Class.forName(s).asInstanceOf[Class[_ <: Transform]].newInstance() } catch { case e: java.lang.InstantiationException => throw new FirrtlInternalException( "NoSuchMethodException during construction of serialized Transform. Is your Transform an inner class?", e) case t: Throwable => throw t }}, { case x: Transform => JString(x.getClass.getName) } )) class LoadMemoryFileTypeSerializer extends CustomSerializer[MemoryLoadFileType](format => ( { case JString(s) => MemoryLoadFileType.deserialize(s) }, { case named: MemoryLoadFileType => JString(named.serialize) } )) class TargetSerializer extends CustomSerializer[Target](format => ( { case JString(s) => Target.deserialize(s) }, { case named: Target => JString(named.serialize) } )) class GenericTargetSerializer extends CustomSerializer[GenericTarget](format => ( { case JString(s) => Target.deserialize(s).asInstanceOf[GenericTarget] }, { case named: GenericTarget => JString(named.serialize) } )) class CircuitTargetSerializer extends CustomSerializer[CircuitTarget](format => ( { case JString(s) => Target.deserialize(s).asInstanceOf[CircuitTarget] }, { case named: CircuitTarget => JString(named.serialize) } )) class ModuleTargetSerializer extends CustomSerializer[ModuleTarget](format => ( { case JString(s) => Target.deserialize(s).asInstanceOf[ModuleTarget] }, { case named: ModuleTarget => JString(named.serialize) } )) class InstanceTargetSerializer extends CustomSerializer[InstanceTarget](format => ( { case JString(s) => Target.deserialize(s).asInstanceOf[InstanceTarget] }, { case named: InstanceTarget => JString(named.serialize) } )) class ReferenceTargetSerializer extends CustomSerializer[ReferenceTarget](format => ( { case JString(s) => Target.deserialize(s).asInstanceOf[ReferenceTarget] }, { case named: ReferenceTarget => JString(named.serialize) } )) /** Construct Json formatter for annotations */ def jsonFormat(tags: Seq[Class[_]]) = { Serialization.formats(FullTypeHints(tags.toList)).withTypeHintFieldName("class") + new TransformClassSerializer + new NamedSerializer + new CircuitNameSerializer + new ModuleNameSerializer + new ComponentNameSerializer + new TargetSerializer + new GenericTargetSerializer + new CircuitTargetSerializer + new ModuleTargetSerializer + new InstanceTargetSerializer + new ReferenceTargetSerializer + new TransformSerializer + new LoadMemoryFileTypeSerializer } /** Serialize annotations to a String for emission */ def serialize(annos: Seq[Annotation]): String = serializeTry(annos).get def serializeTry(annos: Seq[Annotation]): Try[String] = { val tags = annos.flatMap({ case anno: HasSerializationHints => anno.getClass +: anno.typeHints case anno => Seq(anno.getClass) }).distinct implicit val formats = jsonFormat(tags) Try(writePretty(annos)) } def deserialize(in: JsonInput): Seq[Annotation] = deserializeTry(in).get def deserializeTry(in: JsonInput): Try[Seq[Annotation]] = Try({ val parsed = parse(in) val annos = parsed match { case JArray(objs) => objs case x => throw new InvalidAnnotationJSONException( s"Annotations must be serialized as a JArray, got ${x.getClass.getName} instead!") } // Recursively gather typeHints by pulling the "class" field from JObjects // Json4s should emit this as the first field in all serialized classes // Setting requireClassField mandates that all JObjects must provide a typeHint, // this used on the first invocation to check all annotations do so def findTypeHints(classInst: Seq[JValue], requireClassField: Boolean = false): Seq[String] = classInst.flatMap({ case JObject(("class", JString(name)) :: fields) => name +: findTypeHints(fields.map(_._2)) case obj: JObject if requireClassField => throw new InvalidAnnotationJSONException(s"Expected field 'class' not found! $obj") case JObject(fields) => findTypeHints(fields.map(_._2)) case JArray(arr) => findTypeHints(arr) case oJValue => Seq() }).distinct val classes = findTypeHints(annos, true) val loaded = classes.map(Class.forName(_)) implicit val formats = jsonFormat(loaded) read[List[Annotation]](in) }).recoverWith { // Translate some generic errors to specific ones case e: java.lang.ClassNotFoundException => Failure(new AnnotationClassNotFoundException(e.getMessage)) // Eat the stack traces of json4s exceptions case e @ (_: org.json4s.ParserUtil.ParseException | _: org.json4s.MappingException) => Failure(new InvalidAnnotationJSONException(e.getMessage)) }.recoverWith { // If the input is a file, wrap in InvalidAnnotationFileException case e: FirrtlUserException => in match { case FileInput(file) => Failure(new InvalidAnnotationFileException(file, e)) case _ => Failure(e) } } }