Upload 3 files

.env.example

@@ -0,0 +1,17 @@
+# OpenClaw Gateway Key
+OPENCLAW_GATE_KEY=openclaw_ZJLv3akrp511lCANb4bcfREvfLsaTf5KGIx4TeheWLQ
+
+# DeepSeek API Keys (Primary Provider)
+DEEPSEEK_API_KEY_1=your_deepseek_api_key_here
+
+# OpenAI API Keys (Fallback)
+OPENAI_API_KEY_1=your_openai_api_key_here
+
+# Gemini API Keys (Fallback)
+GEMINI_API_KEY_1=your_gemini_api_key_here
+
+# OpenRouter API Keys (Fallback)
+OPENROUTER_API_KEY_1=your_openrouter_api_key_here
+
+# DashScope API Keys (Fallback)
+DASHSCOPE_API_KEY_1=your_dashscope_api_key_here

package.json

@@ -3,9 +3,13 @@
   "private": true,
   "type": "module",
   "scripts": {
-    "start": "node server.js"
+    "start": "node server.js",
+    "dev": "node server.js"
   },
   "dependencies": {
-    "express": "^4.19.2"
+    "express": "^4.19.2",
+    "node-fetch": "^3.3.2",
+    "dotenv": "^16.4.5",
+    "zod": "^3.23.8"
   }
 }

server.js

@@ -1,210 +1,222 @@
 import express from "express";
 import { spawn } from "child_process";
-
-const app = express();
-app.use(express.json());
-
-/* ===============================
-   1. BASIC AUTH
-================================ */
-
-const GATE_KEY = process.env.OPENCLAW_GATE_KEY;
-
-app.use((req, res, next) => {
-  if (!GATE_KEY) return next();
-  if (req.headers["x-openclaw-key"] !== GATE_KEY) {
-    return res.status(401).json({ error: "Unauthorized" });
-  }
-  next();
-});
-
-/* ===============================
-   2. RATE LIMITING (IP-based)
-================================ */
-
-const RATE_LIMIT = 30; // requests
-const WINDOW_MS = 60_000;
-const ipHits = new Map();
-
-app.use((req, res, next) => {
-  const ip = req.headers["x-forwarded-for"] || req.socket.remoteAddress;
-  const now = Date.now();
-
-  const record = ipHits.get(ip) || { count: 0, ts: now };
-  if (now - record.ts > WINDOW_MS) {
-    record.count = 0;
-    record.ts = now;
-  }
-
-  record.count++;
-  ipHits.set(ip, record);
-
-  if (record.count > RATE_LIMIT) {
-    return res.status(429).json({ error: "Rate limit exceeded" });
-  }
-  next();
-});
-
-/* ===============================
-   3. LOAD KEY POOLS
-================================ */
-
+import dotenv from "dotenv";
+dotenv.config();
+
+const app = express();
+app.use(express.json());
+
+/* ===============================
+   1. BASIC AUTH
+================================ */
+
+const GATE_KEY = process.env.OPENCLAW_GATE_KEY;
+
+app.use((req, res, next) => {
+  if (!GATE_KEY) return next();
+  if (req.headers["x-openclaw-key"] !== GATE_KEY) {
+    return res.status(401).json({ error: "Unauthorized" });
+  }
+  next();
+});
+
+/* ===============================
+   2. RATE LIMITING (IP-based)
+================================ */
+
+const RATE_LIMIT = 30; // requests
+const WINDOW_MS = 60_000;
+const ipHits = new Map();
+
+app.use((req, res, next) => {
+  const ip = req.headers["x-forwarded-for"] || req.socket.remoteAddress;
+  const now = Date.now();
+
+  const record = ipHits.get(ip) || { count: 0, ts: now };
+  if (now - record.ts > WINDOW_MS) {
+    record.count = 0;
+    record.ts = now;
+  }
+
+  record.count++;
+  ipHits.set(ip, record);
+
+  if (record.count > RATE_LIMIT) {
+    return res.status(429).json({ error: "Rate limit exceeded" });
+  }
+  next();
+});
+
+/* ===============================
+   3. LOAD KEY POOLS
+================================ */
+
 function loadPool(prefix) {
-  return Object.keys(process.env)
+  const keys = Object.keys(process.env)
     .filter(k => k.startsWith(prefix))
     .map(k => process.env[k])
     .filter(Boolean);
+  
+  console.log(`Loaded ${keys.length} keys for ${prefix}`);
+  return keys;
 }
