server.js

const fastify = require('fastify')({ logger: true });
const path = require('path');
const fs = require('fs');
const initSqlJs = require('sql.js');

// Register plugins
fastify.register(require('@fastify/cors'));
fastify.register(require('@fastify/static'), {
  root: path.join(__dirname, 'public'),
});

let dbMessages, dbTodos;

// Initialize database
async function initDB() {
  const SQL = await initSqlJs();
  const messageDbFile = 'chat.db';
  const todoDbFile = 'todo.db';

  // Messages Database
  if (fs.existsSync(messageDbFile)) {
    const filebuffer = fs.readFileSync(messageDbFile);
    dbMessages = new SQL.Database(filebuffer);
  } else {
    dbMessages = new SQL.Database();
    dbMessages.run(`
      CREATE TABLE messages (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        sender TEXT NOT NULL,
        message TEXT NOT NULL,
        timestamp DATETIME DEFAULT CURRENT_TIMESTAMP
      )
    `);
    fs.writeFileSync(messageDbFile, Buffer.from(dbMessages.export()));
  }

  // Todos Database
  if (fs.existsSync(todoDbFile)) {
    const filebuffer = fs.readFileSync(todoDbFile);
    dbTodos = new SQL.Database(filebuffer);
  } else {
    dbTodos = new SQL.Database();
    dbTodos.run(`
      CREATE TABLE todos (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        task TEXT NOT NULL,
        status TEXT DEFAULT 'pending'
      )
    `);
    fs.writeFileSync(todoDbFile, Buffer.from(dbTodos.export()));
  }
}

// Helper function to save database
function saveDatabase(db, fileName) {
  const data = db.export();
  fs.writeFileSync(fileName, Buffer.from(data));
}

// Routes for Chat Messages
fastify.get('/api/messages', (req, reply) => {
    const result = dbMessages.exec('SELECT * FROM messages ORDER BY timestamp ASC');
    reply.send(result[0] ? result[0].values.map(row => ({
        id: row[0],
        sender: row[1],
        message: row[2],
        timestamp: new Date(row[3]).toISOString()  // Pastikan timestamp dalam format ISO
    })) : []);
});

fastify.post('/api/messages', (req, reply) => {
  const { sender, message } = req.body;

  dbMessages.run('INSERT INTO messages (sender, message) VALUES (?, ?)', [sender, message]);
  saveDatabase(dbMessages, 'chat.db');

  if (message.startsWith('!')) {
    handleCommand(message, reply); // Proses command
    return;
  }

  reply.send({ success: true, response: 'Ketikkan !help untuk informasi semua fitur.' });
});

fastify.delete('/api/messages', (req, reply) => {
  dbMessages.run('DELETE FROM messages');
  saveDatabase(dbMessages, 'chat.db');
  reply.send({ success: true });
});

// Routes for Todo List
fastify.get('/api/todos', (req, reply) => {
  const result = dbTodos.exec('SELECT * FROM todos');
  reply.send(result[0] ? result[0].values.map(row => ({
    id: row[0],
    task: row[1],
    status: row[2]
  })) : []);
});

fastify.post('/api/todos', (req, reply) => {
  const { task } = req.body;
  dbTodos.run('INSERT INTO todos (task) VALUES (?)', [task]);
  saveDatabase(dbTodos, 'todo.db');
  reply.send({ success: true, message: 'Todo berhasil ditambahkan.' });
});

fastify.put('/api/todos/:id', (req, reply) => {
  const { id } = req.params;
  const { status } = req.body;
  dbTodos.run('UPDATE todos SET status = ? WHERE id = ?', [status, id]);
  saveDatabase(dbTodos, 'todo.db');
  reply.send({ success: true, message: 'Status todo berhasil diperbarui.' });
});

fastify.delete('/api/todos/:id', (req, reply) => {
  const { id } = req.params;
  dbTodos.run('DELETE FROM todos WHERE id = ?', [id]);
  saveDatabase(dbTodos, 'todo.db');
  reply.send({ success: true, message: 'Todo berhasil dihapus.' });
});

// Handle commands
function handleCommand(message, reply) {
  const args = message.slice(1).trim().split(' ');
  const command = args.shift().toLowerCase();

  switch (command) {
    case 'help':
      reply.send({
        response: `<b>Daftar perintah:</b><br>!help - Menampilkan bantuan<br>!addtodo [task] - Tambahkan todo baru<br>!listtodo - Lihat daftar todo<br>!donetodo [id] - Tandai todo selesai<br>!deltodo [id] - Hapus todo`
      });
      break;
    case 'addtodo':
      const task = args.join(' ');
      if (!task) {
        reply.send({ response: 'Format salah! Gunakan: !addtodo [task]' });
        return;
      }
      dbTodos.run('INSERT INTO todos (task) VALUES (?)', [task]);
      saveDatabase(dbTodos, 'todo.db');
      reply.send({ response: 'Todo berhasil ditambahkan!' });
      break;
    case 'listtodo':
      const todos = dbTodos.exec('SELECT * FROM todos');
      const todoList = todos[0] ? todos[0].values.map(row => `${row[0]}. ${row[1]} - ${row[2]}`).join('<br>') : 'Todo kosong.';
      reply.send({ response: `<b>Daftar Todo:</b><br>${todoList}` });
      break;
    case 'donetodo':
      const doneId = args[0];
      dbTodos.run('UPDATE todos SET status = "done" WHERE id = ?', [doneId]);
      saveDatabase(dbTodos, 'todo.db');
      reply.send({ response: 'Todo berhasil ditandai selesai!' });
      break;
    case 'deltodo':
      const delId = args[0];
      dbTodos.run('DELETE FROM todos WHERE id = ?', [delId]);
      saveDatabase(dbTodos, 'todo.db');
      reply.send({ response: 'Todo berhasil dihapus!' });
      break;
    default:
      reply.send({ response: 'Perintah tidak dikenali. Ketikkan !help untuk melihat daftar perintah.' });
  }
}

// Start server
const start = async () => {
  try {
    await initDB();
    await fastify.listen({ port: 3000 });
  } catch (err) {
    fastify.log.error(err);
    process.exit(1);
  }
};

start();