Merge branch 'dataconnect' into mtewani/add-heartbeat-dc

Author: maneesht

packages/data-connect/package.json

@@ -46,14 +46,14 @@
 },
   "license": "Apache-2.0",
   "dependencies": {
-    "@firebase/auth-interop-types": "0.2.2",
-    "@firebase/component": "0.6.6",
-    "@firebase/logger": "0.4.1",
-    "@firebase/util": "1.9.5",
+    "@firebase/auth-interop-types": "0.2.3",
+    "@firebase/component": "0.6.7",
+    "@firebase/logger": "0.4.2",
+    "@firebase/util": "1.9.6",
     "tslib": "^2.1.0"
   },
   "devDependencies": {
-    "@firebase/app": "0.10.2",
+    "@firebase/app": "0.10.5",
     "rollup": "2.79.1",
     "rollup-plugin-typescript2": "0.31.2",
     "typescript": "4.7.4"

packages/data-connect/src/api/DataConnect.ts

@@ -36,7 +36,6 @@ import { RESTTransport } from '../network/transport/rest';
 
 import { MutationManager } from './Mutation';
 
-
 /**
  * Connector Config for calling Data Connect backend.
  */
@@ -131,10 +130,10 @@ export class DataConnect {
 
     if (this._authProvider) {
       this._authTokenProvider = new FirebaseAuthProvider(
-            this.app.name,
-            this.app.options,
-            this._authProvider
-          );
+        this.app.name,
+        this.app.options,
+        this._authProvider
+      );
     }
 
     this.initialized = true;
@@ -239,7 +238,7 @@ export function getDataConnect(
 /**
  * Delete DataConnect instance
  * @param dataConnect DataConnect instance
- * @returns 
+ * @returns
  */
 export function terminate(dataConnect: DataConnect): Promise<void> {
   return dataConnect._delete();

packages/data-connect/src/api/Mutation.ts

@@ -40,7 +40,7 @@ export function mutationRef<Data>(
   mutationName: string
 ): MutationRef<Data, undefined>;
 /**
- * 
+ *
  * @param dcInstance Data Connect instance
  * @param mutationName name of mutation
  * @param variables variables to send with mutation
@@ -51,7 +51,7 @@ export function mutationRef<Data, Variables>(
   variables: Variables
 ): MutationRef<Data, Variables>;
 /**
- * 
+ *
  * @param dcInstance Data Connect instance
  * @param mutationName name of mutation
  * @param variables variables to send with mutation

packages/data-connect/src/core/FirebaseAuthProvider.ts

@@ -79,4 +79,3 @@ export class FirebaseAuthProvider implements AuthTokenProvider {
       .then(auth => auth.removeAuthTokenListener(listener));
   }
 }
-

packages/data-connect/src/core/QueryManager.ts

@@ -163,9 +163,7 @@ export class QueryManager {
           queryRef.variables
         )}. Calling executeQuery.`
       );
-      const promise = this.executeQuery(
-        queryRef as QueryRef<Data, Variables>
-      );
+      const promise = this.executeQuery(queryRef as QueryRef<Data, Variables>);
       // We want to ignore the error and let subscriptions handle it
       promise.then(undefined, err => {});
     }

packages/data-connect/src/index.ts

@@ -29,9 +29,8 @@ export * from './api.browser';
 
 registerDataConnect();
 
-
 declare module '@firebase/component' {
   interface NameServiceMapping {
     'data-connect': DataConnect;
   }
-}
+}

packages/data-connect/src/network/fetch.ts

@@ -44,9 +44,13 @@ export function dcFetch<T, U>(
     method: 'POST',
     headers,
     signal
-  }).catch(err => {
-    throw new DataConnectError(Code.OTHER, "Failed to fetch: " + JSON.stringify(err));
   })
+    .catch(err => {
+      throw new DataConnectError(
+        Code.OTHER,
+        'Failed to fetch: ' + JSON.stringify(err)
+      );
+    })
     .then(async response => {
       let jsonResponse = null;
       try {

packages/data-connect/src/util/map.ts

@@ -15,7 +15,11 @@
  * limitations under the License.
  */
 
-export function setIfNotExists<T>(map: Map<string, T>, key: string, val: T): void {
+export function setIfNotExists<T>(
+  map: Map<string, T>,
+  key: string,
+  val: T
+): void {
   if (!map.has(key)) {
     map.set(key, val);
   }

packages/data-connect/test/emulatorSeeder.ts

@@ -38,8 +38,6 @@ import * as path from 'path';
 //      }
 //    }
 
-
-
 import { ReferenceType } from '../src';
 
 //  }

packages/data-connect/test/queries.test.ts

@@ -31,8 +31,10 @@ import {
   QueryResult,
   SerializedRef,
   subscribe,
-  terminate
-, SOURCE_CACHE, SOURCE_SERVER } from '../src';
+  terminate,
+  SOURCE_CACHE,
+  SOURCE_SERVER
+} from '../src';
 
 import { setupQueries } from './emulatorSeeder';
 import { getConnectionConfig, initDatabase, PROJECT_ID } from './util';
@@ -161,7 +163,9 @@ describe('DataConnect Tests', async () => {
     });
     connectDataConnectEmulator(fakeInstance, 'localhost', Number(0));
     const taskListQuery = queryRef<TaskListResponse>(dc, 'listPosts');
-    expect(await executeQuery(taskListQuery)).to.eventually.be.rejectedWith('ECONNREFUSED');
+    expect(await executeQuery(taskListQuery)).to.eventually.be.rejectedWith(
+      'ECONNREFUSED'
+    );
   });
 });
 async function waitForFirstEvent<Data, Variables>(