SNSの会話を週次のリスニングブリーフに変える

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 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() - 7 * 24 * 60 * 60 * 1000) / 1000);

const search = await felo<XData>("/v2/x/tweet/search", {
  query: '"Acme" OR "Acme app"',
  limit: 50,
  since_time: since,
});

const posts = search.data.tweets;

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

const context = await felo<ChatData>("/v2/chat", {
  query: "Recent customer complaints and competitor mentions around Acme",
});

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

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

const pages = await Promise.all(
  sources.slice(0, 3).map((source) =>
    felo<ExtractData>("/v2/web/extract", {
      url: source.link,
      output_format: "markdown",
      with_readability: true,
      with_cache: true,
    }).then((page) => ({ ...source, content: page.data.content })),
  ),
);

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

const ranked = [...posts].sort(
  (a, b) => b.metrics.favorite_count - a.metrics.favorite_count,
);

const brief = [
  `# Social listening brief — ${date}`,
  "",
  "## What the web says",
  context.data.answer,
  "",
  "## What people are posting",
  ...ranked.slice(0, 10).map(
    (post) =>
      `- @${post.author.username} (${post.created_at.slice(0, 10)}): ${post.content}\n  ${post.url}`,
  ),
  "",
  "## Pages behind the answer",
  ...pages.map((page) => `- [${page.title}](${page.link})`),
  "",
  "## Sources",
  ...sources.map((source) => `- [${source.title}](${source.link})`),
].join("\n");

console.log(brief);

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

const archive = await felo<LiveDocData>("/v2/livedocs", {
  name: "Social listening archive",
  description: "One document resource per weekly brief",
});

await felo(`/v2/livedocs/${archive.data.short_id}/resources/doc`, {
  title: `Social listening — ${date}`,
  content: brief,
});

type Retrieved = { data: { title: string; content: string; score: number }[] };

const previous = await felo<Retrieved>(
  `/v2/livedocs/${archive.data.short_id}/resources/retrieve`,
  { query: "what changed since last week" },
).then((res) => res.data.filter((hit) => hit.score >= 0.7));