class Protobuf::Rpc::Stat

def client
  @client ? "#{@client[:ip]}:#{@client[:port]}" : nil
end

def client=(peer)
  @client = {:port => peer[0], :ip => peer[1]}
end

def client?
  @mode == :CLIENT
end

def elapsed_time
  (start_time && end_time ? "#{(end_time - start_time).round(4)}s" : nil)
end

def initialize(mode = :SERVER)
  @mode = mode
  start
end

def method
  @method ||= @dispatcher.try(:callable_method).try(:name)
end

def rpc
  service && method ? "#{service}##{method}" : nil
end

def server
  @server ? "#{@server[:ip]}:#{@server[:port]}" : nil
end

def server=(peer)
  @server = {:port => peer[0], :ip => peer[1]}
end

def server?
  @mode == :SERVER
end

def service
  @service ||= @dispatcher.try(:service).class.name
end

def sizes
  "#{@request_size || 0}B/#{@response_size || 0}B"
end

def start
  @start_time ||= Time.now
end

def stop
  start if !@start_time
  @end_time ||= Time.now
end

def to_s
  [
    server? ? "[SRV]" : "[CLT]",
    rpc,
    elapsed_time,
    sizes,
    server? ? server : client
  ].compact.join(' - ')
end