File size: 3,393 Bytes
f7e1fa7 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 |
/**
* @author D-Jukie
* @warn Do not edit code or edit credits
* @src Disme Project
* @bug fixed by @YanMaglinte
*/
module.exports = function ({ api, Threads }) {
const logger = require("../../utils/log.js");
return async function ({ event }) {
const { threadID, logMessageType, logMessageData } = event;
const { setData, getData, delData } = Threads;
try {
let dataThread = (await getData(threadID)).threadInfo;
switch (logMessageType) {
case "log:thread-admins": {
if (logMessageData.ADMIN_EVENT == "add_admin") {
dataThread.adminIDs.push({
id: logMessageData.TARGET_ID
})
} else if (logMessageData.ADMIN_EVENT == "remove_admin") {
dataThread.adminIDs = dataThread.adminIDs.filter(item => item.id != logMessageData.TARGET_ID);
}
logger.log('Refresh the list of admins in the group ' + threadID, 'UPDATE DATA')
await setData(threadID, { threadInfo: dataThread });
break;
}
case "log:thread-name": {
logger.log('Update name in group ' + threadID, 'UPDATE DATA')
dataThread.threadName = event.logMessageData.name
await setData(threadID, { threadInfo: dataThread });
break;
}
case "log:subscribe": {
if (event.logMessageData.addedParticipants.some(i => i.userFbId == api.getCurrentUserID())) return
for(let i of event.logMessageData.addedParticipants) {
dataThread.participantIDs.push(i.userFbId)
}
var data = await Threads.setData(event.threadID, {threadInfo: dataThread})
logger.log('Perform more group data ' + threadID, 'ADD DATA')
break;
}
case 'log:unsubscribe': {
if (logMessageData.leftParticipantFbId == api.getCurrentUserID()) {
logger.log('Perform group data deletion ' + threadID, 'DELETE DATA')
const index = global.data.allThreadID.findIndex(item => item == threadID);
global.data.allThreadID.splice(index, 1);
await delData(threadID);
return
} else {
const index = dataThread.participantIDs.findIndex(item => item == logMessageData.leftParticipantFbId);
dataThread.participantIDs.splice(index, 1);
if (dataThread.adminIDs.find(i => i.id == logMessageData.leftParticipantFbId)) {
dataThread.adminIDs = dataThread.adminIDs.filter(item => item.id != logMessageData.leftParticipantFbId);
}
logger.log('Perform user deletion ' + logMessageData.leftParticipantFbId, 'DELETE DATA')
await setData(threadID, { threadInfo: dataThread });
}
break;
}
}
} catch (e) {
console.log('There was an error updating data: ' + e)
}
return;
};
} |