Validate Avro schema before encoding

Author: robertomiranda

lib/streamy/serializers/avro_serializer.rb

@@ -20,7 +20,10 @@ def self.clear_messaging_cache
       end
 
       def self.encode(payload, schema_namespace: nil)
-        messaging.encode(payload.deep_stringify_keys, schema_name: payload[:type], namespace: schema_namespace)
+        messaging.encode(payload.deep_stringify_keys,
+                         schema_name: payload[:type],
+                         namespace: schema_namespace,
+                         validate: true)
       end
     end
   end

test/avro_event_test.rb

@@ -88,7 +88,7 @@ def test_helpful_error_message_on_incorrect_attribute_type
       exception = assert_raises Streamy::PublicationFailedError do
         IncorrectAttributeEvent.publish
       end
-      assert_match("Avro::IO::AvroTypeError", exception.message)
+      assert_match("Avro::SchemaValidator::ValidationError", exception.message)
     end
 
     def test_helpful_error_message_on_event_with_no_schema