feat: respect resource annotation

package.json

@@ -18,7 +18,7 @@
     "codecov": "c8 --reporter=lcov mocha build/test/unit && c8 report",
     "lint": "gts check",
     "clean": "gts clean",
-    "compile-protos": "pbjs -p protos -p node_modules/google-gax/protos -t static-module -o pbjs-genfiles/plugin.js google/protobuf/compiler/plugin.proto google/api/annotations.proto google/api/client.proto google/longrunning/operations.proto service_config.proto && pbts pbjs-genfiles/plugin.js -o pbjs-genfiles/plugin.d.ts",
+    "compile-protos": "pbjs -p protos -p node_modules/google-gax/protos -t static-module -o pbjs-genfiles/plugin.js google/protobuf/compiler/plugin.proto google/api/annotations.proto google/api/resource.proto google/api/client.proto google/longrunning/operations.proto service_config.proto && pbts pbjs-genfiles/plugin.js -o pbjs-genfiles/plugin.d.ts",
     "compile": "tsc -p . && cp -r typescript/test/protos build/test/",
     "fix": "gts fix",
     "prepare": "npm run compile-protos && npm run compile",

templates/typescript_gapic/src/$version/$service_client.ts.njk

@@ -55,6 +55,9 @@ export class {{ service.name }}Client {
   */
   private _descriptors: Descriptors = {page: {}, stream: {}, longrunning: {}};
   private _innerApiCalls: {[name: string]: Function};
+  {%- if (service.pathTemplate.length > 0) %}
+  private _pathTemplates: {[name: string]: gax.PathTemplate};
+  {%- endif %}
   auth: gax.GoogleAuth;
 
   /**
@@ -141,6 +144,16 @@ export class {{ service.name }}Client {
         require("../../protos/protos.json") :
         nodejsProtoPath
     );
+{%- if (service.pathTemplate.length > 0) %}
+    this._pathTemplates = {
+{%- for template in service.pathTemplate %}
+      {{ template.type.toCamelCase() }}PathTemplate: new gaxModule.PathTemplate(
+        '{{ template.pattern }}'
+      ),
+{%- endfor %}
+    };
+{%- endif %}
+
 {%- if (service.paging.length > 0) %}
 
     // Some of the methods on this service return "paged" results,
@@ -482,4 +495,23 @@ export class {{ service.name }}Client {
     return this._innerApiCalls.{{ method.name.toCamelCase() }}(request, options, callback);
   } 
 {%- endfor %}
-}
+{%- if (service.pathTemplate.length > 0) %}
+  // --------------------
+  // -- Path templates --
+  // --------------------
+{%- for template in service.pathTemplate %}
+  {{ template.type.toLowerCase() }}Path({{ template.params.addStringType() }}){
+    return this._pathTemplates.{{ template.type.toLowerCase() }}PathTemplate.render({
+{%- for param in template.params %}
+      {{ param }}: {{ param }},
+{%- endfor %}
+    });
+  }
+{%- for param in template.params %}
+  match{{ param.capitalize() }}From{{ template.type }}Name({{ template.type.toLowerCase() }}Name: string){
+    return this._pathTemplates.{{ template.type.toLowerCase() }}PathTemplate.match({{ template.type.toLowerCase() }}Name).{{ param }};
+  }
+{%- endfor %}  
+{%- endfor %}
+{%- endif %}
+}

typescript/index.d.ts

@@ -20,3 +20,7 @@ interface String {
   toKebabCase(): string;
   toSnakeCase(): string;
 }
+
+interface Array<T>{
+  addStringType(): string[];
+}

typescript/src/schema/proto.ts

@@ -158,11 +158,17 @@ interface ServiceDescriptorProto
   port: number;
   oauthScopes: string[];
   comments: string;
+  pathTemplate: ResourceDescriptor[];
   commentsMap: CommentsMap;
   retryableCodeMap: RetryableCodeMap;
   grpcServiceConfig: plugin.grpc.service_config.ServiceConfig;
 }
 
+export interface ResourceDescriptor
+  extends plugin.google.api.IResourceDescriptor {
+  params: string[];
+}
+
 export interface ServicesMap {
   [name: string]: ServiceDescriptorProto;
 }
@@ -436,6 +442,35 @@ function augmentService(
       '.google.api.oauthScopes'
     ].split(',');
   }
+  augmentedService.pathTemplate = [];
+  for (const property of Object.keys(messages)) {
+    const m = messages[property];
+    if (m && m.options) {
+      const option = m.options;
+      if (option && option['.google.api.resource']) {
+        const opt = option['.google.api.resource'];
+        const onePathTemplate = option[
+          '.google.api.resource'
+        ] as ResourceDescriptor;
+        if (opt.type) {
+          const arr = opt.type.match(/\/([^.]+)$/);
+          if (arr) {
+            opt.type = arr[arr.length - 1];
+          }
+        }
+        const pattern = opt.pattern;
+        //TODO: SUPPORT MULTIPLE PATTERNS
+        if (pattern && pattern[0]) {
+          const params = pattern[0].match(/{[a-zA-Z]+}/g) || [];
+          for (let i = 0; i < params.length; i++) {
+            params[i] = params[i].replace('{', '').replace('}', '');
+          }
+          onePathTemplate.params = params;
+        }
+        augmentedService.pathTemplate.push(onePathTemplate);
+      }
+    }
+  }
   return augmentedService;
 }
 

typescript/src/util.ts

@@ -105,3 +105,10 @@ String.prototype.toSnakeCase = function(this: string): string {
   }
   return words.join('_');
 };
+
+Array.prototype.addStringType = function(this: string[]): string[] {
+  if (this.length === 0) {
+    return this;
+  }
+  return this.map(p => p + ': string');
+};

typescript/test/testdata/keymanager/src/v1/key_management_service_client.ts.baseline

@@ -1231,4 +1231,4 @@ export class KeyManagementServiceClient {
     options = options || {};
     return this._innerApiCalls.listImportJobs(request, options, callback);
   }
-}
+}

typescript/test/testdata/showcase/src/v1beta1/echo_client.ts.baseline

@@ -468,4 +468,4 @@ export class EchoClient {
     options = options || {};
     return this._innerApiCalls.pagedExpand(request, options, callback);
   }
-}
+}

typescript/test/testdata/texttospeech/src/v1/text_to_speech_client.ts.baseline

@@ -313,4 +313,4 @@ export class TextToSpeechClient {
     return this._innerApiCalls.synthesizeSpeech(request, options, callback);
   }
 
-}
+}