import express, { Request, Response, NextFunction } from 'express';
import cors from 'cors';
import rateLimit from 'express-rate-limit';
import routes from './routes';
const app = express();
const PORT = process.env.INTEGRATION_MCP_PORT || 3002;
app.use(cors());
app.use(express.json());
const limiter = rateLimit({
windowMs: 15 * 60 * 1000,
max: 100,
message: { error: "Too many requests", message: "Please try again later" },
standardHeaders: true,
legacyHeaders: false,
});
const VALID_API_KEY = process.env.API_KEY;
if (!VALID_API_KEY) {
console.error("[Integration MCP] FATAL: API_KEY environment variable is not configured!");
console.error("[Integration MCP] Set API_KEY in Secrets to enable authentication.");
}
function apiKeyAuth(req: Request, res: Response, next: NextFunction) {
const publicPaths = ["/", "/health"];
if (publicPaths.includes(req.path)) {
return next();
}
if (!VALID_API_KEY) {
return res.status(500).json({
error: "Server Configuration Error",
message: "API_KEY not configured on server",
});
}
const apiKey = req.headers["x-api-key"] as string || req.query.api_key as string;
if (!apiKey) {
return res.status(401).json({
error: "Unauthorized",
message: "Missing X-API-KEY header or api_key query parameter",
});
}
if (apiKey !== VALID_API_KEY) {
return res.status(403).json({
error: "Forbidden",
message: "Invalid API key",
});
}
next();
}
app.use(limiter);
app.use(apiKeyAuth);
app.use((req, res, next) => {
console.log(`[Integration MCP] ${req.method} ${req.path}`);
next();
});
app.get('/health', (req, res) => {
res.json({
status: 'ok',
service: 'Integration MCP',
port: PORT,
timestamp: new Date().toISOString(),
uptime: process.uptime(),
});
});
app.use('/api', routes);
app.get('/', (req, res) => {
res.json({
name: 'Integration MCP',
version: '1.0.0',
description: 'Handles external service integrations and deployments',
services: [
'GitHub Service',
'Vercel Service',
'n8n Service',
'Supabase Service',
'Google Cloud Service',
],
endpoints: {
github: '/api/github/[repos|issues]',
vercel: '/api/vercel/[projects|deployments]',
supabase: '/api/supabase/[tables|query]',
gcloud: '/api/gcloud/[projects|instances|buckets]',
n8n: '/api/n8n/[workflows|executions]',
mcp: '/api/mcp',
},
});
});
app.use((err: any, req: any, res: any, next: any) => {
console.error('[Integration MCP Error]:', err);
res.status(500).json({
error: 'Internal Server Error',
message: err.message,
});
});
app.listen(PORT, () => {
console.log(`🔌 Integration MCP running on http://localhost:${PORT}`);
});
