server.js

import express from 'express';
import cors from 'cors';
import dotenv from 'dotenv';
import { MongoClient } from 'mongodb';

dotenv.config();

const app = express();
const port = process.env.PORT || 4000;
const mongoUri = process.env.MONGO_URI || 'mongodb://127.0.0.1:27017';
const dbName = process.env.MONGO_DB || 'project_pm';

app.use(cors());
app.use(express.json());

let client;
let db;

async function connectToMongo() {
  if (db) return db;
  client = new MongoClient(mongoUri);
  await client.connect();
  db = client.db(dbName);
  return db;
}

app.get('/health', (_req, res) => {
  res.json({ status: 'ok' });
});

app.get('/history', async (_req, res) => {
  try {
    const database = await connectToMongo();
    const history = await database.collection('project_history').find().sort({ archivedAt: -1 }).toArray();
    res.json(history);
  } catch (error) {
    console.error(error);
    res.status(500).json({ error: error.message });
  }
});

app.post('/history', async (req, res) => {
  try {
    const database = await connectToMongo();
    const result = await database.collection('project_history').insertOne(req.body);
    res.json({ insertedId: result.insertedId });
  } catch (error) {
    console.error(error);
    res.status(500).json({ error: error.message });
  }
});

app.delete('/history', async (_req, res) => {
  try {
    const database = await connectToMongo();
    const result = await database.collection('project_history').deleteMany({});
    res.json({ deletedCount: result.deletedCount });
  } catch (error) {
    console.error(error);
    res.status(500).json({ error: error.message });
  }
});

app.listen(port, () => {
  console.log(`PM backend listening on port ${port}`);
});