Sha256: f3aa5e52ebc8467de05ee199692a0823a56ff21f960984fe00850c1aa4c8a02a
Contents?: true
Size: 1.69 KB
Versions: 23
Compression:
Stored size: 1.69 KB
Contents
require 'spec_helper'
require 'protobuf/rpc/service_dispatcher'
RSpec.describe Protobuf::Rpc::ServiceDispatcher do
let(:app) { proc { |env| env } }
let(:env) do
Protobuf::Rpc::Env.new(
'method_name' => method_name,
'request' => request,
'rpc_service' => service_class,
'service_name' => service_name,
)
end
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(-> { rpc_service.__send__(:foo) }) }
it "raises the exeception" do
expect { subject.call(env) }.to raise_exception(NoMethodError)
end
end
end
end
Version data entries
23 entries across 23 versions & 2 rubygems