Method processKeyword

keyword/keyword.ts:160–226

(message: Api.Message)

    return text;
  }

  async processKeyword(message: Api.Message): Promise<void> {
    try {
      const text = this.replaceReply(message);
      const client = await getGlobalClient();

      let sentMsg: Api.Message | null = null;
      try {
        const sendOptions: any = {
          message: text,
          parseMode: "html",
        };

        if (this.reply && message.id) {
          sendOptions.replyTo = message.id;
        }

        sentMsg = await client.sendMessage(message.peerId, sendOptions);

        const cmd = await getCommandFromMessage(text);

        if (cmd && sentMsg)
          await dealCommandPluginWithMessage({ cmd, msg: sentMsg });
      } catch (error) {
        console.error("Reply message error:", error);
      }

      if (this.delete) {
        try {
          if (this.source_delay_delete > 0) {
            const sourceTimer = setTimeout(async () => {
              pendingDeleteTimers.delete(sourceTimer);
              try {
                await client.deleteMessages(message.peerId, [message.id], {
                  revoke: true,
                });
              } catch (error) {
                console.error("Delayed delete message error:", error);
              }
            }, this.source_delay_delete * 1000);
            pendingDeleteTimers.add(sourceTimer);
          } else {
            await client.deleteMessages(message.peerId, [message.id], {
              revoke: true,
            });
          }
        } catch (error) {
          console.error("Delete message error:", error);
        }
      }

      if (this.delay_delete > 0 && sentMsg) {
        const replyTimer = setTimeout(async () => {
          pendingDeleteTimers.delete(replyTimer);
          try {
            await client.deleteMessages(message.peerId, [sentMsg!.id], {
              revoke: true,