PrivateCoffee/element-web
4
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 3

make receiveMessage more robust by checking first if the message is not already in the timeline

Browse source
This commit is contained in:
Bruno Windels 2018-09-13 12:04:18 +02:00
parent 239e6a4bce
commit 9f4cf776c5
1 changed files with 32 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
src/usecases/timeline.js
View file

@ -46,23 +46,38 @@ module.exports.receiveMessage = async function(session, expectedMessage) {
session.log.step(`receives message "${expectedMessage.body}" from ${expectedMessage.sender}`);
// wait for a response to come in that contains the message
// crude, but effective
await session.page.waitForResponse(async (response) => {
if (response.request().url().indexOf("/sync") === -1) {
return false;
}
const body = await response.text();
if (expectedMessage.encrypted) {
return body.indexOf(expectedMessage.sender) !== -1 &&
body.indexOf("m.room.encrypted") !== -1;
} else {
return body.indexOf(expectedMessage.body) !== -1;
}
});
// wait a bit for the incoming event to be rendered
await session.delay(1000);
const lastTile = await getLastEventTile(session);
const foundMessage = await getMessageFromEventTile(lastTile);
assertMessage(foundMessage, expectedMessage);
async function assertLastMessage() {
const lastTile = await getLastEventTile(session);
const lastMessage = await getMessageFromEventTile(lastTile);
await assertMessage(lastMessage, expectedMessage);
}
// first try to see if the message is already the last message in the timeline
let isExpectedMessage = false;
try {
assertLastMessage();
isExpectedMessage = true;
} catch(ex) {}
if (!isExpectedMessage) {
await session.page.waitForResponse(async (response) => {
if (response.request().url().indexOf("/sync") === -1) {
return false;
}
const body = await response.text();
if (expectedMessage.encrypted) {
return body.indexOf(expectedMessage.sender) !== -1 &&
body.indexOf("m.room.encrypted") !== -1;
} else {
return body.indexOf(expectedMessage.body) !== -1;
}
});
// wait a bit for the incoming event to be rendered
await session.delay(1000);
await assertLastMessage();
}
session.log.done();
}