require 'spec_helper'
require 'protobuf/http'
require 'faraday'

describe ::Protobuf::Rpc::Connectors::Http do
  subject { described_class.new({}) }

  it_behaves_like "a Protobuf Connector"
  specify { subject.respond_to?(:post_init, true).should be true }

  let(:client_double) do
    Faraday.new do |builder|
      builder.adapter :test do |stub|
        stub.post("/Foo/UserService/find") { [200, {}, "\n\n\n\x03foo\x12\x03bar"] }
        stub.post("/Foo/UserService/foo1") do
          headers = {
            'x-protobuf-error' => "Foo::UserService#foo1 is not a defined RPC method.",
            'x-protobuf-error-reason' => Protobuf::Socketrpc::ErrorReason::METHOD_NOT_FOUND.to_s,
          }
          [404, headers, '']
        end
        stub.post("/Foo/UserService/foo2") { [500, {}, ""] }
        stub.post("/base/Foo/UserService/foo3") { [200, {}, "\n\n\n\x03foo\x12\x03bar"] }
      end
    end
  end

  describe "#send_data" do
    before do
      subject.stub(:client) { client_double }
      subject.stub(:parse_response) {}
    end

    it "handles RPC success correctly" do
      subject.stub(:request_bytes) { "\n\x10Foo::UserService\x12\x04find\x1A\r\n\vfoo@bar.com\"\rabcdefghijklm" }
      subject.send(:setup_connection)
      subject.send(:send_data)
      subject.instance_variable_get(:@response_data).should eq "\n\f\n\n\n\x03foo\x12\x03bar"
    end

    it "handles RPC error correctly" do
      subject.stub(:request_bytes) { "\n\x10Foo::UserService\x12\x04foo1\x1A\r\n\vfoo@bar.com\"\rabcdefghijklm" }
      subject.send(:setup_connection)
      subject.send(:send_data)
      subject.instance_variable_get(:@response_data).should eq "\n\x00\x122Foo::UserService#foo1 is not a defined RPC method. \x03"
    end

    it "handles server error correctly" do
      subject.stub(:request_bytes) { "\n\x10Foo::UserService\x12\x04foo2\x1A\r\n\vfoo@bar.com\"\rabcdefghijklm" }
      subject.send(:setup_connection)
      subject.send(:send_data)
      subject.instance_variable_get(:@response_data).should eq "\n\x00\x12\x1DBad response from the server. \x07"
    end

    it "prepends base path option correctly" do
      subject.stub(:options) { { :base => "/base" } }
      subject.stub(:request_bytes) { "\n\x10Foo::UserService\x12\x04foo3\x1A\r\n\vfoo@bar.com\"\rabcdefghijklm" }
      subject.send(:setup_connection)
      subject.send(:send_data)
      subject.instance_variable_get(:@response_data).should eq "\n\f\n\n\n\x03foo\x12\x03bar"
    end
  end
end