在压库存之前研究一个产品细分

const BASE = "https://openapi.felo.ai";
const headers = {
  Authorization: `Bearer ${process.env.FELO_API_KEY}`,
  "Content-Type": "application/json",
};

async function felo<T>(path: string, body?: unknown): Promise<T> {
  const res = await fetch(`${BASE}${path}`, {
    method: body ? "POST" : "GET",
    headers,
    body: body ? JSON.stringify(body) : undefined,
  });
  if (!res.ok) throw new Error(`${res.status}: ${await res.text()}`);
  return res.json() as Promise<T>;
}

type ChatData = {
  data: {
    answer: string;
    resources: { link: string; title: string; snippet: string }[];
  };
};

const niche = "portable espresso maker"; // replace with the category you are judging

const context = await felo<ChatData>("/v2/chat", {
  query: `Demand, price bands, and buyer complaints for ${niche} in the US`,
});

const sources = context.data.resources.slice(0, 5);

const PRODUCT_PAGES = [
  { url: "https://example.com/product-a", title: "Example A — product page" },
  { url: "https://example.com/product-b", title: "Example B — product page" },
];

type ExtractData = { data: { content: string } };

const listings = await Promise.all(
  PRODUCT_PAGES.map((page) =>
    felo<ExtractData>("/v2/web/extract", {
      url: page.url,
      output_format: "markdown",
      with_readability: true,
    }).then((extracted) => ({ ...page, content: extracted.data.content })),
  ),
);

type XData = {
  data: {
    tweets: {
      content: string;
      author: { username: string };
      created_at: string;
      metrics: { retweet_count: number; favorite_count: number; reply_count: number };
      url: string;
    }[];
  };
};

const since = Math.floor((Date.now() - 30 * 24 * 60 * 60 * 1000) / 1000);

const search = await felo<XData>("/v2/x/tweet/search", {
  query: `"${niche}" (shipping OR quality OR refund)`,
  limit: 50,
  since_time: since,
});

const complaints = search.data.tweets;

const capturedOn = new Date().toISOString().slice(0, 10);

const memo = [
  `# Product research — ${niche}`,
  "",
  "## Category context",
  context.data.answer,
  "",
  "## Competitor pages",
  ...listings.map(
    (page) => `- [${page.title}](${page.url}) — captured ${capturedOn}`,
  ),
  "",
  "## What buyers report",
  ...complaints.slice(0, 10).map(
    (post) =>
      `- @${post.author.username} (${post.created_at.slice(0, 10)}): ${post.content}`,
  ),
  "",
  "## Sources",
  ...sources.map((source) => `- [${source.title}](${source.link})`),
].join("\n");

console.log(memo);

type LiveDocData = { data: { short_id: string } };

const research = await felo<LiveDocData>("/v2/livedocs", {
  name: `Product research: ${niche}`,
  description: "Competitor pages, buyer posts, and the memo",
});

await felo(`/v2/livedocs/${research.data.short_id}/resources/urls`, {
  urls: [
    ...listings.map((page) => ({ url: page.url, title: page.title })),
    ...sources.map((source) => ({ url: source.link, title: source.title })),
  ].slice(0, 10),
});

await felo(`/v2/livedocs/${research.data.short_id}/resources/doc`, {
  title: `Product memo — ${capturedOn}`,
  content: memo,
});