Run npm run format.

Author: taeold

integration_test/functions/src/index.ts

@@ -1,37 +1,33 @@
-import { PubSub } from '@google-cloud/pubsub';
-import { GoogleAuth } from 'google-auth-library';
-import { Request, Response } from 'express';
-import * as admin from 'firebase-admin';
-import * as functions from 'firebase-functions';
-import * as fs from 'fs';
-import fetch from 'node-fetch';
+import { PubSub } from "@google-cloud/pubsub";
+import { GoogleAuth } from "google-auth-library";
+import { Request, Response } from "express";
+import * as admin from "firebase-admin";
+import * as functions from "firebase-functions";
+import * as fs from "fs";
+import fetch from "node-fetch";
 
-import * as v1 from './v1';
-import * as v2 from './v2';
+import * as v1 from "./v1";
+import * as v2 from "./v2";
 const getNumTests = (m: object): number => {
-  return Object.keys(m).filter((k) =>
-    ({}.hasOwnProperty.call(m[k], '__endpoint'))
-  ).length;
+  return Object.keys(m).filter((k) => ({}.hasOwnProperty.call(m[k], "__endpoint"))).length;
 };
 const numTests = getNumTests(v1) + getNumTests(v2);
 export { v1, v2 };
 
-import { REGION } from './region';
-import * as testLab from './v1/testLab-utils';
+import { REGION } from "./region";
+import * as testLab from "./v1/testLab-utils";
 
 const firebaseConfig = JSON.parse(process.env.FIREBASE_CONFIG);
 admin.initializeApp();
 
 async function callHttpsTrigger(name: string, data: any) {
   const url = `https://${REGION}-${firebaseConfig.projectId}.cloudfunctions.net/${name}`;
-  const client = await new GoogleAuth().getIdTokenClient(
-    '32555940559.apps.googleusercontent.com'
-  );
+  const client = await new GoogleAuth().getIdTokenClient("32555940559.apps.googleusercontent.com");
   const resp = await client.request({
     url,
-    method: 'POST',
+    method: "POST",
     headers: {
-      'Content-Type': 'application/json',
+      "Content-Type": "application/json",
     },
     body: JSON.stringify({ data }),
   });
@@ -40,11 +36,7 @@ async function callHttpsTrigger(name: string, data: any) {
   }
 }
 
