require "spec_helper"

describe Rico::Value do
  before :each do
    RiakHelpers.reset!
  end

  def gunzip(string)
    io = StringIO.new(string)
    gz = Zlib::GzipReader.new(io)
    object = gz.read
    gz.close
    object
  end

  describe "gzip serialization" do
    it "sets the content type of gzip objects" do
      a = Rico::Value.new RiakHelpers.bucket, "value_gzip_content_type"
      a.content_type = "application/x-gzip"
      a.set "JOHN DOE"
      a.content_type.should eql "application/x-gzip"
    end

    it "properly serializes of gzip objects" do
      a = Rico::Value.new RiakHelpers.bucket, "value_gzip_content_type"
      a.content_type = "application/x-gzip"
      a.set "JOHN DOE"
      gunzip(a.raw_data).should eql({"_type" => "value", "_value" => "JOHN DOE"}.to_json)
      a.content_type.should eql "application/x-gzip"
    end

    it "retrieves the content type of persisted gzip objects" do
      a = Rico::Value.new RiakHelpers.bucket, "value_gzip_content_type_2"
      a.content_type = "application/x-gzip"
      a.set "JOHN DOE"

      b = Rico::Value.new RiakHelpers.bucket, "value_gzip_content_type_2"
      b.content_type.should eql "application/x-gzip"
      b.get.should eql "JOHN DOE"
    end
  end

  describe "#exists?" do
    it "returns true if it exists" do
      a = Rico::Value.new RiakHelpers.bucket, "value_exists_true"
      a.set "bob"
      b = Rico::Value.new RiakHelpers.bucket, "value_exists_true"
      b.exists?.should eql true
    end

    it "returns false if it does not exists" do
      a = Rico::Value.new RiakHelpers.bucket, "value_exists_false"
      a.exists?.should eql false
    end
  end

  describe "#get" do
    it "returns the value" do
      a = Rico::Value.new RiakHelpers.bucket, "value_get_return_value"
      a.set([1, 2, 3, 4, 5, "bob", "joe"])
      b = Rico::Value.new RiakHelpers.bucket, "value_get_return_value"
      b.get.should eql [1, 2, 3, 4, 5, "bob", "joe"]
    end

    it "returns nil if the value does not exist" do
      a = Rico::Value.new RiakHelpers.bucket, "value_get_nil"
      a.get.should eql nil
    end
  end

  describe "#set" do
    it "writes the value" do
      a = Rico::Value.new RiakHelpers.bucket, "value_set"
      a.set "john"
      b = Rico::Value.new RiakHelpers.bucket, "value_set"
      b.get.should eql "john"
    end
  end

  describe "#setnx" do
    it "writes the value, returns true if new" do
      a = Rico::Value.new RiakHelpers.bucket, "setnx_new"
      a.setnx("value").should eql true
      b = Rico::Value.new RiakHelpers.bucket, "setnx_new"
      b.get.should eql "value"
    end

    it "does nothing, returns false if the value exists" do
      a = Rico::Value.new RiakHelpers.bucket, "setnx_exists"
      a.set "value"
      b = Rico::Value.new RiakHelpers.bucket, "setnx_exists"
      b.setnx("other").should eql false
      b.get.should eql "value"
      c = Rico::Value.new RiakHelpers.bucket, "setnx_exists"
      c.get.should eql "value"
    end
  end

  describe "#delete" do
    it "deletes an existing object" do
      a = Rico::Value.new RiakHelpers.bucket, "delete_existing"
      a.set "john"
      a.delete
      b = Rico::Value.new RiakHelpers.bucket, "delete_existing"
      b.exists?.should eql false
      b.get.should eql nil
    end
  end

  describe ".resolve" do
    it "just returns the last modified sibling" do
      datas = [
        { "_type" => "value", "_value" => "Oldest" },
        { "_type" => "value", "_value" => "Middle" },
        { "_type" => "value", "_value" => "Newest" },
        { "_type" => "value", "_value" => "Middle" },
        { "_type" => "value", "_value" => "Middle" }
      ]
      times = [
        Time.utc(2012, 10, 10, 10, 10, 10),
        Time.utc(2013, 10, 10, 10, 10, 10),
        Time.utc(2014, 10, 10, 10, 10, 10),
        Time.utc(2013, 10, 10, 10, 10, 10),
        Time.utc(2013, 10, 10, 10, 10, 10)
      ]
      conflicted = RiakHelpers.build_conflicted_robject "value_resolve_simple", datas
      conflicted.siblings.each_with_index do |s, i|
        s.last_modified = times[i]
      end
      result = Rico::Value.resolve(conflicted)
      result.data.should eql({ "_type" => "value", "_value" => "Newest" })
    end
  end
end