validation.test.ts

/**
 * @license
 * Copyright 2017 Google LLC
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

import { expect } from 'chai';

import { Deferred } from '../../util/promise';
import {
  arrayRemove,
  arrayUnion,
  collectionGroup,
  connectFirestoreEmulator,
  deleteField,
  documentId,
  enableIndexedDbPersistence,
  endAt,
  endBefore,
  increment,
  limit,
  limitToLast,
  newTestFirestore,
  startAfter,
  startAt,
  writeBatch,
  collection,
  disableNetwork,
  doc,
  DocumentSnapshot,
  enableNetwork,
  Firestore,
  getDoc,
  onSnapshot,
  orderBy,
  query,
  runTransaction,
  serverTimestamp,
  setDoc,
  updateDoc,
  where,
  or,
  and,
  newTestApp
} from '../util/firebase_export';
import {
  apiDescribe,
  PersistenceMode,
  withAlternateTestDb,
  withTestCollection,
  withTestDb
} from '../util/helpers';
import {
  ALT_PROJECT_ID,
  DEFAULT_PROJECT_ID,
  TARGET_DB_ID,
  USE_EMULATOR,
  getEmulatorPort
} from '../util/settings';

// We're using 'as any' to pass invalid values to APIs for testing purposes.
/* eslint-disable @typescript-eslint/no-explicit-any */

interface ValidationIt {
  (
    persistence: PersistenceMode,
    message: string,
    testFunction: (db: Firestore) => void | Promise<any>
  ): void;
  skip: (
    persistence: PersistenceMode,
    message: string,
    testFunction: (db: Firestore) => void | Promise<any>
  ) => void;
  only: (
    persistence: PersistenceMode,
    message: string,
    testFunction: (db: Firestore) => void | Promise<any>
  ) => void;
}

// Since most of our tests are "synchronous" but require a Firestore instance,
// we have a helper wrapper around it() and withTestDb() to optimize for that.
const validationIt: ValidationIt = Object.assign(
  (
    persistence: PersistenceMode,
    message: string,
    testFunction: (db: Firestore) => void | Promise<any>
  ) => {
    it(message, () => {
      return withTestDb(persistence, async db => {
        const maybePromise = testFunction(db);
        if (maybePromise) {
          return maybePromise;
        }
      });
    });
  },
  {
    skip(
      persistence: PersistenceMode,
      message: string,
      _: (db: Firestore) => void | Promise<any>
    ): void {
      // eslint-disable-next-line no-restricted-properties
      it.skip(message, () => {});
    },
    only(
      persistence: PersistenceMode,
      message: string,
      testFunction: (db: Firestore) => void | Promise<any>
    ): void {
      // eslint-disable-next-line no-restricted-properties
      it.only(message, () => {
        return withTestDb(persistence, async db => {
          const maybePromise = testFunction(db);
          if (maybePromise) {
            return maybePromise;
          }
        });
      });
    }
  }
);

/** Class used to verify custom classes can't be used in writes. */
class TestClass {
  constructor(readonly property: string) {}
}

