Update server.js

server.js

@@ -1,20 +1,24 @@
 import express from "express";
 import { spawn } from "child_process";
 import dotenv from "dotenv";
-import { fileURLToPath } from 'url';
-import { dirname, join } from 'path';
 
-dotenv.config();
+console.log('OpenClaw: Starting server...');
+console.log('OpenClaw: Node version:', process.version);
+console.log('OpenClaw: Current directory:', process.cwd());
 
-const __filename = fileURLToPath(import.meta.url);
-const __dirname = dirname(__filename);
+try {
+  dotenv.config();
+  console.log('OpenClaw: Environment loaded');
+} catch (err) {
+  console.error('OpenClaw: Failed to load environment:', err.message);
+}
 
 const app = express();
 app.use(express.json());
 
 /* ===============================
    1. BASIC AUTH
-=============================== */
+================================ */
 
 const GATE_KEY = process.env.OPENCLAW_GATE_KEY;
 
@@ -28,7 +32,7 @@ app.use((req, res, next) => {
 
 /* ===============================
    2. RATE LIMITING (IP-based)
-=============================== */
+================================ */
 
 const RATE_LIMIT = 30; // requests
 const WINDOW_MS = 60_000;
@@ -55,7 +59,7 @@ app.use((req, res, next) => {
 
 /* ===============================
    3. LOAD KEY POOLS
-=============================== */
+================================ */
 
 function loadPool(prefix) {
   const keys = Object.keys(process.env)
@@ -81,7 +85,7 @@ function randomKey(pool) {
 
 /* ===============================
    4. TASK ROUTING
-=============================== */
+================================ */
 
 const TASKS = new Set([
   "market_research",
@@ -91,7 +95,7 @@ const TASKS = new Set([
 
 /* ===============================
    5. RUN AGENT
-=============================== */
+================================ */
 app.use((req, res, next) => {
   if (req.method === "POST" && !req.is("application/json")) {
     return res.status(400).json({ error: "JSON body required" });
@@ -103,14 +107,79 @@ app.get("/", (req, res) => {
   res.json({
     status: "OpenClaw running on HF Space",
     service: "market_research_agent",
-    endpoints: ["/api/market-research", "/run"],
+    endpoints: {
+      market_research: "POST /api/market-research",
+      health: "GET /health"
+    },
     timestamp: new Date().toISOString()
   });
 });
 
-// Market research endpoint for n8n
+// Simple health check endpoint
+app.get("/health", (req, res) => {
+  res.json({
+    status: "healthy",
+    timestamp: new Date().toISOString(),
+    uptime: process.uptime()
+  });
+});
+
+app.post("/run", async (req, res) => {
+  console.log('OpenClaw: Received request:', { 
+    task: req.body.task, 
+    keyword: req.body.keyword,
+    timestamp: new Date().toISOString()
+  });
+  
+  const { task = "market_research", provider, model, ...payload } = req.body;
+  
+  if (!TASKS.has(task)) {
+    return res.status(400).json({ error: "Unknown task" });
+  }
+
+  const providersToTry = provider
+    ? [provider, ...Object.keys(PROVIDERS).filter(p => p !== provider)]
+    : Object.keys(PROVIDERS);
+
+  let lastError;
+
+  for (const p of providersToTry) {
+    const pool = PROVIDERS[p];
+    if (!pool || pool.length === 0) continue;
+
+    for (let i = 0; i < pool.length; i++) {
+      const apiKey = randomKey(pool);
+
+const env = {
+  ...process.env,
+  OPENCLAW_PROVIDER: p,
+  OPENCLAW_MODEL: model || "",
+  OPENCLAW_API_KEY: apiKey,
+  OPENCLAW_TASK: task,
+  OPENCLAW_TIMEOUT: "180000"
+};
+
+      try {
+        const result = await runOpenClaw(env, payload);
+        return res.json(result);
+      } catch (err) {
+        lastError = err;
+        if (!isRateLimit(err)) break;
+      }
+    }
+  }
+
+  res.status(500).json({
+    error: "All providers failed",
+    details: lastError?.message,
+    keyword: req.body.keyword,
+    timestamp: new Date().toISOString()
+  });
+});
+
+// Add specific market research endpoint for n8n compatibility
 app.post("/api/market-research", async (req, res) => {
-  console.log('OpenClaw HF Space: Market research request:', { 
+  console.log('OpenClaw: Market research request:', { 
     keyword: req.body.keyword,
     timestamp: new Date().toISOString()
   });
@@ -131,7 +200,7 @@ app.post("/api/market-research", async (req, res) => {
     apiKeys[provider] = [api_key];
     providersToTry = [provider];
   } else {
-    // Fallback to environment variables
+    // Fallback to environment variables (for local testing)
     console.log('OpenClaw: Using API keys from environment');
     providersToTry = Object.keys(PROVIDERS);
     apiKeys = PROVIDERS;
@@ -158,7 +227,7 @@ app.post("/api/market-research", async (req, res) => {
       };
 
       try {
-        console.log(`OpenClaw: Trying provider ${p}`);
+        console.log(`OpenClaw: Trying provider ${p} with key ${apiKey.substring(0, 10)}...`);
         const result = await runOpenClaw(env, { keyword });
         console.log('OpenClaw: Success with provider', p);
         return res.json(result);
@@ -179,20 +248,21 @@ app.post("/api/market-research", async (req, res) => {
 });
 
 /* ===============================
-   6. EXECUTION + JSON PARSE (HF Space compatible)
-=============================== */
+   6. EXECUTION + JSON PARSE
+================================ */
 
 function runOpenClaw(env, payload) {
   return new Promise((resolve, reject) => {
-    // Use current directory for HF Space
+    // For HF Space, use current directory instead of /app
     const proc = spawn(process.execPath, ["src/index.js"], {
-      cwd: __dirname,
+      cwd: process.cwd(), // Use current working directory
       env
     });
 
     let stdout = "";
     let stderr = "";
 
+    // CRITICAL: handle spawn errors
     proc.on("error", err => {
       console.error('OpenClaw: Spawn error:', err);
       reject(err);
@@ -227,12 +297,13 @@ function runOpenClaw(env, payload) {
       }
     });
 
-    // Send input to agent
+    // SEND INPUT TO AGENT
     proc.stdin.write(JSON.stringify(payload));
     proc.stdin.end();
   });
 }
 
+
 function isRateLimit(err) {
   const msg = err.message?.toLowerCase() || "";
   return (
@@ -243,13 +314,14 @@ function isRateLimit(err) {
   );
 }
 
+
 /* ===============================
-   7. START SERVER (HF Space uses port 7860)
+   7. START (HF Space compatible)
 =============================== */
 
-const PORT = process.env.PORT || 7860;
+const PORT = process.env.PORT || 7860; // HF Space uses 7860
 app.listen(PORT, "0.0.0.0", () => {
   console.log(`🚀 OpenClaw Agent Gateway running on port ${PORT}`);
   console.log(`📡 Endpoint: /api/market-research`);
-  console.log(`🔑 Providers available: ${Object.keys(PROVIDERS).join(', ')}`);
-});
+  console.log(`🔑 API keys from: ${Object.keys(PROVIDERS).filter(p => PROVIDERS[p].length > 0).join(', ') || 'requests only'}`);
+});