import express from 'express';
import cors from 'cors';
import * as graphql from './graphql-client.js';
const app = express();
const PORT = process.env.MCP_HTTP_PORT || 5000;
// Middleware
app.use(cors());
app.use(express.json());
// Health check endpoint
app.get('/health', (req, res) => {
res.json({ status: 'ok', service: 'ADL MCP HTTP Server' });
});
// List all ADL entries
app.get('/adl/entries', async (req, res) => {
try {
const entries = await graphql.getAllADLEntries();
res.json({ success: true, data: entries });
} catch (error) {
res.status(500).json({ success: false, error: error.message });
}
});
// Get single ADL entry by ID
app.get('/adl/entries/:id', async (req, res) => {
try {
const entry = await graphql.getADLEntry(req.params.id);
if (!entry) {
return res.status(404).json({ success: false, error: 'Entry not found' });
}
res.json({ success: true, data: entry });
} catch (error) {
res.status(500).json({ success: false, error: error.message });
}
});
// Search ADL entries
app.post('/adl/search', async (req, res) => {
try {
const searchCriteria = req.body;
const entries = await graphql.searchADLEntries(searchCriteria);
res.json({ success: true, data: entries });
} catch (error) {
res.status(500).json({ success: false, error: error.message });
}
});
// Create new ADL entry
app.post('/adl/entries', async (req, res) => {
try {
const { author, title, decision, factSheets, status } = req.body;
// Validate required fields
if (!author || !title || !decision || !factSheets || !status) {
return res.status(400).json({
success: false,
error: 'Missing required fields: author, title, decision, factSheets, status'
});
}
const entry = await graphql.createADLEntry({
author,
title,
decision,
factSheets,
status
});
res.status(201).json({ success: true, data: entry });
} catch (error) {
res.status(500).json({ success: false, error: error.message });
}
});
// Update ADL entry
app.put('/adl/entries/:id', async (req, res) => {
try {
const { id } = req.params;
const updates = req.body;
const entry = await graphql.updateADLEntry(id, updates);
res.json({ success: true, data: entry });
} catch (error) {
if (error.message.includes('not found')) {
return res.status(404).json({ success: false, error: error.message });
}
res.status(500).json({ success: false, error: error.message });
}
});
// Delete ADL entry
app.delete('/adl/entries/:id', async (req, res) => {
try {
const success = await graphql.deleteADLEntry(req.params.id);
if (!success) {
return res.status(404).json({ success: false, error: 'Entry not found' });
}
res.json({ success: true, message: 'Entry deleted successfully' });
} catch (error) {
if (error.message.includes('not found')) {
return res.status(404).json({ success: false, error: error.message });
}
res.status(500).json({ success: false, error: error.message });
}
});
// Start server
app.listen(PORT, () => {
console.log(`🔌 MCP HTTP Server ready at: http://localhost:${PORT}`);
});
