Untitled
plain_text
2 months ago
1.7 kB
1
Indexable
Never
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); // }); // }