mirror of
https://github.com/hanzoai/firebase-js-sdk.git
synced 2026-09-24 16:59:10 +00:00
wu-huiandGitHub
4703c99e12
* chore(ci): make all firestore integration tests optional * fix: align expressions and pipelines, address review comments, update yarn.lock, and fix package versions * chore: update yarn.lock after merge * fix: restore firestore package version and devDependencies to 4.15.0
50 lines
1.8 KiB
TypeScript
50 lines
1.8 KiB
TypeScript
/**
|
|
* @license
|
|
* Copyright 2018 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 { MemoryEagerPersistenceMode, withTestDoc } from './util/helpers';
|
|
|
|
// Firestore databases can be subject to a ~30s "cold start" delay if they have not been used
|
|
// recently, so before any tests run we "prime" the backend.
|
|
|
|
const PRIMING_TIMEOUT_MS = 45000;
|
|
|
|
before(
|
|
'Prime backend by waiting for a write to show up in the watch stream',
|
|
function (): Promise<void> {
|
|
this.timeout(PRIMING_TIMEOUT_MS);
|
|
|
|
return withTestDoc(new MemoryEagerPersistenceMode(), async (doc, db) => {
|
|
// const accumulator = new EventsAccumulator<DocumentSnapshot>();
|
|
// const unsubscribe = onSnapshot(doc, accumulator.storeEvent);
|
|
//
|
|
// // Wait for watch to initialize and deliver first event.
|
|
// await accumulator.awaitRemoteEvent();
|
|
//
|
|
// // Use a transaction to perform a write without triggering any local events.
|
|
// await runTransaction(db, async txn => {
|
|
// txn.set(doc, { value: 'done' });
|
|
// });
|
|
//
|
|
// // Wait to see the write on the watch stream.
|
|
// const docSnap = await accumulator.awaitRemoteEvent();
|
|
// expect(docSnap.get('value')).to.equal('done');
|
|
//
|
|
// unsubscribe();
|
|
});
|
|
}
|
|
);
|