require_relative 'rpc/query/query_twirp'

class Namara

  def query(query_statement)
    payload = { statement: query_statement }

    response = rpc_request(query_client) do |client|
      client.query(payload, rpc_headers)
    end

    OpenStruct.new(response.data.to_h)
  end

  private

  def query_client
    @query_client ||= Query::QueryServiceClient.new(api_url)
  end
end