apiDescribe('Validation:', persistence => {
  describe('FirestoreSettings', () => {
    validationIt(
      persistence,
      'disallows changing settings after use',
      async db => {
        await setDoc(doc(db, 'foo/bar'), {});
        expect(() =>
          connectFirestoreEmulator(db, 'something-else.example.com', 8080)
        ).to.throw(
          'Firestore has already been started and its settings can no ' +
            'longer be changed. You can only modify settings before calling any other ' +
            'methods on a Firestore object.'
        );
      }
    );

    validationIt(persistence, 'enforces minimum cache size', () => {
      expect(() =>
        newTestFirestore(newTestApp('test-project'), { cacheSizeBytes: 1 })
      ).to.throw('cacheSizeBytes must be at least 1048576');
    });

    validationIt(persistence, 'garbage collection can be disabled', () => {
      // Verify that this doesn't throw.
      newTestFirestore(newTestApp('test-project'), {
        cacheSizeBytes: /* CACHE_SIZE_UNLIMITED= */ -1
      });
    });

    validationIt(
      persistence,
      'connectFirestoreEmulator() can set host and port',
      () => {
        const db = newTestFirestore(newTestApp('test-project'));
        // Verify that this doesn't throw.
        connectFirestoreEmulator(db, '127.0.0.1', 9000);
      }
    );

    validationIt(
      persistence,
      'connectFirestoreEmulator() can set mockUserToken object',
      () => {
        const db = newTestFirestore(newTestApp('test-project'));
        // Verify that this doesn't throw.
        connectFirestoreEmulator(db, '127.0.0.1', 9000, {
          mockUserToken: { sub: 'foo' }
        });
      }
    );

    validationIt(
      persistence,
      'disallows calling connectFirestoreEmulator() for first time after use',
      async db => {
        const errorMsg =
          'Firestore has already been started and its settings can no longer be changed.';

        await setDoc(doc(db, 'foo/bar'), {});
        expect(() => connectFirestoreEmulator(db, '127.0.0.1', 9000)).to.throw(
          errorMsg
        );
      }
    );

    validationIt(
      persistence,
      'allows calling connectFirestoreEmulator() after use with same config',
      async db => {
        if (USE_EMULATOR) {
          const port = getEmulatorPort();
          connectFirestoreEmulator(db, '127.0.0.1', port);
          await setDoc(doc(db, 'foo/bar'), {});
          expect(() =>
            connectFirestoreEmulator(db, '127.0.0.1', port)
          ).to.not.throw();
        }
      }
    );

    validationIt(
      persistence,
      'disallows calling connectFirestoreEmulator() after use with different config',
      async db => {
        if (USE_EMULATOR) {
          const errorMsg =
            'Firestore has already been started and its settings can no longer be changed.';
          const port = getEmulatorPort();
          connectFirestoreEmulator(db, '127.0.0.1', port);
          await setDoc(doc(db, 'foo/bar'), {});
          expect(() =>
            connectFirestoreEmulator(db, '127.0.0.1', port + 1)
          ).to.throw(errorMsg);
        }
      }
    );

    validationIt(
      persistence,
      'connectFirestoreEmulator() can set mockUserToken string',
      () => {
        const db = newTestFirestore(newTestApp('test-project'));
        // Verify that this doesn't throw.
        connectFirestoreEmulator(db, '127.0.0.1', 9000, {
          mockUserToken: 'my-mock-user-token'
        });
      }
    );

    validationIt(
      persistence,
      'throws if sub / user_id is missing in mockUserToken',
      async db => {
        const errorMsg = "mockUserToken must contain 'sub' or 'user_id' field!";

        expect(() =>
          connectFirestoreEmulator(db, '127.0.0.1', 9000, {
            mockUserToken: {} as any
          })
        ).to.throw(errorMsg);
      }
    );
  });

  describe('Firestore', () => {
    validationIt(
      persistence,
      'disallows calling enableIndexedDbPersistence() after use',
      async db => {
        await getDoc(doc(db, 'foo/bar'));
        expect(() => enableIndexedDbPersistence(db)).to.throw(
          'Firestore has already been started and persistence can no ' +
            'longer be enabled. You can only enable persistence before ' +
            'calling any other methods on a Firestore object.'
        );
      }
    );

    it("fails transaction if function doesn't return a Promise.", () => {
      return withTestDb(persistence, db => {
        return runTransaction(db, () => 5 as any).then(
          () => expect.fail('Transaction should fail'),
          err => {
            expect(err.message).to.equal(
              'Transaction callback must return a Promise'
            );
          }
        );
      });
    });
  });

  describe('Collection paths', () => {
    validationIt(persistence, 'must be non-empty strings', db => {
      expect(() => collection(db, '')).to.throw(
        'Function collection() cannot be called with an empty path.'
      );
    });

    validationIt(persistence, 'must be odd-length', db => {
      const baseDocRef = doc(db, 'foo/bar');
      const badAbsolutePaths = ['foo/bar', 'foo/bar/baz/quu'];
      const badRelativePaths = ['/', 'baz/quu'];
      const badPathLengths = [2, 4];

      for (let i = 0; i < badAbsolutePaths.length; i++) {
        const error =
          'Invalid collection reference. Collection references ' +
          'must have an odd number of segments, but ' +
          `${badAbsolutePaths[i]} has ${badPathLengths[i]}`;
        expect(() => collection(db, badAbsolutePaths[i])).to.throw(error);
        expect(() => collection(baseDocRef, badRelativePaths[i])).to.throw(
          error
        );
      }
    });

    validationIt(persistence, 'must not have empty segments', db => {
      // NOTE: leading / trailing slashes are okay.
      collection(db, '/foo/');
      collection(db, '/foo');
      collection(db, 'foo/');

      const badPaths = ['foo//bar//baz', '//foo', 'foo//'];
      const collRef = collection(db, 'test-collection');
      const docRef = doc(collRef, 'test-document');
      for (const path of badPaths) {
        const reason = `Invalid segment (${path}). Paths must not contain // in them.`;
        expect(() => collection(db, path)).to.throw(reason);
        expect(() => doc(db, path)).to.throw(reason);
        expect(() => doc(collRef, path)).to.throw(reason);
        expect(() => collection(docRef, path)).to.throw(reason);
      }
    });
  });

  describe('Document paths', () => {
    validationIt(persistence, 'must be strings', db => {
      expect(() => doc(db, '')).to.throw(
        'Function doc() cannot be called with an empty path.'
      );
    });

    validationIt(persistence, 'must be even-length', db => {
      const baseCollectionRef = collection(db, 'foo');
      const badAbsolutePaths = ['foo', 'foo/bar/baz'];
      const badRelativePaths = ['/', 'bar/baz'];
      const badPathLengths = [1, 3];

      for (let i = 0; i < badAbsolutePaths.length; i++) {
        const error =
          'Invalid document reference. Document references ' +
          'must have an even number of segments, but ' +
          `${badAbsolutePaths[i]} has ${badPathLengths[i]}`;
        expect(() => doc(db, badAbsolutePaths[i])).to.throw(error);
        expect(() => doc(baseCollectionRef, badRelativePaths[i])).to.throw(
          error
        );
      }
    });
  });

  describe('Writes', () => {
    validationIt(persistence, 'must be objects.', db => {
      // PORTING NOTE: The error for deleteField() is different for minified
      // builds, so omit testing it specifically.
      const badData = [
        42,
        [1],
        new Date(),
        null,
        () => {},
        new TestClass('foo'),
        undefined
      ];
      const errorDescriptions = [
        '42',
        'an array',
        'a custom Date object',
        'null',
        'a function',
        'a custom TestClass object'
      ];
      const promises: Array<Promise<void>> = [];
      for (let i = 0; i < badData.length; i++) {
        const error =
          'Data must be an object, but it was: ' + errorDescriptions[i];
        promises.push(expectWriteToFail(db, badData[i], error));
      }
      return Promise.all(promises);
    });

    validationIt(
      persistence,
      'must not contain custom objects or functions.',
      db => {
        const badData = [
          { foo: new TestClass('foo') },
          { foo: [new TestClass('foo')] },
          { foo: { bar: new TestClass('foo') } },
          { foo: () => {} },
          { foo: [() => {}] },
          { foo: { bar: () => {} } }
        ];
        const errorDescriptions = [
          'Unsupported field value: a custom TestClass object (found in field foo)',
          'Unsupported field value: a custom TestClass object',
          'Unsupported field value: a custom TestClass object (found in field foo.bar)',
          'Unsupported field value: a function (found in field foo)',
          'Unsupported field value: a function',
          'Unsupported field value: a function (found in field foo.bar)'
        ];
        const promises: Array<Promise<void>> = [];
        for (let i = 0; i < badData.length; i++) {
          promises.push(
            expectWriteToFail(db, badData[i], errorDescriptions[i])
          );
        }
        return Promise.all(promises);
      }
    );

    validationIt(
      persistence,
      'must not contain field value transforms in arrays',
      db => {
        return expectWriteToFail(
          db,
          { 'array': [serverTimestamp()] },
          'serverTimestamp() is not currently supported inside arrays'
        );
      }
    );

    validationIt(
      persistence,
      'must not contain directly nested arrays.',
      db => {
        return expectWriteToFail(
          db,
          { 'nested-array': [1, [2]] },
          'Nested arrays are not supported'
        );
      }
    );

    validationIt(persistence, 'may contain indirectly nested arrays.', db => {
      const data = { 'nested-array': [1, { foo: [2] }] };

      const ref = doc(collection(db, 'foo'));
      const ref2 = doc(collection(db, 'foo'));

      return setDoc(ref, data)
        .then(() => writeBatch(db).set(ref, data).commit())
        .then(() => updateDoc(ref, data))
        .then(() => writeBatch(db).update(ref, data).commit())
        .then(() =>
          runTransaction(db, async txn => {
            // Note ref2 does not exist at this point so set that and update ref.
            txn.update(ref, data);
            txn.set(ref2, data);
          })
        );
    });

    validationIt(persistence, 'must not contain undefined.', db => {
      // Note: This test uses the default setting for `ignoreUndefinedProperties`.
      return expectWriteToFail(
        db,
        { foo: undefined },
        'Unsupported field value: undefined (found in field foo)'
      );
    });

    validationIt(
      persistence,
      'must not contain references to a different database',
      db => {
        return withAlternateTestDb(persistence, db2 => {
          const ref = doc(db2, 'baz/quu');
          const data = { foo: ref };
          return expectWriteToFail(
            db,
            data,
            `Document reference is for database ` +
              `${ALT_PROJECT_ID}/${TARGET_DB_ID} but should be for database ` +
              `${DEFAULT_PROJECT_ID}/${TARGET_DB_ID} (found in field ` +
              `foo)`
          );
        });
      }
    );

    validationIt(persistence, 'must not contain reserved field names.', db => {
      return Promise.all([
        expectWriteToFail(
          db,
          { __baz__: 1 },
          'Document fields cannot begin and end with "__" (found in field ' +
            '__baz__)'
        ),
        expectWriteToFail(
          db,
          { foo: { __baz__: 1 } },
          'Document fields cannot begin and end with "__" (found in field ' +
            'foo.__baz__)'
        ),
        expectWriteToFail(
          db,
          { __baz__: { foo: 1 } },
          'Document fields cannot begin and end with "__" (found in field ' +
            '__baz__)'
        ),

        expectUpdateToFail(
          db,
          { 'foo.__baz__': 1 },
          'Document fields cannot begin and end with "__" (found in field ' +
            'foo.__baz__)'
        ),
        expectUpdateToFail(
          db,
          { '__baz__.foo': 1 },
          'Document fields cannot begin and end with "__" (found in field ' +
            '__baz__.foo)'
        )
      ]);
    });

    validationIt(persistence, 'must not contain empty field names.', db => {
      return expectSetToFail(
        db,
        { '': 'foo' },
        'Document fields must not be empty (found in field ``)'
      );
    });

    validationIt(
      persistence,
      'via set() must not contain deleteField()',
      db => {
        return expectSetToFail(
          db,
          { foo: deleteField() },
          'deleteField() cannot be used with set() unless you pass ' +
            '{merge:true} (found in field foo)'
        );
      }
    );

    validationIt(
      persistence,
      'via update() must not contain nested deleteField()',
      db => {
        return expectUpdateToFail(
          db,
          { foo: { bar: deleteField() } },
          'deleteField() can only appear at the top level of your ' +
            'update data (found in field foo.bar)'
        );
      }
    );
  });

  validationIt(
    persistence,
    'Batch writes require correct Document References',
    db => {
      return withAlternateTestDb(persistence, async db2 => {
        const badRef = doc(db2, 'foo/bar');
        const reason =
          'Provided document reference is from a different Firestore instance.';
        const data = { foo: 1 };
        const batch = writeBatch(db);
        expect(() => batch.set(badRef, data)).to.throw(reason);
        expect(() => batch.update(badRef, data)).to.throw(reason);
        expect(() => batch.delete(badRef)).to.throw(reason);
      });
    }
  );

  validationIt(
    persistence,
    'Transaction writes require correct Document References',
    db => {
      return withAlternateTestDb(persistence, db2 => {
        const badRef = doc(db2, 'foo/bar');
        const reason =
          'Provided document reference is from a different Firestore instance.';
        const data = { foo: 1 };
        return runTransaction(db, async txn => {
          expect(() => txn.get(badRef)).to.throw(reason);
          expect(() => txn.set(badRef, data)).to.throw(reason);
          expect(() => txn.update(badRef, data)).to.throw(reason);
          expect(() => txn.delete(badRef)).to.throw(reason);
        });
      });
    }
  );

  validationIt(persistence, 'Field paths must not have empty segments', db => {
    const docRef = doc(collection(db, 'test'));
    return setDoc(docRef, { test: 1 })
      .then(() => getDoc(docRef))
      .then(snapshot => {
        const badFieldPaths = ['', 'foo..baz', '.foo', 'foo.'];
        const promises: Array<Promise<void>> = [];
        for (const fieldPath of badFieldPaths) {
          const reason =
            `Invalid field path (${fieldPath}). Paths must not be ` +
            `empty, begin with '.', end with '.', or contain '..'`;
          promises.push(expectFieldPathToFail(snapshot, fieldPath, reason));
        }
        return Promise.all(promises);
      });
  });

  validationIt(
    persistence,
    'Field paths must not have invalid segments',
    db => {
      const docRef = doc(collection(db, 'test'));
      return setDoc(docRef, { test: 1 })
        .then(() => getDoc(docRef))
        .then(snapshot => {
          const badFieldPaths = [
            'foo~bar',
            'foo*bar',
            'foo/bar',
            'foo[1',
            'foo]1',
            'foo[1]'
          ];
          const promises: Array<Promise<void>> = [];
          for (const fieldPath of badFieldPaths) {
            const reason =
              `Invalid field path (${fieldPath}). Paths must not ` +
              `contain '~', '*', '/', '[', or ']'`;
            promises.push(expectFieldPathToFail(snapshot, fieldPath, reason));
          }
          return Promise.all(promises);
        });
    }
  );

  describe('Array transforms', () => {
    validationIt(persistence, 'fail in queries', db => {
      const coll = collection(db, 'test');
      expect(() =>
        query(coll, where('test', '==', { test: arrayUnion(1) }))
      ).to.throw(
        'Function where() called with invalid data. ' +
          'arrayUnion() can only be used with update() and set() ' +
          '(found in field test)'
      );

      expect(() =>
        query(coll, where('test', '==', { test: arrayRemove(1) }))
      ).to.throw(
        'Function where() called with invalid data. ' +
          'arrayRemove() can only be used with update() and set() ' +
          '(found in field test)'
      );
    });

    validationIt(persistence, 'reject invalid elements', db => {
      const docRef = doc(collection(db, 'test'));
      expect(() =>
        setDoc(docRef, { x: arrayUnion(1, new TestClass('foo')) })
      ).to.throw(
        'Function arrayUnion() called with invalid data. ' +
          'Unsupported field value: a custom TestClass object'
      );

      expect(() =>
        setDoc(docRef, { x: arrayRemove(1, new TestClass('foo')) })
      ).to.throw(
        'Function arrayRemove() called with invalid data. ' +
          'Unsupported field value: a custom TestClass object'
      );

      expect(() => setDoc(docRef, { x: arrayRemove(undefined) })).to.throw(
        'Function arrayRemove() called with invalid data. ' +
          'Unsupported field value: undefined'
      );
    });

    validationIt(persistence, 'reject arrays', db => {
      const docRef = doc(collection(db, 'test'));
      // This would result in a directly nested array which is not supported.
      expect(() => setDoc(docRef, { x: arrayUnion(1, ['nested']) })).to.throw(
        'Function arrayUnion() called with invalid data. ' +
          'Nested arrays are not supported'
      );

      expect(() => setDoc(docRef, { x: arrayRemove(1, ['nested']) })).to.throw(
        'Function arrayRemove() called with invalid data. ' +
          'Nested arrays are not supported'
      );
    });
  });

  describe('Numeric transforms', () => {
    validationIt(persistence, 'fail in queries', db => {
      const coll = collection(db, 'test');
      expect(() =>
        query(coll, where('test', '==', { test: increment(1) }))
      ).to.throw(
        'Function where() called with invalid data. ' +
          'increment() can only be used with update() and set() ' +
          '(found in field test)'
      );
    });
  });

  describe('Queries', () => {
    validationIt(persistence, 'with non-positive limit fail', db => {
      const coll = collection(db, 'test');
      expect(() => query(coll, limit(0))).to.throw(
        `Function limit() requires a positive number, but it was: 0.`
      );
      expect(() => query(coll, limitToLast(-1))).to.throw(
        `Function limitToLast() requires a positive number, but it was: -1.`
      );
    });

    it('cannot be created from documents missing sort values', () => {
      const testDocs = {
        f: { k: 'f', nosort: 1 } // should not show up
      };
      return withTestCollection(persistence, testDocs, coll => {
        const query1 = query(coll, orderBy('sort'));
        return getDoc(doc(coll, 'f')).then(doc => {
          expect(doc.data()).to.deep.equal({ k: 'f', nosort: 1 });
          const reason =
            `Invalid query. You are trying to start or end a ` +
            `query using a document for which the field 'sort' (used as ` +
            `the orderBy) does not exist.`;
          expect(() => query(query1, startAt(doc))).to.throw(reason);
          expect(() => query(query1, startAfter(doc))).to.throw(reason);
          expect(() => query(query1, endBefore(doc))).to.throw(reason);
          expect(() => query(query1, endAt(doc))).to.throw(reason);
        });
      });
    });

    validationIt(
      persistence,
      'cannot be sorted by an uncommitted server timestamp',
      db => {
        return withTestCollection(
          persistence,
          /*docs=*/ {},
          async collection => {
            await disableNetwork(db);

            const offlineDeferred = new Deferred<void>();
            const onlineDeferred = new Deferred<void>();

            const unsubscribe = onSnapshot(collection, snapshot => {
              // Skip the initial empty snapshot.
              if (snapshot.empty) {
                return;
              }

              expect(snapshot.docs).to.have.lengthOf(1);
              const docSnap: DocumentSnapshot = snapshot.docs[0];

              if (snapshot.metadata.hasPendingWrites) {
                // Offline snapshot. Since the server timestamp is uncommitted,
                // we shouldn't be able to query by it.
                expect(() =>
                  onSnapshot(
                    query(collection, orderBy('timestamp'), endAt(docSnap)),
                    () => {}
                  )
                ).to.throw('uncommitted server timestamp');
                offlineDeferred.resolve();
              } else {
                // Online snapshot. Since the server timestamp is committed, we
                // should be able to query by it.
                onSnapshot(
                  query(collection, orderBy('timestamp'), endAt(docSnap)),
                  () => {}
                );
                onlineDeferred.resolve();
              }
            });

            const docRef = doc(collection);
            void setDoc(docRef, { timestamp: serverTimestamp() });
            await offlineDeferred.promise;

            await enableNetwork(db);
            await onlineDeferred.promise;

            unsubscribe();
          }
        );
      }
    );

    validationIt(
      persistence,
      'must not have more components than order by.',
      db => {
        const coll = collection(db, 'collection');
        const query1 = query(coll, orderBy('foo'));
        const reason =
          'Too many arguments provided to startAt(). The number of ' +
          'arguments must be less than or equal to the number of orderBy() ' +
          'clauses';
        expect(() => query(query1, startAt(1, 2))).to.throw(reason);
        expect(() => query(query1, orderBy('bar'), startAt(1, 2, 3))).to.throw(
          reason
        );
      }
    );

    validationIt(
      persistence,
      'order-by-key bounds must be strings without slashes.',
      db => {
        const collQuery = query(
          collection(db, 'collection'),
          orderBy(documentId())
        );
        const cgQuery = query(
          collectionGroup(db, 'collection'),
          orderBy(documentId())
        );
        expect(() => query(collQuery, startAt(1))).to.throw(
          'Invalid query. Expected a string for document ID in ' +
            'startAt(), but got a number'
        );
        expect(() => query(collQuery, startAt('foo/bar'))).to.throw(
          'Invalid query. When querying a collection and ordering by ' +
            'documentId(), the value passed to startAt() ' +
            "must be a plain document ID, but 'foo/bar' contains a slash."
        );
        expect(() => query(cgQuery, startAt('foo'))).to.throw(
          'Invalid query. When querying a collection group and ordering by ' +
            'documentId(), the value passed to startAt() ' +
            "must result in a valid document path, but 'foo' is not because " +
            'it contains an odd number of segments.'
        );
      }
    );

    validationIt(persistence, 'with more than one != query fail', db => {
      const coll = collection(db, 'test');
      expect(() =>
        query(coll, where('x', '!=', 32), where('x', '!=', 33))
      ).to.throw("Invalid query. You cannot use more than one '!=' filter.");
    });

    validationIt(persistence, 'with != and not-in filters fail', db => {
      expect(() =>
        query(
          collection(db, 'test'),
          where('foo', 'not-in', [2, 3]),
          where('foo', '!=', 4)
        )
      ).to.throw(
        "Invalid query. You cannot use '!=' filters with 'not-in' filters."
      );

      expect(() =>
        query(
          collection(db, 'test'),
          where('foo', '!=', 4),
          where('foo', 'not-in', [2, 3])
        )
      ).to.throw(
        "Invalid query. You cannot use 'not-in' filters with '!=' filters."
      );
    });

    validationIt(persistence, 'with multiple disjunctive filters fail', db => {
      expect(() =>
        query(
          collection(db, 'test'),
          where('foo', 'not-in', [1, 2]),
          where('foo', 'not-in', [2, 3])
        )
      ).to.throw(
        "Invalid query. You cannot use more than one 'not-in' filter."
      );

      expect(() =>
        query(
          collection(db, 'test'),
          where('foo', 'not-in', [2, 3]),
          where('foo', 'array-contains-any', [2, 3])
        )
      ).to.throw(
        "Invalid query. You cannot use 'array-contains-any' filters with " +
          "'not-in' filters."
      );

      expect(() =>
        query(
          collection(db, 'test'),
          where('foo', 'array-contains-any', [2, 3]),
          where('foo', 'not-in', [2, 3])
        )
      ).to.throw(
        "Invalid query. You cannot use 'not-in' filters with " +
          "'array-contains-any' filters."
      );

      expect(() =>
        query(
          collection(db, 'test'),
          where('foo', 'not-in', [2, 3]),
          where('foo', 'in', [2, 3])
        )
      ).to.throw(
        "Invalid query. You cannot use 'in' filters with 'not-in' filters."
      );

      expect(() =>
        query(
          collection(db, 'test'),
          where('foo', 'in', [2, 3]),
          where('foo', 'not-in', [2, 3])
        )
      ).to.throw(
        "Invalid query. You cannot use 'not-in' filters with 'in' filters."
      );
    });

    validationIt(
      persistence,
      'can have an IN filter with an array-contains filter.',
      db => {
        expect(() =>
          query(
            collection(db, 'test'),
            where('foo', 'array-contains', 1),
            where('foo', 'in', [2, 3])
          )
        ).not.to.throw();

        expect(() =>
          query(
            collection(db, 'test'),
            where('foo', 'in', [2, 3]),
            where('foo', 'array-contains', 1)
          )
        ).not.to.throw();
      }
    );

    validationIt(
      persistence,
      'enforce array requirements for disjunctive filters',
      db => {
        expect(() =>
          query(collection(db, 'test'), where('foo', 'in', 2))
        ).to.throw(
          "Invalid Query. A non-empty array is required for 'in' filters."
        );

        expect(() =>
          query(collection(db, 'test'), where('foo', 'array-contains-any', 2))
        ).to.throw(
          'Invalid Query. A non-empty array is required for ' +
            "'array-contains-any' filters."
        );

        expect(() =>
          query(collection(db, 'test'), where('foo', 'in', []))
        ).to.throw(
          "Invalid Query. A non-empty array is required for 'in' filters."
        );

        expect(() =>
          query(collection(db, 'test'), where('foo', 'array-contains-any', []))
        ).to.throw(
          'Invalid Query. A non-empty array is required for ' +
            "'array-contains-any' filters."
        );
      }
    );

    validationIt(
      persistence,
      'must not specify starting or ending point after orderBy',
      db => {
        const coll = collection(db, 'collection');
        const query1 = query(coll, orderBy('foo'));
        let reason =
          'Invalid query. You must not call startAt() or startAfter() before calling orderBy().';
        expect(() => query(query1, startAt(1), orderBy('bar'))).to.throw(
          reason
        );
        expect(() => query(query1, startAfter(1), orderBy('bar'))).to.throw(
          reason
        );

        reason =
          'Invalid query. You must not call endAt() or endBefore() before calling orderBy().';
        expect(() => query(query1, endAt(1), orderBy('bar'))).to.throw(reason);
        expect(() => query(query1, endBefore(1), orderBy('bar'))).to.throw(
          reason
        );
      }
    );

    validationIt(
      persistence,
      'must be non-empty strings or references when filtering by document ID',
      db => {
        const coll = collection(db, 'test');
        expect(() => query(coll, where(documentId(), '>=', ''))).to.throw(
          'Invalid query. When querying with documentId(), you ' +
            'must provide a valid document ID, but it was an empty string.'
        );
        expect(() =>
          query(coll, where(documentId(), '>=', 'foo/bar/baz'))
        ).to.throw(
          `Invalid query. When querying a collection by ` +
            `documentId(), you must provide a plain document ID, but ` +
            `'foo/bar/baz' contains a '/' character.`
        );
        expect(() => query(coll, where(documentId(), '>=', 1))).to.throw(
          'Invalid query. When querying with documentId(), you must ' +
            'provide a valid string or a DocumentReference, but it was: 1.'
        );
        expect(() =>
          query(collectionGroup(db, 'foo'), where(documentId(), '>=', 'foo'))
        ).to.throw(
          `Invalid query. When querying a collection group by ` +
            `documentId(), the value provided must result in a valid document path, ` +
            `but 'foo' is not because it has an odd number of segments (1).`
        );

        expect(() =>
          query(coll, where(documentId(), 'array-contains', 1))
        ).to.throw(
          "Invalid Query. You can't perform 'array-contains' queries on " +
            'documentId().'
        );

        expect(() =>
          query(coll, where(documentId(), 'array-contains-any', 1))
        ).to.throw(
          "Invalid Query. You can't perform 'array-contains-any' queries on " +
            'documentId().'
        );
      }
    );

    validationIt(
      persistence,
      'using IN and document id must have proper document references in array',
      db => {
        const coll = collection(db, 'test');

        expect(() =>
          query(coll, where(documentId(), 'in', [coll.path]))
        ).not.to.throw();

        expect(() => query(coll, where(documentId(), 'in', ['']))).to.throw(
          'Invalid query. When querying with documentId(), you ' +
            'must provide a valid document ID, but it was an empty string.'
        );

        expect(() =>
          query(coll, where(documentId(), 'in', ['foo/bar/baz']))
        ).to.throw(
          `Invalid query. When querying a collection by ` +
            `documentId(), you must provide a plain document ID, but ` +
            `'foo/bar/baz' contains a '/' character.`
        );

        expect(() => query(coll, where(documentId(), 'in', [1, 2]))).to.throw(
          'Invalid query. When querying with documentId(), you must ' +
            'provide a valid string or a DocumentReference, but it was: 1.'
        );

        expect(() =>
          query(collectionGroup(db, 'foo'), where(documentId(), 'in', ['foo']))
        ).to.throw(
          `Invalid query. When querying a collection group by ` +
            `documentId(), the value provided must result in a valid document path, ` +
            `but 'foo' is not because it has an odd number of segments (1).`
        );
      }
    );

    validationIt(persistence, 'cannot pass undefined as a field value', db => {
      const coll = collection(db, 'test');
      expect(() => query(coll, where('foo', '==', undefined))).to.throw(
        'Function where() called with invalid data. Unsupported field value: undefined'
      );
      expect(() => query(coll, orderBy('foo'), startAt(undefined))).to.throw(
        'Function startAt() called with invalid data. Unsupported field value: undefined'
      );
    });

    validationIt(persistence, 'invalid query filters fail', db => {
      const coll = collection(db, 'test');

      // Conflicting operations within a composite filter.
      expect(() =>
        query(
          coll,
          or(
            and(where('a', '==', 'b'), where('c', 'in', ['d', 'e'])),
            and(where('e', '==', 'f'), where('c', 'not-in', ['f', 'g']))
          )
        )
      ).to.throw(
        "Invalid query. You cannot use 'not-in' filters with 'in' filters."
      );

      // Conflicting operations between a field filter and a composite filter.
      expect(() =>
        query(
          coll,
          and(
            or(
              and(where('a', '==', 'b'), where('c', 'in', ['d', 'e'])),
              and(where('e', '==', 'f'), where('g', '==', 'h'))
            ),
            where('i', 'not-in', ['j', 'k'])
          )
        )
      ).to.throw(
        "Invalid query. You cannot use 'not-in' filters with 'in' filters."
      );

      // Conflicting operations between two composite filters.
      expect(() =>
        query(
          coll,
          and(
            or(
              and(where('a', '==', 'b'), where('c', 'in', ['d', 'e'])),
              and(where('e', '==', 'f'), where('g', '==', 'h'))
            ),
            or(
              and(where('i', '==', 'j'), where('l', 'not-in', ['m', 'n'])),
              and(where('o', '==', 'p'), where('q', '==', 'r'))
            )
          )
        )
      ).to.throw(
        "Invalid query. You cannot use 'not-in' filters with 'in' filters."
      );

      // Multiple top level composite filters
      expect(() =>
        // @ts-ignore
        query(coll, and(where('a', '==', 'b')), or(where('b', '==', 'a')))
      ).to.throw(
        'InvalidQuery. When using composite filters, you cannot use ' +
          'more than one filter at the top level. Consider nesting the multiple ' +
          'filters within an `and(...)` statement. For example: ' +
          'change `query(query, where(...), or(...))` to ' +
          '`query(query, and(where(...), or(...)))`.'
      );

      // Once top level composite filter and one top level field filter
      expect(() =>
        // @ts-ignore
        query(coll, or(where('a', '==', 'b')), where('b', '==', 'a'))
      ).to.throw(
        'InvalidQuery. When using composite filters, you cannot use ' +
          'more than one filter at the top level. Consider nesting the multiple ' +
          'filters within an `and(...)` statement. For example: ' +
          'change `query(query, where(...), or(...))` to ' +
          '`query(query, and(where(...), or(...)))`.'
      );
    });

    validationIt(
      persistence,
      'passing non-filters to composite operators fails',
      db => {
        const compositeOperators = [
          { name: 'or', func: or },
          { name: 'and', func: and }
        ];
        const nonFilterOps = [
          limit(1),
          limitToLast(2),
          startAt(1),
          startAfter(1),
          endAt(1),
          endBefore(1),
          orderBy('a')
        ];

        for (const compositeOp of compositeOperators) {
          for (const nonFilterOp of nonFilterOps) {
            const coll = collection(db, 'test');
            expect(() =>
              query(
                coll,
                compositeOp.func(
                  // @ts-ignore
                  nonFilterOp
                )
              )
            ).to.throw(
              `Function ${compositeOp.name}() requires AppliableConstraints created with a call to 'where(...)', 'or(...)', or 'and(...)'.`
            );
          }
        }
      }
    );

    validationIt(
      persistence,
      'conflicting operators inside a nested composite filter',
      db => {
        const coll = collection(db, 'test');
        // Composite queries can validate conflicting operators.
        expect(() =>
          query(
            coll,
            and(
              or(
                and(where('a', '!=', 'b'), where('c', '>=', 'd')),
                and(where('e', '==', 'f'), where('g', '!=', 'h'))
              ),
              or(
                and(where('i', '==', 'j'), where('k', '>', 'l')),
                and(where('m', '<=', 'n'), where('o', '<', 'p'))
              )
            )
          )
        ).to.throw("Invalid query. You cannot use more than one '!=' filter.");

        expect(() =>
          query(
            coll,
            and(
              or(
                and(where('a', '==', 'b'), where('c', '>=', 'd')),
                and(where('e', '==', 'f'), where('g', '!=', 'h'))
              ),
              or(
                and(where('i', '==', 'j'), where('k', '>', 'l')),
                and(where('m', '<=', 'n'), where('o', 'not-in', ['p']))
              )
            )
          )
        ).to.throw(
          "Invalid query. You cannot use 'not-in' filters with '!=' filters."
        );

        expect(() =>
          query(
            coll,
            and(
              or(
                and(where('a', '==', 'b'), where('c', '>=', 'd')),
                and(where('e', '==', 'f'), where('g', 'not-in', ['h']))
              ),
              or(
                and(where('i', '==', 'j'), where('k', '>', 'l')),
                and(where('m', '<=', 'n'), where('o', 'not-in', ['p']))
              )
            )
          )
        ).to.throw(
          "Invalid query. You cannot use more than one 'not-in' filter."
        );
      }
    );
  });
});

