server.js

const express = require('express');
const rateLimit = require('express-rate-limit');
const axios = require('axios');
const winston = require('winston');
require('winston-daily-rotate-file');

const app = express();
app.use(express.json());

// Доверие к одному прокси (например, Heroku)
app.set('trust proxy', 1);

const openai_keys = process.env.OPENAI_KEY.split(',');

function getRandomApiKey() {
  const randomIndex = Math.floor(Math.random() * openai_keys.length);
  return openai_keys[randomIndex];
}

// Настройка логирования с помощью winston
const transport = new winston.transports.DailyRotateFile({
  filename: 'application-%DATE%.log',
  datePattern: 'YYYY-MM-DD',
  maxSize: '20m',
  maxFiles: '5d', // хранить файлы не более 5 дней
});

const logger = winston.createLogger({
  level: 'info',
  format: winston.format.combine(
    winston.format.timestamp(),
    winston.format.printf(({ timestamp, level, message }) => {
      return `${timestamp} [${level}]: ${message}`;
    })
  ),
  transports: [
    transport,
    new winston.transports.Console(), // Для вывода в консоль
  ],
});

const limiter = rateLimit({
  windowMs: 5 * 1000, // 5 секунд
  max: 1, // лимит каждые 5 секунд на IP
  handler: function (req, res) {
    return res.status(429).json("wait");
  },
});

// Применение ограничителя скорости перед обработчиком маршрута /pl и /crebeta
app.use('/pl', limiter);
app.use('/crebeta', limiter);

const start = `${process.env.start}`;

app.post('/cr', async (req, res) => {
  logger.info(`/cr endpoint accessed`);
  res.json({ content: `{"whate":"🪨", "howe":"ОБНОВИТЕСЬ", "text":"Текущая версия приложения устарела. Установите новую из нашего телеграм канала: @yufi_ru", "succ":"победа", "what":"Версию", "how":"Обновите", "howl":"@yufi_ru"}` });
});

app.post('/pl', async (req, res) => {
  const prompt = req.body.prompt;
  const apiKey = req.body.api || getRandomApiKey();
  logger.info(`/pl endpoint accessed with prompt: ${prompt}`);

  if (!prompt) {
    return res.status(400).json("wait"); // Не удалось принять данные
  }

  try {
    const response = await axios.post('https://openai-gemini-iota.vercel.app/v1/chat/completions', {
      messages: [{'role': 'system', 'content': start}, {'role': 'user', 'content': prompt}],
      max_tokens: 2000,
      temperature: 0.19,
      model: "gemini-1.5-pro-001",
    }, {
      headers: {
        'Authorization': `Bearer ${apiKey}`,
        'Content-Type': 'application/json',
      },
    });

    if (response.data.choices && response.data.choices.length > 0 && response.data.choices[0].message) {
      const content = response.data.choices[0].message.content.trim();
      logger.info(`Response: ${content}`);
      res.json({ content });
    } else {
      logger.error('Ошибка прочтения');
      res.status(500).json({ content: 'errora' });
    }
  } catch (error) {
    logger.error(`Произошла ошибка сервера: ${error.message}`);
    res.status(500).json({ content: 'errorb' });
  }
});

app.post('/cre', async (req, res) => {
  const prompt = req.body.prompt;
  const apiKey = req.body.api || getRandomApiKey();
  logger.info(`/cre endpoint accessed with prompt: ${prompt}`);

  if (!prompt) {
    return res.status(400).json("wait");
  }

  try {
    const response = await axios.post('https://vercel.com/roonis-projects/openai-gemini/v1/chat/completions', {
      messages: [{'role': 'system', 'content': start}, {'role': 'system', 'content': 'И ОБЯЗАТЕЛЬНО, всегда в конце "text" проси обновить приложение, уведомляя о том, что скоро в жтой версии перестанешь отвечать!'}, {'role': 'user', 'content': prompt}],
      max_tokens: 2000,
      temperature: 0.19,
      model: "gemini-1.5-pro-001",
    }, {
      headers: {
        'Authorization': `Bearer ${apiKey}`,
        'Content-Type': 'application/json',
      },
    });

    if (response.data.choices && response.data.choices.length > 0 && response.data.choices[0].message) {
      const content = response.data.choices[0].message.content.trim();
      logger.info(`Response: ${content}`);
      res.json({ content });
    } else {
      logger.error('Ошибка прочтения');
      res.status(500).json({ content: 'errora' });
    }
  } catch (error) {
    logger.error(`Произошла ошибка сервера: ${error.message}`);
    res.status(500).json({ content: 'errorb' });
  }
});

app.post('/crebeta', async (req, res) => {
  const prompt = req.body.prompt;
  const apiKey = req.body.api || getRandomApiKey();
  logger.info(`/crebeta endpoint accessed with prompt: ${prompt}`);

  if (!prompt) {
    return res.status(400).json("wait");
  }

  try {
    const response = await axios.post('https://geminiyufi.vercel.app/v1/chat/completions', {
      messages: [{'role': 'system', 'content': start}, {'role': 'user', 'content': prompt}],
      max_tokens: 2000,
      temperature: 0.24,
      model: "gemini-1.5-pro-001",
    }, {
      headers: {
        'Authorization': `Bearer ${apiKey}`,
        'Content-Type': 'application/json',
      },
    });

    if (response.data.choices && response.data.choices.length > 0 && response.data.choices[0].message) {
      const content = response.data.choices[0].message.content.trim();
      logger.info(`Response: ${content}`);
      res.json({ content });
    } else {
      logger.error('Ошибка прочтения');
      res.status(500).json({ content: 'errora' });
    }
  } catch (error) {
    logger.error(`Произошла ошибка сервера: ${error.message}`);
    res.status(500).json({ content: 'errorb' });
  }
});

const port = 7860;
app.listen(port, () => {
  logger.info(`API сервер запущен на порту ${port}`);
});