Sha256: 26a6d39cd7a680ac080d2ed6b64dadcbd71630d94a181ca69273b234da0a3499
Contents?: true
Size: 1.69 KB
Versions: 11
Compression:
Stored size: 1.69 KB
Contents
require 'spec_helper'
require 'protobuf/rpc/service_dispatcher'
describe Protobuf::Rpc::ServiceDispatcher do
let(:app) { proc { |env| env } }
let(:env) {
Protobuf::Rpc::Env.new(
'method_name' => method_name,
'request' => request,
'rpc_service' => service_class,
'service_name' => service_name,
)
}
let(:method_name) { :find }
let(:request) { request_type.new(:name => 'required') }
let(:request_type) { service_class.rpcs[method_name].request_type }
let(:response) { response_type.new(:name => 'required') }
let(:response_type) { service_class.rpcs[method_name].response_type }
let(:rpc_service) { service_class.new(env) }
let(:service_class) { Test::ResourceService }
let(:service_name) { service_class.to_s }
subject { described_class.new(app) }
before { allow(subject).to receive(:rpc_service).and_return(rpc_service) }
describe '#call' do
before { allow(rpc_service).to receive(:response).and_return(response) }
it "dispatches the request" do
stack_env = subject.call(env)
expect(stack_env.response).to eq response
end
context "when the given RPC method is not implemented" do
let(:method_name) { :find_not_implemented }
it "raises a method not found exception" do
expect { subject.call(env) }.to raise_exception(Protobuf::Rpc::MethodNotFound)
end
end
context "when the given RPC method is implemented and a NoMethodError is raised" do
before { allow(rpc_service).to receive(:callable_rpc_method).and_return(lambda { rpc_service.__send__(:foo) }) }
it "raises the exeception" do
expect { subject.call(env) }.to raise_exception(NoMethodError)
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems