diff options
author | 2015-01-07 12:13:17 -0800 | |
---|---|---|
committer | 2015-01-09 17:23:18 -0800 | |
commit | e4b409364e4c493a66d4b2a6fe897075aa5c174e (patch) | |
tree | 29467626f50aea49e072e15004dd141625146709 /src/ruby/bin/noproto_server.rb | |
parent | 8232204a36712553b9eedb2dacab13b7c38642c6 (diff) |
Add a --forever flag, to continuously run tests as things change.
Change on 2015/01/07 by ctiller <ctiller@google.com>
-------------
Created by MOE: http://code.google.com/p/moe-java
MOE_MIGRATED_REVID=83451760
Diffstat (limited to 'src/ruby/bin/noproto_server.rb')
-rw-r--r-- | src/ruby/bin/noproto_server.rb | 54 |
1 files changed, 9 insertions, 45 deletions
diff --git a/src/ruby/bin/noproto_server.rb b/src/ruby/bin/noproto_server.rb index d410827b22..7b74fa13ec 100644 --- a/src/ruby/bin/noproto_server.rb +++ b/src/ruby/bin/noproto_server.rb @@ -37,24 +37,23 @@ lib_dir = File.join(File.dirname(this_dir), 'lib') $LOAD_PATH.unshift(lib_dir) unless $LOAD_PATH.include?(lib_dir) require 'grpc' -require 'optparse' -class NoProtoMsg - def self.marshal(o) +class EchoMsg + def marshal '' end def self.unmarshal(o) - NoProtoMsg.new + EchoMsg.new end end -class NoProtoService +class EchoService include GRPC::GenericService - rpc :AnRPC, NoProtoMsg, NoProtoMsg + rpc :AnRPC, EchoMsg, EchoMsg end -class NoProto < NoProtoService +class Echo < EchoService def initialize(default_var='ignored') end @@ -64,46 +63,11 @@ class NoProto < NoProtoService end end -def load_test_certs - this_dir = File.expand_path(File.dirname(__FILE__)) - data_dir = File.join(File.dirname(this_dir), 'spec/testdata') - files = ['ca.pem', 'server1.key', 'server1.pem'] - files.map { |f| File.open(File.join(data_dir, f)).read } -end - -def test_server_creds - certs = load_test_certs - server_creds = GRPC::Core::ServerCredentials.new(nil, certs[1], certs[2]) -end - def main - options = { - 'host' => 'localhost:9090', - 'secure' => false - } - OptionParser.new do |opts| - opts.banner = 'Usage: [--host <hostname>:<port>] [--secure|-s]' - opts.on('--host HOST', '<hostname>:<port>') do |v| - options['host'] = v - end - opts.on('-s', '--secure', 'access using test creds') do |v| - options['secure'] = true - end - end.parse! - - if options['secure'] - s = GRPC::RpcServer.new(creds: test_server_creds) - s.add_http2_port(options['host'], true) - logger.info("... running securely on #{options['host']}") - else - s = GRPC::RpcServer.new - s.add_http2_port(options['host']) - logger.info("... running insecurely on #{options['host']}") - end - - s.handle(NoProto) + s = GRPC::RpcServer.new() + s.add_http2_port('localhost:9090') + s.handle(Echo) s.run end - main |