github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

add new test for exceptions caught on client promises

Browse Source
This commit is contained in:
Nacho Codoñer
2024-03-27 17:52:37 +01:00
parent ecdfd3c610
commit fa94abba42
1 changed files with 69 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

101
packages/mongo/mongo_livedata_tests.js
View File

@@ -4459,39 +4459,76 @@ testAsyncMulti(
],
);
testAsyncMulti("mongo-livedata - support observeChangesAsync and observeAsync to keep isomorphism on client and server", [
async (test) => {
const Collection = new Mongo.Collection(`observe_changes_async${test.runId()}`, { resolverType: 'stub' });
const id = 'a';
await Collection.insertAsync({ _id: id, foo: { bar: 123 } });
testAsyncMulti(
"mongo-livedata - support observeChangesAsync and observeAsync to keep isomorphism on client and server",
[
async (test) => {
const Collection = new Mongo.Collection(
`observe_changes_async${test.runId()}`,
{ resolverType: 'stub' }
);
const id = 'a';
await Collection.insertAsync({ _id: id, foo: { bar: 123 } });
return new Promise(async resolve => {
const obs = await Collection.find(id).observeChangesAsync({
async changed(_id, fields) {
await obs.stop();
resolve();
test.equal(_id, id);
test.equal(fields?.foo?.bar, 456);
},
return new Promise(async (resolve) => {
const obs = await Collection.find(id).observeChangesAsync({
async changed(_id, fields) {
await obs.stop();
resolve();
test.equal(_id, id);
test.equal(fields?.foo?.bar, 456);
},
});
await Collection.updateAsync(id, { $set: { 'foo.bar': 456 } });
});
await Collection.updateAsync(id, { $set: { 'foo.bar': 456 } });
});
},
async (test) => {
const Collection = new Mongo.Collection(`observe_async${test.runId()}`, {
resolverType: 'stub',
});
const id = 'a';
await Collection.insertAsync({ _id: id, foo: { bar: 123 } });
return new Promise(async (resolve) => {
const obs = await Collection.find(id).observeAsync({
async changed(newDocument) {
await obs.stop();
test.equal(newDocument._id, id);
test.equal(newDocument?.foo?.bar, 456);
resolve();
},
});
await Collection.updateAsync(id, { $set: { 'foo.bar': 456 } });
});
},
]
);
Meteor.methods({
[`methodThrowException`]: async () => {
if (Meteor.isClient) {
throw new Meteor.Error('Throw on client');
}
},
async (test) => {
const Collection = new Mongo.Collection(`observe_async${test.runId()}`, { resolverType: 'stub' });
const id = 'a';
await Collection.insertAsync({ _id: id, foo: { bar: 123 } });
});
return new Promise(async resolve => {
const obs = await Collection.find(id).observeAsync({
async changed(newDocument) {
await obs.stop();
test.equal(newDocument._id, id);
test.equal(newDocument?.foo?.bar, 456);
resolve();
},
});
await Collection.updateAsync(id, { $set: { 'foo.bar': 456 } });
});
}
]);
Tinytest.addAsync(
'mongo-livedata - both stub and server promise throw exceptions when client errors',
async function (test) {
const promise = Meteor.callAsync('methodThrowException');
if (Meteor.isClient) {
try {
await promise.stubPromise;
} catch (err) {
test.equal(err.error, 'Throw on client');
}
try {
await promise.serverPromise;
} catch (err) {
test.equal(err.error, 'Throw on client');
}
}
},
);