Better handle retrying rate-limited resend requests (#320)

* Better handle retrying rate-limited resend requests

* Better handle Retrying  Rate Request

* update try of better handle Resend Email retry

* added  retry options for when  the onError callback returns undefined

* Changed header to ratelimit-reset

* Create three-pots-flow.md

---------

Co-authored-by: Matt Aitken <matt@mattaitken.com>

Author: Akshay-Patel-dev

.changeset/three-pots-flow.md

@@ -0,0 +1,5 @@
+---
+"@trigger.dev/resend": patch
+---
+
+Better handle retrying rate-limited resend requests

integrations/resend/package.json

@@ -26,7 +26,7 @@
   "dependencies": {
     "@trigger.dev/integration-kit": "workspace:^2.0.14",
     "@trigger.dev/sdk": "workspace:^2.0.14",
-    "resend": "^0.9.1"
+    "resend": "^1.0.0"
   },
   "engines": {
     "node": ">=16.8.0"

integrations/resend/src/ErrorInterface.ts

@@ -0,0 +1,14 @@
+import type { RESEND_ERROR_CODE_KEY } from "resend/build/src/interfaces";
+import type {RESEND_ERROR_CODE_NUMBER}  from "resend/build/src/interfaces";
+
+
+interface ErrorResponse extends Error {
+        message: string;
+        status: RESEND_ERROR_CODE_NUMBER;
+        type: RESEND_ERROR_CODE_KEY;
+        response: {
+            headers: { [key: string]: string };
+          };
+}
+
+export type { ErrorResponse };

integrations/resend/src/index.ts

@@ -1,17 +1,44 @@
 import type { IntegrationClient, TriggerIntegration } from "@trigger.dev/sdk";
 import { Resend as ResendClient } from "resend";
+import {ErrorResponse} from "./ErrorInterface"
 
 import type { AuthenticatedTask } from "@trigger.dev/sdk";
 
 type SendEmailData = Parameters<InstanceType<typeof ResendClient>["sendEmail"]>[0];
 
 type SendEmailResponse = { id: string };
 
+function isRequestError(error: unknown): error is ErrorResponse {
+  return typeof error === "object" && error !== null && "status" in error;
+}
+
+function onError(error: unknown) {
+  console.log(error);
+  if (!isRequestError(error)) {
+    return;
+  }
+
+  // Check if this is a rate limit error
+  if (error.status === 429) {
+    const rateLimitReset = error.response.headers["ratelimit-reset"];
+
+    if (rateLimitReset) {
+      const resetDate = new Date(Number(rateLimitReset) * 1000);
+
+      return {
+        retryAt: resetDate,
+        error,
+      };
+    } 
+  }
+}
+
 export const sendEmail: AuthenticatedTask<
   InstanceType<typeof ResendClient>,
   SendEmailData,
   SendEmailResponse
 > = {
+  onError,
   run: async (params, client) => {
     return client.sendEmail(params) as Promise<SendEmailResponse>;
   },