feat: add announcements on threads

server/src/config/announcements.ts

@@ -48,6 +48,15 @@ Platform-specific requirements:
 - Do NOT include post numbers or thread indicators
 - Mastodon supports markdown, so you can use basic formatting like **bold** and *italic*
 
+**Threads:**
+- Break content into a thread of individual posts
+- Each post should be under 500 characters (Threads' limit)
+- Posts should flow naturally from one to the next
+- Use relevant hashtags (2-3 per post)
+- Make the first post compelling to encourage thread reading
+- Do NOT include post numbers or thread indicators
+- Plain text format (no markdown)
+
 **Facebook:**
 - Plain text format (no markdown)
 - Professional yet friendly tone
@@ -134,6 +143,16 @@ const announcementJsonSchema = {
       required: [ "content", "title" ],
       type:     "object",
     },
+    threads: {
+      description: "Array of individual Threads posts that form a thread. Each post should be under 500 characters and flow naturally from one to the next.",
+      items:       {
+        description: "A single Threads post in the thread (max 500 characters, no post numbers or thread indicators)",
+        maxLength:   500,
+        type:        "string",
+      },
+      minItems: 1,
+      type:     "array",
+    },
     twitter: {
       description: "Array of individual Twitter posts that form a thread. Each post should be under 280 characters and flow naturally from one to the next.",
       items:       {
@@ -152,6 +171,7 @@ const announcementJsonSchema = {
     "linkedin",
     "mastodon",
     "reddit",
+    "threads",
     "twitter",
   ],
   type: "object",

server/src/interfaces/announcementResponse.ts

@@ -21,5 +21,6 @@ export interface AnnouncementResponse {
     content: string;
     title:   string;
   };
+  threads: Array<string>;
   twitter: Array<string>;
 }

server/src/modules/announceOnThreads.ts

@@ -0,0 +1,190 @@
+
+/**
+ * @copyright nhcarrigan
+ * @license Naomi's Public License
+ * @author Naomi Carrigan
+ */
+
+import { isValidString } from "../utils/typeguards.js";
+
+interface ThreadsErrorResponse {
+  error: {
+    message: string;
+    type:    string;
+    code:    number;
+  };
+}
+
+interface ThreadsSuccessResponse {
+  id: string;
+}
+
+type ThreadsResponse = ThreadsErrorResponse | ThreadsSuccessResponse;
+
+/**
+ * Forwards an announcement to our Threads account.
+ * @param content - The main body of the announcement.
+ * @returns A message indicating the success or failure of the operation.
+ */
+// eslint-disable-next-line max-lines-per-function, max-statements, complexity -- This is a big function.
+export const announceOnThreads = async(
+  content: Array<string>,
+): Promise<string> => {
+  if (
+    process.env.THREADS_ACCESS_TOKEN === undefined
+  ) {
+    return "Threads credentials are not set.";
+  }
+  const [ firstPost, ...restOfPosts ] = content;
+  const failedReplies: Array<string> = [];
+  if (firstPost === undefined) {
+    return "No posts to send to Threads.";
+  }
+  const accessToken = process.env.THREADS_ACCESS_TOKEN;
+  const apiUrl = `https://graph.threads.net/v1.0/me/threads`;
+  // Step 1: Create the first post
+  const firstPostParameters = new URLSearchParams({
+    // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+    access_token: accessToken,
+    // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+    media_type:   "TEXT",
+    text:         firstPost,
+  });
+  const firstPostResponse = await fetch(
+    `${apiUrl}?${firstPostParameters.toString()}`,
+    {
+      headers: {
+        // eslint-disable-next-line @typescript-eslint/naming-convention -- HTTP header name.
+        "Content-Type": "application/x-www-form-urlencoded",
+      },
+      method: "POST",
+    },
+  ).catch((error: unknown) => {
+    return error instanceof Error
+      ? error.message
+      : String(error);
+  });
+  if (typeof firstPostResponse === "string") {
+    return `Failed to send initial post to Threads. ${firstPostResponse}`;
+  }
+  if (!firstPostResponse.ok) {
+    const errorText = await firstPostResponse.text().catch(() => {
+      return firstPostResponse.statusText;
+    });
+    return `Failed to send initial post to Threads. Status: ${firstPostResponse.status.toString()} ${errorText}`;
+  }
+  // eslint-disable-next-line @typescript-eslint/consistent-type-assertions -- Fetch does not accept generics.
+  const firstPostData = await firstPostResponse.json() as ThreadsResponse;
+  if ("error" in firstPostData) {
+    return `Failed to send initial post to Threads. ${firstPostData.error.message}`;
+  }
+  if (!isValidString(firstPostData.id)) {
+    return `Failed to parse initial post ID from Threads. ${JSON.stringify(firstPostData)}`;
+  }
+  // Step 2: Publish the first post
+  const publishUrl = `https://graph.threads.net/v1.0/me/threads_publish`;
+  const publishParameters = new URLSearchParams({
+    // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+    access_token: accessToken,
+    // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+    creation_id:  firstPostData.id,
+  });
+  const publishResponse = await fetch(
+    `${publishUrl}?${publishParameters.toString()}`,
+    {
+      headers: {
+        // eslint-disable-next-line @typescript-eslint/naming-convention -- HTTP header name.
+        "Content-Type": "application/x-www-form-urlencoded",
+      },
+      method: "POST",
+    },
+  ).catch((error: unknown) => {
+    return error instanceof Error
+      ? error.message
+      : String(error);
+  });
+  if (typeof publishResponse === "string") {
+    return `Failed to publish initial post to Threads. ${publishResponse}`;
+  }
+  if (!publishResponse.ok) {
+    const errorText = await publishResponse.text().catch(() => {
+      return publishResponse.statusText;
+    });
+    return `Failed to publish initial post to Threads. Status: ${publishResponse.status.toString()} ${errorText}`;
+  }
+  // eslint-disable-next-line @typescript-eslint/consistent-type-assertions -- Fetch does not accept generics.
+  const publishData = await publishResponse.json() as ThreadsSuccessResponse;
+  let parentThreadId = publishData.id;
+  // Step 3: Create replies for the rest of the posts
+  for (const post of restOfPosts) {
+    const replyParameters = new URLSearchParams({
+      // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+      access_token: accessToken,
+      // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+      media_type:   "TEXT",
+      // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+      reply_to_id:  parentThreadId,
+      text:         post,
+    });
+    // eslint-disable-next-line no-await-in-loop -- We need to do this sequentially.
+    const replyResponse = await fetch(
+      `${apiUrl}?${replyParameters.toString()}`,
+      {
+        headers: {
+          // eslint-disable-next-line @typescript-eslint/naming-convention -- HTTP header name.
+          "Content-Type": "application/x-www-form-urlencoded",
+        },
+      },
+    ).catch((error: unknown) => {
+      return error instanceof Error
+        ? error.message
+        : String(error);
+    });
+    if (typeof replyResponse === "string") {
+      failedReplies.push(post);
+      continue;
+    }
+    if (!replyResponse.ok) {
+      failedReplies.push(post);
+      continue;
+    }
+    // eslint-disable-next-line @typescript-eslint/consistent-type-assertions, no-await-in-loop -- Fetch does not accept generics.
+    const replyData = await replyResponse.json() as ThreadsResponse;
+    if ("error" in replyData) {
+      failedReplies.push(post);
+      continue;
+    }
+    if (!isValidString(replyData.id)) {
+      failedReplies.push(post);
+      continue;
+    }
+    // Publish the reply
+    const replyPublishUrl = `https://graph.threads.net/v1.0/me/threads_publish`;
+    const replyPublishParameters = new URLSearchParams({
+      // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+      access_token: accessToken,
+      // eslint-disable-next-line @typescript-eslint/naming-convention -- API requirement.
+      creation_id:  replyData.id,
+    });
+    // eslint-disable-next-line no-await-in-loop -- We need to do this sequentially.
+    const replyPublishResponse = await fetch(
+      `${replyPublishUrl}?${replyPublishParameters.toString()}`,
+      {
+        method: "POST",
+      },
+    ).catch(() => {
+      return null;
+    });
+    if (replyPublishResponse?.ok !== true) {
+      failedReplies.push(post);
+      continue;
+    }
+    const replyPublishData
+    // eslint-disable-next-line @typescript-eslint/consistent-type-assertions, no-await-in-loop -- Fetch does not accept generics.
+    = await replyPublishResponse.json() as ThreadsSuccessResponse;
+    parentThreadId = replyPublishData.id;
+  }
+  return `Successfully sent initial post to Threads. ${failedReplies.length > 0
+    ? `Failed to send ${failedReplies.length.toString()} replies: ${failedReplies.join(", ")}`
+    : `All ${(content.length - 1).toString()} replies were sent successfully.`}`;
+};

server/src/routes/announcement.ts

@@ -11,6 +11,7 @@ import { announceOnDiscord } from "../modules/announceOnDiscord.js";
 import { announceOnFacebook } from "../modules/announceOnFacebook.js";
 import { announceOnMastodon } from "../modules/announceOnMastodon.js";
 import { announceOnReddit } from "../modules/announceOnReddit.js";
+import { announceOnThreads } from "../modules/announceOnThreads.js";
 import { announceOnTwitter } from "../modules/announceOnTwitter.js";
 import { generateAnnouncements } from "../modules/generateAnnouncements.js";
 import { getIpFromRequest } from "../modules/getIpFromRequest.js";
@@ -94,6 +95,7 @@ export const announcementRoutes: FastifyPluginAsync = async(server) => {
         facebook,
         mastodon,
         reddit,
+        threads,
         twitter,
       } = announcement.response;
       const { title: discordTitle, content: discordContent } = discord;
@@ -121,9 +123,10 @@ export const announcementRoutes: FastifyPluginAsync = async(server) => {
       const twitterPost = await announceOnTwitter(twitter);
       const facebookPost = await announceOnFacebook(facebook);
       const mastodonPost = await announceOnMastodon(mastodon);
+      const threadsPost = await announceOnThreads(threads);
       return await reply.status(201).send({
         cost:    announcement.cost,
-        message: `Announcement processed. Discord: ${discordPost}, Reddit: ${redditPost}, Bluesky: ${blueskyPost}, Twitter: ${twitterPost}, Facebook: ${facebookPost}, Mastodon: ${mastodonPost}`,
+        message: `Announcement processed. Discord: ${discordPost}, Reddit: ${redditPost}, Bluesky: ${blueskyPost}, Twitter: ${twitterPost}, Facebook: ${facebookPost}, Mastodon: ${mastodonPost}, Threads: ${threadsPost}`,
         rawPost: announcement.response,
       });
     },