Update server.js

server.js

@@ -1,24 +1,32 @@
 import express from "express";
-import { spawn } from "child_process";
 import dotenv from "dotenv";
 
 console.log('OpenClaw HF Space: Starting server...');
 
-try {
-  dotenv.config();
-  console.log('Environment loaded');
-} catch (err) {
-  console.error('Failed to load environment:', err.message);
-}
+// Load environment
+dotenv.config();
+console.log('Environment loaded, PORT:', process.env.PORT);
 
 const app = express();
 app.use(express.json());
 
-// Simple health check
+// Handle JSON parsing errors
+app.use((err, req, res, next) => {
+  if (err instanceof SyntaxError && err.status === 400 && 'body' in err) {
+    console.error('JSON parsing error:', err.message);
+    return res.status(400).json({ error: "Invalid JSON" });
+  }
+  next();
+});
+
+// Simple endpoints
 app.get("/", (req, res) => {
   res.json({
     status: "OpenClaw HF Space Running",
-    endpoint: "POST /api/market-research",
+    endpoints: {
+      health: "GET /health",
+      market_research: "POST /api/market-research"
+    },
     timestamp: new Date().toISOString()
   });
 });
@@ -31,14 +39,11 @@ app.get("/health", (req, res) => {
   });
 });
 
-// Market research endpoint
-app.post("/api/market-research", async (req, res) => {
-  console.log('Market research request:', { 
-    keyword: req.body.keyword,
-    timestamp: new Date().toISOString()
-  });
+// Market research endpoint - SIMPLIFIED
+app.post("/api/market-research", (req, res) => {
+  console.log('Received market research request');
   
-  const { keyword, api_key, provider = "deepseek" } = req.body;
+  const { keyword, api_key } = req.body || {};
   
   if (!keyword) {
     return res.status(400).json({ error: "keyword is required" });
@@ -51,75 +56,71 @@ app.post("/api/market-research", async (req, res) => {
     });
   }
 
-  const env = {
-    ...process.env,
-    OPENCLAW_PROVIDER: provider,
-    OPENCLAW_API_KEY: api_key,
-    OPENCLAW_TASK: "market_research",
-    OPENCLAW_TIMEOUT: "180000"
+  console.log('Processing keyword:', keyword, 'with API key (first 10 chars):', api_key.substring(0, 10));
+
+  // Return mock response for testing
+  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 for testing - OpenClaw agent is running!"
   };
 
-  try {
-    console.log(`Calling OpenClaw agent with provider: ${provider}`);
-    const result = await runOpenClaw(env, { keyword });
-    console.log('OpenClaw agent succeeded');
-    return res.json(result);
-  } catch (err) {
-    console.error('OpenClaw agent failed:', err.message);
-    return res.status(500).json({
-      error: "OpenClaw agent failed",
-      details: err.message,
-      keyword: keyword,
-      timestamp: new Date().toISOString()
-    });
-  }
+  console.log('Returning mock response');
+  res.json(mockResponse);
 });
 
-function runOpenClaw(env, payload) {
-  return new Promise((resolve, reject) => {
-    const proc = spawn(process.execPath, ["src/index.js"], {
-      cwd: process.cwd(),
-      env
-    });
-
-    let stdout = "";
-    let stderr = "";
-
-    proc.on("error", err => {
-      console.error('Spawn error:', err);
-      reject(err);
-    });
-
-    proc.stdout.on("data", data => {
-      stdout += data.toString();
-    });
+// Error handling middleware
+app.use((err, req, res, next) => {
+  console.error('Server error:', err.message);
+  res.status(500).json({
+    error: "Internal server error",
+    message: err.message
+  });
+});
 
-    proc.stderr.on("data", data => {
-      stderr += data.toString();
-    });
+// Start server
+const PORT = process.env.PORT || 7860;
+console.log('Starting server on port:', PORT);
 
-    proc.on("close", code => {
-      if (code !== 0) {
-        console.error('Agent exited with code:', code, 'stderr:', stderr);
-        return reject(new Error(`Agent failed: ${stderr || code}`));
-      }
+// Global error handlers to prevent crashes
+process.on('uncaughtException', (error) => {
+  console.error('Uncaught Exception:', error.message);
+  console.error('Stack:', error.stack);
+});
 
-      try {
-        const json = JSON.parse(stdout);
-        resolve(json);
-      } catch (err) {
-        console.error('JSON parse error:', err.message);
-        console.error('Raw output (first 500 chars):', stdout.substring(0, 500));
-        reject(new Error("Invalid JSON from agent"));
-      }
-    });
+process.on('unhandledRejection', (reason, promise) => {
+  console.error('Unhandled Rejection at:', promise);
+  console.error('Reason:', reason);
+});
 
-    proc.stdin.write(JSON.stringify(payload));
-    proc.stdin.end();
+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`);
   });
-}
-
-const PORT = process.env.PORT || 7860;
-app.listen(PORT, "0.0.0.0", () => {
-  console.log(`🚀 Server running on port ${PORT}`);
-});
+} catch (error) {
+  console.error('❌ Failed to start server:', error.message);
+  process.exit(1);
+}