Run gts fix

Author: murgatroid99

grpc-gcp/src/channel_ref.ts

@@ -35,11 +35,8 @@ export class ChannelRef {
    * @param activeStreamsCount Initial streams count.
    */
   constructor(
-    channel: grpc.ChannelInterface,
-    channelId: number,
-    affinityCount?: number,
-    activeStreamsCount?: number
-  ) {
+      channel: grpc.ChannelInterface, channelId: number, affinityCount?: number,
+      activeStreamsCount?: number) {
     this.channel = channel;
     this.channelId = channelId;
     this.affinityCount = affinityCount ? affinityCount : 0;

grpc-gcp/src/gcp_channel_factory.ts

@@ -17,7 +17,7 @@
  */
 
 import * as grpcType from '@grpc/grpc-js';
-import { ChannelInterface } from '@grpc/grpc-js';
+import {ChannelInterface} from '@grpc/grpc-js';
 import {promisify} from 'util';
 
 import {ChannelRef} from './channel_ref';
@@ -38,15 +38,13 @@ export interface GcpChannelFactoryInterface extends grpcType.ChannelInterface {
 }
 
 export interface GcpChannelFactoryConstructor {
-  new (
-    address: string,
-    credentials: grpcType.ChannelCredentials,
-    options: any
-  ): GcpChannelFactoryInterface;
+  new(address: string, credentials: grpcType.ChannelCredentials,
+      // tslint:disable-next-line:no-any options can be any object
+      options: any): GcpChannelFactoryInterface;
 }
 
-export default function(grpc: GrpcModule): GcpChannelFactoryConstructor {
-
+export function getGcpChannelFactoryClass(grpc: GrpcModule):
+    GcpChannelFactoryConstructor {
   /**
    * A channel management factory that implements grpc.Channel APIs.
    */
@@ -66,18 +64,15 @@ export default function(grpc: GrpcModule): GcpChannelFactoryConstructor {
      * @param options A map of channel options.
      */
     constructor(
-      address: string,
-      credentials: grpcType.ChannelCredentials,
-      // tslint:disable-next-line:no-any options can be any object
-      options: any
-    ) {
+        address: string, credentials: grpcType.ChannelCredentials,
+        // tslint:disable-next-line:no-any options can be any object
+        options: any) {
       if (!options) {
         options = {};
       }
       if (typeof options !== 'object') {
         throw new TypeError(
-          'Channel options must be an object with string keys and integer or string values'
-        );
+            'Channel options must be an object with string keys and integer or string values');
       }
       this.maxSize = 10;
       this.maxConcurrentStreamsLowWatermark = 100;
@@ -88,7 +83,7 @@ export default function(grpc: GrpcModule): GcpChannelFactoryConstructor {
           if (channelPool.maxSize) this.maxSize = channelPool.maxSize;
           if (channelPool.maxConcurrentStreamsLowWatermark) {
             this.maxConcurrentStreamsLowWatermark =
-              channelPool.maxConcurrentStreamsLowWatermark;
+                channelPool.maxConcurrentStreamsLowWatermark;
           }
         }
         this.initMethodToAffinityMap(gcpApiConfig);
@@ -138,23 +133,19 @@ export default function(grpc: GrpcModule): GcpChannelFactoryConstructor {
 
       const size = this.channelRefs.length;
       // Chose the channelRef that has the least busy channel.
-      if (
-        size > 0 &&
-        this.channelRefs[0].getActiveStreamsCount() <
-          this.maxConcurrentStreamsLowWatermark
-      ) {
+      if (size > 0 &&
+          this.channelRefs[0].getActiveStreamsCount() <
+              this.maxConcurrentStreamsLowWatermark) {
         return this.channelRefs[0];
       }
 
       // If all existing channels are busy, and channel pool still has capacity,
       // create a new channel in the pool.
       if (size < this.maxSize) {
-        const channelOptions = Object.assign({[CLIENT_CHANNEL_ID]: size}, this.options);
-        const grpcChannel = new grpc.Channel(
-          this.target,
-          this.credentials,
-          channelOptions
-        );
+        const channelOptions =
+            Object.assign({[CLIENT_CHANNEL_ID]: size}, this.options);
+        const grpcChannel =
+            new grpc.Channel(this.target, this.credentials, channelOptions);
         const channelRef = new ChannelRef(grpcChannel, size);
         this.channelRefs.push(channelRef);
         return channelRef;
@@ -264,26 +255,24 @@ export default function(grpc: GrpcModule): GcpChannelFactoryConstructor {
       }
 
       throw new Error(
-        'Cannot get connectivity state because no channel provides valid state.'
-      );
+          'Cannot get connectivity state because no channel provides valid state.');
     }
 
     /**
      * Watch for connectivity state changes.
      * @param currentState The state to watch for transitions from. This should
-     *     always be populated by calling getConnectivityState immediately before.
+     *     always be populated by calling getConnectivityState immediately
+     * before.
      * @param deadline A deadline for waiting for a state change
      * @param callback Called with no error when the state changes, or with an
      *     error if the deadline passes without a state change
      */
     watchConnectivityState(
-      currentState: grpcType.connectivityState,
-      deadline: grpcType.Deadline,
-      callback: (error?: Error) => void
-    ): void {
+        currentState: grpcType.connectivityState, deadline: grpcType.Deadline,
+        callback: (error?: Error) => void): void {
       if (!this.channelRefs.length) {
         callback(new Error(
-          'Cannot watch connectivity state because there are no channels.'));
+            'Cannot watch connectivity state because there are no channels.'));
         return;
       }
 
@@ -294,12 +283,12 @@ export default function(grpc: GrpcModule): GcpChannelFactoryConstructor {
         return;
       }
 
-      const watchState = async (channelRef: ChannelRef): Promise<void> => {
+      const watchState = async(channelRef: ChannelRef): Promise<void> => {
         const channel = channelRef.getChannel();
         const startingState = channel.getConnectivityState(false);
 
         await promisify(channel.watchConnectivityState)
-          .call(channel, startingState, deadline);
+            .call(channel, startingState, deadline);
 
         const state = this.getConnectivityState(false);
 
@@ -326,20 +315,12 @@ export default function(grpc: GrpcModule): GcpChannelFactoryConstructor {
      * @return a grpc call object.
      */
     createCall(
-      method: string,
-      deadline: grpcType.Deadline,
-      host: string | null,
-      parentCall: any,
-      propagateFlags: number | null
-    ) {
+        method: string, deadline: grpcType.Deadline, host: string|null,
+        // tslint:disable-next-line:no-any There isn't a good type to use here
+        parentCall: any, propagateFlags: number|null) {
       const grpcChannel = this.getChannelRef().getChannel();
       return grpcChannel.createCall(
-        method,
-        deadline,
-        host,
-        parentCall,
-        propagateFlags
-      );
+          method, deadline, host, parentCall, propagateFlags);
     }
-  }
+  };
 }