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

Merge pull request #13052 from meteor/350-persist-local-doc-temporary

Browse Source 
[3.0] Report and extend test cases for the new async behaviors
This commit is contained in:
Nacho Codoñer
2024-03-21 15:20:49 +01:00
committed by GitHub
parent ad0a63b4c8 615ae2c974
commit 3e439dfd3a
1 changed files with 173 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

190
packages/mongo/mongo_livedata_tests.js
View File

@@ -4276,32 +4276,188 @@ if (Meteor.isServer) {
});
}
Tinytest.addAsync('mongo-livedata - maintained isomorphism using resolverType config for both client and server', async function(test, expect) {
const Collection = new Mongo.Collection(`resolver_type${test.runId()}`, { resolverType: 'stub' });
Tinytest.addAsync(
'mongo-livedata - maintained isomorphism on collection operations for both client and server',
async function (test) {
const Collection = new Mongo.Collection(
`maintained_col_op_iso${test.runId()}`,
{ resolverType: 'stub' }
);
await Collection.insertAsync({ _id: 'a' });
await Collection.insertAsync({ _id: 'b' });
await Collection.insertAsync({ _id: 'a' });
await Collection.insertAsync({ _id: 'b' });
let items = await Collection.find().fetchAsync();
let itemIds = items.map(_item => _item._id);
let items = await Collection.find().fetchAsync();
let itemIds = items.map(_item => _item._id);
test.equal(itemIds, ['a', 'b']);
test.equal(itemIds, ['a', 'b']);
await Collection.updateAsync({ _id: 'a' }, { $set: { num: 1 } });
await Collection.updateAsync({ _id: 'b' }, { $set: { num: 2 } });
await Collection.updateAsync({ _id: 'a' }, { $set: { num: 1 } });
await Collection.updateAsync({ _id: 'b' }, { $set: { num: 2 } });
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item.num);
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item.num);
test.equal(itemIds, [1, 2]);
test.equal(itemIds, [1, 2]);
await Collection.removeAsync({ _id: 'a' });
await Collection.removeAsync({ _id: 'b' });
await Collection.removeAsync({ _id: 'a' });
await Collection.removeAsync({ _id: 'b' });
items = await Collection.find().fetchAsync();
items = await Collection.find().fetchAsync();
test.equal(items, []);
});
test.equal(items, []);
},
);
testAsyncMulti(
'mongo-livedata - collection async operations data persistence',
[
async function (test) {
// Using remote collection
const Collection = new Mongo.Collection(
`remoteop_persistence${test.runId()}`,
{
resolverType: Meteor.isClient ? 'stub' : 'server',
},
);
await Collection.insertAsync({ _id: 'a' });
await Collection.updateAsync({ _id: 'a' }, { $set: { num: 1 } });
const insertedId = await Collection.insertAsync({ num: 2 });
let items = await Collection.find().fetchAsync();
let itemIds = items.map(_item => _item._id);
test.equal(itemIds, ['a', insertedId]); // temporary data accessible
const aItem = items[0];
const insertedItem = items[1];
test.equal(aItem?.num, 1);
test.equal(insertedItem?.num, 2);
await Collection.removeAsync({ _id: insertedId });
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item._id);
test.equal(itemIds, ['a']); // temporary data accessible
if (Meteor.isClient) {
return new Promise(resolve => {
Meteor.setTimeout(async () => {
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item._id);
test.equal(itemIds, []); // data IS NOT persisted
resolve();
}, 100);
});
}
return Promise.resolve();
},
async function (test) {
// Using local collection
const Collection = new Mongo.Collection(
`localop_persistence${test.runId()}`,
);
await Collection._collection.insertAsync({ _id: 'a' });
await Collection._collection.updateAsync(
{ _id: 'a' },
{ $set: { num: 1 } },
);
const insertedId = await Collection._collection.insertAsync({ num: 2 });
let items = await Collection.find().fetchAsync();
let itemIds = items.map(_item => _item._id);
test.equal(itemIds, ['a', insertedId]); // temporary data accessible
const aItem = items[0];
const insertedItem = items[1];
test.equal(aItem?.num, 1);
test.equal(insertedItem?.num, 2);
await Collection._collection.removeAsync({ _id: insertedId });
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item._id);
test.equal(itemIds, ['a']); // temporary data accessible
if (Meteor.isClient) {
return new Promise(resolve => {
Meteor.setTimeout(async () => {
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item._id);
test.equal(itemIds, ['a']); // data is persisted
resolve();
}, 100);
});
}
return Promise.resolve();
},
async function (test) {
// Using methods
const Collection = new Mongo.Collection(
`methodop_persistence${test.runId()}`,
);
Collection.allow({
insertAsync() {
return true;
},
insert() {
return true;
},
});
Meteor.methods({
[`insertMethodPersistence${test.runId()}`]: async () => {
await Collection.insertAsync({ _id: 'a' });
},
});
const promise = Meteor.callAsync(
`insertMethodPersistence${test.runId()}`,
);
let items;
let itemIds;
if (Meteor.isServer) {
await promise;
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item._id);
test.equal(itemIds, ['a']); // temporary data accessible
}
if (Meteor.isClient) {
await promise.stubPromise;
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item._id);
test.equal(itemIds, ['a']); // temporary data accessible
try {
await promise.serverPromise;
} catch (e) {
// error as no insert method enabled on server
return new Promise(resolve => {
Meteor.setTimeout(async () => {
items = await Collection.find().fetchAsync();
itemIds = items.map(_item => _item._id);
test.equal(itemIds, []); // data IS NOT persisted
resolve();
}, 100);
});
}
} else {
return Promise.resolve();
}
},
],
);
testAsyncMulti("mongo-livedata - support observeChangesAsync and observeAsync to keep isomorphism on client and server", [
async (test) => {