first commit

node_modules/@grpc/proto-loader/build/bin/proto-loader-gen-types.js

@@ -0,0 +1,828 @@
+#!/usr/bin/env node
+"use strict";
+/**
+ * @license
+ * Copyright 2020 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.
+ *
+ */
+Object.defineProperty(exports, "__esModule", { value: true });
+const fs = require("fs");
+const path = require("path");
+const Protobuf = require("protobufjs");
+const yargs = require("yargs");
+const camelCase = require("lodash.camelcase");
+const util_1 = require("../src/util");
+class TextFormatter {
+    constructor() {
+        this.indentText = '  ';
+        this.indentValue = 0;
+        this.textParts = [];
+    }
+    indent() {
+        this.indentValue += 1;
+    }
+    unindent() {
+        this.indentValue -= 1;
+    }
+    writeLine(line) {
+        for (let i = 0; i < this.indentValue; i += 1) {
+            this.textParts.push(this.indentText);
+        }
+        this.textParts.push(line);
+        this.textParts.push('\n');
+    }
+    getFullText() {
+        return this.textParts.join('');
+    }
+}
+// GENERATOR UTILITY FUNCTIONS
+function compareName(x, y) {
+    if (x.name < y.name) {
+        return -1;
+    }
+    else if (x.name > y.name) {
+        return 1;
+    }
+    else {
+        return 0;
+    }
+}
+function isNamespaceBase(obj) {
+    return Array.isArray(obj.nestedArray);
+}
+function stripLeadingPeriod(name) {
+    return name.startsWith('.') ? name.substring(1) : name;
+}
+function getImportPath(to) {
+    /* If the thing we are importing is defined in a message, it is generated in
+     * the same file as that message. */
+    if (to.parent instanceof Protobuf.Type) {
+        return getImportPath(to.parent);
+    }
+    return stripLeadingPeriod(to.fullName).replace(/\./g, '/');
+}
+function getPath(to) {
+    return stripLeadingPeriod(to.fullName).replace(/\./g, '/') + '.ts';
+}
+function getPathToRoot(from) {
+    const depth = stripLeadingPeriod(from.fullName).split('.').length - 1;
+    if (depth === 0) {
+        return './';
+    }
+    let path = '';
+    for (let i = 0; i < depth; i++) {
+        path += '../';
+    }
+    return path;
+}
+function getRelativeImportPath(from, to) {
+    return getPathToRoot(from) + getImportPath(to);
+}
+function getTypeInterfaceName(type) {
+    return type.fullName.replace(/\./g, '_');
+}
+function getImportLine(dependency, from) {
+    const filePath = from === undefined ? './' + getImportPath(dependency) : getRelativeImportPath(from, dependency);
+    const typeInterfaceName = getTypeInterfaceName(dependency);
+    let importedTypes;
+    /* If the dependency is defined within a message, it will be generated in that
+     * message's file and exported using its typeInterfaceName. */
+    if (dependency.parent instanceof Protobuf.Type) {
+        if (dependency instanceof Protobuf.Type) {
+            importedTypes = `${typeInterfaceName}, ${typeInterfaceName}__Output`;
+        }
+        else if (dependency instanceof Protobuf.Enum) {
+            importedTypes = `${typeInterfaceName}`;
+        }
+        else if (dependency instanceof Protobuf.Service) {
+            importedTypes = `${typeInterfaceName}Client, ${typeInterfaceName}Definition`;
+        }
+        else {
+            throw new Error('Invalid object passed to getImportLine');
+        }
+    }
+    else {
+        if (dependency instanceof Protobuf.Type) {
+            importedTypes = `${dependency.name} as ${typeInterfaceName}, ${dependency.name}__Output as ${typeInterfaceName}__Output`;
+        }
+        else if (dependency instanceof Protobuf.Enum) {
+            importedTypes = `${dependency.name} as ${typeInterfaceName}`;
+        }
+        else if (dependency instanceof Protobuf.Service) {
+            importedTypes = `${dependency.name}Client as ${typeInterfaceName}Client, ${dependency.name}Definition as ${typeInterfaceName}Definition`;
+        }
+        else {
+            throw new Error('Invalid object passed to getImportLine');
+        }
+    }
+    return `import type { ${importedTypes} } from '${filePath}';`;
+}
+function getChildMessagesAndEnums(namespace) {
+    const messageList = [];
+    for (const nested of namespace.nestedArray) {
+        if (nested instanceof Protobuf.Type || nested instanceof Protobuf.Enum) {
+            messageList.push(nested);
+        }
+        if (isNamespaceBase(nested)) {
+            messageList.push(...getChildMessagesAndEnums(nested));
+        }
+    }
+    return messageList;
+}
+function formatComment(formatter, comment) {
+    if (!comment) {
+        return;
+    }
+    formatter.writeLine('/**');
+    for (const line of comment.split('\n')) {
+        formatter.writeLine(` * ${line.replace(/\*\//g, '* /')}`);
+    }
+    formatter.writeLine(' */');
+}
+// GENERATOR FUNCTIONS
+function getTypeNamePermissive(fieldType, resolvedType, repeated, map) {
+    switch (fieldType) {
+        case 'double':
+        case 'float':
+            return 'number | string';
+        case 'int32':
+        case 'uint32':
+        case 'sint32':
+        case 'fixed32':
+        case 'sfixed32':
+            return 'number';
+        case 'int64':
+        case 'uint64':
+        case 'sint64':
+        case 'fixed64':
+        case 'sfixed64':
+            return 'number | string | Long';
+        case 'bool':
+            return 'boolean';
+        case 'string':
+            return 'string';
+        case 'bytes':
+            return 'Buffer | Uint8Array | string';
+        default:
+            if (resolvedType === null) {
+                throw new Error('Found field with no usable type');
+            }
+            const typeInterfaceName = getTypeInterfaceName(resolvedType);
+            if (resolvedType instanceof Protobuf.Type) {
+                if (repeated || map) {
+                    return typeInterfaceName;
+                }
+                else {
+                    return `${typeInterfaceName} | null`;
+                }
+            }
+            else {
+                return `${typeInterfaceName} | keyof typeof ${typeInterfaceName}`;
+            }
+    }
+}
+function getFieldTypePermissive(field) {
+    const valueType = getTypeNamePermissive(field.type, field.resolvedType, field.repeated, field.map);
+    if (field instanceof Protobuf.MapField) {
+        const keyType = field.keyType === 'string' ? 'string' : 'number';
+        return `{[key: ${keyType}]: ${valueType}}`;
+    }
+    else {
+        return valueType;
+    }
+}
+function generatePermissiveMessageInterface(formatter, messageType, options, nameOverride) {
+    if (options.includeComments) {
+        formatComment(formatter, messageType.comment);
+    }
+    if (messageType.fullName === '.google.protobuf.Any') {
+        /* This describes the behavior of the Protobuf.js Any wrapper fromObject
+         * replacement function */
+        formatter.writeLine('export type Any = AnyExtension | {');
+        formatter.writeLine('  type_url: string;');
+        formatter.writeLine('  value: Buffer | Uint8Array | string;');
+        formatter.writeLine('}');
+        return;
+    }
+    formatter.writeLine(`export interface ${nameOverride !== null && nameOverride !== void 0 ? nameOverride : messageType.name} {`);
+    formatter.indent();
+    for (const field of messageType.fieldsArray) {
+        const repeatedString = field.repeated ? '[]' : '';
+        const type = getFieldTypePermissive(field);
+        if (options.includeComments) {
+            formatComment(formatter, field.comment);
+        }
+        formatter.writeLine(`'${field.name}'?: (${type})${repeatedString};`);
+    }
+    for (const oneof of messageType.oneofsArray) {
+        const typeString = oneof.fieldsArray.map(field => `"${field.name}"`).join('|');
+        if (options.includeComments) {
+            formatComment(formatter, oneof.comment);
+        }
+        formatter.writeLine(`'${oneof.name}'?: ${typeString};`);
+    }
+    formatter.unindent();
+    formatter.writeLine('}');
+}
+function getTypeNameRestricted(fieldType, resolvedType, repeated, map, options) {
+    switch (fieldType) {
+        case 'double':
+        case 'float':
+            if (options.json) {
+                return 'number | string';
+            }
+            else {
+                return 'number';
+            }
+        case 'int32':
+        case 'uint32':
+        case 'sint32':
+        case 'fixed32':
+        case 'sfixed32':
+            return 'number';
+        case 'int64':
+        case 'uint64':
+        case 'sint64':
+        case 'fixed64':
+        case 'sfixed64':
+            if (options.longs === Number) {
+                return 'number';
+            }
+            else if (options.longs === String) {
+                return 'string';
+            }
+            else {
+                return 'Long';
+            }
+        case 'bool':
+            return 'boolean';
+        case 'string':
+            return 'string';
+        case 'bytes':
+            if (options.bytes === Array) {
+                return 'Uint8Array';
+            }
+            else if (options.bytes === String) {
+                return 'string';
+            }
+            else {
+                return 'Buffer';
+            }
+        default:
+            if (resolvedType === null) {
+                throw new Error('Found field with no usable type');
+            }
+            const typeInterfaceName = getTypeInterfaceName(resolvedType);
+            if (resolvedType instanceof Protobuf.Type) {
+                /* null is only used to represent absent message values if the defaults
+                 * option is set, and only for non-repeated, non-map fields. */
+                if (options.defaults && !repeated && !map) {
+                    return `${typeInterfaceName}__Output | null`;
+                }
+                else {
+                    return `${typeInterfaceName}__Output`;
+                }
+            }
+            else {
+                if (options.enums == String) {
+                    return `keyof typeof ${typeInterfaceName}`;
+                }
+                else {
+                    return typeInterfaceName;
+                }
+            }
+    }
+}
+function getFieldTypeRestricted(field, options) {
+    const valueType = getTypeNameRestricted(field.type, field.resolvedType, field.repeated, field.map, options);
+    if (field instanceof Protobuf.MapField) {
+        const keyType = field.keyType === 'string' ? 'string' : 'number';
+        return `{[key: ${keyType}]: ${valueType}}`;
+    }
+    else {
+        return valueType;
+    }
+}
+function generateRestrictedMessageInterface(formatter, messageType, options, nameOverride) {
+    var _a, _b, _c;
+    if (options.includeComments) {
+        formatComment(formatter, messageType.comment);
+    }
+    if (messageType.fullName === '.google.protobuf.Any' && options.json) {
+        /* This describes the behavior of the Protobuf.js Any wrapper toObject
+         * replacement function */
+        let optionalString = options.defaults ? '' : '?';
+        formatter.writeLine('export type Any__Output = AnyExtension | {');
+        formatter.writeLine(`  type_url${optionalString}: string;`);
+        formatter.writeLine(`  value${optionalString}: ${getTypeNameRestricted('bytes', null, false, false, options)};`);
+        formatter.writeLine('}');
+        return;
+    }
+    formatter.writeLine(`export interface ${nameOverride !== null && nameOverride !== void 0 ? nameOverride : messageType.name}__Output {`);
+    formatter.indent();
+    for (const field of messageType.fieldsArray) {
+        let fieldGuaranteed;
+        if (field.partOf) {
+            // The field is not guaranteed populated if it is part of a oneof
+            fieldGuaranteed = false;
+        }
+        else if (field.repeated) {
+            fieldGuaranteed = (_a = (options.defaults || options.arrays)) !== null && _a !== void 0 ? _a : false;
+        }
+        else if (field.map) {
+            fieldGuaranteed = (_b = (options.defaults || options.objects)) !== null && _b !== void 0 ? _b : false;
+        }
+        else {
+            fieldGuaranteed = (_c = options.defaults) !== null && _c !== void 0 ? _c : false;
+        }
+        const optionalString = fieldGuaranteed ? '' : '?';
+        const repeatedString = field.repeated ? '[]' : '';
+        const type = getFieldTypeRestricted(field, options);
+        if (options.includeComments) {
+            formatComment(formatter, field.comment);
+        }
+        formatter.writeLine(`'${field.name}'${optionalString}: (${type})${repeatedString};`);
+    }
+    if (options.oneofs) {
+        for (const oneof of messageType.oneofsArray) {
+            const typeString = oneof.fieldsArray.map(field => `"${field.name}"`).join('|');
+            if (options.includeComments) {
+                formatComment(formatter, oneof.comment);
+            }
+            formatter.writeLine(`'${oneof.name}': ${typeString};`);
+        }
+    }
+    formatter.unindent();
+    formatter.writeLine('}');
+}
+function generateMessageInterfaces(formatter, messageType, options) {
+    var _a, _b;
+    let usesLong = false;
+    let seenDeps = new Set();
+    const childTypes = getChildMessagesAndEnums(messageType);
+    formatter.writeLine(`// Original file: ${(_b = ((_a = messageType.filename) !== null && _a !== void 0 ? _a : 'null')) === null || _b === void 0 ? void 0 : _b.replace(/\\/g, '/')}`);
+    formatter.writeLine('');
+    messageType.fieldsArray.sort((fieldA, fieldB) => fieldA.id - fieldB.id);
+    for (const field of messageType.fieldsArray) {
+        if (field.resolvedType && childTypes.indexOf(field.resolvedType) < 0) {
+            const dependency = field.resolvedType;
+            if (seenDeps.has(dependency.fullName)) {
+                continue;
+            }
+            seenDeps.add(dependency.fullName);
+            formatter.writeLine(getImportLine(dependency, messageType));
+        }
+        if (field.type.indexOf('64') >= 0) {
+            usesLong = true;
+        }
+    }
+    for (const childType of childTypes) {
+        if (childType instanceof Protobuf.Type) {
+            for (const field of childType.fieldsArray) {
+                if (field.resolvedType && childTypes.indexOf(field.resolvedType) < 0) {
+                    const dependency = field.resolvedType;
+                    if (seenDeps.has(dependency.fullName)) {
+                        continue;
+                    }
+                    seenDeps.add(dependency.fullName);
+                    formatter.writeLine(getImportLine(dependency, messageType));
+                }
+                if (field.type.indexOf('64') >= 0) {
+                    usesLong = true;
+                }
+            }
+        }
+    }
+    if (usesLong) {
+        formatter.writeLine("import type { Long } from '@grpc/proto-loader';");
+    }
+    if (messageType.fullName === '.google.protobuf.Any') {
+        formatter.writeLine("import type { AnyExtension } from '@grpc/proto-loader';");
+    }
+    formatter.writeLine('');
+    for (const childType of childTypes.sort(compareName)) {
+        const nameOverride = getTypeInterfaceName(childType);
+        if (childType instanceof Protobuf.Type) {
+            generatePermissiveMessageInterface(formatter, childType, options, nameOverride);
+            formatter.writeLine('');
+            generateRestrictedMessageInterface(formatter, childType, options, nameOverride);
+        }
+        else {
+            generateEnumInterface(formatter, childType, options, nameOverride);
+        }
+        formatter.writeLine('');
+    }
+    generatePermissiveMessageInterface(formatter, messageType, options);
+    formatter.writeLine('');
+    generateRestrictedMessageInterface(formatter, messageType, options);
+}
+function generateEnumInterface(formatter, enumType, options, nameOverride) {
+    var _a, _b;
+    formatter.writeLine(`// Original file: ${(_b = ((_a = enumType.filename) !== null && _a !== void 0 ? _a : 'null')) === null || _b === void 0 ? void 0 : _b.replace(/\\/g, '/')}`);
+    formatter.writeLine('');
+    if (options.includeComments) {
+        formatComment(formatter, enumType.comment);
+    }
+    formatter.writeLine(`export enum ${nameOverride !== null && nameOverride !== void 0 ? nameOverride : enumType.name} {`);
+    formatter.indent();
+    for (const key of Object.keys(enumType.values)) {
+        if (options.includeComments) {
+            formatComment(formatter, enumType.comments[key]);
+        }
+        formatter.writeLine(`${key} = ${enumType.values[key]},`);
+    }
+    formatter.unindent();
+    formatter.writeLine('}');
+}
+/**
+ * This is a list of methods that are exist in the generic Client class in the
+ * gRPC libraries. TypeScript has a problem with methods in subclasses with the
+ * same names as methods in the superclass, but with mismatched APIs. So, we
+ * avoid generating methods with these names in the service client interfaces.
+ * We always generate two service client methods per service method: one camel
+ * cased, and one with the original casing. So we will still generate one
+ * service client method for any conflicting name.
+ *
+ * Technically, at runtime conflicting name in the service client method
+ * actually shadows the original method, but TypeScript does not have a good
+ * way to represent that. So this change is not 100% accurate, but it gets the
+ * generated code to compile.
+ *
+ * This is just a list of the methods in the Client class definitions in
+ * grpc@1.24.11 and @grpc/grpc-js@1.4.0.
+ */
+const CLIENT_RESERVED_METHOD_NAMES = new Set([
+    'close',
+    'getChannel',
+    'waitForReady',
+    'makeUnaryRequest',
+    'makeClientStreamRequest',
+    'makeServerStreamRequest',
+    'makeBidiStreamRequest',
+    'resolveCallInterceptors',
+    /* These methods are private, but TypeScript is not happy with overriding even
+     * private methods with mismatched APIs. */
+    'checkOptionalUnaryResponseArguments',
+    'checkMetadataAndOptions'
+]);
+function generateServiceClientInterface(formatter, serviceType, options) {
+    if (options.includeComments) {
+        formatComment(formatter, serviceType.comment);
+    }
+    formatter.writeLine(`export interface ${serviceType.name}Client extends grpc.Client {`);
+    formatter.indent();
+    for (const methodName of Object.keys(serviceType.methods).sort()) {
+        const method = serviceType.methods[methodName];
+        for (const name of [methodName, camelCase(methodName)]) {
+            if (CLIENT_RESERVED_METHOD_NAMES.has(name)) {
+                continue;
+            }
+            if (options.includeComments) {
+                formatComment(formatter, method.comment);
+            }
+            const requestType = getTypeInterfaceName(method.resolvedRequestType);
+            const responseType = getTypeInterfaceName(method.resolvedResponseType) + '__Output';
+            const callbackType = `grpc.requestCallback<${responseType}>`;
+            if (method.requestStream) {
+                if (method.responseStream) {
+                    // Bidi streaming
+                    const callType = `grpc.ClientDuplexStream<${requestType}, ${responseType}>`;
+                    formatter.writeLine(`${name}(metadata: grpc.Metadata, options?: grpc.CallOptions): ${callType};`);
+                    formatter.writeLine(`${name}(options?: grpc.CallOptions): ${callType};`);
+                }
+                else {
+                    // Client streaming
+                    const callType = `grpc.ClientWritableStream<${requestType}>`;
+                    formatter.writeLine(`${name}(metadata: grpc.Metadata, options: grpc.CallOptions, callback: ${callbackType}): ${callType};`);
+                    formatter.writeLine(`${name}(metadata: grpc.Metadata, callback: ${callbackType}): ${callType};`);
+                    formatter.writeLine(`${name}(options: grpc.CallOptions, callback: ${callbackType}): ${callType};`);
+                    formatter.writeLine(`${name}(callback: ${callbackType}): ${callType};`);
+                }
+            }
+            else {
+                if (method.responseStream) {
+                    // Server streaming
+                    const callType = `grpc.ClientReadableStream<${responseType}>`;
+                    formatter.writeLine(`${name}(argument: ${requestType}, metadata: grpc.Metadata, options?: grpc.CallOptions): ${callType};`);
+                    formatter.writeLine(`${name}(argument: ${requestType}, options?: grpc.CallOptions): ${callType};`);
+                }
+                else {
+                    // Unary
+                    const callType = 'grpc.ClientUnaryCall';
+                    formatter.writeLine(`${name}(argument: ${requestType}, metadata: grpc.Metadata, options: grpc.CallOptions, callback: ${callbackType}): ${callType};`);
+                    formatter.writeLine(`${name}(argument: ${requestType}, metadata: grpc.Metadata, callback: ${callbackType}): ${callType};`);
+                    formatter.writeLine(`${name}(argument: ${requestType}, options: grpc.CallOptions, callback: ${callbackType}): ${callType};`);
+                    formatter.writeLine(`${name}(argument: ${requestType}, callback: ${callbackType}): ${callType};`);
+                }
+            }
+        }
+        formatter.writeLine('');
+    }
+    formatter.unindent();
+    formatter.writeLine('}');
+}
+function generateServiceHandlerInterface(formatter, serviceType, options) {
+    if (options.includeComments) {
+        formatComment(formatter, serviceType.comment);
+    }
+    formatter.writeLine(`export interface ${serviceType.name}Handlers extends grpc.UntypedServiceImplementation {`);
+    formatter.indent();
+    for (const methodName of Object.keys(serviceType.methods).sort()) {
+        const method = serviceType.methods[methodName];
+        if (options.includeComments) {
+            formatComment(formatter, method.comment);
+        }
+        const requestType = getTypeInterfaceName(method.resolvedRequestType) + '__Output';
+        const responseType = getTypeInterfaceName(method.resolvedResponseType);
+        if (method.requestStream) {
+            if (method.responseStream) {
+                // Bidi streaming
+                formatter.writeLine(`${methodName}: grpc.handleBidiStreamingCall<${requestType}, ${responseType}>;`);
+            }
+            else {
+                // Client streaming
+                formatter.writeLine(`${methodName}: grpc.handleClientStreamingCall<${requestType}, ${responseType}>;`);
+            }
+        }
+        else {
+            if (method.responseStream) {
+                // Server streaming
+                formatter.writeLine(`${methodName}: grpc.handleServerStreamingCall<${requestType}, ${responseType}>;`);
+            }
+            else {
+                // Unary
+                formatter.writeLine(`${methodName}: grpc.handleUnaryCall<${requestType}, ${responseType}>;`);
+            }
+        }
+        formatter.writeLine('');
+    }
+    formatter.unindent();
+    formatter.writeLine('}');
+}
+function generateServiceDefinitionInterface(formatter, serviceType) {
+    formatter.writeLine(`export interface ${serviceType.name}Definition extends grpc.ServiceDefinition {`);
+    formatter.indent();
+    for (const methodName of Object.keys(serviceType.methods).sort()) {
+        const method = serviceType.methods[methodName];
+        const requestType = getTypeInterfaceName(method.resolvedRequestType);
+        const responseType = getTypeInterfaceName(method.resolvedResponseType);
+        formatter.writeLine(`${methodName}: MethodDefinition<${requestType}, ${responseType}, ${requestType}__Output, ${responseType}__Output>`);
+    }
+    formatter.unindent();
+    formatter.writeLine('}');
+}
+function generateServiceInterfaces(formatter, serviceType, options) {
+    var _a, _b;
+    formatter.writeLine(`// Original file: ${(_b = ((_a = serviceType.filename) !== null && _a !== void 0 ? _a : 'null')) === null || _b === void 0 ? void 0 : _b.replace(/\\/g, '/')}`);
+    formatter.writeLine('');
+    const grpcImportPath = options.grpcLib.startsWith('.') ? getPathToRoot(serviceType) + options.grpcLib : options.grpcLib;
+    formatter.writeLine(`import type * as grpc from '${grpcImportPath}'`);
+    formatter.writeLine(`import type { MethodDefinition } from '@grpc/proto-loader'`);
+    const dependencies = new Set();
+    for (const method of serviceType.methodsArray) {
+        dependencies.add(method.resolvedRequestType);
+        dependencies.add(method.resolvedResponseType);
+    }
+    for (const dep of Array.from(dependencies.values()).sort(compareName)) {
+        formatter.writeLine(getImportLine(dep, serviceType));
+    }
+    formatter.writeLine('');
+    generateServiceClientInterface(formatter, serviceType, options);
+    formatter.writeLine('');
+    generateServiceHandlerInterface(formatter, serviceType, options);
+    formatter.writeLine('');
+    generateServiceDefinitionInterface(formatter, serviceType);
+}
+function containsDefinition(definitionType, namespace) {
+    for (const nested of namespace.nestedArray.sort(compareName)) {
+        if (nested instanceof definitionType) {
+            return true;
+        }
+        else if (isNamespaceBase(nested) && !(nested instanceof Protobuf.Type) && !(nested instanceof Protobuf.Enum) && containsDefinition(definitionType, nested)) {
+            return true;
+        }
+    }
+    return false;
+}
+function generateDefinitionImports(formatter, namespace, options) {
+    const imports = [];
+    if (containsDefinition(Protobuf.Enum, namespace)) {
+        imports.push('EnumTypeDefinition');
+    }
+    if (containsDefinition(Protobuf.Type, namespace)) {
+        imports.push('MessageTypeDefinition');
+    }
+    if (imports.length) {
+        formatter.writeLine(`import type { ${imports.join(', ')} } from '@grpc/proto-loader';`);
+    }
+}
+function generateServiceImports(formatter, namespace, options) {
+    for (const nested of namespace.nestedArray.sort(compareName)) {
+        if (nested instanceof Protobuf.Service) {
+            formatter.writeLine(getImportLine(nested));
+        }
+        else if (isNamespaceBase(nested) && !(nested instanceof Protobuf.Type) && !(nested instanceof Protobuf.Enum)) {
+            generateServiceImports(formatter, nested, options);
+        }
+    }
+}
+function generateSingleLoadedDefinitionType(formatter, nested, options) {
+    if (nested instanceof Protobuf.Service) {
+        if (options.includeComments) {
+            formatComment(formatter, nested.comment);
+        }
+        const typeInterfaceName = getTypeInterfaceName(nested);
+        formatter.writeLine(`${nested.name}: SubtypeConstructor<typeof grpc.Client, ${typeInterfaceName}Client> & { service: ${typeInterfaceName}Definition }`);
+    }
+    else if (nested instanceof Protobuf.Enum) {
+        formatter.writeLine(`${nested.name}: EnumTypeDefinition`);
+    }
+    else if (nested instanceof Protobuf.Type) {
+        formatter.writeLine(`${nested.name}: MessageTypeDefinition`);
+    }
+    else if (isNamespaceBase(nested)) {
+        generateLoadedDefinitionTypes(formatter, nested, options);
+    }
+}
+function generateLoadedDefinitionTypes(formatter, namespace, options) {
+    formatter.writeLine(`${namespace.name}: {`);
+    formatter.indent();
+    for (const nested of namespace.nestedArray.sort(compareName)) {
+        generateSingleLoadedDefinitionType(formatter, nested, options);
+    }
+    formatter.unindent();
+    formatter.writeLine('}');
+}
+function generateRootFile(formatter, root, options) {
+    formatter.writeLine(`import type * as grpc from '${options.grpcLib}';`);
+    generateDefinitionImports(formatter, root, options);
+    formatter.writeLine('');
+    generateServiceImports(formatter, root, options);
+    formatter.writeLine('');
+    formatter.writeLine('type SubtypeConstructor<Constructor extends new (...args: any) => any, Subtype> = {');
+    formatter.writeLine('  new(...args: ConstructorParameters<Constructor>): Subtype;');
+    formatter.writeLine('};');
+    formatter.writeLine('');
+    formatter.writeLine('export interface ProtoGrpcType {');
+    formatter.indent();
+    for (const nested of root.nestedArray) {
+        generateSingleLoadedDefinitionType(formatter, nested, options);
+    }
+    formatter.unindent();
+    formatter.writeLine('}');
+    formatter.writeLine('');
+}
+async function writeFile(filename, contents) {
+    await fs.promises.mkdir(path.dirname(filename), { recursive: true });
+    return fs.promises.writeFile(filename, contents);
+}
+function generateFilesForNamespace(namespace, options) {
+    const filePromises = [];
+    for (const nested of namespace.nestedArray) {
+        const fileFormatter = new TextFormatter();
+        if (nested instanceof Protobuf.Type) {
+            generateMessageInterfaces(fileFormatter, nested, options);
+            if (options.verbose) {
+                console.log(`Writing ${options.outDir}/${getPath(nested)} from file ${nested.filename}`);
+            }
+            filePromises.push(writeFile(`${options.outDir}/${getPath(nested)}`, fileFormatter.getFullText()));
+        }
+        else if (nested instanceof Protobuf.Enum) {
+            generateEnumInterface(fileFormatter, nested, options);
+            if (options.verbose) {
+                console.log(`Writing ${options.outDir}/${getPath(nested)} from file ${nested.filename}`);
+            }
+            filePromises.push(writeFile(`${options.outDir}/${getPath(nested)}`, fileFormatter.getFullText()));
+        }
+        else if (nested instanceof Protobuf.Service) {
+            generateServiceInterfaces(fileFormatter, nested, options);
+            if (options.verbose) {
+                console.log(`Writing ${options.outDir}/${getPath(nested)} from file ${nested.filename}`);
+            }
+            filePromises.push(writeFile(`${options.outDir}/${getPath(nested)}`, fileFormatter.getFullText()));
+        }
+        else if (isNamespaceBase(nested)) {
+            filePromises.push(...generateFilesForNamespace(nested, options));
+        }
+    }
+    return filePromises;
+}
+function writeFilesForRoot(root, masterFileName, options) {
+    const filePromises = [];
+    const masterFileFormatter = new TextFormatter();
+    generateRootFile(masterFileFormatter, root, options);
+    if (options.verbose) {
+        console.log(`Writing ${options.outDir}/${masterFileName}`);
+    }
+    filePromises.push(writeFile(`${options.outDir}/${masterFileName}`, masterFileFormatter.getFullText()));
+    filePromises.push(...generateFilesForNamespace(root, options));
+    return filePromises;
+}
+async function writeAllFiles(protoFiles, options) {
+    await fs.promises.mkdir(options.outDir, { recursive: true });
+    const basenameMap = new Map();
+    for (const filename of protoFiles) {
+        const basename = path.basename(filename).replace(/\.proto$/, '.ts');
+        if (basenameMap.has(basename)) {
+            basenameMap.get(basename).push(filename);
+        }
+        else {
+            basenameMap.set(basename, [filename]);
+        }
+    }
+    for (const [basename, filenames] of basenameMap.entries()) {
+        const loadedRoot = await util_1.loadProtosWithOptions(filenames, options);
+        writeFilesForRoot(loadedRoot, basename, options);
+    }
+}
+async function runScript() {
+    const argv = yargs
+        .parserConfiguration({
+        'parse-positional-numbers': false
+    })
+        .string(['includeDirs', 'grpcLib'])
+        .normalize(['includeDirs', 'outDir'])
+        .array('includeDirs')
+        .boolean(['keepCase', 'defaults', 'arrays', 'objects', 'oneofs', 'json', 'verbose', 'includeComments'])
+        .string(['longs', 'enums', 'bytes'])
+        .default('keepCase', false)
+        .default('defaults', false)
+        .default('arrays', false)
+        .default('objects', false)
+        .default('oneofs', false)
+        .default('json', false)
+        .default('includeComments', false)
+        .default('longs', 'Long')
+        .default('enums', 'number')
+        .default('bytes', 'Buffer')
+        .coerce('longs', value => {
+        switch (value) {
+            case 'String': return String;
+            case 'Number': return Number;
+            default: return undefined;
+        }
+    }).coerce('enums', value => {
+        if (value === 'String') {
+            return String;
+        }
+        else {
+            return undefined;
+        }
+    }).coerce('bytes', value => {
+        switch (value) {
+            case 'Array': return Array;
+            case 'String': return String;
+            default: return undefined;
+        }
+    }).alias({
+        includeDirs: 'I',
+        outDir: 'O',
+        verbose: 'v'
+    }).describe({
+        keepCase: 'Preserve the case of field names',
+        longs: 'The type that should be used to output 64 bit integer values. Can be String, Number',
+        enums: 'The type that should be used to output enum fields. Can be String',
+        bytes: 'The type that should be used to output bytes fields. Can be String, Array',
+        defaults: 'Output default values for omitted fields',
+        arrays: 'Output default values for omitted repeated fields even if --defaults is not set',
+        objects: 'Output default values for omitted message fields even if --defaults is not set',
+        oneofs: 'Output virtual oneof fields set to the present field\'s name',
+        json: 'Represent Infinity and NaN as strings in float fields. Also decode google.protobuf.Any automatically',
+        includeComments: 'Generate doc comments from comments in the original files',
+        includeDirs: 'Directories to search for included files',
+        outDir: 'Directory in which to output files',
+        grpcLib: 'The gRPC implementation library that these types will be used with'
+    }).demandOption(['outDir', 'grpcLib'])
+        .demand(1)
+        .usage('$0 [options] filenames...')
+        .epilogue('WARNING: This tool is in alpha. The CLI and generated code are subject to change')
+        .argv;
+    if (argv.verbose) {
+        console.log('Parsed arguments:', argv);
+    }
+    util_1.addCommonProtos();
+    writeAllFiles(argv._, Object.assign(Object.assign({}, argv), { alternateCommentMode: true })).then(() => {
+        if (argv.verbose) {
+            console.log('Success');
+        }
+    }, (error) => {
+        console.error(error);
+        process.exit(1);
+    });
+}
+if (require.main === module) {
+    runScript();
+}
+//# sourceMappingURL=proto-loader-gen-types.js.map

