Update index.js

index.js

@@ -1,4 +1,3 @@
-
 const express = require('express');
 const { spawn } = require('child_process');
 const { Chess } = require('chess.js');
@@ -7,69 +6,95 @@ const app = express();
 const PORT = process.env.PORT || 7860;
 const STOCKFISH_PATH = '/usr/games/stockfish';
 
-let engine;
-let isEngineBusy = false;
-const requestQueue = [];
-let currentRequestResolver = null;
+let mesin;
+let isMesinSibuk = false;
+const antrianRequest = [];
+let resolverRequestSekarang = null;
+let analisisSekarang = { score: null, bestMove: null };
 
 app.use(express.json());
 
-function initializeEngine() {
+function klasifikasiLangkah(rugiCentipawn) {
+    if (rugiCentipawn <= 15) return 'Terbaik';
+    if (rugiCentipawn <= 50) return 'Luar Biasa';
+    if (rugiCentipawn <= 100) return 'Bagus';
+    if (rugiCentipawn <= 200) return 'Kurang Akurat';
+    if (rugiCentipawn <= 350) return 'Kesalahan';
+    return 'Blunder';
+}
+
+function siapkanMesin() {
     return new Promise((resolve, reject) => {
         try {
-            engine = spawn(STOCKFISH_PATH);
+            mesin = spawn(STOCKFISH_PATH);
         } catch (error) {
-            return reject(new Error(`Failed to spawn Stockfish. Make sure the binary is at '${STOCKFISH_PATH}' and has execute permissions. Details: ${error.message}`));
+            return reject(new Error(`Gagal menjalankan Stockfish. Pastikan file ada di '${STOCKFISH_PATH}' dan bisa dieksekusi. Detail: ${error.message}`));
         }
 
-        const startupTimeout = setTimeout(() => {
-            reject(new Error('Stockfish startup timed out. The engine failed to send "readyok".'));
+        const waktuTungguStartup = setTimeout(() => {
+            reject(new Error('Waktu startup Stockfish habis. Mesin gagal mengirim "readyok".'));
         }, 10000);
 
-        engine.on('error', (err) => {
-            clearTimeout(startupTimeout);
-            reject(new Error(`Failed to start Stockfish process: ${err.message}`));
+        mesin.on('error', (err) => {
+            clearTimeout(waktuTungguStartup);
+            reject(new Error(`Gagal memulai proses Stockfish: ${err.message}`));
         });
 
-        engine.on('close', (code) => {
-            console.error(`Stockfish process exited with code ${code}. The application will now exit.`);
+        mesin.on('close', (code) => {
+            console.error(`Proses Stockfish berhenti dengan kode ${code}. Aplikasi akan ditutup.`);
             process.exit(1);
         });
         
-        engine.stderr.on('data', (data) => {
-            console.error(`Stockfish stderr: ${data.toString()}`);
+        mesin.stderr.on('data', (data) => {
+            console.error(`Pesan error dari Stockfish: ${data.toString()}`);
         });
 
-        engine.stdout.on('data', (data) => {
+        mesin.stdout.on('data', (data) => {
             const output = data.toString();
-
             if (output.includes('readyok')) {
-                console.log('Stockfish engine is ready.');
-                clearTimeout(startupTimeout);
+                console.log('Mesin Stockfish sudah siap.');
+                clearTimeout(waktuTungguStartup);
                 
-                engine.stdout.removeAllListeners('data');
+                mesin.stdout.removeAllListeners('data');
                 
-                engine.stdout.on('data', (data) => {
-                    const lines = data.toString().split('\n');
-                    for (const line of lines) {
-                        if (line.startsWith('bestmove')) {
-                            const parts = line.split(' ');
-                            const bestMove = parts[1];
-
-                            if (currentRequestResolver) {
-                                if (!bestMove || bestMove === '(none)') {
-                                    currentRequestResolver.reject(new Error('No valid move found'));
+                mesin.stdout.on('data', (data) => {
+                    const baris = data.toString().split('\n');
+                    for (const teks of baris) {
+                        if (teks.startsWith('info') && teks.includes('score')) {
+                            const bagian = teks.split(' ');
+                            const indeksSkor = bagian.indexOf('score');
+                            if (indeksSkor !== -1) {
+                                const tipeSkor = bagian[indeksSkor + 1];
+                                const nilaiSkor = parseInt(bagian[indeksSkor + 2], 10);
+                                if (tipeSkor === 'cp') {
+                                    analisisSekarang.score = nilaiSkor;
+                                } else if (tipeSkor === 'mate') {
+                                    analisisSekarang.score = (nilaiSkor > 0 ? 20000 - nilaiSkor : -20000 - nilaiSkor);
+                                }
+                            }
+                        }
+
+                        if (teks.startsWith('bestmove')) {
+                            const bagian = teks.split(' ');
+                            const langkahTerbaik = bagian[1];
+                            analisisSekarang.bestMove = langkahTerbaik;
+
+                            if (resolverRequestSekarang) {
+                                if (!langkahTerbaik || langkahTerbaik === '(none)') {
+                                    resolverRequestSekarang.reject(new Error('Tidak ditemukan langkah yang valid'));
                                 } else {
-                                    const from = bestMove.slice(0, 2);
-                                    const to = bestMove.slice(2, 4);
-                                    const promotion = bestMove.length === 5 ? bestMove[4] : null;
-                                    currentRequestResolver.resolve({ bestMove, from, to, promotion });
+                                    const dari = langkahTerbaik.slice(0, 2);
+                                    const ke = langkahTerbaik.slice(2, 4);
+                                    const promosi = langkahTerbaik.length === 5 ? langkahTerbaik[4] : null;
+                                    resolverRequestSekarang.resolve({ 
+                                        bestMove: langkahTerbaik, dari, ke, promosi, score: analisisSekarang.score 
+                                    });
                                 }
                             }
                             
-                            isEngineBusy = false;
-                            currentRequestResolver = null;
-                            processQueue();
+                            isMesinSibuk = false;
+                            resolverRequestSekarang = null;
+                            prosesAntrian();
                             return;
                         }
                     }
@@ -79,51 +104,41 @@ function initializeEngine() {
             }
         });
 
-        engine.stdin.write('uci\n');
-        engine.stdin.write('isready\n');
+        mesin.stdin.write('uci\n');
+        mesin.stdin.write('isready\n');
     });
 }
 
-function processQueue() {
-    if (isEngineBusy || requestQueue.length === 0) {
+function prosesAntrian() {
+    if (isMesinSibuk || antrianRequest.length === 0) {
         return;
     }
-
-    isEngineBusy = true;
-    const request = requestQueue.shift();
-    currentRequestResolver = request;
-
-    const moveTimeout = setTimeout(() => {
-        if (currentRequestResolver === request) {
-            request.reject(new Error('Engine move calculation timed out'));
-            isEngineBusy = false;
-            currentRequestResolver = null;
-            processQueue();
+    isMesinSibuk = true;
+    const request = antrianRequest.shift();
+    resolverRequestSekarang = request;
+    analisisSekarang = { score: null, bestMove: null };
+
+    const batasWaktuLangkah = setTimeout(() => {
+        if (resolverRequestSekarang === request) {
+            request.reject(new Error('Waktu kalkulasi langkah oleh mesin habis'));
+            isMesinSibuk = false;
+            resolverRequestSekarang = null;
+            prosesAntrian();
         }
     }, 15000);
 
-    request.resolve = (value) => {
-        clearTimeout(moveTimeout);
-        request.originalResolve(value);
-    };
-
-    request.reject = (reason) => {
-        clearTimeout(moveTimeout);
-        request.originalReject(reason);
-    };
+    request.resolve = (value) => { clearTimeout(batasWaktuLangkah); request.originalResolve(value); };
+    request.reject = (reason) => { clearTimeout(batasWaktuLangkah); request.originalReject(reason); };
 
-    engine.stdin.write(`position fen ${request.fen}\n`);
-    engine.stdin.write('go movetime 2000\n');
+    mesin.stdin.write(`position fen ${request.fen}\n`);
+    // Waktu mikir mesin per langkah (dalam milidetik)
+    mesin.stdin.write('go movetime 1000\n');
 }
 
-function getBestMoveFromEngine(fen) {
+function dapatkanAnalisisDariMesin(fen) {
     return new Promise((resolve, reject) => {
-        requestQueue.push({
-            fen,
-            originalResolve: resolve,
-            originalReject: reject,
-        });
-        processQueue();
+        antrianRequest.push({ fen, originalResolve: resolve, originalReject: reject });
+        prosesAntrian();
     });
 }
 
@@ -131,86 +146,94 @@ app.use((req, res, next) => {
     res.setHeader('Access-Control-Allow-Origin', '*');
     res.setHeader('Access-Control-Allow-Methods', 'GET, POST, OPTIONS');
     res.setHeader('Access-Control-Allow-Headers', 'Content-Type');
-    if (req.method === 'OPTIONS') {
-        return res.sendStatus(204);
-    }
+    if (req.method === 'OPTIONS') { return res.sendStatus(204); }
     next();
 });
 
 app.get('/', (req, res) => {
     const baseUrl = `${req.protocol}://${req.get('host')}`;
+
     const doc = `
-STOCKFISH CHESS API DOCUMENTATION
-=================================
+DOKUMENTASI API CATUR STOCKFISH
+===============================
 
-This API provides access to the Stockfish chess engine for getting the best move and analyzing games.
+API ini menyediakan akses ke mesin catur Stockfish untuk mendapatkan langkah terbaik dan menganalisis permainan lengkap dengan klasifikasi langkah.
 
 ---------------------------------
 ENDPOINT: GET /chessbot
 ---------------------------------
-Calculates the best move for a given FEN position.
+Memberikan analisis lengkap untuk satu posisi FEN, termasuk langkah terbaik dan evaluasi skor dari mesin.
 
-METHOD: GET
+METODE: GET
 
 URL: ${baseUrl}/chessbot
 
-QUERY PARAMETERS:
-- fen (string, required): The FEN string of the chess position.
+PARAMETER QUERY:
+- fen (string, wajib): String FEN dari posisi catur.
 
-EXAMPLE REQUEST:
+CONTOH REQUEST:
 GET ${baseUrl}/chessbot?fen=rnbqkbnr/pppp1ppp/8/4p3/4P3/8/PPPP1PPP/RNBQKBNR w KQkq - 0 2
 
-EXAMPLE RESPONSE (SUCCESS):
+CONTOH RESPON (SUKSES):
 {
     "bestMove": "g1f3",
     "from": "g1",
     "to": "f3",
-    "promotion": null
+    "promotion": null,
+    "score": 35 
 }
+// Catatan: Skor dalam satuan centipawn dari sudut pandang Putih.
+// Nilai positif menguntungkan Putih, nilai negatif menguntungkan Hitam.
 
-EXAMPLE RESPONSE (ERROR):
+CONTOH RESPON (ERROR):
 {
-    "error": "missing fen"
+    "error": "FEN tidak ditemukan"
 }
 
 ---------------------------------
 ENDPOINT: POST /analisis
 ---------------------------------
-Analyzes a full game from a PGN string. It compares the move played in the game with the best move suggested by the engine for each position.
+Menganalisis permainan lengkap dari string PGN. Endpoint ini memberikan **respons streaming** (langsung dikirim per bagian) menggunakan Server-Sent Events (SSE). Analisis setiap langkah dikirim sebagai potongan data terpisah segera setelah siap.
 
-METHOD: POST
+METODE: POST
 
 URL: ${baseUrl}/analisis
 
-REQUEST BODY:
+BODY REQUEST:
 - Content-Type: application/json
-- Body: { "pgn": "<Your-PGN-String>" }
+- Body: { "pgn": "<String-PGN-Anda>" }
 
-EXAMPLE PAYLOAD:
+CONTOH PAYLOAD:
 {
-    "pgn": "[Event \\"Live Chess\\"]\\n[Site \\"Chess.com\\"]\\n[Date \\"2025.09.28\\"]\\n[Round \\"?\\"]\\n[White \\"Puru-Jawa\\"]\\n[Black \\"saahil905\\"]\\n[Result \\"1-0\\"]\\n\\n1. e4 Nc6 2. Nf3 f6 3. e5 Nxe5 4. Qe2 b5 5. Nxe5 fxe5 6. Qxe5 d6 7. Qxb5+ Qd7 8. d3 c6 9. Qa4 Bb7 10. Nc3 c5 11. Be3 Bc6 12. Qh4 Qb7 13. b3 Bxg2 14. Bxg2 Qxg2 15. Ke2 h6 16. Rhg1 g5 17. Qa4+ 1-0"
+    "pgn": "[Event \\"Live Chess\\"]\\n1. e4 Nc6 2. Nf3 f6 3. e5"
 }
 
-EXAMPLE RESPONSE (SUCCESS):
-[
-    {
-        "moveNumber": "1.",
-        "playedMove": "e4",
-        "bestMove": "e4",
-        "fenBeforeMove": "rnbqkbnr/pppppppp/8/8/8/8/PPPPPPPP/RNBQKBNR w KQkq - 0 1"
-    },
-    {
-        "moveNumber": "1...",
-        "playedMove": "Nc6",
-        "bestMove": "e5",
-        "fenBeforeMove": "rnbqkbnr/pppppppp/8/8/4P3/8/PPPP1PPP/RNBQKBNR b KQkq - 0 1"
-    },
-    ... (and so on for every move in the PGN)
-]
-
-EXAMPLE RESPONSE (ERROR):
+--- FORMAT RESPON STREAMING ---
+Server akan mengirim serangkaian event. Klien Anda harus mendengarkan event 'data'.
+
+CONTOH RESPON STREAMING (SUKSES):
+// Setiap baris 'data' adalah objek JSON terpisah yang dikirim server satu per satu.
+
+data: {"moveNumber":"1.","playedMove":"e4","bestMove":"e4","fenBeforeMove":"rnbqkbnr/pppppppp/8/8/8/8/PPPPPPPP/RNBQKBNR w KQkq - 0 1","classification":"Terbaik","centipawnLoss":0}
+
+data: {"moveNumber":"1...","playedMove":"Nc6","bestMove":"e5","fenBeforeMove":"rnbqkbnr/pppppppp/8/8/4P3/8/PPPP1PPP/RNBQKBNR b KQkq - 0 1","classification":"Kurang Akurat","centipawnLoss":78}
+
+data: {"moveNumber":"2.","playedMove":"Nf3","bestMove":"Nf3","fenBeforeMove":"r1bqkbnr/pppppppp/2n5/8/4P3/8/PPPP1PPP/RNBQKBNR w KQkq - 1 2","classification":"Luar Biasa","centipawnLoss":25}
+
+data: {"moveNumber":"2...","playedMove":"f6","bestMove":"d5","fenBeforeMove":"r1bqkbnr/pppppppp/2n5/8/4P3/5N2/PPPP1PPP/RNBQKB1R b KQkq - 0 2","classification":"Blunder","centipawnLoss":412}
+
+data: {"moveNumber":"3.","playedMove":"e5","bestMove":"d4","fenBeforeMove":"r1bqkbnr/pppp2pp/2n2p2/4P3/8/5N2/PPPP1PPP/RNBQKB1R w KQkq - 0 3","classification":"Kesalahan","centipawnLoss":280}
+
+// Setelah langkah terakhir dianalisis, server akan mengirim event 'end'.
+event: end
+data: {"message":"Analisis selesai"}
+
+// Catatan: Jika terjadi error di tengah jalan, event 'error' akan dikirim beserta detailnya.
+
+CONTOH RESPON (ERROR VALIDASI AWAL):
 {
-    "error": "Invalid PGN provided"
+    "error": "Format PGN tidak valid",
+    "details": "Invalid PGN"
 }
     `;
     res.setHeader('Content-Type', 'text/plain');
@@ -219,13 +242,10 @@ EXAMPLE RESPONSE (ERROR):
 
 app.get('/chessbot', async (req, res) => {
     const fen = req.query.fen;
-    if (!fen) {
-        return res.status(400).json({ error: 'missing fen' });
-    }
-
+    if (!fen) { return res.status(400).json({ error: 'FEN tidak ditemukan' }); }
     try {
-        const move = await getBestMoveFromEngine(fen);
-        res.json(move);
+        const analisis = await dapatkanAnalisisDariMesin(fen);
+        res.json(analisis);
     } catch (e) {
         res.status(500).json({ error: e.message });
     }
@@ -233,74 +253,84 @@ app.get('/chessbot', async (req, res) => {
 
 app.post('/analisis', async (req, res) => {
     const { pgn } = req.body;
-    if (!pgn) {
-        return res.status(400).json({ error: 'missing pgn in request body' });
-    }
+    if (!pgn) { return res.status(400).json({ error: 'PGN tidak ditemukan di body request' }); }
 
-    const chess = new Chess();
+    const catur = new Chess();
     try {
-        if (typeof chess.loadPgn === 'function') {
-            chess.loadPgn(pgn);
-        } else {
-            chess.load_pgn(pgn);
-        }
+        catur.loadPgn(pgn.replace(/\\n/g, '\n'));
     } catch (e) {
-        return res.status(400).json({ error: 'Invalid PGN provided', details: e.message });
+        return res.status(400).json({ error: 'Format PGN tidak valid', details: e.message });
     }
 
-    const history = chess.history({ verbose: true });
-    if (history.length === 0) {
-        return res.status(400).json({ error: 'PGN contains no valid moves' });
-    }
+    const riwayat = catur.history({ verbose: true });
+    if (riwayat.length === 0) { return res.status(400).json({ error: 'PGN tidak berisi langkah yang valid' }); }
+
+    res.setHeader('Content-Type', 'text/event-stream');
+    res.setHeader('Cache-Control', 'no-cache');
+    res.setHeader('Connection', 'keep-alive');
+    res.flushHeaders();
 
-    const analysisResults = [];
+    const game = new Chess();
     try {
-        const game = new Chess();
-        for (const move of history) {
-            const fenBeforeMove = game.fen();
-            const engineResponse = await getBestMoveFromEngine(fenBeforeMove);
+        for (const langkah of riwayat) {
+            const fenSebelum = game.fen();
+            const giliran = game.turn();
             
-            let bestMoveSan = engineResponse.bestMove;
-            try {
-                const tempGame = new Chess(fenBeforeMove);
-                const moveResult = tempGame.move({
-                    from: engineResponse.from,
-                    to: engineResponse.to,
-                    promotion: engineResponse.promotion
-                });
-                if (moveResult) {
-                    bestMoveSan = moveResult.san;
-                }
-            } catch (e) {
-                // Ignore conversion error, use UCI move
-            }
+            const analisisSebelum = await dapatkanAnalisisDariMesin(fenSebelum);
+            let skorSebelum = analisisSebelum.score;
+            if (giliran === 'b') { skorSebelum = -skorSebelum; }
+            
+            game.move(langkah.san);
+            const fenSesudah = game.fen();
+
+            const analisisSesudah = await dapatkanAnalisisDariMesin(fenSesudah);
+            let skorSesudah = analisisSesudah.score;
+            if (giliran === 'b') { skorSesudah = -skorSesudah; }
 
-            analysisResults.push({
-                moveNumber: `${game.moveNumber()}${game.turn() === 'w' ? '.' : '...'}`,
-                playedMove: move.san,
-                bestMove: bestMoveSan,
-                fenBeforeMove: fenBeforeMove,
-            });
-            game.move(move.san);
+            const rugiCentipawn = Math.round(skorSebelum - skorSesudah);
+            const klasifikasi = klasifikasiLangkah(rugiCentipawn);
+
+            let sanLangkahTerbaik = analisisSebelum.bestMove;
+            try {
+                const gameSementara = new Chess(fenSebelum);
+                const hasilLangkah = gameSementara.move({ from: analisisSebelum.from, to: analisisSebelum.to, promotion: analisisSebelum.promotion });
+                if (hasilLangkah) { sanLangkahTerbaik = hasilLangkah.san; }
+            } catch (e) { /* Abaikan error konversi notasi */ }
+
+            const hasil = {
+                moveNumber: `${game.moveNumber() - (giliran === 'b' ? 0 : 1)}${giliran === 'w' ? '.' : '...'}`,
+                playedMove: langkah.san,
+                bestMove: sanLangkahTerbaik,
+                fenBeforeMove: fenSebelum,
+                classification: klasifikasi,
+                centipawnLoss: rugiCentipawn < 0 ? 0 : rugiCentipawn,
+            };
+
+            res.write(`data: ${JSON.stringify(hasil)}\n\n`);
         }
-        res.json(analysisResults);
+
+        res.write('event: end\ndata: {"message":"Analisis selesai"}\n\n');
+        res.end();
+
     } catch (e) {
-        res.status(500).json({ error: 'Analysis failed', details: e.message });
+        const payloadError = { error: 'Analisis gagal', details: e.message };
+        res.write(`event: error\ndata: ${JSON.stringify(payloadError)}\n\n`);
+        res.end();
     }
 });
 
-async function startServer() {
+async function jalankanServer() {
     try {
-        console.log('Initializing Stockfish engine...');
-        await initializeEngine();
+        console.log('Lagi nyiapin mesin Stockfish...');
+        await siapkanMesin();
         app.listen(PORT, () => {
-            console.log(`Server is running on port ${PORT}`);
-            console.log(`API documentation available at http://localhost:${PORT}/`);
+            console.log(`Server jalan di port ${PORT}`);
+            console.log(`Dokumentasi API bisa dibuka di http://localhost:${PORT}/`);
         });
     } catch (error) {
-        console.error('Failed to start the application:', error.message);
+        console.error('Gagal memulai aplikasi:', error.message);
         process.exit(1);
     }
 }
 
-startServer();
+jalankanServer();