[AUTOMATED]: Prettier Code Styling

Author: Feiyang1

packages/rxfire/database/list/audit-trail.ts

@@ -75,7 +75,10 @@ function waitForLoaded(
     // This is the magical part, only emit when the last load key
     // in the dataset has been loaded by a child event. At this point
     // we can assume the dataset is "whole".
-    skipWhile(meta => meta.loadedKeys.indexOf(meta.lastKeyToLoad as string | null) === -1),
+    skipWhile(
+      meta =>
+        meta.loadedKeys.indexOf(meta.lastKeyToLoad as string | null) === -1
+    ),
     // Pluck off the meta data because the user only cares
     // to iterate through the snapshots
     map(meta => meta.changes)

packages/rxfire/database/list/index.ts

@@ -23,7 +23,10 @@ import { fromRef } from '../fromRef';
 import { switchMap, scan, distinctUntilChanged, map } from 'rxjs/operators';
 import { changeToData } from '../object';
 
-export function stateChanges(query: database.Query, events?: ListenEvent[]): Observable<QueryChange> {
+export function stateChanges(
+  query: database.Query,
+  events?: ListenEvent[]
+): Observable<QueryChange> {
   events = validateEventsArray(events);
   const childEvent$ = events.map(event => fromRef(query, event));
   return merge(...childEvent$);

packages/rxfire/firestore/collection/index.ts

@@ -146,7 +146,9 @@ export function collectionChanges(
  * Return a stream of document snapshots on a query. These results are in sort order.
  * @param query
  */
-export function collection(query: firestore.Query): Observable<firestore.QueryDocumentSnapshot[]> {
+export function collection(
+  query: firestore.Query
+): Observable<firestore.QueryDocumentSnapshot[]> {
   return fromCollectionRef(query).pipe(map(changes => changes.docs));
 }
 

packages/rxfire/firestore/document/index.ts

@@ -20,7 +20,9 @@ import { fromDocRef } from '../fromRef';
 import { map } from 'rxjs/operators';
 import { Observable } from 'rxjs';
 
-export function doc(ref: firestore.DocumentReference): Observable<firestore.DocumentSnapshot> {
+export function doc(
+  ref: firestore.DocumentReference
+): Observable<firestore.DocumentSnapshot> {
   return fromDocRef(ref);
 }
 

packages/rxfire/firestore/fromRef.ts

@@ -26,7 +26,9 @@ function _fromRef(ref: any): Observable<any> {
   });
 }
 
-export function fromRef(ref: firestore.DocumentReference | firestore.Query): Observable<{}> {
+export function fromRef(
+  ref: firestore.DocumentReference | firestore.Query
+): Observable<{}> {
   return _fromRef(ref);
 }
 

packages/rxfire/storage/index.ts

@@ -19,7 +19,9 @@ import { storage } from 'firebase/app';
 import { Observable, from } from 'rxjs';
 import { map } from 'rxjs/operators';
 
-export function fromTask(task: storage.UploadTask): Observable<storage.UploadTaskSnapshot> {
+export function fromTask(
+  task: storage.UploadTask
+): Observable<storage.UploadTaskSnapshot> {
   return new Observable<storage.UploadTaskSnapshot>(subscriber => {
     const progress = (snap: storage.UploadTaskSnapshot): void =>
       subscriber.next(snap);

packages/rxfire/test/database.test.ts

@@ -22,7 +22,13 @@ import { expect } from 'chai';
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
 import { initializeApp, database, app } from 'firebase';
 import { fromRef } from '../database/fromRef';
-import { list, ListenEvent, objectVal, listVal, QueryChange } from '../database';
+import {
+  list,
+  ListenEvent,
+  objectVal,
+  listVal,
+  QueryChange
+} from '../database';
 import { take, skip, switchMap } from 'rxjs/operators';
 import { BehaviorSubject, Observable } from 'rxjs';
 import { auditTrail } from '../database/list/audit-trail';
@@ -37,7 +43,7 @@ const rando = (): string =>
 
 const batch = (items: any[]): Readonly<{}> => {
   const batch = {};
-  Object.keys(items).forEach((key) => {
+  Object.keys(items).forEach(key => {
     const itemValue = items[key];
     batch[itemValue.key] = itemValue;
   });
@@ -224,7 +230,7 @@ describe('RxFire Database', () => {
           sub.unsubscribe();
           done();
         });
-        itemRef.child(key).setPriority(-100, () => { });
+        itemRef.child(key).setPriority(-100, () => {});
       });
 
       /**
@@ -454,7 +460,7 @@ describe('RxFire Database', () => {
           .add(done);
         app.database().goOnline();
         aref.set(itemsObj).then(() => {
-          aref.child(items[0].key).setPriority('a', () => { });
+          aref.child(items[0].key).setPriority('a', () => {});
         });
       });
 
@@ -481,7 +487,7 @@ describe('RxFire Database', () => {
        */
       it('should handle multiple subscriptions (hot)', done => {
         const { snapChanges, ref } = prepareList();
-        const sub = snapChanges.subscribe(() => { }).add(done);
+        const sub = snapChanges.subscribe(() => {}).add(done);
         snapChanges
           .pipe(take(1))
           .subscribe(actions => {
@@ -499,7 +505,7 @@ describe('RxFire Database', () => {
         const { snapChanges, ref } = prepareList();
         snapChanges
           .pipe(take(1))
-          .subscribe(() => { })
+          .subscribe(() => {})
           .add(() => {
             snapChanges
               .pipe(take(1))

packages/rxfire/test/firestore.test.ts

@@ -44,8 +44,9 @@ const createId = (): string =>
  * Create a collection with a random name. This helps sandbox offline tests and
  * makes sure tests don't interfere with each other as they run.
  */
-const createRandomCol = (firestore: firestore.Firestore): firestore.CollectionReference =>
-  firestore.collection(createId());
+const createRandomCol = (
+  firestore: firestore.Firestore
+): firestore.CollectionReference => firestore.collection(createId());
 
 /**
  * Unwrap a snapshot but add the type property to the data object.