Update server.js

server.js

@@ -16,14 +16,14 @@ function getRandomApiKey() {
 }
 
 const limiter = rateLimit({
-  windowMs: 60 * 1000, // 5 секунд
-  max: 15, // лимит каждые 5 секунд на IP
+  windowMs: 60 * 1000, // 60 секунд
+  max: 15, // лимит каждые 60 секунд на IP
   handler: function (req, res) {
-    return res.status(429).json("wait");
+    return res.status(429).json({ content: "wait" });
   },
 });
 
-// Применение ограничителя скорости перед обработчиком маршрута /pl и /crebeta
+// Применение ограничителя скорости перед обработчиком маршрута /pl и /plbeta
 app.use('/pl', limiter);
 app.use('/plbeta', limiter);
 
@@ -34,52 +34,77 @@ app.post('/update', async (req, res) => {
   res.json({ content: `{"error":"", "title":"Требуется обновление", "text":"Текущая версия приложения устарела. Установите новую из нашего телеграм канала: @yufi_ru", "okb":"Обновить", "oklink":"https://t.me/yufi_ru", "cancelable":"false"}` });
 });
 
-app.post('/pl', async (req, res) => {
-  const prompt = req.body.prompt;
- // const apiKey = req.body.api || getRandomApiKey();
-
-  let prs;  // Объявление переменной prs перед использованием
-
-  if (req.body.mode === "1") {
-    prs = start;
-  } else {
-    prs = startconnect;
-  }
-
-  if (!prompt) {
-    return res.status(400).json("wait"); // Не удалось принять данные
-  }
+async function sendRequest(prompt, prs) {
+  const firstUrl = 'https://text.pollinations.ai/openai';
+  const secondUrl = 'https://text.pollinations.ai/qwen-coder';
 
   try {
-    const response = await axios.post('https://text.pollinations.ai/openai', { //https://openai-gemini-iota.vercel.app/v1/chat/completions
+    const response = await axios.post(firstUrl, {
       messages: [{'role': 'system', 'content': prs}, {'role': 'user', 'content': prompt}],
-      max_tokens: 2000,
+      max_tokens: 1200,
       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();
-      res.json({ content });
+      return response.data.choices[0].message.content.trim();
     } else {
-      res.json({ content: `{"error":"", "title":"Ошибка", "text":"Произошла ошибка на сервере. (Ошибка прочтения)", "okb":"Ок", "oklink":"", "cancelable":"true"}` });
+      throw new Error("Ошибка прочтения на первой ссылке");
+    }
+  } catch (error) {
+    console.error("Первая попытка не удалась:", error);
+    // Попытка с другой ссылкой
+    try {
+      const response = await axios.post(secondUrl, {
+        messages: [{'role': 'system', 'content': prs}, {'role': 'user', 'content': prompt}],
+        max_tokens: 1200,
+        temperature: 0.19,
+      }, {
+        headers: {
+          'Content-Type': 'application/json',
+        },
+      });
+
+      if (response.data.choices && response.data.choices.length > 0 && response.data.choices[0].message) {
+        return response.data.choices[0].message.content.trim();
+      } else {
+        throw new Error("Ошибка прочтения на второй ссылке");
+      }
+    } catch (secondError) {
+      console.error("Вторая попытка не удалась:", secondError);
+      throw new Error("Ошибка при генерации");
     }
+  }
+}
+
+app.post('/pl', async (req, res) => {
+  const prompt = req.body.prompt;
+  let prs;
+
+  if (req.body.mode === "1") {
+    prs = start;
+  } else {
+    prs = startconnect;
+  }
+
+  if (!prompt) {
+    return res.status(400).json({ content: "wait" }); // Не удалось принять данные
+  }
+
+  try {
+    const content = await sendRequest(prompt, prs);
+    res.json({ content });
   } catch (error) {
-    console.error(error);
-    res.json({ content: `{"error":"", "title":"Ошибка", "text":"Произошла ошибка на сервере. (Ошибка при генерации)", "okb":"Ок", "oklink":"", "cancelable":"true"}` });
+    res.json({ content: `{"error":"", "title":"Ошибка", "text":"Произошла ошибка на сервере. (${error.message})", "okb":"Ок", "oklink":"", "cancelable":"true"}` });
   }
 });
 
 app.post('/plbeta', async (req, res) => {
   const prompt = req.body.prompt;
-  //const apiKey = req.body.api || getRandomApiKey();
-
-  let prs;  // Объявление переменной prs перед использованием
+  let prs;
 
   if (req.body.mode === "1") {
     prs = start;
@@ -88,37 +113,19 @@ app.post('/plbeta', async (req, res) => {
   }
 
   if (!prompt) {
-    return res.status(400).json("wait"); // Не удалось принять данные
+    return res.status(400).json({ content: "wait" }); // Не удалось принять данные
   }
 
   try {
-    const response = await axios.post('https://text.pollinations.ai/openai', { //https://openai-gemini-iota.vercel.app/v1/chat/completions
-      messages: [{'role': 'system', 'content': prs}, {'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();
-      console.log(`\n---\nПользователь: ${prompt}\n    Ответ:\n      ${content}`);
-      res.json({ content });
-    } else {
-      res.json({ content: `{"error":"", "title":"Ошибка", "text":"Произошла ошибка на сервере. (Ошибка прочтения)", "okb":"Ок", "oklink":"", "cancelable":"true"}` });
-    }
+    const content = await sendRequest(prompt, prs);
+    console.log(`\n---\nПользователь: ${prompt}\n    Ответ:\n      ${content}`);
+    res.json({ content });
   } catch (error) {
-    console.error(error);
-    res.json({ content: `{"error":"", "title":"Ошибка", "text":"Произошла ошибка на сервере. (Ошибка при генерации)", "okb":"Ок", "oklink":"", "cancelable":"true"}` });
+    res.json({ content: `{"error":"", "title":"Ошибка", "text":"Произошла ошибка на сервере. (${error.message})", "okb":"Ок", "oklink":"", "cancelable":"true"}` });
   }
 });
 
-
 const port = 7860;
 app.listen(port, () => {
   console.log(`API сервер запущен на порту ${port}`);
-});
+});