Untitled
unknown
plain_text
2 years ago
1.7 kB
8
Indexable
private async checkAndAddAnswerToQueue(user: UserModel, message: string) {
const commandMessage = await this.commandsHandler.checkMessageForCommand(user, message);
if (typeof commandMessage === "string") {
return this.messagesQueueHandler.enqueue(commandMessage);
}
const triggerMessage = await this.triggersHandler.checkMessageForTrigger(message);
if (triggerMessage) {
this.messagesQueueHandler.enqueue(triggerMessage);
}
}
// private async chceckAndSendAnswer(user: UserModel, message: string) {
// // const commandMessage = await this.commandsHandler.checkMessageForCommand(user, message);
// // if (commandMessage) {
// // if (typeof commandMessage === "string") {
// // console.log("commands disabled for now");
// // }
// // return;
// // }
// //either check for timer / trigger / random message
// const messagesQueue = (
// await Promise.all([
// this.triggersHandler.checkMessageForTrigger(message),
// this.timersHandler.checkMessageForTimer(user)
// ])
// ).filter((x) => x) as string[];
// this.sendMessagesFromQueue(messagesQueue);
// }
// private sendMessagesFromQueue(messages: string[]) {
// const { min, max } = this.configs.headConfigs.delayBetweenMessages;
// messages.forEach((msgInQue, index) => {
// const delay = (index + 1) * Math.floor(Math.random() * (max - min + 1) + min);
// headLogger.info(`Send message ${msgInQue} in ${delay}ms`);
// setTimeout(() => {
// this.kickHandler.sendMessage(msgInQue);
// headLogger.info(`Sending msg ${msgInQue}`);
// }, delay);
// });
// }Editor is loading...