Class KeywordPlugin

keyword/keyword.ts:837–879

    try {
      if (db && typeof db.close === "function") {
        db.close();
        db = null as any;
      }
    } catch (error) {
      console.error("Failed to close keyword DB:", error);
      db = null as any;
    }
  }

  description: string = `关键词回复管理`;
  cmdHandlers: Record<string, (msg: Api.Message) => Promise<void>> = {
    keyword,
  };
  listenMessageHandler?: ((msg: Api.Message) => Promise<void>) | undefined =
    async (message) => {
      try {
        const text =
          message.message ||
          (message.media && "caption" in message.media
            ? String(message.media.caption || "")
            : "");
        if (!text) {
          return;
        }

        if (message.out) {
          return;
        }

        await keywordTasks.checkAndReply(message);
      } catch (error) {
        console.error("Process keyword message error:", error);
      }
    };
}

export default new KeywordPlugin();

export async function processKeywordMessage(
  message: Api.Message
): Promise<void> {
  try {
    const text =
      message.message ||
      (message.media && "caption" in message.media
        ? String(message.media.caption || "")