Update index.js

index.js

@@ -1,250 +1,83 @@
 const express = require('express');
 const bodyParser = require('body-parser');
-const app = express();
 const axios = require('axios');
 const { DateTime, Duration } = require('luxon');
-const { format } = require("util")
-const port = 7860;
-app.use(bodyParser.json());
-
-function textToBase64(text) {
-  return Buffer.from(text).toString('base64');
-}
-
-// Fungsi untuk mengembalikan teks dari Base64
-function base64ToText(base64) {
-  return Buffer.from(base64, 'base64').toString('utf-8');
-}
-
+const { format } = require("util");
+const puppeteer = require("puppeteer");
 const { GoogleGenerativeAI } = require("@google/generative-ai");
-const genAI = new GoogleGenerativeAI(base64ToText("QUl6YVN5QXdTbndWaVdkUmZhS1ozQVVsaUtnQnFZczlLbUZqOWEw"));
-
-const chatHistory = {};
-
-const generateRandomString = (length) => {
-	const characters = 'abcdefghijklmnopqrstuvwxyz0123456789';
-	let result = '';
-	for (let i = 0; i < length; i++) {
-		result += characters.charAt(Math.floor(Math.random() * characters.length));
-	}
-	return result;
-};
-
-const generateRandomIP = () => {
-	const octet = () => Math.floor(Math.random() * 256);
-	return `${octet()}.${octet()}.${octet()}.${octet()}`;
-};
-
-async function createNewChat() {
-	try {
-		const randomUserId = generateRandomString(17);
-		const randomIP = generateRandomIP();
-
-		const response = await axios.post('https://chat.chatgptdemo.net/new_chat', {
-			user_id: randomUserId
-		}, {
-			headers: {
-				'Content-Type': 'application/json',
-				'User-Agent': 'Mozilla/5.0 (iPhone14,3; U; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/602.1.50 (KHTML, like Gecko) Version/10.0 Mobile/19A346 Safari/602.1',
-				'X-Forwarded-For': randomIP
-			}
-		});
+const GPT4js = require('gpt4js');
 
-		return response.data.id_;
-	} catch (error) {
-		console.error(error);
-		return false;
-	}
-}
+const app = express();
+const port = 7860;
 
-async function updateChatName(id, chatName) {
-	try {
-		const response = await axios.post('https://chat.chatgptdemo.net/update_chat_name', {
-			chat_id: id,
-			chat_name: chatName
-		}, {
-			headers: {
-				'Content-Type': 'application/json',
-				'User-Agent': 'Mozilla/5.0 (iPhone14,3; U; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/602.1.50 (KHTML, like Gecko) Version/10.0 Mobile/19A346 Safari/602.1',
-				'X-Forwarded-For': generateRandomIP()
-			}
-		});
-	} catch (error) {
-		console.error(error);
-	}
-}
+app.use(bodyParser.json());
 
-async function sendMessage(question, id, retry) {
-	try {
-		const response = await axios.post('https://chat.chatgptdemo.net/chat_api_stream', {
-			question: question,
-			chat_id: id,
-			timestamp: Date.now(),
-			retry: retry
-		}, {
-			headers: {
-				'Content-Type': 'application/json',
-				'User-Agent': 'Mozilla/5.0 (iPhone14,3; U; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/602.1.50 (KHTML, like Gecko) Version/10.0 Mobile/19A346 Safari/602.1',
-				'X-Forwarded-For': generateRandomIP()
-			}
-		});
-		return response.data;
-	} catch (error) {
-		console.error(error);
-	}
-}
 
