chore: run format on test hooks

Author: gagik

testing/integration-testing-hooks.ts

@@ -1,13 +1,13 @@
-import child_process from 'child_process';
-import { promises as fs } from 'fs';
-import { MongoClient, MongoClientOptions } from 'mongodb';
-import path from 'path';
-import semver from 'semver';
-import { promisify } from 'util';
-import which from 'which';
-import { ConnectionString } from 'mongodb-connection-string-url';
-import { MongoCluster, MongoClusterOptions } from 'mongodb-runner';
-import { downloadCryptLibrary } from '../packages/build/src/packaging/download-crypt-library';
+import child_process from "child_process";
+import { promises as fs } from "fs";
+import { MongoClient, MongoClientOptions } from "mongodb";
+import path from "path";
+import semver from "semver";
+import { promisify } from "util";
+import which from "which";
+import { ConnectionString } from "mongodb-connection-string-url";
+import { MongoCluster, MongoClusterOptions } from "mongodb-runner";
+import { downloadCryptLibrary } from "../packages/build/src/packaging/download-crypt-library";
 
 const execFile = promisify(child_process.execFile);
 
@@ -20,7 +20,7 @@ function ciLog(...args: any[]) {
 
 // Return the path to the temporary directory and ensure that it exists.
 async function getTmpdir(): Promise<string> {
-  const tmpdir = path.resolve(__dirname, '..', 'tmp');
+  const tmpdir = path.resolve(__dirname, "..", "tmp");
   await fs.mkdir(tmpdir, { recursive: true });
   return tmpdir;
 }
@@ -31,11 +31,11 @@ export class MongodSetup {
   _setConnectionString: (connectionString: string) => void;
   _serverVersion: string | null = null;
   _isCommunityServer: boolean | null = null;
-  _bindir = '';
+  _bindir = "";
 
   constructor(connectionString?: string) {
-    this._setConnectionString = (connectionString: string) => {};  // Make TypeScript happy.
-    this._connectionString = new Promise(resolve => {
+    this._setConnectionString = (connectionString: string) => {}; // Make TypeScript happy.
+    this._connectionString = new Promise((resolve) => {
       this._setConnectionString = resolve;
     });
 
@@ -45,15 +45,21 @@ export class MongodSetup {
   }
 
   async start(): Promise<void> {
-    throw new Error('Server not managed');
+    throw new Error("Server not managed");
   }
 
   async stop(): Promise<void> {
-    throw new Error('Server not managed');
+    throw new Error("Server not managed");
   }
 
-  async connectionString(searchParams: Partial<Record<keyof MongoClientOptions, string>> = {}, uriOptions: Partial<ConnectionString> = {}): Promise<string> {
-    if (Object.keys(searchParams).length + Object.keys(uriOptions).length === 0) {
+  async connectionString(
+    searchParams: Partial<Record<keyof MongoClientOptions, string>> = {},
+    uriOptions: Partial<ConnectionString> = {}
+  ): Promise<string> {
+    if (
+      Object.keys(searchParams).length + Object.keys(uriOptions).length ===
+      0
+    ) {
       return this._connectionString;
     }
 
@@ -70,7 +76,7 @@ export class MongodSetup {
   }
 
   async port(): Promise<string> {
-    return (await this.hostport()).split(':').reverse()[0];
+    return (await this.hostport()).split(":").reverse()[0];
   }
 
   async hostport(): Promise<string> {
@@ -82,8 +88,8 @@ export class MongodSetup {
       return this._serverVersion;
     }
 
-    const { version } = await this.withClient(async client => {
-      return await client.db('db1').admin().serverStatus();
+    const { version } = await this.withClient(async (client) => {
+      return await client.db("db1").admin().serverStatus();
     });
     this._serverVersion = version;
     return version;
@@ -94,10 +100,10 @@ export class MongodSetup {
       return this._isCommunityServer;
     }
 
-    const { modules } = await this.withClient(async client => {
-      return await client.db('db1').admin().command({ buildInfo: 1 });
+    const { modules } = await this.withClient(async (client) => {
+      return await client.db("db1").admin().command({ buildInfo: 1 });
     });
-    const isCommunityServer = !modules.includes('enterprise');
+    const isCommunityServer = !modules.includes("enterprise");
     this._isCommunityServer = isCommunityServer;
     return isCommunityServer;
   }
@@ -123,8 +129,15 @@ export class MongodSetup {
 export class MongoRunnerSetup extends MongodSetup {
   private static _usedDirPrefix: Record<string, 0> = {};
 
-  private static _buildDirPath(id: string, version?: string, topology?: string) {
-    const prefix = [id, version, topology].filter(Boolean).join('-').replace(/[^a-zA-Z0-9_.-]/g, '');
+  private static _buildDirPath(
+    id: string,
+    version?: string,
+    topology?: string
+  ) {
+    const prefix = [id, version, topology]
+      .filter(Boolean)
+      .join("-")
+      .replace(/[^a-zA-Z0-9_.-]/g, "");
 
     this._usedDirPrefix[prefix] ??= 0;
 
@@ -148,15 +161,19 @@ export class MongoRunnerSetup extends MongodSetup {
     if (this._cluster) return;
     const tmpDir = await getTmpdir();
     const version = process.env.MONGOSH_SERVER_TEST_VERSION;
-    const dirPath = MongoRunnerSetup._buildDirPath(this._id, version, this._opts.topology);
+    const dirPath = MongoRunnerSetup._buildDirPath(
+      this._id,
+      version,
+      this._opts.topology
+    );
 
     this._cluster = await MongoCluster.start({
-      topology: 'standalone',
-      tmpDir: path.join(tmpDir, 'mongodb-runner', 'dbs', dirPath),
-      logDir: path.join(tmpDir, 'mongodb-runner', 'logs', dirPath),
+      topology: "standalone",
+      tmpDir: path.join(tmpDir, "mongodb-runner", "dbs", dirPath),
+      logDir: path.join(tmpDir, "mongodb-runner", "logs", dirPath),
       version: version,
-      ...this._opts
-    })
+      ...this._opts,
+    });
 
     this._setConnectionString(this._cluster.connectionString);
   }
@@ -168,17 +185,25 @@ export class MongoRunnerSetup extends MongodSetup {
 }
 
 async function getInstalledMongodVersion(): Promise<string> {
-  await Promise.all([which('mongod'), which('mongos')]);
-  const { stdout } = await execFile('mongod', ['--version']);
-  const { version } = stdout.match(/^db version (?<version>.+)$/m)!.groups as any;
+  await Promise.all([which("mongod"), which("mongos")]);
+  const { stdout } = await execFile("mongod", ["--version"]);
+  const { version } = stdout.match(/^db version (?<version>.+)$/m)!
+    .groups as any;
   return version;
 }
 
-export async function downloadCurrentCryptSharedLibrary(versionSpec?: string): Promise<string> {
-  if (process.platform === 'linux') {
-    return (await downloadCryptLibrary(`linux-${process.arch.replace('ppc64', 'ppc64le')}` as any, versionSpec)).cryptLibrary;
+export async function downloadCurrentCryptSharedLibrary(
+  versionSpec?: string
+): Promise<string> {
+  if (process.platform === "linux") {
+    return (
+      await downloadCryptLibrary(
+        `linux-${process.arch.replace("ppc64", "ppc64le")}` as any,
+        versionSpec
+      )
+    ).cryptLibrary;
   }
-  return (await downloadCryptLibrary('host', versionSpec)).cryptLibrary;
+  return (await downloadCryptLibrary("host", versionSpec)).cryptLibrary;
 }
 
 /**
@@ -188,23 +213,25 @@ export async function downloadCurrentCryptSharedLibrary(versionSpec?: string): P
  * @export
  * @returns {MongodSetup} - Object with information about the started server.
  */
-let sharedSetup : MongodSetup | null = null;
-export function startTestServer(id: string, args: Partial<MongoClusterOptions> = {}): MongodSetup {
+let sharedSetup: MongodSetup | null = null;
+export function startTestServer(
+  id: string,
+  args: Partial<MongoClusterOptions> = {}
+): MongodSetup {
   const server = new MongoRunnerSetup(id, args);
-  before(async function() {
-    this.timeout(120_000);  // Include potential mongod download time.
+  before(async function () {
+    this.timeout(120_000); // Include potential mongod download time.
     await server.start();
   });
 
-  after(async function() {
+  after(async function () {
     this.timeout(30_000);
     await server.stop();
   });
 
   return server;
 }
 
-
 /**
  * Starts or reuse an existing shared local server managed by this process.
  *
@@ -221,10 +248,10 @@ export function startSharedTestServer(): MongodSetup {
     return new MongodSetup(process.env.MONGOSH_TEST_SERVER_URL);
   }
 
-  const server = sharedSetup ?? (sharedSetup = new MongoRunnerSetup('shared'));
+  const server = sharedSetup ?? (sharedSetup = new MongoRunnerSetup("shared"));
 
-  before(async function() {
-    this.timeout(120_000);  // Include potential mongod download time.
+  before(async function () {
+    this.timeout(120_000); // Include potential mongod download time.
     await server.start();
   });
 
@@ -233,7 +260,7 @@ export function startSharedTestServer(): MongodSetup {
   return server;
 }
 
-global.after?.(async function() {
+global.after?.(async function () {
   if (sharedSetup !== null) {
     this.timeout(30_000);
     await sharedSetup.stop();
@@ -242,24 +269,35 @@ global.after?.(async function() {
 
 // The same as startTestServer(), except that this starts multiple servers
 // in parallel in the same before() call.
-export function startTestCluster(id: string, ...argLists: Partial<MongoClusterOptions>[]): MongodSetup[] {
-  const servers = argLists.map(args => new MongoRunnerSetup(id, args));
+export function startTestCluster(
+  id: string,
+  ...argLists: Partial<MongoClusterOptions>[]
+): MongodSetup[] {
+  const servers = argLists.map((args) => new MongoRunnerSetup(id, args));
 
-  before(async function() {
+  before(async function () {
     this.timeout(90_000 + 30_000 * servers.length);
     await Promise.all(servers.map((server: MongodSetup) => server.start()));
   });
 
-  after(async function() {
+  after(async function () {
     this.timeout(30_000 * servers.length);
     await Promise.all(servers.map((server: MongodSetup) => server.stop()));
   });
 
   return servers;
 }
 
-function skipIfVersion(test: any, testServerVersion: string, semverCondition: string): void {
-  if (semver.satisfies(testServerVersion, semverCondition, { includePrerelease: true })) {
+function skipIfVersion(
+  test: any,
+  testServerVersion: string,
+  semverCondition: string
+): void {
+  if (
+    semver.satisfies(testServerVersion, semverCondition, {
+      includePrerelease: true,
+    })
+  ) {
     test.skip();
   }
 }
@@ -272,8 +310,11 @@ function skipIfVersion(test: any, testServerVersion: string, semverCondition: st
  *   e.g. skipIfServerVersion(testServer, '< 4.4')
  * });
  */
-export function skipIfServerVersion(server: MongodSetup, semverCondition: string): void {
-  before(async function() {
+export function skipIfServerVersion(
+  server: MongodSetup,
+  semverCondition: string
+): void {
+  before(async function () {
     skipIfVersion(this, await server.serverVersion(), semverCondition);
   });
 }
@@ -286,7 +327,7 @@ export function skipIfServerVersion(server: MongodSetup, semverCondition: string
  * });
  */
 export function skipIfCommunityServer(server: MongodSetup): void {
-  before(async function() {
+  before(async function () {
     if (await server.isCommunityServer()) {
       this.skip();
     }
@@ -298,7 +339,7 @@ export function skipIfCommunityServer(server: MongodSetup): void {
  * --apiStrict.
  */
 export function skipIfApiStrict(): void {
-  before(function() {
+  before(function () {
     if (process.env.MONGOSH_TEST_FORCE_API_STRICT) {
       this.skip();
     }
@@ -320,19 +361,21 @@ export function skipIfApiStrict(): void {
  * @param semverCondition Semver condition
  */
 export function skipIfEnvServerVersion(semverCondition: string): void {
-  before(async function() {
+  before(async function () {
     let testServerVersion = process.env.MONGOSH_SERVER_TEST_VERSION;
     if (!testServerVersion) {
       try {
         testServerVersion = await getInstalledMongodVersion();
-      } catch(e: any) {
+      } catch (e: any) {
         // no explicitly specified version but also no local mongod installation
-        testServerVersion = '9999.9999.9999';
+        testServerVersion = "9999.9999.9999";
       }
     } else {
-      testServerVersion = testServerVersion.split('-')[0].split('.')
-        .map(num => /[0-9]+/.test(num) ? num : '0')
-        .join('.');
+      testServerVersion = testServerVersion
+        .split("-")[0]
+        .split(".")
+        .map((num) => (/[0-9]+/.test(num) ? num : "0"))
+        .join(".");
     }
     skipIfVersion(this, testServerVersion, semverCondition);
   });