xref: /aosp_15_r20/external/grpc-grpc/src/ruby/end2end/echo_server.rb (revision cc02d7e222339f7a4f6ba5f422e6413f4bd931f2)

#!/usr/bin/env ruby
#
# Copyright 2016 gRPC authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

this_dir = File.expand_path(File.dirname(__FILE__))
protos_lib_dir = File.join(this_dir, 'lib')
grpc_lib_dir = File.join(File.dirname(this_dir), 'lib')
$LOAD_PATH.unshift(grpc_lib_dir) unless $LOAD_PATH.include?(grpc_lib_dir)
$LOAD_PATH.unshift(protos_lib_dir) unless $LOAD_PATH.include?(protos_lib_dir)
$LOAD_PATH.unshift(this_dir) unless $LOAD_PATH.include?(this_dir)

require 'grpc'
require 'end2end_common'

def create_server_creds
  test_root = File.join(File.dirname(__FILE__), '..', 'spec', 'testdata')
  GRPC.logger.info("test root: #{test_root}")
  files = ['ca.pem', 'server1.key', 'server1.pem']
  creds = files.map { |f| File.open(File.join(test_root, f)).read }
  GRPC::Core::ServerCredentials.new(
    creds[0],
    [{ private_key: creds[1], cert_chain: creds[2] }],
    true) # force client auth
end

# Runs an echo server. Once the server is running, this writes the port of the
# server to stdout. Terminates after reading EOF on stdin.
def main
  secure = false
  OptionParser.new do |opts|
    opts.on('--secure') do
      secure = true
    end
  end.parse!
  STDERR.puts 'start server'
  if secure
    server_runner = ServerRunner.new(SecureEchoServerImpl)
    server_runner.server_creds = create_server_creds
  else
    server_runner = ServerRunner.new(EchoServerImpl)
  end
  server_port = server_runner.run
  p server_port
  STDIN.read
  server_runner.stop
end

main