node_modules/@grpc/proto-loader/build/src/index.d.ts

@@ -0,0 +1,135 @@
+/**
+ * @license
+ * Copyright 2018 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.
+ *
+ */
+/// <reference types="node" />
+import * as Protobuf from 'protobufjs';
+import * as descriptor from 'protobufjs/ext/descriptor';
+import { Options } from './util';
+import Long = require('long');
+export { Options, Long };
+/**
+ * This type exists for use with code generated by the proto-loader-gen-types
+ * tool. This type should be used with another interface, e.g.
+ * MessageType & AnyExtension for an object that is converted to or from a
+ * google.protobuf.Any message.
+ * For example, when processing an Any message:
+ *
+ * ```ts
+ * if (isAnyExtension(message)) {
+ *   switch (message['@type']) {
+ *     case TYPE1_URL:
+ *       handleType1(message as AnyExtension & Type1);
+ *       break;
+ *     case TYPE2_URL:
+ *       handleType2(message as AnyExtension & Type2);
+ *       break;
+ *     // ...
+ *   }
+ * }
+ * ```
+ */
+export interface AnyExtension {
+    /**
+     * The fully qualified name of the message type that this object represents,
+     * possibly including a URL prefix.
+     */
+    '@type': string;
+}
+export declare function isAnyExtension(obj: object): obj is AnyExtension;
+declare module 'protobufjs' {
+    interface Type {
+        toDescriptor(protoVersion: string): Protobuf.Message<descriptor.IDescriptorProto> & descriptor.IDescriptorProto;
+    }
+    interface RootConstructor {
+        new (options?: Options): Root;
+        fromDescriptor(descriptorSet: descriptor.IFileDescriptorSet | Protobuf.Reader | Uint8Array): Root;
+        fromJSON(json: Protobuf.INamespace, root?: Root): Root;
+    }
+    interface Root {
+        toDescriptor(protoVersion: string): Protobuf.Message<descriptor.IFileDescriptorSet> & descriptor.IFileDescriptorSet;
+    }
+    interface Enum {
+        toDescriptor(protoVersion: string): Protobuf.Message<descriptor.IEnumDescriptorProto> & descriptor.IEnumDescriptorProto;
+    }
+}
+export interface Serialize<T> {
+    (value: T): Buffer;
+}
+export interface Deserialize<T> {
+    (bytes: Buffer): T;
+}
+export interface ProtobufTypeDefinition {
+    format: string;
+    type: object;
+    fileDescriptorProtos: Buffer[];
+}
+export interface MessageTypeDefinition extends ProtobufTypeDefinition {
+    format: 'Protocol Buffer 3 DescriptorProto';
+}
+export interface EnumTypeDefinition extends ProtobufTypeDefinition {
+    format: 'Protocol Buffer 3 EnumDescriptorProto';
+}
+export interface MethodDefinition<RequestType, ResponseType, OutputRequestType = RequestType, OutputResponseType = ResponseType> {
+    path: string;
+    requestStream: boolean;
+    responseStream: boolean;
+    requestSerialize: Serialize<RequestType>;
+    responseSerialize: Serialize<ResponseType>;
+    requestDeserialize: Deserialize<OutputRequestType>;
+    responseDeserialize: Deserialize<OutputResponseType>;
+    originalName?: string;
+    requestType: MessageTypeDefinition;
+    responseType: MessageTypeDefinition;
+}
+export interface ServiceDefinition {
+    [index: string]: MethodDefinition<object, object>;
+}
+export declare type AnyDefinition = ServiceDefinition | MessageTypeDefinition | EnumTypeDefinition;
+export interface PackageDefinition {
+    [index: string]: AnyDefinition;
+}
+/**
+ * Load a .proto file with the specified options.
+ * @param filename One or multiple file paths to load. Can be an absolute path
+ *     or relative to an include path.
+ * @param options.keepCase Preserve field names. The default is to change them
+ *     to camel case.
+ * @param options.longs The type that should be used to represent `long` values.
+ *     Valid options are `Number` and `String`. Defaults to a `Long` object type
+ *     from a library.
+ * @param options.enums The type that should be used to represent `enum` values.
+ *     The only valid option is `String`. Defaults to the numeric value.
+ * @param options.bytes The type that should be used to represent `bytes`
+ *     values. Valid options are `Array` and `String`. The default is to use
+ *     `Buffer`.
+ * @param options.defaults Set default values on output objects. Defaults to
+ *     `false`.
+ * @param options.arrays Set empty arrays for missing array values even if
+ *     `defaults` is `false`. Defaults to `false`.
+ * @param options.objects Set empty objects for missing object values even if
+ *     `defaults` is `false`. Defaults to `false`.
+ * @param options.oneofs Set virtual oneof properties to the present field's
+ *     name
+ * @param options.json Represent Infinity and NaN as strings in float fields,
+ *     and automatically decode google.protobuf.Any values.
+ * @param options.includeDirs Paths to search for imported `.proto` files.
+ */
+export declare function load(filename: string | string[], options?: Options): Promise<PackageDefinition>;
+export declare function loadSync(filename: string | string[], options?: Options): PackageDefinition;
+export declare function fromJSON(json: Protobuf.INamespace, options?: Options): PackageDefinition;
+export declare function loadFileDescriptorSetFromBuffer(descriptorSet: Buffer, options?: Options): PackageDefinition;
+export declare function loadFileDescriptorSetFromObject(descriptorSet: Parameters<typeof descriptor.FileDescriptorSet.fromObject>[0], options?: Options): PackageDefinition;

