require 'spec_helper'
require 'spec/support/test/resource_service'
require 'protobuf/rpc/service_directory'

describe 'Functional ZMQ Client' do
  let(:options) {{
    :host => "127.0.0.1",
    :port => 9399,
    :worker_port => 9400,
    :backlog => 100,
    :threshold => 100,
    :threads => 5
  }}

  let(:server) { ::Protobuf::Rpc::Zmq::Server.new(options) }
  let(:server_thread) { Thread.new(server) { |server| server.run } }

  before do
    load "protobuf/zmq.rb"
    server_thread.abort_on_exception = true
    Thread.pass until server.running?
  end

  after do
    server.stop
    server_thread.join
  end

  it 'runs fine when required fields are set' do
    expect {
      client = ::Test::ResourceService.client

      client.find(:name => 'Test Name', :active => true) do |c|
        c.on_success do |succ|
          succ.name.should eq("Test Name")
          succ.status.should eq(::Test::StatusType::ENABLED)
        end

        c.on_failure do |err|
          raise err.inspect
        end
      end
    }.to_not raise_error
  end

  context 'when a message is malformed' do
    it 'calls the on_failure callback' do
      error = nil
      StubServer.new(:server => Protobuf::Rpc::Zmq::Server) do
        request = ::Test::ResourceFindRequest.new(:active => true)
        client = ::Test::ResourceService.client

        client.find(request) do |c|
          c.on_success { raise "shouldn't pass" }
          c.on_failure {|e| error = e }
        end
      end
      error.message.should match(/name.*required/)
    end
  end

  context 'when the request type is wrong' do
    it 'calls the on_failure callback' do
      error = nil
      StubServer.new(:server => Protobuf::Rpc::Zmq::Server) do
        request = ::Test::Resource.new(:name => 'Test Name')
        client = ::Test::ResourceService.client

        client.find(request) do |c|
          c.on_success { raise "shouldn't pass" }
          c.on_failure {|e| error = e}
        end
      end
      error.message.should match(/expected request.*ResourceFindRequest.*Resource instead/i)
    end
  end

  context 'when the server takes too long to respond' do
    it 'responds with a timeout error' do
      error = nil
      StubServer.new(:server => Protobuf::Rpc::Zmq::Server) do
        client = ::Test::ResourceService.client(:timeout => 1)

        client.find_with_sleep(:sleep => 2) do |c|
          c.on_success { raise "shouldn't pass" }
          c.on_failure { |e| error = e }
        end
      end
      error.message.should match(/The server took longer than 1 seconds to respond/i)
    end
  end

end