# encoding: utf-8

require File.dirname(__FILE__) + '/../spec_helper'

describe Backup::Database::Redis do

  before do
    Backup::Database::Redis.any_instance.stubs(:load_defaults!)
    Backup::Logger.stubs(:error)
  end

  let(:db) do
    Backup::Database::Redis.new do |db|
      db.name        = 'mydatabase'
      db.path        = '/var/lib/redis/db/'
      db.password    = 'secret'
      db.host        =  'localhost'
      db.port        = 123
      db.socket      = '/redis.sock'
      db.invoke_save = true

      db.additional_options = ['--query']
    end
  end

  describe '#new' do
    it 'should read the adapter details correctly' do
      db.name.should        == 'mydatabase'
      db.password.should    == 'secret'
      db.host.should        == 'localhost'
      db.port.should        == 123
      db.socket.should      == '/redis.sock'
      db.invoke_save.should == true

      db.additional_options.should == '--query'
    end

    it 'arrays should default to empty arrays when not specified' do
      db = Backup::Database::Redis.new do |db|
        db.name     = 'mydatabase'
        db.password = 'secret'
      end

      db.additional_options.should == ""
    end

    it 'should ensure the directory is available' do
      Backup::Database::Redis.any_instance.expects(:mkdir).with("#{Backup::TMP_PATH}/myapp/Redis")
      Backup::Database::Redis.new {}
    end
  end

  describe '#credential_options' do
    it 'should return the mongo syntax for the credential options' do
      db.credential_options.should == "-a 'secret'"
    end
  end

  describe '#connectivity_options' do
    it 'should return the redis syntax for the connectivity options' do
      db.connectivity_options.should == "-h 'localhost' -p '123' -s '/redis.sock'"
    end

    it 'should return only the port' do
      db = Backup::Database::Redis.new do |db|
        db.host   = nil
        db.port   = 123
      end

      db.connectivity_options.should == "-p '123'"
    end
  end

  describe '#invoke_save!' do
    it 'should return the full mongodump string' do
      db.expects(:utility).with('redis-cli').returns('redis-cli')
      db.expects(:run).with("redis-cli -a 'secret' -h 'localhost' -p '123' -s '/redis.sock' --query SAVE")
      db.invoke_save!
    end
  end

  describe '#copy!' do
    it do
      File.expects(:exist?).returns(true)
      db.stubs(:utility).returns('cp')
      db.expects(:run).with("cp '#{ File.join('/var/lib/redis/db/mydatabase.rdb') }' '#{ File.join(Backup::TMP_PATH, Backup::TRIGGER, 'Redis', 'mydatabase.rdb') }'")
      db.copy!
    end
  end

  describe '#perform!' do
    before do
      Backup::Logger.stubs(:message)
      File.stubs(:exist?).returns(true)
      db.stubs(:utility).returns('redis-cli')
      db.stubs(:mkdir)
      db.stubs(:run)
    end

    it 'should copy over without persisting (saving) first' do
      db.invoke_save = nil
      db.expects(:invoke_save!).never
      db.expects(:copy!)

      db.perform!
    end

    it 'should copy over after persisting (saving) the most recent updates' do
      db.invoke_save = true
      db.expects(:invoke_save!)
      db.expects(:copy!)

      db.perform!
    end

    it do
      Backup::Logger.expects(:message).with("Backup::Database::Redis started dumping and archiving \"mydatabase\".")

      db.perform!
    end
  end
end