node_modules/@grpc/proto-loader/build/src/index.js

@@ -0,0 +1,218 @@
+"use strict";
+/**
+ * @license
+ * Copyright 2018 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.
+ *
+ */
+Object.defineProperty(exports, "__esModule", { value: true });
+const camelCase = require("lodash.camelcase");
+const Protobuf = require("protobufjs");
+const descriptor = require("protobufjs/ext/descriptor");
+const util_1 = require("./util");
+const Long = require("long");
+exports.Long = Long;
+function isAnyExtension(obj) {
+    return ('@type' in obj) && (typeof obj['@type'] === 'string');
+}
+exports.isAnyExtension = isAnyExtension;
+const descriptorOptions = {
+    longs: String,
+    enums: String,
+    bytes: String,
+    defaults: true,
+    oneofs: true,
+    json: true,
+};
+function joinName(baseName, name) {
+    if (baseName === '') {
+        return name;
+    }
+    else {
+        return baseName + '.' + name;
+    }
+}
+function isHandledReflectionObject(obj) {
+    return (obj instanceof Protobuf.Service ||
+        obj instanceof Protobuf.Type ||
+        obj instanceof Protobuf.Enum);
+}
+function isNamespaceBase(obj) {
+    return obj instanceof Protobuf.Namespace || obj instanceof Protobuf.Root;
+}
+function getAllHandledReflectionObjects(obj, parentName) {
+    const objName = joinName(parentName, obj.name);
+    if (isHandledReflectionObject(obj)) {
+        return [[objName, obj]];
+    }
+    else {
+        if (isNamespaceBase(obj) && typeof obj.nested !== 'undefined') {
+            return Object.keys(obj.nested)
+                .map(name => {
+                return getAllHandledReflectionObjects(obj.nested[name], objName);
+            })
+                .reduce((accumulator, currentValue) => accumulator.concat(currentValue), []);
+        }
+    }
+    return [];
+}
+function createDeserializer(cls, options) {
+    return function deserialize(argBuf) {
+        return cls.toObject(cls.decode(argBuf), options);
+    };
+}
+function createSerializer(cls) {
+    return function serialize(arg) {
+        if (Array.isArray(arg)) {
+            throw new Error(`Failed to serialize message: expected object with ${cls.name} structure, got array instead`);
+        }
+        const message = cls.fromObject(arg);
+        return cls.encode(message).finish();
+    };
+}
+function createMethodDefinition(method, serviceName, options, fileDescriptors) {
+    /* This is only ever called after the corresponding root.resolveAll(), so we
+     * can assume that the resolved request and response types are non-null */
+    const requestType = method.resolvedRequestType;
+    const responseType = method.resolvedResponseType;
+    return {
+        path: '/' + serviceName + '/' + method.name,
+        requestStream: !!method.requestStream,
+        responseStream: !!method.responseStream,
+        requestSerialize: createSerializer(requestType),
+        requestDeserialize: createDeserializer(requestType, options),
+        responseSerialize: createSerializer(responseType),
+        responseDeserialize: createDeserializer(responseType, options),
+        // TODO(murgatroid99): Find a better way to handle this
+        originalName: camelCase(method.name),
+        requestType: createMessageDefinition(requestType, fileDescriptors),
+        responseType: createMessageDefinition(responseType, fileDescriptors),
+    };
+}
+function createServiceDefinition(service, name, options, fileDescriptors) {
+    const def = {};
+    for (const method of service.methodsArray) {
+        def[method.name] = createMethodDefinition(method, name, options, fileDescriptors);
+    }
+    return def;
+}
+function createMessageDefinition(message, fileDescriptors) {
+    const messageDescriptor = message.toDescriptor('proto3');
+    return {
+        format: 'Protocol Buffer 3 DescriptorProto',
+        type: messageDescriptor.$type.toObject(messageDescriptor, descriptorOptions),
+        fileDescriptorProtos: fileDescriptors,
+    };
+}
+function createEnumDefinition(enumType, fileDescriptors) {
+    const enumDescriptor = enumType.toDescriptor('proto3');
+    return {
+        format: 'Protocol Buffer 3 EnumDescriptorProto',
+        type: enumDescriptor.$type.toObject(enumDescriptor, descriptorOptions),
+        fileDescriptorProtos: fileDescriptors,
+    };
+}
+/**
+ * function createDefinition(obj: Protobuf.Service, name: string, options:
+ * Options): ServiceDefinition; function createDefinition(obj: Protobuf.Type,
+ * name: string, options: Options): MessageTypeDefinition; function
+ * createDefinition(obj: Protobuf.Enum, name: string, options: Options):
+ * EnumTypeDefinition;
+ */
+function createDefinition(obj, name, options, fileDescriptors) {
+    if (obj instanceof Protobuf.Service) {
+        return createServiceDefinition(obj, name, options, fileDescriptors);
+    }
+    else if (obj instanceof Protobuf.Type) {
+        return createMessageDefinition(obj, fileDescriptors);
+    }
+    else if (obj instanceof Protobuf.Enum) {
+        return createEnumDefinition(obj, fileDescriptors);
+    }
+    else {
+        throw new Error('Type mismatch in reflection object handling');
+    }
+}
+function createPackageDefinition(root, options) {
+    const def = {};
+    root.resolveAll();
+    const descriptorList = root.toDescriptor('proto3').file;
+    const bufferList = descriptorList.map(value => Buffer.from(descriptor.FileDescriptorProto.encode(value).finish()));
+    for (const [name, obj] of getAllHandledReflectionObjects(root, '')) {
+        def[name] = createDefinition(obj, name, options, bufferList);
+    }
+    return def;
+}
+function createPackageDefinitionFromDescriptorSet(decodedDescriptorSet, options) {
+    options = options || {};
+    const root = Protobuf.Root.fromDescriptor(decodedDescriptorSet);
+    root.resolveAll();
+    return createPackageDefinition(root, options);
+}
+/**
+ * Load a .proto file with the specified options.
+ * @param filename One or multiple file paths to load. Can be an absolute path
+ *     or relative to an include path.
+ * @param options.keepCase Preserve field names. The default is to change them
+ *     to camel case.
+ * @param options.longs The type that should be used to represent `long` values.
+ *     Valid options are `Number` and `String`. Defaults to a `Long` object type
+ *     from a library.
+ * @param options.enums The type that should be used to represent `enum` values.
+ *     The only valid option is `String`. Defaults to the numeric value.
+ * @param options.bytes The type that should be used to represent `bytes`
+ *     values. Valid options are `Array` and `String`. The default is to use
+ *     `Buffer`.
+ * @param options.defaults Set default values on output objects. Defaults to
+ *     `false`.
+ * @param options.arrays Set empty arrays for missing array values even if
+ *     `defaults` is `false`. Defaults to `false`.
+ * @param options.objects Set empty objects for missing object values even if
+ *     `defaults` is `false`. Defaults to `false`.
+ * @param options.oneofs Set virtual oneof properties to the present field's
+ *     name
+ * @param options.json Represent Infinity and NaN as strings in float fields,
+ *     and automatically decode google.protobuf.Any values.
+ * @param options.includeDirs Paths to search for imported `.proto` files.
+ */
+function load(filename, options) {
+    return util_1.loadProtosWithOptions(filename, options).then(loadedRoot => {
+        return createPackageDefinition(loadedRoot, options);
+    });
+}
+exports.load = load;
+function loadSync(filename, options) {
+    const loadedRoot = util_1.loadProtosWithOptionsSync(filename, options);
+    return createPackageDefinition(loadedRoot, options);
+}
+exports.loadSync = loadSync;
+function fromJSON(json, options) {
+    options = options || {};
+    const loadedRoot = Protobuf.Root.fromJSON(json);
+    loadedRoot.resolveAll();
+    return createPackageDefinition(loadedRoot, options);
+}
+exports.fromJSON = fromJSON;
+function loadFileDescriptorSetFromBuffer(descriptorSet, options) {
+    const decodedDescriptorSet = descriptor.FileDescriptorSet.decode(descriptorSet);
+    return createPackageDefinitionFromDescriptorSet(decodedDescriptorSet, options);
+}
+exports.loadFileDescriptorSetFromBuffer = loadFileDescriptorSetFromBuffer;
+function loadFileDescriptorSetFromObject(descriptorSet, options) {
+    const decodedDescriptorSet = descriptor.FileDescriptorSet.fromObject(descriptorSet);
+    return createPackageDefinitionFromDescriptorSet(decodedDescriptorSet, options);
+}
+exports.loadFileDescriptorSetFromObject = loadFileDescriptorSetFromObject;
+util_1.addCommonProtos();
+//# sourceMappingURL=index.js.map

