[AUTOMATED]: Prettier Code Styling

Author: schmidt-sebastian

packages/firestore/test/unit/specs/perf_spec.test.ts

@@ -32,9 +32,9 @@ describeSpec('Performance Tests:', ['benchmark'], () => {
   });
 
   specTest('Insert a new document and wait for snapshot', [], () => {
-    let version = 2;
-
+    let currentVersion = 1;
     let steps = spec().withGCEnabled(false);
+
     for (let i = 0; i < STEP_COUNT; ++i) {
       const query = Query.atPath(path(`collection/${i}`));
       const docLocal = doc(
@@ -43,7 +43,7 @@ describeSpec('Performance Tests:', ['benchmark'], () => {
         { doc: i },
         { hasLocalMutations: true }
       );
-      const docRemote = doc(`collection/${i}`, ++version, { doc: i });
+      const docRemote = doc(`collection/${i}`, ++currentVersion, { doc: i });
 
       steps = steps
         .userListens(query)
@@ -53,8 +53,8 @@ describeSpec('Performance Tests:', ['benchmark'], () => {
           fromCache: true,
           hasPendingWrites: true
         })
-        .writeAcks(++version)
-        .watchAcksFull(query, ++version, docRemote)
+        .writeAcks(++currentVersion)
+        .watchAcksFull(query, ++currentVersion, docRemote)
         .expectEvents(query, { metadata: [docRemote] })
         .userUnlistens(query)
         .watchRemoves(query);
@@ -94,91 +94,88 @@ describeSpec('Performance Tests:', ['benchmark'], () => {
 
   specTest('Update a single document', [], () => {
     let steps = spec().withGCEnabled(false);
-
     steps = steps.userSets(`collection/doc`, { v: 0 });
     for (let i = 1; i <= STEP_COUNT; ++i) {
       steps = steps.userPatches(`collection/doc`, { v: i }).writeAcks(i);
     }
     return steps;
   });
 
-  specTest(
-    'Update a single document and wait for snapshot',
-    [],
-    () => {
-      let version = 1;
+  specTest('Update a single document and wait for snapshot', [], () => {
+    const query = Query.atPath(path(`collection/doc`));
+
+    let currentVersion = 1;
+    let steps = spec().withGCEnabled(false);
+
+    let docLocal = doc(
+      `collection/doc`,
+      0,
+      { v: 0 },
+      { hasLocalMutations: true }
+    );
+    let docRemote = doc(`collection/doc`, ++currentVersion, { v: 0 });
+    let lastRemoteVersion = currentVersion;
 
-      const query = Query.atPath(path(`collection/doc`));
-      let docLocal = doc(
+    steps = steps
+      .userListens(query)
+      .userSets(`collection/doc`, { v: 0 })
+      .expectEvents(query, {
+        added: [docLocal],
+        fromCache: true,
+        hasPendingWrites: true
+      })
+      .writeAcks(++currentVersion)
+      .watchAcksFull(query, ++currentVersion, docRemote)
+      .expectEvents(query, { metadata: [docRemote] });
+
+    for (let i = 1; i <= STEP_COUNT; ++i) {
+      docLocal = doc(
         `collection/doc`,
-        0,
-        { v: 0 },
+        lastRemoteVersion,
+        { v: i },
         { hasLocalMutations: true }
       );
-      let docRemote = doc(`collection/doc`, ++version, { v: 0 });
-      let lastRemoteVersion = version;
-
-      let steps = spec().withGCEnabled(false);
+      docRemote = doc(`collection/doc`, ++currentVersion, { v: i });
+      lastRemoteVersion = currentVersion;
 
       steps = steps
-        .userListens(query)
-        .userSets(`collection/doc`, { v: 0 })
-        .expectEvents(query, {
-          added: [docLocal],
-          fromCache: true,
-          hasPendingWrites: true
-        })
-        .writeAcks(++version)
-        .watchAcksFull(query, ++version, docRemote)
+        .userPatches(`collection/doc`, { v: i })
+        .expectEvents(query, { modified: [docLocal], hasPendingWrites: true })
+        .writeAcks(++currentVersion)
+        .watchSends({ affects: [query] }, docRemote)
+        .watchSnapshots(++currentVersion)
         .expectEvents(query, { metadata: [docRemote] });
-
-      for (let i = 1; i <= STEP_COUNT; ++i) {
-        docLocal = doc(
-          `collection/doc`,
-          lastRemoteVersion,
-          { v: i },
-          { hasLocalMutations: true }
-        );
-        docRemote = doc(`collection/doc`, ++version, { v: i });
-        lastRemoteVersion = version;
-
-        steps = steps
-          .userPatches(`collection/doc`, { v: i })
-          .expectEvents(query, { modified: [docLocal], hasPendingWrites: true })
-          .writeAcks(++version)
-          .watchSends({ affects: [query] }, docRemote)
-          .watchSnapshots(++version)
-          .expectEvents(query, { metadata: [docRemote] });
-      }
-      return steps;
     }
-  );
+    return steps;
+  });
 
   specTest('Watch sends 100 documents', [], () => {
-    let version = 1;
     const documentsPerStep = 100;
 
     const query = Query.atPath(path(`collection`)).addOrderBy(orderBy('v'));
 
+    let currentVersion = 1;
     let steps = spec().withGCEnabled(false);
 
     steps = steps
       .userListens(query)
-      .watchAcksFull(query, version)
+      .watchAcksFull(query, currentVersion)
       .expectEvents(query, {});
 
     for (let i = 1; i <= STEP_COUNT; ++i) {
       const docs = [];
 
       for (let j = 0; j < documentsPerStep; ++j) {
-        docs.push(doc(`collection/${j}`, ++version, { v: version }));
+        docs.push(
+          doc(`collection/${j}`, ++currentVersion, { v: currentVersion })
+        );
       }
 
       const changeType = i === 1 ? 'added' : 'modified';
 
       steps = steps
         .watchSends({ affects: [query] }, ...docs)
-        .watchSnapshots(++version)
+        .watchSnapshots(++currentVersion)
         .expectEvents(query, { [changeType]: docs });
     }
 
@@ -187,8 +184,8 @@ describeSpec('Performance Tests:', ['benchmark'], () => {
 
   specTest('Watch has cached results', [], () => {
     const documentsPerStep = 100;
-    let version = 1;
 
+    let currentVersion = 1;
     let steps = spec().withGCEnabled(false);
 
     for (let i = 1; i <= STEP_COUNT; ++i) {
@@ -197,18 +194,18 @@ describeSpec('Performance Tests:', ['benchmark'], () => {
 
       const docs = [];
       for (let j = 0; j < documentsPerStep; ++j) {
-        docs.push(doc(`${collPath}/${j}`, ++version, { v: j }));
+        docs.push(doc(`${collPath}/${j}`, ++currentVersion, { v: j }));
       }
 
       steps = steps
         .userListens(query)
-        .watchAcksFull(query, ++version, ...docs)
+        .watchAcksFull(query, ++currentVersion, ...docs)
         .expectEvents(query, { added: docs })
         .userUnlistens(query)
         .watchRemoves(query)
-        .userListens(query, 'resume-token-' + version)
+        .userListens(query, 'resume-token-' + currentVersion)
         .expectEvents(query, { added: docs, fromCache: true })
-        .watchAcksFull(query, ++version)
+        .watchAcksFull(query, ++currentVersion)
         .expectEvents(query, {})
         .userUnlistens(query)
         .watchRemoves(query);