Add QstashDailyRatelimitError

src/client/error.ts

@@ -12,12 +12,18 @@ export class QstashError extends Error {
 
 export class QstashRatelimitError extends QstashError {
   constructor(args: RateLimit) {
-    super(`You have been ratelimited. ${JSON.stringify(args)} `);
+    super(`Exceeded burst rate limit. ${JSON.stringify(args)} `);
   }
 }
 
 export class QstashChatRatelimitError extends QstashError {
   constructor(args: ChatRateLimit) {
-    super(`You have been ratelimited. ${JSON.stringify(args)} `);
+    super(`Exceeded chat rate limit. ${JSON.stringify(args)} `);
+  }
+}
+
+export class QstashDailyRatelimitError extends QstashError {
+  constructor(args: RateLimit) {
+    super(`Exceeded daily rate limit. ${JSON.stringify(args)} `);
   }
 }

src/client/http.ts

@@ -1,5 +1,10 @@
 /* eslint-disable @typescript-eslint/no-magic-numbers */
-import { QstashError, QstashRatelimitError, QstashChatRatelimitError } from "./error";
+import {
+  QstashError,
+  QstashRatelimitError,
+  QstashChatRatelimitError,
+  QstashDailyRatelimitError,
+} from "./error";
 import type { BodyInit, HeadersInit, RequestOptions } from "./types";
 import type { ChatCompletionChunk } from "./llm/types";
 
@@ -217,6 +222,12 @@ export class HttpClient implements Requester {
           "reset-requests": response.headers.get("x-ratelimit-reset-requests"),
           "reset-tokens": response.headers.get("x-ratelimit-reset-tokens"),
         });
+      } else if (response.headers.get("RateLimit-Limit")) {
+        throw new QstashDailyRatelimitError({
+          limit: response.headers.get("RateLimit-Limit"),
+          remaining: response.headers.get("RateLimit-Remaining"),
+          reset: response.headers.get("RateLimit-Reset"),
+        });
       }
 
       throw new QstashRatelimitError({