require 'spec_helper'
require 'riak/test_server'

describe Riak::TestServer, :nodegen => true do
  subject { test_server }
  let(:app_config) { (subject.etc + 'app.config').read }

  it "should add the test backends to the code path" do
    erl_src = File.expand_path("../../../../erl_src", __FILE__)
    subject.env[:riak_kv][:add_paths].should include(erl_src)
    app_config.should match(/\{add_paths, \[.*#{erl_src.inspect}.*\]\}/)
  end

  it "should use the KV test backend" do
    backend = if subject.version < "1.0.0"
                :riak_kv_test014_backend
              elsif subject.version < "1.2.0"
                :riak_kv_test_backend
              else
                :riak_kv_memory_backend
              end
    subject.kv_backend.should == backend
    subject.env[:riak_kv][:storage_backend].should == backend
    app_config.should include("{storage_backend, #{backend}}")
  end

  it "should use the Search test backend" do
    subject.search_backend.should == :riak_search_test_backend
    subject.env[:riak_search][:search_backend].should == :riak_search_test_backend
    app_config.should include("{search_backend, riak_search_test_backend}")
  end

  it "should clear stored data" do
    # TODO: use $test_server.to_host when client/host split is finished.
    client = Riak::Client.new(:http_port => subject.http_port)
    obj = client['test_bucket'].new("test_item")
    obj.data = {"data" => "testing"}
    obj.store # rescue nil

    subject.drop
    expect {
      client['test_bucket']['test_item']
    }.to raise_error(Riak::FailedRequest)
  end

  it "should not clobber user-specified paths in riak_kv/add_paths [seancribbs/ripple #256]", :test_server => false do
    # clean up the existing directory so the config is not overwritten
    test_server.send(:delete)
    config = {
      :root => subject.root,
      :source => subject.source,
      :env => {:riak_kv => {:add_paths => ["app/mapreduce/erlang"]}}
    }
    ts = described_class.new(config)
    ts.env[:riak_kv][:add_paths].should include("app/mapreduce/erlang")
  end
end