chore!: publish gax-nodejs in dual format (CJS and ESM)

gax/.babelrc

@@ -0,0 +1,19 @@
+{
+    "presets": [
+      "@babel/preset-typescript",
+      "@babel/env"
+    ],
+    "plugins": [
+      [
+        "replace-import-extension",
+        {
+          "extMapping": {
+            ".js": ".cjs"
+          }
+        }
+      ],
+      "./node_modules/gapic-tools/build/src/replaceESMMockingLib.js",
+      "./node_modules/gapic-tools/build/src/replaceImportMetaUrl.js",
+      "./node_modules/gapic-tools/build/src/toggleESMFlagVariable.js"
+    ]
+  }

gax/.eslintignore

@@ -5,3 +5,6 @@ build/
 docs/
 protos/
 samples/generated/
+**/*.d.ts
+*.d.ts
+**/**.d.ts

gax/.gitignore

@@ -23,3 +23,6 @@ dist/
 *.tgz
 **/*.tgz
 test/showcase-echo-client/protos/protos.*
+**/*.d.ts
+*.d.ts
+**/**.d.ts

gax/add-cjs-extension.cjs

@@ -0,0 +1,50 @@
+const fs = require('fs');
+const path = require('path');
+
+function getAllFiles(dirPath, arrayOfFiles) {
+  const files = fs.readdirSync(dirPath);
+
+  arrayOfFiles = arrayOfFiles || [];
+
+  files.forEach(file => {
+    if (fs.statSync(path.join(dirPath, file)).isDirectory()) {
+      arrayOfFiles = getAllFiles(path.join(dirPath, file), arrayOfFiles);
+    } else {
+      arrayOfFiles.push(path.join(dirPath, file));
+    }
+  });
+
+  return arrayOfFiles;
+}
+
+function getAllFullFilePaths(dirname, filenames) {
+  // const files = fs.readdirSync(dirPath);
+
+  const arrayOfFiles = [];
+
+  filenames.forEach(file => {
+    arrayOfFiles.push(path.join(dirname, file));
+  });
+
+  return arrayOfFiles;
+}
+
+function main(directoryOrFilenames) {
+  let fileNames;
+  if (
+    fs.statSync(path.join(__dirname, directoryOrFilenames[0])).isDirectory()
+  ) {
+    fileNames = getAllFiles(directoryOrFilenames[0]);
+  } else {
+    fileNames = getAllFullFilePaths(__dirname, directoryOrFilenames);
+  }
+  for (const file of fileNames) {
+    let contents = fs.readFileSync(file, 'utf8');
+    if (contents.includes('proxyquire')) {
+      contents = contents.replace(/\.js'/g, ".cjs'");
+      fs.writeFileSync(file, contents);
+    }
+  }
+}
+
+main(process.argv.slice(2));

gax/src/apiCaller.ts → gax/esm/src/apiCaller.ts

@@ -20,13 +20,13 @@ import {
   GRPCCall,
   ResultTuple,
   SimpleCallbackFunction,
-} from './apitypes';
-import {CancellablePromise, OngoingCall, OngoingCallPromise} from './call';
-import {Descriptor} from './descriptor';
-import {CallSettings} from './gax';
-import {GoogleError} from './googleError';
-import {NormalApiCaller} from './normalCalls/normalApiCaller';
-import {StreamProxy} from './streamingCalls/streaming';
+} from './apitypes.js';
+import {CancellablePromise, OngoingCall, OngoingCallPromise} from './call.js';
+import {Descriptor} from './descriptor.js';
+import {CallSettings} from './gax.js';
+import {GoogleError} from './googleError.js';
+import {NormalApiCaller} from './normalCalls/normalApiCaller.js';
+import {StreamProxy} from './streamingCalls/streaming.js';
 
 /**
  * An interface for all kinds of API callers (normal, that just calls API, and

gax/src/apitypes.ts → gax/esm/src/apitypes.ts

@@ -16,10 +16,10 @@
 
 import {Duplex} from 'stream';
 
-import {CancellablePromise} from './call';
-import {CallOptions} from './gax';
-import {GoogleError} from './googleError';
-import {Operation} from './longRunningCalls/longrunning';
+import {CancellablePromise} from './call.js';
+import {CallOptions} from './gax.js';
+import {GoogleError} from './googleError.js';
+import {Operation} from './longRunningCalls/longrunning.js';
 
 // gRPC functions return object with `.cancel()` method that can be used for
 // canceling the ongoing call.

gax/src/bundlingCalls/bundleApiCaller.ts → gax/esm/src/bundlingCalls/bundleApiCaller.ts

@@ -14,14 +14,14 @@
  * limitations under the License.
  */
 