function expectSetToFail(
  db: Firestore,
  data: any,
  reason: string
): Promise<void> {
  return expectWriteToFail(
    db,
    data,
    reason,
    /*includeSets=*/ true,
    /*includeUpdates=*/ false
  );
}

function expectUpdateToFail(
  db: Firestore,
  data: any,
  reason: string
): Promise<void> {
  return expectWriteToFail(
    db,
    data,
    reason,
    /*includeSets=*/ false,
    /*includeUpdates=*/ true
  );
}

/**
 * Performs a write using each set and/or update API and makes sure it fails
 * with the expected reason.
 */
function expectWriteToFail(
  db: Firestore,
  data: any,
  reason: string,
  includeSets?: boolean,
  includeUpdates?: boolean
): Promise<void> {
  if (includeSets === undefined) {
    includeSets = true;
  }
  if (includeUpdates === undefined) {
    includeUpdates = true;
  }

  const docPath = 'foo/bar';
  if (reason.includes('in field')) {
    reason = `${reason.slice(0, -1)} in document ${docPath})`;
  } else {
    reason = `${reason} (found in document ${docPath})`;
  }

  const docRef = doc(db, docPath);
  const error = (fnName: string): string =>
    `Function ${fnName}() called with invalid data. ${reason}`;

  if (includeSets) {
    expect(() => setDoc(docRef, data)).to.throw(error('setDoc'));
    expect(() => writeBatch(db).set(docRef, data)).to.throw(
      error('WriteBatch.set')
    );
  }

  if (includeUpdates) {
    expect(() => updateDoc(docRef, data)).to.throw(error('updateDoc'));
    expect(() => writeBatch(db).update(docRef, data)).to.throw(
      error('WriteBatch.update')
    );
  }

  return runTransaction(db, async txn => {
    if (includeSets) {
      expect(() => txn.set(docRef, data)).to.throw(error('Transaction.set'));
    }

    if (includeUpdates) {
      expect(() => txn.update(docRef, data)).to.throw(
        error('Transaction.update')
      );
    }
  });
}

/**
 * Tests a field path with all of our APIs that accept field paths and ensures
 * they fail with the specified reason.
 */
function expectFieldPathToFail(
  snapshot: DocumentSnapshot,
  path: string,
  reason: string
): Promise<void> {
  // Get an arbitrary snapshot we can use for testing.
  return Promise.resolve().then(() => {
    // Snapshot paths.
    expect(() => snapshot.get(path)).to.throw(
      'Function DocumentSnapshot.get() called with invalid data. ' + reason
    );

    const db = snapshot.ref.firestore;

    // Query filter / order fields.
    const coll = collection(db, 'test-collection');
    // <=, etc omitted for brevity since the code path is trivially
    // shared.
    expect(() => query(coll, where(path, '==', 1))).to.throw(
      `Function where() called with invalid data. ` + reason
    );
    expect(() => query(coll, orderBy(path))).to.throw(
      `Function orderBy() called with invalid data. ` + reason
    );

    // Update paths.
    const data = {} as { [field: string]: number };
    data[path] = 1;
    return expectUpdateToFail(db as Firestore, data, reason);
  });
}