add schema registry implementation for tests (#28)

Author: davideicardi

kaa/src/main/scala/com/davideicardi/kaa/test/TestSchemaRegistry.scala

@@ -0,0 +1,23 @@
+package com.davideicardi.kaa.test
+
+import org.apache.avro.Schema
+import org.apache.avro.SchemaNormalization
+import com.davideicardi.kaa.SchemaId
+import com.davideicardi.kaa.SchemaRegistry
+
+class TestSchemaRegistry() extends SchemaRegistry {
+  val schemas = collection.mutable.Map[SchemaId, Schema]()
+
+  override def put(schema: Schema): SchemaId = {
+    val fingerprint = SchemaNormalization.parsingFingerprint64(schema)
+    val key = SchemaId(fingerprint)
+
+    schemas.put(key, schema)
+
+    key
+  }
+
+  override def get(id: SchemaId): Option[Schema] = {
+    schemas.get(id)
+  }
+}

kaa/src/test/scala/kaa/darwin/AvroSingleObjectSerializerSpec.scala

@@ -5,16 +5,15 @@ import org.apache.avro.{Schema, SchemaNormalization}
 import org.scalatest._
 import flatspec._
 import com.davideicardi.kaa.avro.{AvroBinarySerializer, AvroSingleObjectEncoding, AvroSingleObjectSerializer}
-import com.davideicardi.kaa.{SchemaId, SchemaRegistry}
+import com.davideicardi.kaa.SchemaId
+import com.davideicardi.kaa.test.TestSchemaRegistry
 import matchers._
 
-import scala.collection.mutable
-
 case class Pokemon(name: String, mainType: String, offType: Option[String], level: Int)
 
 class AvroSingleObjectSerializerSpec extends AnyFlatSpec with should.Matchers {
 
-  val registry = new SchemaRegistryFake
+  val registry = new TestSchemaRegistry
   val dragonite = Pokemon("Dragonite", "Dragon", None, 100)
 
   val singleObjectSerializer = new AvroSingleObjectSerializer[Pokemon](registry)
@@ -42,20 +41,3 @@ class AvroSingleObjectSerializerSpec extends AnyFlatSpec with should.Matchers {
     }
   }
 }
-
-class SchemaRegistryFake extends SchemaRegistry {
-  val _schemas = new mutable.HashMap[SchemaId, Schema]
-
-  override def put(schema: Schema): SchemaId = {
-    val id = SchemaId(
-      SchemaNormalization.parsingFingerprint64(schema)
-    )
-    _schemas.put(id, schema)
-
-    id
-  }
-
-  override def get(id: SchemaId): Option[Schema] = {
-    _schemas.get(id)
-  }
-}