-import {APICaller} from '../apiCaller';
-import {APICallback, GRPCCall, SimpleCallbackFunction} from '../apitypes';
-import {OngoingCall, OngoingCallPromise} from '../call';
-import {CallSettings} from '../gax';
-import {GoogleError} from '../googleError';
+import {APICaller} from '../apiCaller.js';
+import {APICallback, GRPCCall, SimpleCallbackFunction} from '../apitypes.js';
+import {OngoingCall, OngoingCallPromise} from '../call.js';
+import {CallSettings} from '../gax.js';
+import {GoogleError} from '../googleError.js';
 
-import {BundleExecutor} from './bundleExecutor';
-import {TaskCallback} from './task';
+import {BundleExecutor} from './bundleExecutor.js';
+import {TaskCallback} from './task.js';
 
 /**
  * An implementation of APICaller for bundled calls.

gax/src/bundlingCalls/bundleDescriptor.ts → gax/esm/src/bundlingCalls/bundleDescriptor.ts

@@ -14,13 +14,13 @@
  * limitations under the License.
  */
 
-import {Descriptor} from '../descriptor';
-import {CallSettings} from '../gax';
-import {NormalApiCaller} from '../normalCalls/normalApiCaller';
+import {Descriptor} from '../descriptor.js';
+import {CallSettings} from '../gax.js';
+import {NormalApiCaller} from '../normalCalls/normalApiCaller.js';
 
-import {BundleApiCaller} from './bundleApiCaller';
-import {BundleExecutor} from './bundleExecutor';
-import {toCamelCase as snakeToCamelCase} from '../util';
+import {BundleApiCaller} from './bundleApiCaller.js';
+import {BundleExecutor} from './bundleExecutor.js';
+import {toCamelCase as snakeToCamelCase} from '../util.js';
 
 /**
  * A descriptor for calls that can be bundled into one call.

gax/src/bundlingCalls/bundleExecutor.ts → gax/esm/src/bundlingCalls/bundleExecutor.ts

@@ -14,15 +14,15 @@
  * limitations under the License.
  */
 
-import {Status} from '../status';
+import {Status} from '../status.js';
 
-import {SimpleCallbackFunction} from '../apitypes';
-import {GoogleError} from '../googleError';
-import {warn} from '../warnings';
+import {SimpleCallbackFunction} from '../apitypes.js';
+import {GoogleError} from '../googleError.js';
+import {warn} from '../warnings.js';
 
-import {BundleDescriptor} from './bundleDescriptor';
-import {computeBundleId} from './bundlingUtils';
-import {Task, TaskCallback} from './task';
+import {BundleDescriptor} from './bundleDescriptor.js';
+import {computeBundleId} from './bundlingUtils.js';
+import {Task, TaskCallback} from './task.js';
 
 function noop() {}
 

gax/src/bundlingCalls/bundlingUtils.ts → gax/esm/src/bundlingCalls/bundlingUtils.ts

@@ -18,7 +18,7 @@
  * Provides behavior that supports request bundling.
  */
 
-import {RequestType} from '../apitypes';
+import {RequestType} from '../apitypes.js';
 
 /**
  * Compute the identifier of the `obj`. The objects of the same ID

gax/src/bundlingCalls/task.ts → gax/esm/src/bundlingCalls/task.ts

@@ -14,10 +14,14 @@
  * limitations under the License.
  */
 
-import {Status} from '../status';
+import {Status} from '../status.js';
 
