fix: updating testing, rest-only generation, & minor bug-fixes

gapic/generator/generator.py

@@ -278,6 +278,10 @@ def _render_template(
                         or
                         ('transport' in template_name
                         and not self._is_desired_transport(template_name, opts))
+                        or
+                        # TODO(yon-mg) - remove when rest async implementation resolved
+                        # temporarily stop async client gen while rest async is unkown
+                        ('async' in template_name and 'grpc' not in opts.transport)
                 ):
                     continue
 

gapic/schema/wrappers.py

@@ -411,7 +411,8 @@ def get_field(self, *field_path: str,
         collisions = collisions or self.meta.address.collisions
 
         # Get the first field in the path.
-        cursor = self.fields[field_path[0]]
+        first_field = field_path[0]
+        cursor = self.fields[first_field+('_' if first_field in utils.RESERVED_NAMES else '')]
 
         # Base case: If this is the last field in the path, return it outright.
         if len(field_path) == 1:

gapic/templates/%namespace/%name/__init__.py.j2

@@ -12,8 +12,10 @@ from {% if api.naming.module_namespace %}{{ api.naming.module_namespace|join('.'
         if service.meta.address.subpackage == api.subpackage_view -%}
 from {% if api.naming.module_namespace %}{{ api.naming.module_namespace|join('.') }}.{% endif -%}
     {{ api.naming.versioned_module_name }}.services.{{ service.name|snake_case }}.client import {{ service.client_name }}
+{%- if 'grpc' in opts.transport %}
 from {% if api.naming.module_namespace %}{{ api.naming.module_namespace|join('.') }}.{% endif -%}
     {{ api.naming.versioned_module_name }}.services.{{ service.name|snake_case }}.async_client import {{ service.async_client_name }}
+{%- endif %}
 {% endfor -%}
 
 {#  Import messages and enums from each proto.
@@ -50,7 +52,9 @@ __all__ = (
 {% for service in api.services.values()|sort(attribute='name')
    if service.meta.address.subpackage == api.subpackage_view -%}
 '{{ service.client_name }}',
+    {%- if 'grpc' in opts.transport %}
 '{{ service.async_client_name }}',
+    {%- endif %}
 {% endfor -%}
 {% for proto in api.protos.values()|sort(attribute='module_name')
    if proto.meta.address.subpackage == api.subpackage_view -%}

gapic/templates/%namespace/%name_%version/%sub/services/%service/__init__.py.j2

@@ -2,10 +2,14 @@
 
 {% block content %}
 from .client import {{ service.client_name }}
+{%- if 'grpc' in opts.transport %}
 from .async_client import {{ service.async_client_name }}
+{%- endif %}
 
 __all__ = (
     '{{ service.client_name }}',
+    {%- if 'grpc' in opts.transport %}
     '{{ service.async_client_name }}',
+    {%- endif %}
 )
 {% endblock %}

gapic/templates/%namespace/%name_%version/%sub/services/%service/transports/rest.py.j2

@@ -78,7 +78,13 @@ class {{ service.name }}RestTransport({{ service.name }}Transport):
                 Generally, you only need to set this if you're developing	
                 your own client library.
         """
-        super().__init__(host=host, credentials=credentials)
+        # Run the base constructor
+        # TODO(yon-mg): resolve other ctor params i.e. scopes, quota, etc.
+        super().__init__(
+            host=host,
+            credentials=credentials,
+            client_info=client_info,
+        )
         self._session = AuthorizedSession(self._credentials)
         {%- if service.has_lro %}
         self._operations_client = None
@@ -180,10 +186,8 @@ class {{ service.name }}RestTransport({{ service.name }}Transport):
         # TODO(yon-mg): further discussion needed whether 'python truthiness' is appropriate here
         #               discards default values
         # TODO(yon-mg): add test for proper url encoded strings
-        query_params = ((k, v) for k, v in query_params.items() if v)
-        for i, (param_name, param_value) in enumerate(query_params):
-            q = '?' if i == 0 else '&'
-            url += "{q}{name}={value}".format(q=q, name=param_name, value=param_value.replace(' ', '+'))
+        query_params = ['{k}={v}'.format(k=k, v=v) for k, v in query_params.items() if v]
+        url += '?{}'.format('&'.join(query_params)).replace(' ', '+')
 
         # Send the request
         {% if not method.void %}response = {% endif %}self._session.{{ method.http_opt['verb'] }}(