-
-const PROVIDERS = {
-  openai: loadPool("OPENAI_API_KEY_"),
-  deepseek: loadPool("DEEPSEEK_API_KEY_"),
-  gemini: loadPool("GEMINI_API_KEY_"),
-  openrouter: loadPool("OPENROUTER_API_KEY_"),
-  dashscope: loadPool("DASHSCOPE_API_KEY_")
-};
-
-function randomKey(pool) {
-  return pool[Math.floor(Math.random() * pool.length)];
-}
-
-/* ===============================
-   4. TASK ROUTING
-================================ */
-
-const TASKS = new Set([
-  "market_research",
-  "summarize",
-  "classify"
-]);
-
-/* ===============================
-   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" });
-  }
-  next();
-});
-
-app.get("/", (req, res) => {
-  res.json({
-    status: "OpenClaw running",
-    service: "market_research_agent"
-  });
-});
-
+
+const PROVIDERS = {
+  openai: loadPool("OPENAI_API_KEY_"),
+  deepseek: loadPool("DEEPSEEK_API_KEY_"),
+  gemini: loadPool("GEMINI_API_KEY_"),
+  openrouter: loadPool("OPENROUTER_API_KEY_"),
+  dashscope: loadPool("DASHSCOPE_API_KEY_")
+};
+
+function randomKey(pool) {
+  return pool[Math.floor(Math.random() * pool.length)];
+}
+
+/* ===============================
+   4. TASK ROUTING
+================================ */
+
+const TASKS = new Set([
+  "market_research",
+  "summarize",
+  "classify"
+]);
+
+/* ===============================
+   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" });
+  }
+  next();
+});
+
+app.get("/", (req, res) => {
+  res.json({
+    status: "OpenClaw running",
+    service: "market_research_agent"
+  });
+});
+
 app.post("/run", async (req, res) => {
-  /* console.log("Incoming body:", req.body); */
+  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);
-
+  
+  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_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
-  });
-});
-
-/* ===============================
-   6. EXECUTION + JSON PARSE
-================================ */
-
-function runOpenClaw(env, payload) {
-  return new Promise((resolve, reject) => {
-    const proc = spawn(process.execPath, ["src/index.js"], {
-      cwd: "/app",
-      env
-    });
-
-    let stdout = "";
-    let stderr = "";
-
-    // CRITICAL: handle spawn errors
-    proc.on("error", err => {
-      reject(err);
-    });
-
-    proc.stdout.on("data", data => {
-      stdout += data.toString();
-    });
-
-    proc.stderr.on("data", data => {
-      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"));
-      }
-    });
-
-    // SEND INPUT TO AGENT
-    proc.stdin.write(JSON.stringify(payload));
-    proc.stdin.end();
+    details: lastError?.message,
+    keyword: req.body.keyword,
+    timestamp: new Date().toISOString()
   });
-}
-
-
-function isRateLimit(err) {
-  const msg = err.message?.toLowerCase() || "";
-  return (
-    msg.includes("429") ||
-    msg.includes("rate") ||
-    msg.includes("quota") ||
-    msg.includes("limit")
-  );
-}
-
-
-/* ===============================
-   7. START
-================================ */
-
-app.listen(7860, () => {
-  console.log("🚀 OpenClaw Agent Gateway running");
-});
+});
+
+/* ===============================
+   6. EXECUTION + JSON PARSE
+================================ */
+
+function runOpenClaw(env, payload) {
+  return new Promise((resolve, reject) => {
+    const proc = spawn(process.execPath, ["src/index.js"], {
+      cwd: "/app",
+      env
+    });
+
+    let stdout = "";
+    let stderr = "";
+
+    // CRITICAL: handle spawn errors
+    proc.on("error", err => {
+      reject(err);
+    });
+
+    proc.stdout.on("data", data => {
+      stdout += data.toString();
+    });
+
+    proc.stderr.on("data", data => {
+      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"));
+      }
+    });
+
+    // SEND INPUT TO AGENT
+    proc.stdin.write(JSON.stringify(payload));
+    proc.stdin.end();
+  });
+}
+
+
+function isRateLimit(err) {
+  const msg = err.message?.toLowerCase() || "";
+  return (
+    msg.includes("429") ||
+    msg.includes("rate") ||
+    msg.includes("quota") ||
+    msg.includes("limit")
+  );
+}
+
+
+/* ===============================
+   7. START
+================================ */
+
+app.listen(7860, () => {
+  console.log("🚀 OpenClaw Agent Gateway running");
+});