-import {APICallback, GRPCCallResult, SimpleCallbackFunction} from '../apitypes';
-import {GoogleError} from '../googleError';
+import {
+  APICallback,
+  GRPCCallResult,
+  SimpleCallbackFunction,
+} from '../apitypes.js';
+import {GoogleError} from '../googleError.js';
 
 export interface SubResponseInfo {
   field: string;

gax/src/call.ts → gax/esm/src/call.ts

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-import {Status} from './status';
+import {Status} from './status.js';
 
 import {
   APICallback,
@@ -24,8 +24,8 @@ import {
   ResponseType,
   ResultTuple,
   SimpleCallbackFunction,
-} from './apitypes';
-import {GoogleError} from './googleError';
+} from './apitypes.js';
+import {GoogleError} from './googleError.js';
 
 export class OngoingCall {
   callback: APICallback;

gax/src/clientInterface.ts → gax/esm/src/clientInterface.ts

@@ -16,17 +16,17 @@
 // ** https://github.com/googleapis/gapic-generator-typescript **
 // ** All changes to this file may be overwritten. **
 
-import {GrpcClientOptions, ClientStubOptions} from './grpc';
-import * as gax from './gax';
+import {GrpcClientOptions, ClientStubOptions} from './grpc.js';
+import * as gax from './gax.js';
 import {GoogleAuthOptions} from 'google-auth-library';
 import {
   BundleDescriptor,
   LongrunningDescriptor,
   PageDescriptor,
   StreamDescriptor,
-} from './descriptor';
-import * as longrunning from './longRunningCalls/longrunning';
-import * as operationProtos from '../protos/operations';
+} from './descriptor.js';
+import * as longrunning from './longRunningCalls/longrunning.js';
+import * as operationProtos from '../../protos/operations.js';
 
 export interface ClientOptions
   extends GrpcClientOptions,

gax/src/createApiCall.ts → gax/esm/src/createApiCall.ts

@@ -18,21 +18,21 @@
  * Provides function wrappers that implement page streaming and retrying.
  */
 
-import {createAPICaller} from './apiCaller';
+import {createAPICaller} from './apiCaller.js';
 import {
   APICallback,
   GaxCall,
   GRPCCall,
   GRPCCallOtherArgs,
   RequestType,
   SimpleCallbackFunction,
-} from './apitypes';
-import {Descriptor} from './descriptor';
-import {CallOptions, CallSettings, convertRetryOptions} from './gax';
-import {retryable} from './normalCalls/retries';
-import {addTimeoutArg} from './normalCalls/timeout';
-import {StreamingApiCaller} from './streamingCalls/streamingApiCaller';
-import {warn} from './warnings';
+} from './apitypes.js';
+import {Descriptor} from './descriptor.js';
+import {CallOptions, CallSettings, convertRetryOptions} from './gax.js';
+import retryable from './normalCalls/retries.js';
+import {addTimeoutArg} from './normalCalls/timeout.js';
+import {StreamingApiCaller} from './streamingCalls/streamingApiCaller.js';
+import {warn} from './warnings.js';
 
 /**
  * Converts an rpc call into an API call governed by the settings.

gax/src/descriptor.ts → gax/esm/src/descriptor.ts

@@ -20,14 +20,14 @@
 // can create its own apiCaller that will handle all the specifics for the given
 // call type.
 
-import {APICaller} from './apiCaller';
-import {CallSettings} from './gax';
+import {APICaller} from './apiCaller.js';
+import {CallSettings} from './gax.js';
 
 export interface Descriptor {
   getApiCaller(settings: CallSettings): APICaller;
 }
 
-export {LongRunningDescriptor as LongrunningDescriptor} from './longRunningCalls/longRunningDescriptor';
-export {PageDescriptor} from './paginationCalls/pageDescriptor';
-export {StreamDescriptor} from './streamingCalls/streamDescriptor';
-export {BundleDescriptor} from './bundlingCalls/bundleDescriptor';
+export {LongRunningDescriptor as LongrunningDescriptor} from './longRunningCalls/longRunningDescriptor.js';
+export {PageDescriptor} from './paginationCalls/pageDescriptor.js';
+export {StreamDescriptor} from './streamingCalls/streamDescriptor.js';
+export {BundleDescriptor} from './bundlingCalls/bundleDescriptor.js';