Upload 2 files

.env

@@ -0,0 +1,5 @@
+# OpenClaw Gateway Key
+OPENCLAW_GATE_KEY=openclaw_ZJLv3akrp511lCANb4bcfREvfLsaTf5KGIx4TeheWLQ
+
+# Server Port
+PORT=3000

server.js

@@ -108,24 +108,24 @@ app.post("/run", async (req, res) => {
   });
   
   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);
-
+  
+  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,
@@ -134,24 +134,94 @@ const env = {
   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;
-      }
-    }
-  }
-
+
+      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: Market research request:', { 
+    keyword: req.body.keyword,
+    timestamp: new Date().toISOString()
+  });
+  
+  const { keyword, api_key, provider = "deepseek" } = req.body;
+  
+  if (!keyword) {
+    return res.status(400).json({ error: "keyword is required" });
+  }
+
+  // Use API key from request or fallback to environment
+  let providersToTry;
+  let apiKeys = {};
+
+  if (api_key) {
+    // Use API key from n8n request
+    console.log('OpenClaw: Using API key from request');
+    apiKeys[provider] = [api_key];
+    providersToTry = [provider];
+  } else {
+    // Fallback to environment variables (for local testing)
+    console.log('OpenClaw: Using API keys from environment');
+    providersToTry = Object.keys(PROVIDERS);
+    apiKeys = PROVIDERS;
+  }
+
+  let lastError;
+
+  for (const p of providersToTry) {
+    const pool = apiKeys[p];
+    if (!pool || pool.length === 0) {
+      console.log(`OpenClaw: No API keys for provider ${p}`);
+      continue;
+    }
+
+    for (let i = 0; i < pool.length; i++) {
+      const apiKey = pool[i];
+
+      const env = {
+        ...process.env,
+        OPENCLAW_PROVIDER: p,
+        OPENCLAW_API_KEY: apiKey,
+        OPENCLAW_TASK: "market_research",
+        OPENCLAW_TIMEOUT: "180000"
+      };
+
+      try {
+        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);
+      } catch (err) {
+        lastError = err;
+        console.error('OpenClaw: Provider failed:', p, err.message);
+        if (!isRateLimit(err)) break;
+      }
+    }
+  }
+
+  res.status(500).json({
+    error: "All providers failed",
+    details: lastError?.message || "No API keys configured",
+    keyword: keyword,
+    timestamp: new Date().toISOString()
+  });
+});
 
 /* ===============================
    6. EXECUTION + JSON PARSE
@@ -180,20 +250,26 @@ function runOpenClaw(env, payload) {
       stderr += data.toString();
     });
 
-    proc.on("close", code => {
-      if (code !== 0) {
-        return reject(
-          new Error(stderr || `Agent exited with code ${code}`)
-        );
-      }
-
-      try {
-        const json = JSON.parse(stdout);
-        resolve(json);
-      } catch (err) {
-        reject(new Error("Invalid JSON from OpenClaw agent"));
-      }
-    });
+    proc.on("close", code => {
+      if (code !== 0) {
+        console.error('OpenClaw: Agent exited with code:', code);
+        console.error('OpenClaw: stderr:', stderr);
+        return reject(
+          new Error(stderr || `Agent exited with code ${code}`)
+        );
+      }
+
+      try {
+        console.log('OpenClaw: Agent stdout (first 500 chars):', stdout.substring(0, 500));
+        const json = JSON.parse(stdout);
+        console.log('OpenClaw: JSON parsed successfully');
+        resolve(json);
+      } catch (err) {
+        console.error('OpenClaw: JSON parse error:', err.message);
+        console.error('OpenClaw: Raw stdout:', stdout);
+        reject(new Error("Invalid JSON from OpenClaw agent: " + err.message));
+      }
+    });
 
     // SEND INPUT TO AGENT
     proc.stdin.write(JSON.stringify(payload));
@@ -217,6 +293,7 @@ function isRateLimit(err) {
    7. START
 ================================ */
 
-app.listen(7860, () => {
-  console.log("🚀 OpenClaw Agent Gateway running");
-});
+const PORT = process.env.PORT || 3000;
+app.listen(PORT, () => {
+  console.log(`🚀 OpenClaw Agent Gateway running on port ${PORT}`);
+});