Update server.js

server.js

@@ -10,6 +10,12 @@ console.log('Environment loaded, PORT:', process.env.PORT);
 const app = express();
 app.use(express.json());
 
+// Log all incoming requests for debugging
+app.use((req, res, next) => {
+  console.log(`${req.method} ${req.path} - Headers:`, req.headers);
+  next();
+});
+
 // Handle JSON parsing errors
 app.use((err, req, res, next) => {
   if (err instanceof SyntaxError && err.status === 400 && 'body' in err) {
@@ -90,6 +96,57 @@ app.post("/api/market-research", (req, res) => {
   res.json(mockResponse);
 });
 
+// Add /run endpoint for n8n compatibility (original workflow uses this)
+app.post("/run", (req, res) => {
+  console.log('Received request at /run endpoint');
+  
+  const { keyword, api_key, task = "market_research" } = req.body || {};
+  
+  if (!keyword) {
+    return res.status(400).json({ error: "keyword is required" });
+  }
+
+  if (!api_key) {
+    return res.status(400).json({ 
+      error: "API key required",
+      message: "Send api_key in request body from n8n credentials"
+    });
+  }
+
+  console.log('Processing /run request for task:', task, 'keyword:', keyword);
+
+  // Return mock response in the format n8n expects
+  const mockResponse = {
+    marketTitle: `Global ${keyword} Market Analysis`,
+    marketOverview: {
+      pastYear_2023: 10.5,
+      currentYear_2025: 15.2,
+      forecastYear_2033: 28.7,
+      global_cagr_Forecast: 12.5
+    },
+    marketSegments: [
+      {
+        segment: "Primary Segment",
+        segment_marketShare_2023: "35%",
+        segment_marketShare_2025: "38%",
+        segment_marketShare_2033: "42%",
+        segment_cagr: "12%"
+      }
+    ],
+    competitiveLandscape: [
+      {
+        company: "Leading Company",
+        player_marketShare_2025: 25
+      }
+    ],
+    status: "success",
+    message: "Mock data from /run endpoint"
+  };
+
+  console.log('Returning mock response from /run');
+  res.json(mockResponse);
+});
+
 // Error handling middleware
 app.use((err, req, res, next) => {
   console.error('Server error:', err.message);
@@ -114,11 +171,12 @@ process.on('unhandledRejection', (reason, promise) => {
   console.error('Reason:', reason);
 });
 
-try {
+  try {
   app.listen(PORT, "0.0.0.0", () => {
     console.log(`✅ Server successfully running on port ${PORT}`);
     console.log(`✅ Health endpoint: GET /health`);
     console.log(`✅ API endpoint: POST /api/market-research`);
+    console.log(`✅ n8n endpoint: POST /run (with X-OpenClaw-Key header)`);
   });
 } catch (error) {
   console.error('❌ Failed to start server:', error.message);