aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/ruby/bin/noproto_server.rb
diff options
context:
space:
mode:
authorGravatar ctiller <ctiller@google.com>2015-01-07 12:13:17 -0800
committerGravatar Nicolas Noble <nnoble@google.com>2015-01-09 17:23:18 -0800
commite4b409364e4c493a66d4b2a6fe897075aa5c174e (patch)
tree29467626f50aea49e072e15004dd141625146709 /src/ruby/bin/noproto_server.rb
parent8232204a36712553b9eedb2dacab13b7c38642c6 (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.rb54
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