require 'spec_helper'
require 'rflow/message'

class RFlow
  class Message
    describe Data do
      let(:string) { 'this is a string to be serialized' }
      let(:invalid_schema) { 'invalid schema' }
      let(:valid_schema) { '{"type": "string"}' }
      let(:serialized_string) { encode_avro(valid_schema, string) }

      context "if created without a schema" do
        it "should throw an exception" do
          expect { Data.new(nil) }.to raise_error(ArgumentError, /^Invalid schema/)
        end
      end

      context "if created with an invalid schema for the serialization" do
        ['avro', :avro].each do |it|
          it "should throw an exception for serialization type #{it.inspect}" do
            expect { Data.new(invalid_schema, it) }.to raise_error(ArgumentError, /^Invalid schema/)
          end
        end
      end

      context "if created with a valid avro schema" do
        ['avro', :avro].each do |it|
          it "should instantiate correctly for serialization type #{it.inspect}" do
            expect { Data.new(valid_schema, it) }.to_not raise_error
          end
        end

        context "if created with a non-avro data serialization" do
          ['unknown', :unknown, 'xml', :xml].each do |it|
            it "should throw an exception for serialization type #{it.inspect}" do
              expect { Data.new(valid_schema, it) }.to raise_error(
                ArgumentError, 'Only Avro serialization_type supported at the moment')
            end
          end
        end

        context "if created with an avro serialization" do
          ['avro', :avro].each do |it|
            it "should instantiate correctly for serialization type #{it.inspect}" do
              expect { Data.new(valid_schema, it) }.to_not raise_error
            end
          end

          context "if created with a serialized data object" do
            it "should instantiate correctly" do
              expect { Data.new(valid_schema, 'avro', serialized_string )}.to_not raise_error
            end
          end
        end
      end
    end
  end
end