Merge branch 'main' into 194-sdk-ci-pipeline-for-publishing-pythonnode-sdk

apps/api/src/services/notification/email_notification.ts

@@ -3,9 +3,6 @@ import { withAuth } from "../../lib/withAuth";
 import { Resend } from "resend";
 import { NotificationType } from "../../types";
 
-
-
-
 const emailTemplates: Record<
   NotificationType,
   { subject: string; html: string }
@@ -15,12 +12,13 @@ const emailTemplates: Record<
     html: "Hey there,<br/><p>You are approaching your credit limit for this billing period. Your usage right now is around 80% of your total credit limit. Consider upgrading your plan to avoid hitting the limit. Check out our <a href='https://firecrawl.dev/pricing'>pricing page</a> for more info.</p><br/>Thanks,<br/>Firecrawl Team<br/>",
   },
   [NotificationType.LIMIT_REACHED]: {
-    subject: "Credit Limit Reached! Take action now to resume usage - Firecrawl",
+    subject:
+      "Credit Limit Reached! Take action now to resume usage - Firecrawl",
     html: "Hey there,<br/><p>You have reached your credit limit for this billing period. To resume usage, please upgrade your plan. Check out our <a href='https://firecrawl.dev/pricing'>pricing page</a> for more info.</p><br/>Thanks,<br/>Firecrawl Team<br/>",
   },
   [NotificationType.RATE_LIMIT_REACHED]: {
     subject: "Rate Limit Reached - Firecrawl",
-    html: "Hey there,<br/><p>You've hit your Firecrawl rate limit! Take a breather and try again in a few moments. If you need higher rate limits, consider upgrading your plan. Check out our <a href='https://firecrawl.dev/pricing'>pricing page</a> for more info.</p><p>If you have any questions, feel free to reach out to us at <a href='mailto:hello@firecrawl.com'>hello@firecrawl.com</a></p><br/>Thanks,<br/>Firecrawl Team<br/><br/>Ps. this email is only sent once every 7 days if you reach the limit.",
+    html: "Hey there,<br/><p>You've hit one of the Firecrawl endpoint's rate limit! Take a breather and try again in a few moments. If you need higher rate limits, consider upgrading your plan. Check out our <a href='https://firecrawl.dev/pricing'>pricing page</a> for more info.</p><p>If you have any questions, feel free to reach out to us at <a href='mailto:hello@firecrawl.com'>hello@firecrawl.com</a></p><br/>Thanks,<br/>Firecrawl Team<br/><br/>Ps. this email is only sent once every 7 days if you reach a rate limit.",
   },
 };
 
@@ -42,7 +40,7 @@ async function sendEmailNotification(
   email: string,
   notificationType: NotificationType
 ) {
-const resend = new Resend(process.env.RESEND_API_KEY);
+  const resend = new Resend(process.env.RESEND_API_KEY);
 
   try {
     const { data, error } = await resend.emails.send({
@@ -69,6 +67,9 @@ export async function sendNotificationInternal(
   startDateString: string,
   endDateString: string
 ): Promise<{ success: boolean }> {
+  if (team_id === "preview") {
+    return { success: true };
+  }
   const { data, error } = await supabase_service
     .from("user_notifications")
     .select("*")

apps/api/src/services/rate-limiter.ts

@@ -4,6 +4,7 @@ import { RateLimiterMode } from "../../src/types";
 
 const RATE_LIMITS = {
   crawl: {
+    default: 3,
     free: 2,
     starter: 3,
     standard: 5,
@@ -14,6 +15,7 @@ const RATE_LIMITS = {
     growth: 50,
   },
   scrape: {
+    default: 20,
     free: 5,
     starter: 20,
     standard: 50,
@@ -24,6 +26,7 @@ const RATE_LIMITS = {
     growth: 500,
   },
   search: {
+    default: 20,
     free: 5,
     starter: 20,
     standard: 40,
@@ -33,10 +36,18 @@ const RATE_LIMITS = {
     standardNew: 50,
     growth: 500,
   },
-  preview: 5,
-  account: 20,
-  crawlStatus: 150,
-  testSuite: 10000,
+  preview: {
+    default: 5,
+  },
+  account: {
+    default: 20,
+  },
+  crawlStatus: {
+    default: 150,
+  },
+  testSuite: {
+    default: 10000,
+  },
 };
 
 export const redisClient = redis.createClient({
@@ -44,30 +55,46 @@ export const redisClient = redis.createClient({
   legacyMode: true,
 });
 
-const createRateLimiter = (keyPrefix, points) => new RateLimiterRedis({
-  storeClient: redisClient,
-  keyPrefix,
-  points,
-  duration: 60, // Duration in seconds
-});
+const createRateLimiter = (keyPrefix, points) =>
+  new RateLimiterRedis({
+    storeClient: redisClient,
+    keyPrefix,
+    points,
+    duration: 60, // Duration in seconds
+  });
 
-export const previewRateLimiter = createRateLimiter("preview", RATE_LIMITS.preview);
-export const serverRateLimiter = createRateLimiter("server", RATE_LIMITS.account);
-export const crawlStatusRateLimiter = createRateLimiter("crawl-status", RATE_LIMITS.crawlStatus);
-export const testSuiteRateLimiter = createRateLimiter("test-suite", RATE_LIMITS.testSuite);
+export const previewRateLimiter = createRateLimiter(
+  "preview",
+  RATE_LIMITS.preview
+);
+export const serverRateLimiter = createRateLimiter(
+  "server",
+  RATE_LIMITS.account
+);
+export const crawlStatusRateLimiter = createRateLimiter(
+  "crawl-status",
+  RATE_LIMITS.crawlStatus
+);
+export const testSuiteRateLimiter = createRateLimiter(
+  "test-suite",
+  RATE_LIMITS.testSuite
+);
 
-export function getRateLimiter(mode: RateLimiterMode, token: string, plan?: string) {
+export function getRateLimiter(
+  mode: RateLimiterMode,
+  token: string,
+  plan?: string
+) {
   if (token.includes("a01ccae") || token.includes("6254cf9")) {
     return testSuiteRateLimiter;
   }
-  
 
-  const rateLimitConfig = RATE_LIMITS[mode];
+  const rateLimitConfig = RATE_LIMITS[mode]; // {default : 5}
   if (!rateLimitConfig) return serverRateLimiter;
 
-  const planKey = plan ? plan.replace("-", "") : "starter";
-  const points = rateLimitConfig[planKey] || rateLimitConfig.preview;
+  const planKey = plan ? plan.replace("-", "") : "default"; // "default"
+  const points =
+    rateLimitConfig[planKey] || rateLimitConfig.default || rateLimitConfig; // 5
 
-  
   return createRateLimiter(`${mode}-${planKey}`, points);
 }