Reddit research / listening pulse

import { SocialFetchClient } from "@socialfetch/sdk";

const client = new SocialFetchClient({
  apiKey: process.env.SOCIALFETCH_API_KEY!,
});

const QUERIES = [
  "acme alternative",
  "switching from acme",
  "acme too expensive",
];

const SUBREDDITS = ["SaaS", "startups", "ProductManagement"];

async function redditPulse() {
  const hits = [];

  for (const query of QUERIES) {
    const global = await client.reddit.search({
      query,
      sortBy: "new",
      timeframe: "week",
    });

    if (!global.ok) {
      console.error(global.error.code, global.error.requestId);
      continue;
    }

    hits.push({
      scope: "global" as const,
      query,
      posts: global.value.data.posts ?? [],
      creditsCharged: global.value.meta.creditsCharged,
      requestId: global.value.meta.requestId,
    });
  }

  for (const subreddit of SUBREDDITS) {
    const scoped = await client.reddit.searchSubreddit({
      subreddit,
      query: "acme",
      sort: "new",
      timeframe: "week",
    });

    if (!scoped.ok) {
      console.error(scoped.error.code, scoped.error.requestId);
      continue;
    }

    hits.push({
      scope: "subreddit" as const,
      subreddit,
      query: "acme",
      posts: scoped.value.data.posts ?? [],
      creditsCharged: scoped.value.meta.creditsCharged,
      requestId: scoped.value.meta.requestId,
    });
  }

  return hits;
}

async function enrichWithComments(postUrl: string) {
  const comments = await client.reddit.listPostComments({
    url: postUrl,
  });

  if (!comments.ok) {
    return { ok: false as const, error: comments.error };
  }

  return {
    ok: true as const,
    lookupStatus: comments.value.data.lookupStatus,
    comments: comments.value.data.comments ?? [],
    creditsCharged: comments.value.meta.creditsCharged,
    requestId: comments.value.meta.requestId,
  };
}