style: run eslint fix on codebase

Fixes #2464

Author: dancrumb

packages/grpc-js/src/admin.ts

@@ -15,8 +15,8 @@
  *
  */
 
-import { ServiceDefinition } from "./make-client";
-import { Server, UntypedServiceImplementation } from "./server";
+import { ServiceDefinition } from './make-client';
+import { Server, UntypedServiceImplementation } from './server';
 
 interface GetServiceDefinition {
   (): ServiceDefinition;
@@ -26,14 +26,20 @@ interface GetHandlers {
   (): UntypedServiceImplementation;
 }
 
-const registeredAdminServices: {getServiceDefinition: GetServiceDefinition, getHandlers: GetHandlers}[] = [];
+const registeredAdminServices: {
+  getServiceDefinition: GetServiceDefinition;
+  getHandlers: GetHandlers;
+}[] = [];
 
-export function registerAdminService(getServiceDefinition: GetServiceDefinition, getHandlers: GetHandlers) {
-  registeredAdminServices.push({getServiceDefinition, getHandlers});
+export function registerAdminService(
+  getServiceDefinition: GetServiceDefinition,
+  getHandlers: GetHandlers
+) {
+  registeredAdminServices.push({ getServiceDefinition, getHandlers });
 }
 
 export function addAdminServicesToServer(server: Server): void {
-  for (const {getServiceDefinition, getHandlers} of registeredAdminServices) {
+  for (const { getServiceDefinition, getHandlers } of registeredAdminServices) {
     server.addService(getServiceDefinition(), getHandlers());
   }
-}
+}

packages/grpc-js/src/call-credentials.ts

@@ -125,14 +125,14 @@ export abstract class CallCredentials {
         });
       }
       getHeaders.then(
-        (headers) => {
+        headers => {
           const metadata = new Metadata();
           for (const key of Object.keys(headers)) {
             metadata.add(key, headers[key]);
           }
           callback(null, metadata);
         },
-        (err) => {
+        err => {
           callback(err);
         }
       );
@@ -152,7 +152,7 @@ class ComposedCallCredentials extends CallCredentials {
   async generateMetadata(options: CallMetadataOptions): Promise<Metadata> {
     const base: Metadata = new Metadata();
     const generated: Metadata[] = await Promise.all(
-      this.creds.map((cred) => cred.generateMetadata(options))
+      this.creds.map(cred => cred.generateMetadata(options))
     );
     for (const gen of generated) {
       base.merge(gen);

packages/grpc-js/src/call-interface.ts

@@ -15,11 +15,11 @@
  *
  */
 
-import { CallCredentials } from "./call-credentials";
-import { Status } from "./constants";
-import { Deadline } from "./deadline";
-import { Metadata } from "./metadata";
-import { ServerSurfaceCall } from "./server-call";
+import { CallCredentials } from './call-credentials';
+import { Status } from './constants';
+import { Deadline } from './deadline';
+import { Metadata } from './metadata';
+import { ServerSurfaceCall } from './server-call';
 
 export interface CallStreamOptions {
   deadline: Deadline;
@@ -38,7 +38,7 @@ export interface StatusObject {
 
 export type PartialStatusObject = Pick<StatusObject, 'code' | 'details'> & {
   metadata: Metadata | null;
-}
+};
 
 export const enum WriteFlags {
   BufferHint = 1,
@@ -118,7 +118,7 @@ export class InterceptingListenerImpl implements InterceptingListener {
 
   onReceiveMetadata(metadata: Metadata): void {
     this.processingMetadata = true;
-    this.listener.onReceiveMetadata(metadata, (metadata) => {
+    this.listener.onReceiveMetadata(metadata, metadata => {
       this.processingMetadata = false;
       this.nextListener.onReceiveMetadata(metadata);
       this.processPendingMessage();
@@ -128,9 +128,9 @@ export class InterceptingListenerImpl implements InterceptingListener {
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
   onReceiveMessage(message: any): void {
     /* If this listener processes messages asynchronously, the last message may
-      * be reordered with respect to the status */
+     * be reordered with respect to the status */
     this.processingMessage = true;
-    this.listener.onReceiveMessage(message, (msg) => {
+    this.listener.onReceiveMessage(message, msg => {
       this.processingMessage = false;
       if (this.processingMetadata) {
         this.pendingMessage = msg;
@@ -142,7 +142,7 @@ export class InterceptingListenerImpl implements InterceptingListener {
     });
   }
   onReceiveStatus(status: StatusObject): void {
-    this.listener.onReceiveStatus(status, (processedStatus) => {
+    this.listener.onReceiveStatus(status, processedStatus => {
       if (this.processingMetadata || this.processingMessage) {
         this.pendingStatus = processedStatus;
       } else {
@@ -170,4 +170,4 @@ export interface Call {
   halfClose(): void;
   getCallNumber(): number;
   setCredentials(credentials: CallCredentials): void;
-}
+}

packages/grpc-js/src/call-number.ts

@@ -18,5 +18,5 @@
 let nextCallNumber = 0;
 
 export function getNextCallNumber() {
-    return nextCallNumber++;
-}
+  return nextCallNumber++;
+}

packages/grpc-js/src/call.ts

@@ -65,27 +65,29 @@ export type ClientWritableStream<RequestType> = {
 /**
  * A type representing the return value of a bidirectional stream method call.
  */
-export type ClientDuplexStream<
-  RequestType,
-  ResponseType
-> = ClientWritableStream<RequestType> & ClientReadableStream<ResponseType>;
+export type ClientDuplexStream<RequestType, ResponseType> =
+  ClientWritableStream<RequestType> & ClientReadableStream<ResponseType>;
 
 /**
  * Construct a ServiceError from a StatusObject. This function exists primarily
  * as an attempt to make the error stack trace clearly communicate that the
  * error is not necessarily a problem in gRPC itself.
  * @param status
  */
-export function callErrorFromStatus(status: StatusObject, callerStack: string): ServiceError {
+export function callErrorFromStatus(
+  status: StatusObject,
+  callerStack: string
+): ServiceError {
   const message = `${status.code} ${Status[status.code]}: ${status.details}`;
   const error = new Error(message);
   const stack = `${error.stack}\nfor call at\n${callerStack}`;
-  return Object.assign(new Error(message), status, {stack});
+  return Object.assign(new Error(message), status, { stack });
 }
 
 export class ClientUnaryCallImpl
   extends EventEmitter
-  implements ClientUnaryCall {
+  implements ClientUnaryCall
+{
   public call?: InterceptingCallInterface;
   constructor() {
     super();
@@ -102,7 +104,8 @@ export class ClientUnaryCallImpl
 
 export class ClientReadableStreamImpl<ResponseType>
   extends Readable
-  implements ClientReadableStream<ResponseType> {
+  implements ClientReadableStream<ResponseType>
+{
   public call?: InterceptingCallInterface;
   constructor(readonly deserialize: (chunk: Buffer) => ResponseType) {
     super({ objectMode: true });
@@ -123,7 +126,8 @@ export class ClientReadableStreamImpl<ResponseType>
 
 export class ClientWritableStreamImpl<RequestType>
   extends Writable
-  implements ClientWritableStream<RequestType> {
+  implements ClientWritableStream<RequestType>
+{
   public call?: InterceptingCallInterface;
   constructor(readonly serialize: (value: RequestType) => Buffer) {
     super({ objectMode: true });
@@ -156,7 +160,8 @@ export class ClientWritableStreamImpl<RequestType>
 
 export class ClientDuplexStreamImpl<RequestType, ResponseType>
   extends Duplex
-  implements ClientDuplexStream<RequestType, ResponseType> {
+  implements ClientDuplexStream<RequestType, ResponseType>
+{
   public call?: InterceptingCallInterface;
   constructor(
     readonly serialize: (value: RequestType) => Buffer,

packages/grpc-js/src/channel-credentials.ts

@@ -15,7 +15,12 @@
  *
  */
 
-import { ConnectionOptions, createSecureContext, PeerCertificate, SecureContext } from 'tls';
+import {
+  ConnectionOptions,
+  createSecureContext,
+  PeerCertificate,
+  SecureContext,
+} from 'tls';
 
 import { CallCredentials } from './call-credentials';
 import { CIPHER_SUITES, getDefaultRootsData } from './tls-helpers';
@@ -137,10 +142,7 @@ export abstract class ChannelCredentials {
       cert: certChain ?? undefined,
       ciphers: CIPHER_SUITES,
     });
-    return new SecureChannelCredentialsImpl(
-      secureContext,
-      verifyOptions ?? {}
-    );
+    return new SecureChannelCredentialsImpl(secureContext, verifyOptions ?? {});
   }
 
   /**
@@ -153,11 +155,11 @@ export abstract class ChannelCredentials {
    * @param secureContext The return value of tls.createSecureContext()
    * @param verifyOptions Additional options to modify certificate verification
    */
-  static createFromSecureContext(secureContext: SecureContext, verifyOptions?: VerifyOptions): ChannelCredentials {
-    return new SecureChannelCredentialsImpl(
-      secureContext,
-      verifyOptions ?? {}
-    )
+  static createFromSecureContext(
+    secureContext: SecureContext,
+    verifyOptions?: VerifyOptions
+  ): ChannelCredentials {
+    return new SecureChannelCredentialsImpl(secureContext, verifyOptions ?? {});
   }
 
   /**
@@ -196,19 +198,19 @@ class SecureChannelCredentialsImpl extends ChannelCredentials {
     private verifyOptions: VerifyOptions
   ) {
     super();
-    this.connectionOptions = { 
-      secureContext
+    this.connectionOptions = {
+      secureContext,
     };
     // Node asserts that this option is a function, so we cannot pass undefined
     if (verifyOptions?.checkServerIdentity) {
-      this.connectionOptions.checkServerIdentity = verifyOptions.checkServerIdentity;
+      this.connectionOptions.checkServerIdentity =
+        verifyOptions.checkServerIdentity;
     }
   }
 
   compose(callCredentials: CallCredentials): ChannelCredentials {
-    const combinedCallCredentials = this.callCredentials.compose(
-      callCredentials
-    );
+    const combinedCallCredentials =
+      this.callCredentials.compose(callCredentials);
     return new ComposedChannelCredentialsImpl(this, combinedCallCredentials);
   }
 
@@ -225,9 +227,10 @@ class SecureChannelCredentialsImpl extends ChannelCredentials {
     }
     if (other instanceof SecureChannelCredentialsImpl) {
       return (
-        this.secureContext === other.secureContext && 
-        this.verifyOptions.checkServerIdentity === other.verifyOptions.checkServerIdentity
-        );
+        this.secureContext === other.secureContext &&
+        this.verifyOptions.checkServerIdentity ===
+          other.verifyOptions.checkServerIdentity
+      );
     } else {
       return false;
     }
@@ -242,9 +245,8 @@ class ComposedChannelCredentialsImpl extends ChannelCredentials {
     super(callCreds);
   }
   compose(callCredentials: CallCredentials) {
-    const combinedCallCredentials = this.callCredentials.compose(
-      callCredentials
-    );
+    const combinedCallCredentials =
+      this.callCredentials.compose(callCredentials);
     return new ComposedChannelCredentialsImpl(
       this.channelCredentials,
       combinedCallCredentials

packages/grpc-js/src/channel.ts

@@ -91,7 +91,6 @@ export interface Channel {
 }
 
 export class ChannelImplementation implements Channel {
-
   private internalChannel: InternalChannel;
 
   constructor(
@@ -133,13 +132,17 @@ export class ChannelImplementation implements Channel {
     deadline: Date | number,
     callback: (error?: Error) => void
   ): void {
-    this.internalChannel.watchConnectivityState(currentState, deadline, callback);
+    this.internalChannel.watchConnectivityState(
+      currentState,
+      deadline,
+      callback
+    );
   }
 
   /**
    * Get the channelz reference object for this channel. The returned value is
    * garbage if channelz is disabled for this channel.
-   * @returns 
+   * @returns
    */
   getChannelzRef() {
     return this.internalChannel.getChannelzRef();
@@ -160,6 +163,12 @@ export class ChannelImplementation implements Channel {
         'Channel#createCall: deadline must be a number or Date'
       );
     }
-    return this.internalChannel.createCall(method, deadline, host, parentCall, propagateFlags);
+    return this.internalChannel.createCall(
+      method,
+      deadline,
+      host,
+      parentCall,
+      propagateFlags
+    );
   }
 }