node_modules/@grpc/proto-loader/build/src/util.d.ts

@@ -0,0 +1,27 @@
+/**
+ * @license
+ * Copyright 2018 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.
+ *
+ */
+import * as Protobuf from 'protobufjs';
+export declare type Options = Protobuf.IParseOptions & Protobuf.IConversionOptions & {
+    includeDirs?: string[];
+};
+export declare function loadProtosWithOptions(filename: string | string[], options?: Options): Promise<Protobuf.Root>;
+export declare function loadProtosWithOptionsSync(filename: string | string[], options?: Options): Protobuf.Root;
+/**
+ * Load Google's well-known proto files that aren't exposed by Protobuf.js.
+ */
+export declare function addCommonProtos(): void;

node_modules/@grpc/proto-loader/build/src/util.js

@@ -0,0 +1,88 @@
+"use strict";
+/**
+ * @license
+ * Copyright 2018 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.
+ *
+ */
+Object.defineProperty(exports, "__esModule", { value: true });
+const fs = require("fs");
+const path = require("path");
+const Protobuf = require("protobufjs");
+function addIncludePathResolver(root, includePaths) {
+    const originalResolvePath = root.resolvePath;
+    root.resolvePath = (origin, target) => {
+        if (path.isAbsolute(target)) {
+            return target;
+        }
+        for (const directory of includePaths) {
+            const fullPath = path.join(directory, target);
+            try {
+                fs.accessSync(fullPath, fs.constants.R_OK);
+                return fullPath;
+            }
+            catch (err) {
+                continue;
+            }
+        }
+        process.emitWarning(`${target} not found in any of the include paths ${includePaths}`);
+        return originalResolvePath(origin, target);
+    };
+}
+async function loadProtosWithOptions(filename, options) {
+    const root = new Protobuf.Root();
+    options = options || {};
+    if (!!options.includeDirs) {
+        if (!Array.isArray(options.includeDirs)) {
+            return Promise.reject(new Error('The includeDirs option must be an array'));
+        }
+        addIncludePathResolver(root, options.includeDirs);
+    }
+    const loadedRoot = await root.load(filename, options);
+    loadedRoot.resolveAll();
+    return loadedRoot;
+}
+exports.loadProtosWithOptions = loadProtosWithOptions;
+function loadProtosWithOptionsSync(filename, options) {
+    const root = new Protobuf.Root();
+    options = options || {};
+    if (!!options.includeDirs) {
+        if (!Array.isArray(options.includeDirs)) {
+            throw new Error('The includeDirs option must be an array');
+        }
+        addIncludePathResolver(root, options.includeDirs);
+    }
+    const loadedRoot = root.loadSync(filename, options);
+    loadedRoot.resolveAll();
+    return loadedRoot;
+}
+exports.loadProtosWithOptionsSync = loadProtosWithOptionsSync;
+/**
+ * Load Google's well-known proto files that aren't exposed by Protobuf.js.
+ */
+function addCommonProtos() {
+    // Protobuf.js exposes: any, duration, empty, field_mask, struct, timestamp,
+    // and wrappers. compiler/plugin is excluded in Protobuf.js and here.
+    // Using constant strings for compatibility with tools like Webpack
+    const apiDescriptor = require('protobufjs/google/protobuf/api.json');
+    const descriptorDescriptor = require('protobufjs/google/protobuf/descriptor.json');
+    const sourceContextDescriptor = require('protobufjs/google/protobuf/source_context.json');
+    const typeDescriptor = require('protobufjs/google/protobuf/type.json');
+    Protobuf.common('api', apiDescriptor.nested.google.nested.protobuf.nested);
+    Protobuf.common('descriptor', descriptorDescriptor.nested.google.nested.protobuf.nested);
+    Protobuf.common('source_context', sourceContextDescriptor.nested.google.nested.protobuf.nested);
+    Protobuf.common('type', typeDescriptor.nested.google.nested.protobuf.nested);
+}
+exports.addCommonProtos = addCommonProtos;
+//# sourceMappingURL=util.js.map