Upload cai.js

cai.js

@@ -0,0 +1,101 @@
+const express = require('express');
+const CharacterAI = require('node_characterai');
+const app = express();
+const PORT = 7860;
+
+const DEFAULT_TOKEN = process.env['TOKEN']; // ganti dengan token default Anda
+
+let sessions = [];
+
+const createSession = async (token) => {
+    const existingSession = sessions.find(v => v.token == token && v.expires > Date.now());
+    if (existingSession) {
+        return existingSession;
+    } else {
+        // Hapus sesi kadaluarsa
+        await cleanExpiredSessions();
+
+        const characterAI = new CharacterAI();
+        await characterAI.authenticateWithToken(token);
+        const session = {
+            token,
+            characterAI,
+            expires: Date.now() + 3600000, // 1 jam
+            browser: characterAI.browser // Simpan instance browser
+        };
+        sessions.push(session);
+        return session;
+    }
+};
+
+const getSession = async (token) => {
+    let session = sessions.find(s => s.token === token);
+    if (session && session.expires > Date.now()) {
+        return session;
+    } else {
+        // Hapus sesi kadaluarsa
+        await cleanExpiredSessions();
+        return await createSession(token);
+    }
+};
+
+const cleanExpiredSessions = async () => {
+    const now = Date.now();
+    const expiredSessions = sessions.filter(session => session.expires <= now);
+
+    // Tutup browser dari sesi yang kedaluwarsa
+    for (const session of expiredSessions) {
+        if (session.browser && session.browser.close) {
+            await session.browser.close();
+        }
+    }
+
+    // Hapus sesi yang kadaluarsa dari array sessions
+    sessions = sessions.filter(session => session.expires > now);
+};
+
+// Jalankan pembersihan sesi kadaluarsa setiap 10 menit
+setInterval(cleanExpiredSessions, 10 * 60 * 1000);
+
+app.use(express.json());
+
+app.post('/chat', async (req, res) => {
+    const { token, message, characterId, externalId } = req.body;
+
+    try {
+        const session = token ? await getSession(token) : await createSession(DEFAULT_TOKEN);
+        const chat = await session.characterAI.createOrContinueChat(characterId, externalId);
+        const response = await chat.sendAndAwaitResponse(message, true);
+        res.json({ response: response.text });
+    } catch (error) {
+        res.status(500).json({ error: error.message });
+    }
+});
+
+app.get('/search', async (req, res) => {
+    const { name, token } = req.query;
+
+    try {
+        const session = token ? await getSession(token) : await createSession(DEFAULT_TOKEN);
+        const characters = await session.characterAI.searchCharacters(name);
+        res.json({ characters });
+    } catch (error) {
+        res.status(500).json({ error: error.message });
+    }
+});
+
+app.get('/character', async (req, res) => {
+    const { characterId, token } = req.query;
+
+    try {
+        const session = token ? await getSession(token) : await createSession(DEFAULT_TOKEN);
+        const characterInfo = await session.characterAI.fetchCharacterInfo(characterId);
+        res.json({ characterInfo });
+    } catch (error) {
+        res.status(500).json({ error: error.message });
+    }
+});
+
+app.listen(PORT, () => {
+    console.log(`Server running on port ${PORT}`);
+});