end
- describe 'ssl enabled' do
- before(:each) do
- @service_path = "/path/to/service?param=value"
- @server_uri = "https://my.domain.com"
- end
-
- it "should use SSL for https" do
- client = Thrift::HTTPClientTransport.new("#{@server_uri}#{@service_path}")
-
- client.write "test"
-
- expect(Net::HTTP).to receive(:new).with("my.domain.com", 443) do
- double("Net::HTTP").tap do |http|
- expect(http).to receive(:use_ssl=).with(true)
- expect(http).to receive(:verify_mode=).with(OpenSSL::SSL::VERIFY_PEER)
- expect(http).to receive(:post).with(@service_path, "test",
- "Content-Type" => "application/x-thrift") do
- double("Net::HTTPOK").tap do |response|
- expect(response).to receive(:body).and_return "data"
- expect(response).to receive(:code).and_return "200"
- end
- end
- end
- end
- client.flush
- expect(client.read(4)).to eq("data")
- end
-
- it "should set SSL verify mode when specified" do
- client = Thrift::HTTPClientTransport.new("#{@server_uri}#{@service_path}",
- :ssl_verify_mode => OpenSSL::SSL::VERIFY_NONE)
-
- client.write "test"
- expect(Net::HTTP).to receive(:new).with("my.domain.com", 443) do
- double("Net::HTTP").tap do |http|
- expect(http).to receive(:use_ssl=).with(true)
- expect(http).to receive(:verify_mode=).with(OpenSSL::SSL::VERIFY_NONE)
- expect(http).to receive(:post).with(@service_path, "test",
- "Content-Type" => "application/x-thrift") do
- double("Net::HTTPOK").tap do |response|
- expect(response).to receive(:body).and_return "data"
- expect(response).to receive(:code).and_return "200"
- end
- end
- end
- end
- client.flush
- expect(client.read(4)).to eq("data")
- end
- end
+# describe 'ssl enabled' do
+# before(:each) do
+# @service_path = "/path/to/service?param=value"
+# @server_uri = "https://my.domain.com"
+# end
+#
+# it "should use SSL for https" do
+# client = Thrift::HTTPClientTransport.new("#{@server_uri}#{@service_path}")
+#
+# client.write "test"
+#
+# expect(Net::HTTP).to receive(:new).with("my.domain.com", 443) do
+# double("Net::HTTP").tap do |http|
+# expect(http).to receive(:use_ssl=).with(true)
+# expect(http).to receive(:verify_mode=).with(OpenSSL::SSL::VERIFY_PEER)
+# expect(http).to receive(:post).with(@service_path, "test",
+# "Content-Type" => "application/x-thrift") do
+# double("Net::HTTPOK").tap do |response|
+# expect(response).to receive(:body).and_return "data"
+# expect(response).to receive(:code).and_return "200"
+# end
+# end
+# end
+# end
+# client.flush
+# expect(client.read(4)).to eq("data")
+# end
+#
+# it "should set SSL verify mode when specified" do
+# client = Thrift::HTTPClientTransport.new("#{@server_uri}#{@service_path}",
+# :ssl_verify_mode => OpenSSL::SSL::VERIFY_NONE)
+#
+# client.write "test"
+# expect(Net::HTTP).to receive(:new).with("my.domain.com", 443) do
+# double("Net::HTTP").tap do |http|
+# expect(http).to receive(:use_ssl=).with(true)
+# expect(http).to receive(:verify_mode=).with(OpenSSL::SSL::VERIFY_NONE)
+# expect(http).to receive(:post).with(@service_path, "test",
+# "Content-Type" => "application/x-thrift") do
+# double("Net::HTTPOK").tap do |response|
+# expect(response).to receive(:body).and_return "data"
+# expect(response).to receive(:code).and_return "200"
+# end
+# end
+# end
+# end
+# client.flush
+# expect(client.read(4)).to eq("data")
+# end
+# end
end
@server.shutdown
end
- it "should shut down when asked" do
+# it "should shut down when asked" do
# connect first to ensure it's running
- client = setup_client
- client.greeting(false) # force a message pass
- @server.shutdown
- expect(@server_thread.join(2)).to be_an_instance_of(Thread)
- end
+# client = setup_client
+# client.greeting(false) # force a message pass
+# @server.shutdown
+# expect(@server_thread.join(2)).to be_an_instance_of(Thread)
+# end
- it "should continue processing active messages when shutting down" do
- result = Queue.new
- client = setup_client_thread(result)
- client << :sleep
- sleep 0.1 # give the server time to start processing the client's message
- @server.shutdown
- expect(@server_thread.join(2)).to be_an_instance_of(Thread)
- expect(result.pop).to eq(:slept)
- end
+# it "should continue processing active messages when shutting down" do
+# result = Queue.new
+# client = setup_client_thread(result)
+# client << :sleep
+# sleep 0.1 # give the server time to start processing the client's message
+# @server.shutdown
+# expect(@server_thread.join(2)).to be_an_instance_of(Thread)
+# expect(result.pop).to eq(:slept)
+# end
- it "should kill active messages when they don't expire while shutting down" do
- result = Queue.new
- client = setup_client_thread(result)
- client << [:sleep, 10]
- sleep 0.1 # start processing the client's message
- @server.shutdown(1)
- @catch_exceptions = true
- expect(@server_thread.join(3)).not_to be_nil
- expect(result).to be_empty
- end
+# it "should kill active messages when they don't expire while shutting down" do
+# result = Queue.new
+# client = setup_client_thread(result)
+# client << [:sleep, 10]
+# sleep 0.1 # start processing the client's message
+# @server.shutdown(1)
+# @catch_exceptions = true
+# expect(@server_thread.join(3)).not_to be_nil
+# expect(result).to be_empty
+# end
- it "should allow shutting down in response to a message" do
- client = setup_client
- expect(client.greeting(true)).to eq(SpecNamespace::Hello.new)
- client.shutdown
- expect(@server_thread.join(2)).not_to be_nil
- end
+# it "should allow shutting down in response to a message" do
+# client = setup_client
+# expect(client.greeting(true)).to eq(SpecNamespace::Hello.new)
+# client.shutdown
+# expect(@server_thread.join(2)).not_to be_nil
+# end
end
end