-async function updateMessages(id, message) {
-	const url = 'https://chat.chatgptdemo.net/update_messages';
-	const data = {
-		chat_id: id,
-		bot_response: message,
-		timestamp: Date.now(),
-	};
 
-	try {
-		const response = await axios.post(url, data, {
-			headers: {
-				'Content-Type': 'application/json',
-				'User-Agent': 'Mozilla/5.0 (iPhone14,3; U; CPU iPhone OS 15_0 like Mac OS X) AppleWebKit/602.1.50 (KHTML, like Gecko) Version/10.0 Mobile/19A346 Safari/602.1',
-				'X-Forwarded-For': generateRandomIP()
-			}
-		});
 
-		return response.data;
-	} catch (error) {
-		console.error(error);
-	}
+// Fungsi untuk mengonversi teks menjadi Base64
+function convertTextToBase64(text) {
+  return Buffer.from(text).toString('base64');
 }
 
-
-async function cleanInactiveUsers() {
-  const currentTime = DateTime.local();
-
-  Object.keys(chatHistory).forEach((userId) => {
-    const user = chatHistory[userId];
-
-    if (user && user.lastChat && user.lastChat.plus(Duration.fromObject({ minutes: 20 })) < currentTime) {
-      // User's last message was more than 10 minutes ago, remove the user from chatHistory
-      delete chatHistory[userId];
-    }
-  });
-
-  // Schedule the next execution after 1 minute
-  setTimeout(cleanInactiveUsers, 180000);
+// Fungsi untuk mengembalikan teks dari Base64
+function convertBase64ToText(base64) {
+  return Buffer.from(base64, 'base64').toString('utf-8');
 }
 
-// Start the continuous execution of cleanInactiveUsers
-cleanInactiveUsers();
-
-
-
-
-app.get('/send', async (req, res) => {
-	try {
-	const { id, message } = req.query;
-	if(!id)return res.status(400).json({ success: false, response: "input param id & input id user"});
-	if(!message)return res.status(400).json({ success: false, response: "input param message & input a message from user"});
-	if (!chatHistory[id]) {
-		const newid = await createNewChat();
-		await updateChatName(newid, 'you are AI chat gpt-3.5-turbo who will help me and will always answer with cute kaomoji like this (⁠≧⁠▽⁠≦⁠), always answer me cutely like loli in anime');
-		chatHistory[id] = {
-			lastChat: DateTime.local(),
-			chat_id: newid,
-			message: [],
-		};
-	}
-	const role = 'user';
-	chatHistory[id].message.push({ role, message });
-	chatHistory[id].lastChat = DateTime.local();
-	id_room = chatHistory[id].chat_id
-	const botResponse = await sendMessage(message, id_room, false);
-	const regex = /"content":"(.*?)"/g;
-	let matches;
-	let contents = '';
-	while ((matches = regex.exec(botResponse)) !== null) {
-		if (typeof matches[1] !== 'undefined') {
-			contents += matches[1];
-		}
-	}
-	chatHistory[id].message.push({ role: 'Assistant', message: contents });
-	chatHistory[id].lastChat = DateTime.local();
-	await updateMessages(id_room, contents);
-	res.status(200).json({ success: true, response: contents });
-	} catch (e) {
-	res.status(400).json({ success: false, response: format(e) });
-	}
-});
-
-app.get('/listuser', (req, res) => {
-  const userList = Object.keys(chatHistory);
-  res.status(200).json({ userList });
-});
-
-app.get('/get/message', (req, res) => {
-  const id = req.query.id;
-  if(!id)return res.status(400).json({ success: false, response: "input id"});
-  if (!chatHistory[id]) {
-    return res.status(404).json({ error: 'User not found' });
-  }
-  const userMessages = chatHistory[id].message;
-  const userRoom = chatHistory[id].chat_id;
-  res.status(200).json({ id, messages: userMessages });
-});
-
-
+// Inisialisasi GoogleGenerativeAI
+const genAI = new GoogleGenerativeAI(convertBase64ToText("QUl6YVN5RGFVX1dTWlduWXF4ZG9fclJhbktCM0Z0elMtQTg2dzUw"));
 
+// Data sesi chat untuk versi 2
+const db_chatSessions = {};
 
-
-
-
-
-const db_chatHistory = {};
-
+// Fungsi untuk menghasilkan UID
 function generateUID(length) {
   const characters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
-  const charactersLength = characters.length;
   let uid = '';
   for (let i = 0; i < length; i++) {
-    uid += characters.charAt(Math.floor(Math.random() * charactersLength));
+    uid += characters.charAt(Math.floor(Math.random() * characters.length));
   }
   return uid;
 }
 
-async function sendMessageV2(data_chat, msg) {
+// Fungsi untuk mengirim pesan versi 2
+async function sendChatMessageV2(data_chat, msg) {
   try {
-    const model = genAI.getGenerativeModel({ model: "gemini-pro"});
-    
-    const chat = model.startChat(data_chat)
+    const model = genAI.getGenerativeModel({ model: "gemini-1.5-flash" });
+
+    const chat = model.startChat(data_chat);
     const result = await chat.sendMessage(msg);
     const response = await result.response;
-	const text = response.text();
-	
+    const text = response.text();
+
     return text;
   } catch (error) {
     console.error(error);
   }
 }
 
-async function cleanInactiveUsersV2() {
+// Fungsi untuk membersihkan pengguna tidak aktif versi 2
+async function clearInactiveUsersV2() {
   const currentTime = DateTime.local();
 
-  Object.keys(db_chatHistory).forEach((userId) => {
-    const user = db_chatHistory[userId];
+  Object.keys(db_chatSessions).forEach((userId) => {
+    const user = db_chatSessions[userId];
 
     if (user && user.lastChat && user.lastChat.plus(Duration.fromObject({ minutes: 20 })) < currentTime) {
-      // User's last message was more than 10 minutes ago, remove the user from db_chatHistory
-      delete db_chatHistory[userId];
+      // Hapus pengguna yang tidak aktif lebih dari 20 menit dari db_chatSessions
+      delete db_chatSessions[userId];
     }
   });
 
-  // Schedule the next execution after 1 minute
-  setTimeout(cleanInactiveUsersV2, 180000);
+  // Jadwalkan eksekusi berikutnya setelah 3 menit
+  setTimeout(clearInactiveUsersV2, 180000);
 }
 
-// Start the continuous execution of cleanInactiveUsers
-cleanInactiveUsersV2();
+// Mulai eksekusi terus-menerus untuk membersihkan pengguna tidak aktif
+clearInactiveUsersV2();
 
+// Endpoint untuk mengirim pesan versi 2
 app.get('/v2/send', async (req, res) => {
   try {
     const { id, message } = req.query;
@@ -255,31 +88,31 @@ app.get('/v2/send', async (req, res) => {
       });
     }
 
-    let chatData = db_chatHistory[id];
+    let chatData = db_chatSessions[id];
 
     if (!chatData) {
       // Jika data riwayat obrolan tidak ada, buat data baru
       chatData = {
         lastChat: DateTime.local(),
         data: {
-		    history: [
-		      {
-		        role: "user",
-		        parts: "hello, can you answer my question with a cute kaomoji like this ｡⁠◕⁠‿⁠◕⁠｡"
-		      },
-		      {
-		        role: "model",
-		        parts: "sure (⁠◠⁠‿⁠◕⁠) , so.... (⁠ ⁠/⁠^⁠ω⁠^⁠)⁠/⁠♪⁠♪ how can I help dear user (⁠ ⁠╹⁠▽⁠╹⁠ ⁠)?",
-		      },
-		    ],
-		    generationConfig: {
+          history: [
+            {
+              role: "user",
+              parts: "hello, can you answer my question with a cute kaomoji like this ｡⁠◕⁠‿⁠◕⁠｡"
+            },
+            {
+              role: "model",
+              parts: "sure (⁠◠⁠‿⁠◕⁠) , so.... (⁠ ⁠/⁠^⁠ω⁠^⁠)⁠/⁠♪⁠♪ how can I help dear user (⁠ ⁠╹⁠▽⁠╹⁠ ⁠)?",
+            },
+          ],
+          generationConfig: {
             maxOutputTokens: 500,
           },
         }
-      }
+      };
     }
-    
-    const botResponse = await sendMessageV2(chatData.data, message);
+
+    const botResponse = await sendChatMessageV2(chatData.data, message);
 
     // Simpan pesan user ke riwayat obrolan
     chatData.data.history.push({
@@ -288,12 +121,12 @@ app.get('/v2/send', async (req, res) => {
     });
     // Simpan bot response ke riwayat obrolan
     chatData.data.history.push({
-    	role: 'model',
-        parts: botResponse
+      role: 'model',
+      parts: botResponse
     });
     // Update waktu terakhir obrolan
     chatData.lastChat = DateTime.local();
-    db_chatHistory[id] = chatData;
+    db_chatSessions[id] = chatData;
     res.status(200).json({
       success: true,
       response: botResponse
@@ -306,23 +139,47 @@ app.get('/v2/send', async (req, res) => {
   }
 });
 
-
+// Endpoint untuk daftar pengguna versi 2
 app.get('/v2/listuser', (req, res) => {
-  const userList = Object.keys(db_chatHistory);
+  const userList = Object.keys(db_chatSessions);
   res.status(200).json({ userList });
 });
 
+// Endpoint untuk mendapatkan pesan versi 2
 app.get('/v2/get/message', (req, res) => {
   const id = req.query.id;
   if (!id) return res.status(400).json({ success: false, response: "input id" });
-  if (!db_chatHistory[id]) {
+  if (!db_chatSessions[id]) {
     return res.status(404).json({ error: 'User not found' });
   }
-  const userMessages = db_chatHistory[id].data.history;
+  const userMessages = db_chatSessions[id].data.history;
   res.status(200).json({ messages: userMessages });
 });
 
+// Fungsi untuk ping website
+async function pingWebsite() {
+  const browser = await puppeteer.launch({
+    headless: true,
+    args: ['--no-sandbox', '--disable-setuid-sandbox']
+  });
+  const page = await browser.newPage();
+  await page.setUserAgent("Mozilla/5.0 (Linux; Android 10; SM-G965U Build/QP1A.190711.020; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/114.0.5735.141 Mobile Safari/537.36 [FB_IAB/FB4A;FBAV/420.0.0.32.61;]");
+  await page.goto('https://huggingface.co/spaces/Nexchan/gptdemo');
+  console.log("Ping");
+  await browser.close();
+}
+
+// Ping website setiap 5 jam
+async function pingEvery5Hours() {
+  await pingWebsite();
+  setInterval(async () => {
+    await pingWebsite();
+  }, 5 * 60 * 60 * 1000); // 5 jam dalam milidetik
+}
+
+// Mulai ping
+pingEvery5Hours();
 
 app.listen(port, () => {
-	console.log(`Server is running on port ${port}`);
-});
+  console.log(`Server is running on port ${port}`);
+});