Untitled

mail@pastecode.io avatarunknown
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);
  //   });
  // }