# frozen_string_literal: true

# rubocop:disable Style/GlobalVars

$LOAD_PATH.unshift File.expand_path('./examples/routeguide')

require 'grpc_kit'
require 'pry'
require 'json'
require 'logger'
require 'routeguide_services_pb'

RESOURCE_PATH = './examples/routeguide/routeguide.json'
HOST = 'localhost'
PORT = 50051

$logger = Logger.new(STDOUT)

def get_feature(stub)
  $logger.info('===== get_feature =====')
  points = [
    Routeguide::Point.new(latitude:  409_146_138, longitude: -746_188_906),
    Routeguide::Point.new(latitude:  0, longitude: 0)
  ]

  points.each do |pt|
    feature = stub.get_feature(pt)
    if feature.name == ''
      $logger.info("Found nothing at #{feature.inspect}")
    else
      $logger.info("Found '#{feature.name}' at #{feature.location.inspect}")
    end
  end
end

def list_features(stub)
  $logger.info('===== list_features =====')
  rect = Routeguide::Rectangle.new(
    lo: Routeguide::Point.new(latitude: 400_000_000, longitude: -750_000_000),
    hi: Routeguide::Point.new(latitude: 420_000_000, longitude: -730_000_000),
  )

  stream = stub.list_features(rect)

  loop do
    r = stream.recv
    $logger.info("Found #{r.name} at #{r.location.inspect}")
  end
end

def record_route(stub, size)
  features = File.open(RESOURCE_PATH) do |f|
    JSON.parse(f.read)
  end

  stream = stub.record_route({})

  size.times do
    location = features.sample['location']
    point = Routeguide::Point.new(latitude: location['latitude'], longitude: location['longitude'])
    puts "Next point is #{point.inspect}"
    stream.send_msg(point)
    sleep(rand(0..1))
  end

  resp = stream.close_and_recv
  puts "summary: #{resp[0].inspect}"
end

opts = {}

if ENV['GRPC_INTERCEPTOR']
  require_relative 'interceptors/client_logging_interceptor'
  opts[:interceptors] = [LoggingInterceptor.new]
elsif ENV['GRPC_TIMEOUT']
  opts[:timeout] = Integer(ENV['GRPC_TIMEOUT'])
end

sock = TCPSocket.new(HOST, PORT)
stub = Routeguide::RouteGuide::Stub.new(sock, **opts)

get_feature(stub)
list_features(stub)
record_route(stub, 10)

# rubocop:enable Style/GlobalVars