require "spec_helper"

describe Lita::Handlers::Consul, lita_handler: true do
  describe 'lita routes' do
    it { is_expected.to route_command('consul get mykey').to(:consul_get) }
    it { is_expected.to route_command('consul set mykey myvalue').to(:consul_set) }
    it { is_expected.to route_command('consul members').to(:consul_members) }
  end

  before do
    allow_any_instance_of(Faraday::Connection).to receive(:get).and_return(response)
    allow_any_instance_of(Faraday::Connection).to receive(:put).and_return(response)
  end
    
  let(:response) { double("Faraday::Response") }
  let(:single_key_response) {
    %{
      [
        {
          "CreateIndex":67,
          "ModifyIndex":67,
          "LockIndex":0,
          "Key":"mykey",
          "Flags":0,
          "Value":"dGVzdGluZw=="
        }
      ]
    }
  }

  let(:null_value_response) {
    %{
      [
        {
          "CreateIndex":67,
          "ModifyIndex":67,
          "LockIndex":0,
          "Key":"mykey",
          "Flags":0,
          "Value":null
        }
      ]
    }
  }

  let(:new_key_response) {
    %{
      [
        {
          "CreateIndex":67,
          "ModifyIndex":67,
          "LockIndex":0,
          "Key":"myapp/config/url",
          "Flags":0,
          "Value":"d3d3LnRlc3QuY29t"
        }
      ]
    }
  }

  let(:members_response) {
    %{
      [
        {"Node":"node1.node.consul","Address":"192.168.0.33"},
        {"Node":"node2.node.consul","Address":"192.168.0.34"}
      ]
    }
  }

  describe '#consul members' do
    it 'should list member nodes' do
      allow(response).to receive(:body).and_return(members_response)
      send_command('consul members')
      expect(replies.last).to eq("node1.node.consul - 192.168.0.33\nnode2.node.consul - 192.168.0.34")
    end
  end

  describe '#consul get' do
    it 'return value for key' do
      allow(response).to receive(:body).and_return(single_key_response)
      send_command('consul get mykey')
      expect(replies.last).to eq("mykey = testing")
    end

    it 'return null value for key' do
      allow(response).to receive(:body).and_return(null_value_response)
      send_command('consul get mykey')
      expect(replies.last).to eq("mykey = null")
    end
  end

  describe '#consul set' do
    it 'set and return value for key' do
      allow(response).to receive(:body).and_return(new_key_response)
      allow(response).to receive(:status).and_return(200)
      send_command('consul set myapp/config/url www.test.com')
      expect(replies.last).to eq("myapp/config/url = www.test.com")
    end
  end
end