Skip to content

Commit 5e93b06

Browse files
committed
Create processedEvents.json file if it doesn't exist
Signed-off-by: patilsach022 <patilsach022@gmail.com>
1 parent 65f8eaa commit 5e93b06

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

app.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ async function joinRoomOnInvite(member, count) {
108108
const retrievedEvents = chunk.filter((message) => message.type === 'm.room.message');
109109
// eslint-disable-next-line max-len
110110
if (retrievedEvents.length) {
111-
const readdata = fs.readFileSync('processedEvents.json', (err) => {
111+
const readdata = fs.readFileSync('processedEvents.json', {flag:'a+'}, (err) => {
112112
if (err) throw err;
113113
});
114114
// eslint-disable-next-line max-len
@@ -223,7 +223,7 @@ client.on('Room.timeline', async (event, room) => {
223223
if (event.getType() === 'm.room.message' && event.getSender() !== client.credentials.userId) {
224224
console.log('Recieved message:', event.getContent().body);
225225
const rmId = event.getRoomId();
226-
const readdata = fs.readFileSync('processedEvents.json', (err) => {
226+
const readdata = fs.readFileSync('processedEvents.json', {flag:'a+'}, (err) => {
227227
if (err) throw err;
228228
});
229229
if (readdata.length > 0 && JSON.parse(readdata)[`${rmId}-lastProcessedEventTS`] >= event.getTs()) {

0 commit comments

Comments
 (0)