react-native-firebase/bridge/e2e/firestore/transactions.e2e.js

167 lines
4.7 KiB
JavaScript
Raw Normal View History

2018-04-16 16:45:32 +00:00
const { testDocRef } = TestHelpers.firestore;
2018-03-24 05:53:49 +00:00
2018-04-09 18:03:07 +00:00
describe('firestore()', () => {
describe('runTransaction()', () => {
2018-04-16 16:45:32 +00:00
it('should set() values', async () => {
2018-04-09 18:03:07 +00:00
const firestore = firebase.firestore();
2018-04-16 16:45:32 +00:00
const docRef = testDocRef('tSet');
2018-03-24 05:53:49 +00:00
2018-04-09 18:03:07 +00:00
const updateFunction = async transaction => {
const doc = await transaction.get(docRef);
2018-04-16 16:45:32 +00:00
if (!doc.exists) {
transaction.set(docRef, { value: 1, somethingElse: 'set' });
return 1;
2018-04-09 18:03:07 +00:00
}
2018-03-24 05:53:49 +00:00
2018-04-16 16:45:32 +00:00
return 0;
};
const result = await firestore.runTransaction(updateFunction);
should.equal(result, 1);
const finalDoc = await docRef.get();
finalDoc.data().value.should.equal(1);
finalDoc.data().somethingElse.should.equal('set');
});
it('should update() values', async () => {
const firestore = firebase.firestore();
const docRef = testDocRef('tUpdate');
await docRef.set({ value: 1 });
const updateFunction = async transaction => {
const doc = await transaction.get(docRef);
if (doc.exists) {
transaction.update(docRef, {
value: doc.data().value + 1,
somethingElse: 'update',
});
2018-04-09 18:03:07 +00:00
return 1;
}
2018-03-24 05:53:49 +00:00
2018-04-16 16:45:32 +00:00
return 0;
};
2018-03-24 05:53:49 +00:00
2018-04-16 16:45:32 +00:00
const result = await firestore.runTransaction(updateFunction);
should.equal(result, 1);
const finalDoc = await docRef.get();
finalDoc.data().value.should.equal(2);
finalDoc.data().somethingElse.should.equal('update');
});
it('should delete() values', async () => {
const firestore = firebase.firestore();
const docRef = testDocRef('tDelete');
await docRef.set({ value: 1, somethingElse: 'delete' });
const updateFunction = async transaction => {
const doc = await transaction.get(docRef);
if (doc.exists) {
transaction.delete(docRef);
return 1;
2018-04-09 18:03:07 +00:00
}
2018-03-24 05:53:49 +00:00
2018-04-16 16:45:32 +00:00
return 0;
};
const result = await firestore.runTransaction(updateFunction);
should.equal(result, 1);
const finalDoc = await docRef.get();
finalDoc.exists.should.equal(false);
});
it('error if updateFn does return a promise', async () => {
const firestore = firebase.firestore();
// test async functions - they always return a promise in JS
let didReject = false;
let updateFunction = async () => 1;
try {
await firestore.runTransaction(updateFunction);
} catch (e) {
didReject = true;
}
should.equal(didReject, false);
2018-03-24 05:53:49 +00:00
2018-04-16 16:45:32 +00:00
// should not error as a promise returned
didReject = false;
updateFunction = () => Promise.resolve();
try {
await firestore.runTransaction(updateFunction);
} catch (e) {
didReject = true;
}
should.equal(didReject, false);
// should error as no promise returned
didReject = false;
updateFunction = () => '123456';
try {
await firestore.runTransaction(updateFunction);
} catch (e) {
didReject = true;
e.message.includes('must return a Promise');
}
should.equal(didReject, true);
});
it('updateFn promise rejections / js exceptions handled', async () => {
const firestore = firebase.firestore();
// rejections
let didReject = false;
let updateFunction = () => Promise.reject('shoop');
try {
await firestore.runTransaction(updateFunction);
} catch (e) {
didReject = true;
should.equal(e, 'shoop');
}
should.equal(didReject, true);
// exceptions
didReject = false;
updateFunction = () => {
// eslint-disable-next-line no-throw-literal
throw 'doop';
};
try {
await firestore.runTransaction(updateFunction);
} catch (e) {
didReject = true;
should.equal(e, 'doop');
}
should.equal(didReject, true);
});
it.only('handle native exceptions', async () => {
2018-04-16 16:45:32 +00:00
const firestore = firebase.firestore();
const docRef = testDocRef('tSet');
2018-04-16 18:20:00 +00:00
const blockedRef = firestore.doc('denied/foo');
2018-04-16 16:45:32 +00:00
const updateFunction = async transaction => {
await transaction.get(docRef);
transaction.set(blockedRef, { value: 1, somethingElse: 'set' });
return 1;
2018-04-09 18:03:07 +00:00
};
2018-03-24 05:53:49 +00:00
2018-04-16 16:45:32 +00:00
// rejections
2018-04-09 18:03:07 +00:00
let didReject = false;
try {
await firestore.runTransaction(updateFunction);
} catch (e) {
// TODO sdks are giving different errors - standardise?
if (device.getPlatform() === 'ios') {
e.message.should.containEql('firestore/failed-precondition');
} else {
e.message.should.containEql('firestore/aborted');
}
2018-04-09 18:03:07 +00:00
didReject = true;
}
should.equal(didReject, true);
});
2018-03-24 05:53:49 +00:00
});
});