Add test and support for compressing and decompressing byte buffers

lib/cql/compression/lz4_compressor.rb

@@ -30,11 +30,11 @@ def compress?(str)
       end
 
       def compress(str)
-        [str.bytesize, LZ4::Raw.compress(str).first].pack(BUFFER_FORMAT)
+        [str.bytesize, LZ4::Raw.compress(str.to_s).first].pack(BUFFER_FORMAT)
       end
 
       def decompress(str)
-        decompressed_size, compressed_data = str.unpack(BUFFER_FORMAT)
+        decompressed_size, compressed_data = str.to_s.unpack(BUFFER_FORMAT)
         LZ4::Raw.decompress(compressed_data, decompressed_size).first
       end
 

spec/cql/compression/compression_common.rb

@@ -36,12 +36,24 @@
       compressed.bytesize.should be < input.bytesize
     end
 
+    it 'compresses byte buffers' do
+      input = Cql::Protocol::CqlByteBuffer.new('hello' * 100)
+      compressed = compressor.compress(input)
+      compressed.should == compressor.compress(input.to_s)
+    end
+
     it 'decompresses compressed strings' do
       input = compressed_string
       decompressed = compressor.decompress(input)
       decompressed.should == 'hellohellohellohellohello'
     end
 
+    it 'decompresses byte buffers' do
+      input = Cql::Protocol::CqlByteBuffer.new(compressed_string)
+      decompressed = compressor.decompress(input)
+      decompressed.should == 'hellohellohellohellohello'
+    end
+
     it 'decompresses its own compressed output' do
       input = 'Ķ' * 100
       output = compressor.decompress(compressor.compress(input))