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}`);
});