WhatsApp demo чат-бот с GPT на JS#

const bot = new WhatsappGptBot({
    idInstance: process.env.INSTANCE_ID || "",
    apiTokenInstance: process.env.INSTANCE_TOKEN || "",
    openaiApiKey: process.env.OPENAI_API_KEY || "",
    model: "gpt-4o",
    systemMessage: "Всегда отвечай на языке, на котором пишет пользователь...",
    maxHistoryLength: 15,
    temperature: 0.5,
    handlersFirst: true,
    clearWebhookQueueOnStart: true,
});

class EnhancedImageHandler extends ImageMessageHandler {
    async processMessage(message: Message, openai: OpenAI, model: OpenAIModel): Promise<any> {
        const result = await super.processMessage(message, openai, model);

        if (typeof result === "string") {
            return result.replace(
                "[The user sent an image",
                "[Пользователь отправил изображение. Скажите ему, что вы не та модель..."
            );
        }

        return result;
    }
}

// Регистрация пользовательского обработчика
bot.replaceHandler(ImageMessageHandler, new EnhancedImageHandler());

const loggingMessageMiddleware: ProcessMessageMiddleware = async (
    message, messageContent, messages, _
) => {
    console.log(`[${new Date().toISOString()}] Пользователь (${message.chatId}): `,
        typeof messageContent === "string"
            ? messageContent
            : JSON.stringify(messageContent));

    return {messageContent, messages};
};

bot.addMessageMiddleware(loggingMessageMiddleware);

const timeContextMiddleware: ProcessMessageMiddleware = async (
    _, messageContent, messages, __
) => {
    const systemIndex = messages.findIndex(m => m.role === "system");
    if (systemIndex >= 0 && typeof messages[systemIndex].content === "string") {
        const now = new Date();
        const timeContext = `Текущее время: ${now.toLocaleString()}`;

        // Добавление или обновление контекста времени в системном сообщении
        // ...
    }

    return {messageContent, messages};
};

bot.addMessageMiddleware(timeContextMiddleware);

const moderationMiddleware: ProcessMessageMiddleware = async (
    _, messageContent, messages, __
) => {
    const sensitiveKeywords = [
        "stupid", "bad", "awful",
    ];

    if (typeof messageContent === "string") {
        // Проверка на наличие чувствительных ключевых слов и их пометка при необходимости
        // ...
    }

    return {messageContent, messages};
};

bot.addMessageMiddleware(moderationMiddleware);

const signatureMiddleware: ProcessResponseMiddleware = async (
    response, messages, _
) => {
    const signature = "— GREEN-API WhatsApp GPT бот";

    // Добавление подписи к ответам
    // ...

    return {
        response: enhancedResponse,
        messages
    };
};

bot.addResponseMiddleware(signatureMiddleware);

bot.onText("/help", async (message, _) => {
    const helpText = `*Демо-бот WhatsAppGPT*

Доступные команды:
- /help - Показать это сообщение помощи
- /clear - Очистить историю разговора
- /mode [professional|casual|creative] - Изменить стиль ответов
- /weather [местоположение] - Получить информацию о погоде (демо)
...`;

    await bot.sendText(message.chatId, helpText);
});

bot.onText("/clear", async (message, session) => {
    // Сохранить только системное сообщение
    if (session.stateData && session.stateData.messages) {
        const systemMessage = session.stateData.messages.find(m => m.role === "system");
        session.stateData.messages = systemMessage ? [systemMessage] : [];
        await bot.sendText(message.chatId, "✓ История разговора очищена!");
    } else {
        await bot.sendText(message.chatId, "Нет истории разговора для очистки.");
    }
});

bot.onRegex(/^\/mode\s+(professional|casual)$/i, async (message, session) => {
    // Извлечение режима из команды
    // ...

    // Обновление системной подсказки в зависимости от выбранного режима
    // ...

    await bot.sendText(message.chatId, `Режим переключен на стиль *${mode}*! 🎭`);
});

bot.onRegex(/^\/weather\s+(.+)$/i, async (message, _) => {
    // Извлечение местоположения из команды
    // ...

    // Имитация вызова API погоды
    // ...

    await bot.sendText(
        message.chatId,
        `*Погода для ${weather.location}*\n` +
        // Форматирование данных о погоде
        // ...
    );
});

bot.onType("location", async (message, _) => {
    if (!message.location) return;

    // Извлечение данных о местоположении
    // ...

    // Имитация ближайших мест
    // ...

    await bot.sendText(message.chatId, response);
});

bot.onType("document", async (message, _) => {
    if (!message.media) return;

    const fileName = message.media.fileName || "неизвестный файл";

    await bot.sendText(
        message.chatId,
        `Я получил ваш документ: "${fileName}"\n\n_Примечание: Это демонстрация..._`
    );
    return true;
});

console.log("Запуск демо-бота WhatsApp GPT...");
bot.start().then(() => {
    console.log("Бот успешно запущен!");
}).catch(error => {
    console.error("Не удалось запустить бота:", error);
});

process.on("SIGINT", () => {
    console.log("Остановка бота...");
    bot.stop();
    process.exit(0);
});

bot.onText("/mycommand", async (message, session) => {
    // Ваша логика команды здесь
    await bot.sendText(message.chatId, "Ответ на мою команду");
});

const myMiddleware: ProcessMessageMiddleware = async (
    message, messageContent, messages, sessionData
) => {
    // Ваша логика промежуточного ПО здесь
    return {messageContent, messages};
};

bot.addMessageMiddleware(myMiddleware);

class MyCustomHandler implements MessageHandler {
    canHandle(message: Message): boolean {
        // Определите, может ли этот обработчик обработать сообщение
        return message.type === "my-custom-type";
    }

    async processMessage(message: Message): Promise<any> {
        // Обработка сообщения
        return "Обработанный контент";
    }
}

bot.registerMessageHandler(new MyCustomHandler());