-async function callV2HttpsTrigger(
-  name: string,
-  data: any,
-  accessToken: string
-) {
+async function callV2HttpsTrigger(name: string, data: any, accessToken: string) {
   const getFnResp = await fetch(
     `https://cloudfunctions.googleapis.com/v2beta/projects/${firebaseConfig.projectId}/locations/${REGION}/functions/${name}`,
     {
@@ -62,14 +54,12 @@ async function callV2HttpsTrigger(
     throw new Error(`Cannot call v2 https trigger ${name} - no uri found`);
   }
 
-  const client = await new GoogleAuth().getIdTokenClient(
-    '32555940559.apps.googleusercontent.com'
-  );
+  const client = await new GoogleAuth().getIdTokenClient("32555940559.apps.googleusercontent.com");
   const invokeFnREsp = await client.request({
     url: uri,
-    method: 'POST',
+    method: "POST",
     headers: {
-      'Content-Type': 'application/json',
+      "Content-Type": "application/json",
     },
     body: JSON.stringify({ data }),
   });
@@ -78,17 +68,13 @@ async function callV2HttpsTrigger(
   }
 }
 
-async function callScheduleTrigger(
-  functionName: string,
-  region: string,
-  accessToken: string
-) {
+async function callScheduleTrigger(functionName: string, region: string, accessToken: string) {
   const response = await fetch(
     `https://cloudscheduler.googleapis.com/v1/projects/${firebaseConfig.projectId}/locations/us-central1/jobs/firebase-schedule-${functionName}-${region}:run`,
     {
-      method: 'POST',
+      method: "POST",
       headers: {
-        'Content-Type': 'application/json',
+        "Content-Type": "application/json",
         Authorization: `Bearer ${accessToken}`,
       },
     }
@@ -101,19 +87,16 @@ async function callScheduleTrigger(
   return;
 }
 
-async function updateRemoteConfig(
-  testId: string,
-  accessToken: string
-): Promise<void> {
+async function updateRemoteConfig(testId: string, accessToken: string): Promise<void> {
   const resp = await fetch(
     `https://firebaseremoteconfig.googleapis.com/v1/projects/${firebaseConfig.projectId}/remoteConfig`,
     {
-      method: 'PUT',
+      method: "PUT",
       headers: {
         Authorization: `Bearer ${accessToken}`,
-        'Content-Type': 'application/json; UTF-8',
-        'Accept-Encoding': 'gzip',
-        'If-Match': '*',
+        "Content-Type": "application/json; UTF-8",
+        "Accept-Encoding": "gzip",
+        "If-Match": "*",
       },
       body: JSON.stringify({ version: { description: testId } }),
     }
@@ -126,88 +109,78 @@ async function updateRemoteConfig(
 function v1Tests(testId: string, accessToken: string): Array<Promise<unknown>> {
   return [
     // A database write to trigger the Firebase Realtime Database tests.
-    admin.database().ref(`dbTests/${testId}/start`).set({ '.sv': 'timestamp' }),
+    admin.database().ref(`dbTests/${testId}/start`).set({ ".sv": "timestamp" }),
     // A Pub/Sub publish to trigger the Cloud Pub/Sub tests.
-    new PubSub()
-      .topic('pubsubTests')
-      .publish(Buffer.from(JSON.stringify({ testId }))),
+    new PubSub().topic("pubsubTests").publish(Buffer.from(JSON.stringify({ testId }))),
     // A user creation to trigger the Firebase Auth user creation tests.
     admin
       .auth()
       .createUser({
         email: `${testId}@fake.com`,
-        password: 'secret',
+        password: "secret",
         displayName: `${testId}`,
       })
       .then((userRecord) => {
         // A user deletion to trigger the Firebase Auth user deletion tests.
         admin.auth().deleteUser(userRecord.uid);
       }),
     // A firestore write to trigger the Cloud Firestore tests.
-    admin.firestore().collection('tests').doc(testId).set({ test: testId }),
+    admin.firestore().collection("tests").doc(testId).set({ test: testId }),
     // Invoke a callable HTTPS trigger.
-    callHttpsTrigger('v1-callableTests', { foo: 'bar', testId }),
+    callHttpsTrigger("v1-callableTests", { foo: "bar", testId }),
     // A Remote Config update to trigger the Remote Config tests.
     updateRemoteConfig(testId, accessToken),
     // A storage upload to trigger the Storage tests
     admin
       .storage()
       .bucket()
-      .upload('/tmp/' + testId + '.txt'),
+      .upload("/tmp/" + testId + ".txt"),
     testLab.startTestRun(firebaseConfig.projectId, testId, accessToken),
     // Invoke the schedule for our scheduled function to fire
-    callScheduleTrigger('v1-schedule', 'us-central1', accessToken),
+    callScheduleTrigger("v1-schedule", "us-central1", accessToken),
   ];
 }
 
 function v2Tests(testId: string, accessToken: string): Array<Promise<void>> {
   return [
     // Invoke a callable HTTPS trigger.
-    callV2HttpsTrigger('v2-callabletests', { foo: 'bar', testId }, accessToken),
+    callV2HttpsTrigger("v2-callabletests", { foo: "bar", testId }, accessToken),
   ];
 }
 
 export const integrationTests: any = functions
   .region(REGION)
   .runWith({
     timeoutSeconds: 540,
-    invoker: 'private',
+    invoker: "private",
   })
   .https.onRequest(async (req: Request, resp: Response) => {
     const testId = admin.database().ref().push().key;
     admin.database().ref(`testRuns/${testId}/timestamp`).set(Date.now());
     const testIdRef = admin.database().ref(`testRuns/${testId}`);
-    functions.logger.info('testId is: ', testId);
-    fs.writeFile('/tmp/' + testId + '.txt', 'test', () => {});
+    functions.logger.info("testId is: ", testId);
+    fs.writeFile("/tmp/" + testId + ".txt", "test", () => {});
     try {
-      const accessToken = await admin.credential
-        .applicationDefault()
-        .getAccessToken();
+      const accessToken = await admin.credential.applicationDefault().getAccessToken();
       await Promise.all([
         ...v1Tests(testId, accessToken.access_token),
         ...v2Tests(testId, accessToken.access_token),
       ]);
       // On test completion, check that all tests pass and reply "PASS", or provide further details.
-      functions.logger.info('Waiting for all tests to report they pass...');
+      functions.logger.info("Waiting for all tests to report they pass...");
       await new Promise<void>((resolve, reject) => {
-        setTimeout(() => reject(new Error('Timeout')), 5 * 60 * 1000);
+        setTimeout(() => reject(new Error("Timeout")), 5 * 60 * 1000);
         let testsExecuted = 0;
-        testIdRef.on('child_added', (snapshot) => {
-          if (snapshot.key === 'timestamp') {
+        testIdRef.on("child_added", (snapshot) => {
+          if (snapshot.key === "timestamp") {
             return;
           }
           testsExecuted += 1;
           if (!snapshot.val().passed) {
-            reject(
-              new Error(
-                `test ${snapshot.key} failed; see database for details.`
-              )
-            );
+            reject(new Error(`test ${snapshot.key} failed; see database for details.`));
             return;
           }
-          functions.logger.info(
-            `${snapshot.key} passed (${testsExecuted} of ${numTests})`
-          );
+          functions.logger.info(`${snapshot.key} passed (${testsExecuted} of ${numTests})`);
           if (testsExecuted < numTests) {
             // Not all tests have completed. Wait longer.
             return;
@@ -216,17 +189,14 @@ export const integrationTests: any = functions
           resolve();
         });
       });
-      functions.logger.info('All tests pass!');
-      resp.status(200).send('PASS \n');
+      functions.logger.info("All tests pass!");
+      resp.status(200).send("PASS \n");
     } catch (err) {
       functions.logger.info(`Some tests failed: ${err}`, err);
       resp
         .status(500)
-        .send(
-          `FAIL - details at ${functions.firebaseConfig()
-            .databaseURL!}/testRuns/${testId}`
-        );
+        .send(`FAIL - details at ${functions.firebaseConfig().databaseURL}/testRuns/${testId}`);
     } finally {
-      testIdRef.off('child_added');
+      testIdRef.off("child_added");
     }
   });

integration_test/functions/src/region.ts

@@ -1,2 +1,2 @@
 // TODO: Add back support for selecting region for integration test once params is ready.
-export const REGION = 'us-central1';
+export const REGION = "us-central1";

integration_test/functions/src/testing.ts

@@ -1,5 +1,5 @@
-import * as firebase from 'firebase-admin';
-import * as functions from 'firebase-functions';
+import * as firebase from "firebase-admin";
+import * as functions from "firebase-functions";
 
 export type TestCase<T> = (data: T, context?: functions.EventContext) => any;
 export interface TestCaseMap<T> {
@@ -31,7 +31,7 @@ export class TestSuite<T> {
         .then(
           (result) => {
             functions.logger.info(
-              `${result ? 'Passed' : 'Failed with successful op'}: ${testName}`
+              `${result ? "Passed" : "Failed with successful op"}: ${testName}`
             );
             return { name: testName, passed: !!result };
           },
@@ -49,10 +49,7 @@ export class TestSuite<T> {
       const passed = sum === running.length;
       functions.logger.info(summary);
       const result = { passed, summary, tests: results };
-      return firebase
-        .database()
-        .ref(`testRuns/${testId}/${this.name}`)
-        .set(result);
+      return firebase.database().ref(`testRuns/${testId}/${this.name}`).set(result);
     });
   }
 }
@@ -73,10 +70,7 @@ export function evaluate(value: boolean, errMsg: string) {
 }
 
 export function expectEq(left: any, right: any) {
-  return evaluate(
-    left == right,
-    JSON.stringify(left) + ' does not equal ' + JSON.stringify(right)
-  );
+  return evaluate(left == right, JSON.stringify(left) + " does not equal " + JSON.stringify(right));
 }
 
 function deepEq(left: any, right: any) {
@@ -128,7 +122,7 @@ export function expectReject<EventType>(f: (e: EventType) => Promise<void>) {
     }
 
     if (!rejected) {
-      throw new Error('Test should have returned a rejected promise');
+      throw new Error("Test should have returned a rejected promise");
     }
   };
 }

mocha/setup.ts

@@ -1,6 +1,6 @@
-import * as chai from 'chai';
-import * as chaiAsPromised from 'chai-as-promised';
-import * as nock from 'nock';
+import * as chai from "chai";
+import * as chaiAsPromised from "chai-as-promised";
+import * as nock from "nock";
 
 chai.use(chaiAsPromised);
 

scripts/bin-test/mocha-setup.ts

@@ -1,4 +1,4 @@
-import * as chai from 'chai';
-import * as chaiAsPromised from 'chai-as-promised';
+import * as chai from "chai";
+import * as chaiAsPromised from "chai-as-promised";
 
 chai.use(chaiAsPromised);