Initial: Clear out compilation commands for multiple reflection protocols

Author: deve-sh

package.json

@@ -44,7 +44,7 @@
     "prepare": "yarn run compile",
     "pretest": "yarn run compile && yarn run fix",
     "posttest": "yarn run check",
-    "protoc": "grpc_tools_node_protoc --js_out=import_style=commonjs,binary:./src --grpc_out=grpc_js:./src --ts_out=grpc_js:./src --plugin=protoc-gen-ts=./node_modules/.bin/protoc-gen-ts -I ./static/grpc/reflection/v1alpha reflection.proto",
+    "protoc": "node scripts/compile-protoc",
     "build": "yarn run compile && yarn run fix && yarn run check"
   },
   "files": [

scripts/compile-protoc.js

@@ -0,0 +1,40 @@
+const fs = require('fs');
+const {execSync} = require('child_process');
+
+const supportedProtocols = ['v1alpha', 'v1'];
+
+async function main() {
+  for (const protocol of supportedProtocols) {
+    if (fs.existsSync(`./src/reflection_providers/${protocol}`)) {
+      fs.rmdirSync(`./src/reflection_providers/${protocol}`, {recursive: true});
+    }
+
+    fs.mkdirSync(`./src/reflection_providers/${protocol}`);
+
+    console.log(
+      `Compiling protocol buffers and building services + clients for protocol: ${protocol}...\n`
+    );
+
+    const command = [
+      'grpc_tools_node_protoc',
+      `--js_out=import_style=commonjs,binary:./src/reflection_providers/${protocol}`,
+      `--grpc_out=grpc_js:./src/reflection_providers/${protocol}`,
+      `--ts_out=grpc_js:./src/reflection_providers/${protocol}`,
+      '--plugin=protoc-gen-ts=./node_modules/.bin/protoc-gen-ts',
+      `-I ./static/grpc/reflection/${protocol}`,
+      'reflection.proto',
+    ].join(' ');
+
+    execSync(command, {stdio: 'inherit'});
+
+    console.log('Compilation done for', protocol, '\n');
+  }
+
+  console.log('Protocol buffers compilation completed.');
+}
+
+main().catch(err => {
+  console.error('Error during protocol buffers compilation:');
+
+  throw err;
+});

src/reflection_providers/v1/reflection_grpc_pb.d.ts

@@ -0,0 +1,40 @@
+// package: grpc.reflection.v1
+// file: reflection.proto
+
+/* tslint:disable */
+/* eslint-disable */
+
+import * as grpc from "@postman/grpc-js";
+import * as reflection_pb from "./reflection_pb";
+
+interface IServerReflectionService extends grpc.ServiceDefinition<grpc.UntypedServiceImplementation> {
+    serverReflectionInfo: IServerReflectionService_IServerReflectionInfo;
+}
+
+interface IServerReflectionService_IServerReflectionInfo extends grpc.MethodDefinition<reflection_pb.ServerReflectionRequest, reflection_pb.ServerReflectionResponse> {
+    path: "/grpc.reflection.v1.ServerReflection/ServerReflectionInfo";
+    requestStream: true;
+    responseStream: true;
+    requestSerialize: grpc.serialize<reflection_pb.ServerReflectionRequest>;
+    requestDeserialize: grpc.deserialize<reflection_pb.ServerReflectionRequest>;
+    responseSerialize: grpc.serialize<reflection_pb.ServerReflectionResponse>;
+    responseDeserialize: grpc.deserialize<reflection_pb.ServerReflectionResponse>;
+}
+
+export const ServerReflectionService: IServerReflectionService;
+
+export interface IServerReflectionServer extends grpc.UntypedServiceImplementation {
+    serverReflectionInfo: grpc.handleBidiStreamingCall<reflection_pb.ServerReflectionRequest, reflection_pb.ServerReflectionResponse>;
+}
+
+export interface IServerReflectionClient {
+    serverReflectionInfo(): grpc.ClientDuplexStream<reflection_pb.ServerReflectionRequest, reflection_pb.ServerReflectionResponse>;
+    serverReflectionInfo(options: Partial<grpc.CallOptions>): grpc.ClientDuplexStream<reflection_pb.ServerReflectionRequest, reflection_pb.ServerReflectionResponse>;
+    serverReflectionInfo(metadata: grpc.Metadata, options?: Partial<grpc.CallOptions>): grpc.ClientDuplexStream<reflection_pb.ServerReflectionRequest, reflection_pb.ServerReflectionResponse>;
+}
+
+export class ServerReflectionClient extends grpc.Client implements IServerReflectionClient {
+    constructor(address: string, credentials: grpc.ChannelCredentials, options?: Partial<grpc.ClientOptions>);
+    public serverReflectionInfo(options?: Partial<grpc.CallOptions>): grpc.ClientDuplexStream<reflection_pb.ServerReflectionRequest, reflection_pb.ServerReflectionResponse>;
+    public serverReflectionInfo(metadata?: grpc.Metadata, options?: Partial<grpc.CallOptions>): grpc.ClientDuplexStream<reflection_pb.ServerReflectionRequest, reflection_pb.ServerReflectionResponse>;
+}

src/reflection_providers/v1/reflection_grpc_pb.js

@@ -0,0 +1,68 @@
+// GENERATED CODE -- DO NOT EDIT!
+
+// Original file comments:
+// Copyright 2016 The gRPC Authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+//
+// Service exported by server reflection.  A more complete description of how
+// server reflection works can be found at
+// https://github.com/grpc/grpc/blob/master/doc/server-reflection.md
+//
+// The canonical version of this proto can be found at
+// https://github.com/grpc/grpc-proto/blob/master/grpc/reflection/v1/reflection.proto
+//
+'use strict';
+var grpc = require('@postman/grpc-js');
+var reflection_pb = require('./reflection_pb.js');
+
+function serialize_grpc_reflection_v1_ServerReflectionRequest(arg) {
+  if (!(arg instanceof reflection_pb.ServerReflectionRequest)) {
+    throw new Error('Expected argument of type grpc.reflection.v1.ServerReflectionRequest');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_grpc_reflection_v1_ServerReflectionRequest(buffer_arg) {
+  return reflection_pb.ServerReflectionRequest.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+function serialize_grpc_reflection_v1_ServerReflectionResponse(arg) {
+  if (!(arg instanceof reflection_pb.ServerReflectionResponse)) {
+    throw new Error('Expected argument of type grpc.reflection.v1.ServerReflectionResponse');
+  }
+  return Buffer.from(arg.serializeBinary());
+}
+
+function deserialize_grpc_reflection_v1_ServerReflectionResponse(buffer_arg) {
+  return reflection_pb.ServerReflectionResponse.deserializeBinary(new Uint8Array(buffer_arg));
+}
+
+
+var ServerReflectionService = exports.ServerReflectionService = {
+  // The reflection service is structured as a bidirectional stream, ensuring
+// all related requests go to a single server.
+serverReflectionInfo: {
+    path: '/grpc.reflection.v1.ServerReflection/ServerReflectionInfo',
+    requestStream: true,
+    responseStream: true,
+    requestType: reflection_pb.ServerReflectionRequest,
+    responseType: reflection_pb.ServerReflectionResponse,
+    requestSerialize: serialize_grpc_reflection_v1_ServerReflectionRequest,
+    requestDeserialize: deserialize_grpc_reflection_v1_ServerReflectionRequest,
+    responseSerialize: serialize_grpc_reflection_v1_ServerReflectionResponse,
+    responseDeserialize: deserialize_grpc_reflection_v1_ServerReflectionResponse,
+  },
+};
+
+exports.ServerReflectionClient = grpc.makeGenericClientConstructor(ServerReflectionService, 'ServerReflection');