fix(bluesky): add missing catch; add some debug logs

src/services/bluesky-sender.service.ts

@@ -110,6 +110,10 @@ export const blueskySenderService = async (
    * If the tweet is long, each child chunk will reference the previous one as replyId.
    */
   for (const chunk of post.chunks) {
+    if (DEBUG) {
+      console.log("bluesky post chunk: ", chunk);
+    }
+
     const richText = new bsky.RichText({ text: chunk });
     await richText.detectFacets(client);
 
@@ -220,43 +224,46 @@ export const blueskySenderService = async (
     log.text = `☁️ | post sending: ${getPostExcerpt(post.tweet.text ?? VOID)}`;
 
     // Post
-    await client.post({ ...data }).then(async (createdPost) => {
-      oraProgress(
-        log,
-        { before: "☁️ | post sending: " },
-        chunkIndex,
-        post.chunks.length,
-      );
-
-      // Save post ID to be able to reference it while posting the next chunk.
-      const RKEY_REGEX = /\/(?<rkey>\w+)$/;
-      chunkReferences.push({
-        cid: createdPost.cid,
-        uri: createdPost.uri,
-        rkey: RKEY_REGEX.exec(createdPost.uri)?.groups?.["rkey"] ?? "",
-      });
-
-      // If this is the last chunk, save the all chunks ID to the cache.
-      if (chunkIndex === post.chunks.length - 1) {
-        log.succeed(
-          `☁️ | post sent: ${getPostExcerpt(post.tweet.text ?? VOID)}${
-            chunkReferences.length > 1
-              ? ` (${chunkReferences.length} chunks)`
-              : ""
-          }`,
+    await client
+      .post({ ...data })
+      .then(async (createdPost) => {
+        oraProgress(
+          log,
+          { before: "☁️ | post sending: " },
+          chunkIndex,
+          post.chunks.length,
         );
 
-        await savePostToCache({
-          tweetId: post.tweet.id,
-          data: chunkReferences.map((ref) => ({
-            rkey: ref.rkey,
-            cid: ref.cid,
-          })),
-          platform: Platform.BLUESKY,
+        // Save post ID to be able to reference it while posting the next chunk.
+        const RKEY_REGEX = /\/(?<rkey>\w+)$/;
+        chunkReferences.push({
+          cid: createdPost.cid,
+          uri: createdPost.uri,
+          rkey: RKEY_REGEX.exec(createdPost.uri)?.groups?.["rkey"] ?? "",
         });
-      }
 
-      chunkIndex++;
-    });
+        // If this is the last chunk, save the all chunks ID to the cache.
+        if (chunkIndex === post.chunks.length - 1) {
+          log.succeed(
+            `☁️ | post sent: ${getPostExcerpt(post.tweet.text ?? VOID)}${
+              chunkReferences.length > 1
+                ? ` (${chunkReferences.length} chunks)`
+                : ""
+            }`,
+          );
+
+          await savePostToCache({
+            tweetId: post.tweet.id,
+            data: chunkReferences.map((ref) => ({
+              rkey: ref.rkey,
+              cid: ref.cid,
+            })),
+            platform: Platform.BLUESKY,
+          });
+        }
+
+        chunkIndex++;
+      })
+      .catch((err) => log.fail(err));
   }
 };

src/services/mastodon-sender.service.ts

@@ -1,7 +1,7 @@
 import { mastodon } from "masto";
 import { Ora } from "ora";
 
-import { VOID } from "../constants.js";
+import { DEBUG, VOID } from "../constants.js";
 import { savePostToCache } from "../helpers/cache/save-post-to-cache.js";
 import { oraProgress } from "../helpers/logs/index.js";
 import { getPostExcerpt } from "../helpers/post/get-post-excerpt.js";
@@ -92,6 +92,10 @@ export const mastodonSenderService = async (
    * If the tweet is long, each child chunk will reference the previous one as replyId.
    */
   for (const chunk of post.chunks) {
+    if (DEBUG) {
+      console.log("mastodon post chunk: ", chunk);
+    }
+
     await client.v1.statuses
       .create({
         status: chunk,