Merge pull request #16 from getlate-dev/fix/error-handling-account-validation

Fix: error handling and account validation for post operations

Author: PauGuirao

late/resources/posts.ts

@@ -1,5 +1,5 @@
 import type { LateResourceModule } from "../types";
-import { postsCreatePreSend, postsUpdatePreSend } from "../utils/routingHooks";
+import { postsCreatePreSend, postsUpdatePreSend, handleApiErrorResponse } from "../utils/routingHooks";
 import {
   buildPlatformSelector,
   buildAccountSelectors,
@@ -46,10 +46,15 @@ export const postsResource: LateResourceModule = {
         request: {
           method: "POST",
           url: "/posts",
+          ignoreHttpStatusErrors: true,
+          returnFullResponse: true,
         },
         send: {
           preSend: [postsCreatePreSend],
         },
+        output: {
+          postReceive: [handleApiErrorResponse],
+        },
       },
     },
     {
@@ -60,10 +65,15 @@ export const postsResource: LateResourceModule = {
         request: {
           method: "PUT",
           url: "=/posts/{{ $parameter.postId }}",
+          ignoreHttpStatusErrors: true,
+          returnFullResponse: true,
         },
         send: {
           preSend: [postsUpdatePreSend],
         },
+        output: {
+          postReceive: [handleApiErrorResponse],
+        },
       },
     },
     {
@@ -74,6 +84,11 @@ export const postsResource: LateResourceModule = {
         request: {
           method: "DELETE",
           url: "=/posts/{{ $parameter.postId }}",
+          ignoreHttpStatusErrors: true,
+          returnFullResponse: true,
+        },
+        output: {
+          postReceive: [handleApiErrorResponse],
         },
       },
     },
@@ -85,6 +100,11 @@ export const postsResource: LateResourceModule = {
         request: {
           method: "POST",
           url: "=/posts/{{ $parameter.postId }}/retry",
+          ignoreHttpStatusErrors: true,
+          returnFullResponse: true,
+        },
+        output: {
+          postReceive: [handleApiErrorResponse],
         },
       },
     },
@@ -107,6 +127,8 @@ export const postsResource: LateResourceModule = {
         request: {
           method: "POST",
           url: "/posts/bulk-upload",
+          ignoreHttpStatusErrors: true,
+          returnFullResponse: true,
           headers: {
             "Content-Type": "multipart/form-data",
           },
@@ -117,6 +139,9 @@ export const postsResource: LateResourceModule = {
             file: "={{ { value: $parameter.csvFile, options: { filename: 'bulk-upload.csv', contentType: 'text/csv' } } }}",
           },
         },
+        output: {
+          postReceive: [handleApiErrorResponse],
+        },
       },
     },
   ],

late/utils/platformHelpers.ts

@@ -83,15 +83,15 @@ export async function loadPlatformAccounts(
     );
 
     if (!response?.accounts) {
-      return [{ name: `No ${platform} accounts found`, value: "none" }];
+      return [{ name: `No ${platform} accounts found - connect at getlate.dev first`, value: "none" }];
     }
 
     const platformAccounts = response.accounts.filter(
       (account: PlatformAccount) => account.platform === platform
     );
 
     if (platformAccounts.length === 0) {
-      return [{ name: `No ${platform} accounts connected`, value: "none" }];
+      return [{ name: `No ${platform} accounts connected - connect at getlate.dev first`, value: "none" }];
     }
 
     const platformConfig = SUPPORTED_PLATFORMS.find(
@@ -108,7 +108,7 @@ export async function loadPlatformAccounts(
       (error as any)?.cause?.code === "ECONNREFUSED"
         ? "Cannot connect to LATE API. Please check your internet connection."
         : (error as Error).message || "Failed to load accounts";
-    return [{ name: `Error: ${errorMsg}`, value: "error" }];
+    return [{ name: `Connection error: ${errorMsg} - check API key`, value: "error" }];
   }
 }
 

late/utils/routingHooks.ts

@@ -4,6 +4,35 @@ import { processParametersWithExpressions } from "./expressionProcessor";
  * Utility functions for routing hooks that process expressions
  */
 
+/**
+ * Post-receive hook that surfaces API error messages in n8n UI.
+ * Requires ignoreHttpStatusErrors: true and returnFullResponse: true on the request.
+ */
+export async function handleApiErrorResponse(
+  this: any,
+  items: any[],
+  responseData: any,
+): Promise<any[]> {
+  const statusCode = responseData?.statusCode;
+  if (statusCode && statusCode >= 400) {
+    const body = responseData.body;
+    let errorMessage = `LATE API Error (${statusCode})`;
+
+    if (typeof body === 'object' && body !== null) {
+      if (body.error) errorMessage += `: ${body.error}`;
+      if (body.details) {
+        errorMessage += ` - ${typeof body.details === 'string' ? body.details : JSON.stringify(body.details)}`;
+      }
+      if (body.code) errorMessage += ` [${body.code}]`;
+    } else if (typeof body === 'string') {
+      errorMessage += `: ${body}`;
+    }
+
+    throw new Error(errorMessage);
+  }
+  return items;
+}
+
 /**
  * Builds the platforms array from selected platforms and accounts
  */
@@ -24,10 +53,12 @@ function buildPlatformsArray(
         itemIndex,
         []
       ) as string[];
-      return accounts.map((id: string) => ({
-        platform,
-        accountId: id,
-      }));
+      return accounts
+        .filter((id: string) => id && id !== "none" && id !== "error" && id.length === 24)
+        .map((id: string) => ({
+          platform,
+          accountId: id,
+        }));
     })
     .flat();
 }
@@ -103,14 +134,26 @@ export async function postsCreatePreSend(
     0
   );
 
+  // Build platforms and validate before sending
+  const platforms = buildPlatformsArray(this, 0);
+  const publishNow = this.getNodeParameter("publishNow", 0, false);
+  const isDraft = this.getNodeParameter("isDraft", 0, false);
+
+  if (!isDraft && platforms.length === 0) {
+    throw new Error(
+      'No valid accounts selected. Please select at least one account for each platform you want to post to. ' +
+      'If no accounts appear in the dropdown, make sure you have connected accounts in your LATE dashboard (https://getlate.dev).'
+    );
+  }
+
   // Build the body with processed parameters
   requestOptions.body = {
     content: this.getNodeParameter("content", 0),
-    platforms: buildPlatformsArray(this, 0),
+    platforms,
     scheduledFor: this.getNodeParameter("scheduledFor", 0, undefined),
     timezone: this.getNodeParameter("timezone", 0, "UTC"),
-    publishNow: this.getNodeParameter("publishNow", 0, false),
-    isDraft: this.getNodeParameter("isDraft", 0, false),
+    publishNow,
+    isDraft,
     visibility: this.getNodeParameter("visibility", 0, "public"),
     tags: buildTagsArray(this, 0),
     mediaItems: processedParams.mediaItems?.items || [],