spec/messaging_spec.rb in avro_turf-0.6.1 vs spec/messaging_spec.rb in avro_turf-0.6.2

@@ -47,6 +47,33 @@
   it "allows specifying a reader's schema" do
     message = { "full_name" => "John Doe" }
     data = avro.encode(message, schema_name: "person")
     expect(avro.decode(data, schema_name: "person")).to eq message
   end
+
+  context "when active_support/core_ext is present" do
+    let(:avro) do
+      super().tap do |messaging|
+        # Simulate the presence of active_support/core_ext by monkey patching
+        # the schema store to monkey patch #to_json on the returned schema.
+        schema_store = messaging.instance_variable_get(:@schema_store)
+        def schema_store.find(*)
+          super.extend(Module.new do
+            # Replace to_json on the returned schema with an implementation
+            # that returns something similar to active_support/core_ext/json
+            def to_json(*args)
+              instance_variables.each_with_object(Hash.new) do |ivar, result|
+                result[ivar.to_s.sub('@','')] = instance_variable_get(ivar)
+              end.to_json(*args)
+            end
+          end)
+        end
+      end
+    end
+
+    it "encodes and decodes messages" do
+      message = { "full_name" => "John Doe" }
+      data = avro.encode(message, schema_name: "person")
+      expect(avro.decode(data)).to eq message
+    end
+  end
 end