[AUTOMATED]: Prettier Code Styling

Author: schmidt-sebastian

packages/firestore/src/api/database.ts

@@ -311,7 +311,7 @@ export class Firestore implements firestore.Firestore, FirebaseService {
       PlatformSupport.getPlatform(),
       databaseInfo,
       this._config.credentials,
-      this._queue,
+      this._queue
     );
     return this._firestoreClient.start(persistence);
   }
@@ -376,7 +376,7 @@ export class Firestore implements firestore.Firestore, FirebaseService {
     // Exposed via INTERNAL for use in tests.
     disableNetwork: () => this._firestoreClient.disableNetwork(),
     enableNetwork: () => this._firestoreClient.enableNetwork(),
-    queue :  this._queue,
+    queue: this._queue
   };
 
   collection(pathString: string): firestore.CollectionReference {

packages/firestore/src/util/async_queue.ts

@@ -20,12 +20,12 @@ import { AnyDuringMigration, AnyJs } from './misc';
 import { Deferred } from './promise';
 import { Code, FirestoreError } from './error';
 
-type DelayedOperation <T> = {
+type DelayedOperation<T> = {
   // tslint:disable-next-line:no-any Accept any return type from setTimeout().
   handle: any;
-  op:() => Promise<T>,
+  op: () => Promise<T>;
   deferred: Deferred<T>;
-}
+};
 
 export class AsyncQueue {
   // The last promise in the queue.
@@ -69,7 +69,7 @@ export class AsyncQueue {
     if ((delay || 0) > 0) {
       this.delayedOperationsCount++;
       const nextIndex = this.delayedOperations.length;
-      const delayedOp : DelayedOperation<T> = {
+      const delayedOp: DelayedOperation<T> = {
         handle: null,
         op: op,
         deferred: new Deferred<T>()
@@ -135,10 +135,16 @@ export class AsyncQueue {
       if (entry.handle) {
         clearTimeout(entry.handle);
         if (executeDelayedTasks) {
-          this.scheduleInternal(entry.op).then(entry.deferred.resolve, entry.deferred.reject);
+          this.scheduleInternal(entry.op).then(
+            entry.deferred.resolve,
+            entry.deferred.reject
+          );
         } else {
           entry.deferred.reject(
-              new FirestoreError(Code.CANCELLED, 'Operation cancelled by shutdown')
+            new FirestoreError(
+              Code.CANCELLED,
+              'Operation cancelled by shutdown'
+            )
           );
         }
       }

packages/firestore/test/integration/api/database.test.ts

@@ -18,7 +18,7 @@ import { expect } from 'chai';
 import * as firestore from 'firestore';
 
 import { Deferred } from '../../../src/util/promise';
-import {asyncIt, fasyncIt} from '../../util/helpers';
+import { asyncIt, fasyncIt } from '../../util/helpers';
 import firebase from '../util/firebase_export';
 import {
   apiDescribe,
@@ -629,11 +629,14 @@ apiDescribe('Database', persistence => {
   asyncIt('can write document after idle timeout', () => {
     return withTestDb(persistence, (db, queue) => {
       const docRef = db.collection('test-collection').doc();
-      return docRef.set({ foo: 'bar' }).then(() => {
-        console.log(JSON.stringify(queue));
-        expect(queue.delayedOperationsCount).to.be.equal(1);
-        return queue.drain(/* executeDelayedTasks= */ true);
-      }).then(() => docRef.set({ foo: 'bar' }));
+      return docRef
+        .set({ foo: 'bar' })
+        .then(() => {
+          console.log(JSON.stringify(queue));
+          expect(queue.delayedOperationsCount).to.be.equal(1);
+          return queue.drain(/* executeDelayedTasks= */ true);
+        })
+        .then(() => docRef.set({ foo: 'bar' }));
     });
   });
 
@@ -653,10 +656,12 @@ apiDescribe('Database', persistence => {
         return deferred.promise.then(unregister);
       };
 
-      return awaitOnlineSnapshot().then(() => {
-        expect(queue.delayedOperationsCount).to.be.equal(1);
-        return queue.drain(/* executeDelayedTasks= */ true);
-      }).then(() => awaitOnlineSnapshot());
+      return awaitOnlineSnapshot()
+        .then(() => {
+          expect(queue.delayedOperationsCount).to.be.equal(1);
+          return queue.drain(/* executeDelayedTasks= */ true);
+        })
+        .then(() => awaitOnlineSnapshot());
     });
   });
 });

packages/firestore/test/integration/remote/stream.test.ts

@@ -229,11 +229,11 @@ describe('Write Stream', () => {
       .then(() => {
         writeStream.markIdle();
         expect(queue.delayedOperationsCount).to.be.equal(1);
-          return Promise.all([
-           streamListener.awaitCallback('close'),
-              queue.drain(/*executeDelayedTasks=*/ true)
-              ]);
-        })
+        return Promise.all([
+          streamListener.awaitCallback('close'),
+          queue.drain(/*executeDelayedTasks=*/ true)
+        ]);
+      })
       .then(() => {
         expect(writeStream.isOpen()).to.be.false;
       });
@@ -259,9 +259,10 @@ describe('Write Stream', () => {
         expect(queue.delayedOperationsCount).to.be.equal(1);
         writeStream.writeMutations(SINGLE_MUTATION);
         return streamListener.awaitCallback('mutationResult');
-      }).then(() => queue.drain(/*executeDelayedTasks=*/ true))
-        .then(() => {
-          expect(writeStream.isOpen()).to.be.true;
-    });
+      })
+      .then(() => queue.drain(/*executeDelayedTasks=*/ true))
+      .then(() => {
+        expect(writeStream.isOpen()).to.be.true;
+      });
   });
 });