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

the result message is out of order

Browse Source
This commit is contained in:
Leonardo Venturini
2024-11-01 11:39:29 -04:00
parent 4954976d9d
commit 855cfa712a
1 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
packages/ddp-client/test/livedata_tests.js
View File

@@ -1234,19 +1234,21 @@ if (Meteor.isClient) {
});
let insertId;
let resultId
try {
for (let i = 0; i < 100; i++) {
for (let i = 0; i < 250; i++) {
messages = [];
insertId = await Meteor.callAsync(`insert-${collName}`);
await Meteor.sleep(1)
const hasResult = messages.some(msg => msg.msg === 'result');
resultId = messages.find(msg => msg.msg === 'result').id;
const hasAdded = messages.some(msg => msg.msg === 'added');
const hasUpdated = messages.some(msg =>
msg.msg === 'updated' && msg.methods?.includes(messages[0].id)
msg.msg === 'updated' && msg.methods?.includes(resultId)
);
test.isTrue(hasResult, `Iteration ${i}: Should receive RESULT message for insert`);
@@ -1257,12 +1259,13 @@ if (Meteor.isClient) {
await Meteor.callAsync(`update-${collName}`, insertId);
await Meteor.sleep(1)
const hasUpdateResult = messages.some(msg => msg.msg === 'result');
resultId = messages.find(msg => msg.msg === 'result').id;
const hasChanged = messages.some(msg => msg.msg === 'changed');
const hasUpdateUpdated = messages.some(msg =>
msg.msg === 'updated' && msg.methods?.includes(messages[0].id)
msg.msg === 'updated' && msg.methods?.includes(resultId)
);
test.isTrue(hasUpdateResult, `Iteration ${i}: Should receive RESULT message for update`);
@@ -1273,12 +1276,13 @@ if (Meteor.isClient) {
await Meteor.callAsync(`remove-${collName}`, insertId);
await Meteor.sleep(1)
const hasRemoveResult = messages.some(msg => msg.msg === 'result');
resultId = messages.find(msg => msg.msg === 'result').id;
const hasRemoved = messages.some(msg => msg.msg === 'removed');
const hasRemoveUpdated = messages.some(msg =>
msg.msg === 'updated' && msg.methods?.includes(messages[0].id)
msg.msg === 'updated' && msg.methods?.includes(resultId)
);
test.isTrue(hasRemoveResult, `Iteration ${i}: Should receive RESULT message for remove`);