import { marketResearchAgent } from "./marketResearchAgent.js";

function readStdin() {
  return new Promise(resolve => {
    let data = "";
    process.stdin.on("data", chunk => data += chunk);
    process.stdin.on("end", () => resolve(data));
  });
}

(async () => {
  try {
    const input = JSON.parse(await readStdin());

    const result = await marketResearchAgent({
      input,
      provider: process.env.OPENCLAW_PROVIDER,
      model: process.env.OPENCLAW_MODEL
    });

    // CRITICAL: JSON ONLY
    console.log(JSON.stringify(result));
  } catch (e) {
    console.log(JSON.stringify({
      meta: {
        status: "failed",
        error: e.message
      },
      dashboard_view: {},
      report_view: {}
    }));
  }
})();