بناء وظائف متينة وسير عمل مبني على الأحداث مع Inngest و Next.js

npx create-next-app@latest inngest-saas --typescript --tailwind --eslint --app --src-dir --use-npm
cd inngest-saas

npm install inngest

// src/inngest/client.ts
import { Inngest } from "inngest";
 
export const inngest = new Inngest({
  id: "inngest-saas",
});

// src/inngest/client.ts
import { Inngest } from "inngest";
 
type Events = {
  "user/signup.completed": {
    data: {
      userId: string;
      email: string;
      name: string;
      plan: "free" | "pro" | "enterprise";
    };
  };
  "billing/subscription.created": {
    data: {
      userId: string;
      subscriptionId: string;
      plan: "pro" | "enterprise";
    };
  };
  "user/trial.started": {
    data: {
      userId: string;
      trialEndDate: string;
    };
  };
};
 
export const inngest = new Inngest({
  id: "inngest-saas",
  schemas: new EventSchemas().fromRecord<Events>(),
});

// src/app/api/inngest/route.ts
import { serve } from "inngest/next";
import { inngest } from "@/inngest/client";
import { provisionAccount } from "@/inngest/functions/provision-account";
import { sendWelcomeEmail } from "@/inngest/functions/send-welcome-email";
import { manageTrialWorkflow } from "@/inngest/functions/manage-trial";
import { dailyChurnReport } from "@/inngest/functions/daily-churn-report";
 
export const { GET, POST, PUT } = serve({
  client: inngest,
  functions: [
    provisionAccount,
    sendWelcomeEmail,
    manageTrialWorkflow,
    dailyChurnReport,
  ],
});

// src/inngest/functions/provision-account.ts
import { inngest } from "@/inngest/client";
 
export const provisionAccount = inngest.createFunction(
  {
    id: "provision-account",
    retries: 3,
  },
  { event: "user/signup.completed" },
  async ({ event, step }) => {
    // الخطوة 1: إنشاء سجل المستخدم في قاعدة البيانات
    const user = await step.run("create-user-record", async () => {
      console.log(`Creating user record for ${event.data.email}`);
      return {
        id: event.data.userId,
        email: event.data.email,
        name: event.data.name,
        plan: event.data.plan,
        createdAt: new Date().toISOString(),
      };
    });
 
    // الخطوة 2: إنشاء مساحة عمل افتراضية
    const workspace = await step.run("create-workspace", async () => {
      console.log(`Creating workspace for user ${user.id}`);
      return {
        workspaceId: `ws_${user.id}`,
        name: `${user.name}'s Workspace`,
      };
    });
 
    // الخطوة 3: زرع الإعدادات الافتراضية
    await step.run("seed-defaults", async () => {
      console.log(`Seeding defaults for workspace ${workspace.workspaceId}`);
      return { seeded: true };
    });
 
    // الخطوة 4: إرسال حدث بدء الفترة التجريبية
    await step.sendEvent("start-trial", {
      name: "user/trial.started",
      data: {
        userId: user.id,
        trialEndDate: new Date(
          Date.now() + 14 * 24 * 60 * 60 * 1000
        ).toISOString(),
      },
    });
 
    return { user, workspace, status: "provisioned" };
  }
);

// src/inngest/functions/send-welcome-email.ts
import { inngest } from "@/inngest/client";
 
export const sendWelcomeEmail = inngest.createFunction(
  {
    id: "send-welcome-email",
    retries: 5,
    throttle: {
      limit: 10,
      period: "1m",
    },
  },
  { event: "user/signup.completed" },
  async ({ event, step }) => {
    // الخطوة 1: تقديم قالب البريد
    const emailHtml = await step.run("render-template", async () => {
      return renderWelcomeTemplate({
        name: event.data.name,
        plan: event.data.plan,
      });
    });
 
    // الخطوة 2: الإرسال عبر مزود البريد
    const result = await step.run("send-email", async () => {
      console.log(`Sending welcome email to ${event.data.email}`);
      return {
        messageId: `msg_${Date.now()}`,
        to: event.data.email,
        status: "sent",
      };
    });
 
    // الخطوة 3: تسجيل حدث تحليلي
    await step.run("track-analytics", async () => {
      console.log(`Tracking welcome email sent for ${event.data.userId}`);
    });
 
    return result;
  }
);
 
function renderWelcomeTemplate(data: { name: string; plan: string }) {
  return `
    <h1>مرحبًا بك في تطبيق SaaS، ${data.name}!</h1>
    <p>أنت على خطة <strong>${data.plan}</strong>.</p>
    <p>فترتك التجريبية لمدة 14 يومًا تبدأ الآن. استكشف جميع الميزات!</p>
  `;
}

// src/inngest/functions/manage-trial.ts
import { inngest } from "@/inngest/client";
 
export const manageTrialWorkflow = inngest.createFunction(
  {
    id: "manage-trial-workflow",
    retries: 3,
    cancelOn: [
      {
        event: "billing/subscription.created",
        match: "data.userId",
      },
    ],
  },
  { event: "user/trial.started" },
  async ({ event, step }) => {
    const userId = event.data.userId;
    const trialEndDate = new Date(event.data.trialEndDate);
 
    // الخطوة 1: الانتظار 7 أيام ثم إرسال بريد منتصف الفترة التجريبية
    await step.sleep("wait-for-day-7", "7 days");
 
    await step.run("send-mid-trial-email", async () => {
      console.log(`Sending mid-trial reminder to user ${userId}`);
      return { sent: true, type: "mid-trial" };
    });
 
    // الخطوة 2: الانتظار حتى اليوم 13 (6 أيام إضافية)
    await step.sleep("wait-for-day-13", "6 days");
 
    await step.run("send-trial-ending-email", async () => {
      console.log(`Sending trial-ending warning to user ${userId}`);
      return { sent: true, type: "trial-ending" };
    });
 
    // الخطوة 3: الانتظار لليوم الأخير
    await step.sleep("wait-for-trial-end", "1 day");
 
    // الخطوة 4: التحقق مما إذا كان المستخدم قد تحول
    const hasSubscription = await step.run("check-subscription", async () => {
      console.log(`Checking if user ${userId} has converted`);
      return false;
    });
 
    if (!hasSubscription) {
      // الخطوة 5: تخفيض الرتبة إلى الخطة المجانية
      await step.run("downgrade-to-free", async () => {
        console.log(`Downgrading user ${userId} to free plan`);
        return { plan: "free" };
      });
 
      await step.run("send-downgrade-email", async () => {
        console.log(`Sending downgrade notification to user ${userId}`);
        return { sent: true, type: "downgraded" };
      });
    }
 
    return { userId, converted: hasSubscription };
  }
);

// src/inngest/functions/daily-churn-report.ts
import { inngest } from "@/inngest/client";
 
export const dailyChurnReport = inngest.createFunction(
  {
    id: "daily-churn-report",
  },
  { cron: "0 9 * * *" }, // كل يوم في الساعة 9:00 صباحًا
  async ({ step }) => {
    // الخطوة 1: استعلام المستخدمين المعرضين للخطر
    const atRiskUsers = await step.run("query-at-risk-users", async () => {
      console.log("Querying users with trials ending in 3 days...");
      return [
        { userId: "user_1", email: "alice@example.com", trialEndsIn: 2 },
        { userId: "user_2", email: "bob@example.com", trialEndsIn: 1 },
      ];
    });
 
    if (atRiskUsers.length === 0) {
      return { report: "لا يوجد مستخدمون معرضون للخطر اليوم" };
    }
 
    // الخطوة 2: تجميع التقرير
    const report = await step.run("compile-report", async () => {
      return {
        date: new Date().toISOString(),
        atRiskCount: atRiskUsers.length,
        users: atRiskUsers,
        summary: `${atRiskUsers.length} مستخدمين معرضين لخطر فقدان العملاء`,
      };
    });
 
    // الخطوة 3: الإرسال إلى Slack
    await step.run("notify-team", async () => {
      console.log(`Sending churn report to Slack: ${report.summary}`);
      return { notified: true };
    });
 
    return report;
  }
);

npx inngest-cli@latest dev

npm run dev

// src/app/api/auth/signup/route.ts
import { NextResponse } from "next/server";
import { inngest } from "@/inngest/client";
 
export async function POST(request: Request) {
  const body = await request.json();
  const { email, name, plan } = body;
 
  const userId = `user_${Date.now()}`;
 
  // أرسل حدث التسجيل — Inngest يتعامل مع الباقي
  await inngest.send({
    name: "user/signup.completed",
    data: {
      userId,
      email,
      name,
      plan: plan || "free",
    },
  });
 
  return NextResponse.json({ userId, status: "created" });
}

// src/inngest/functions/onboarding-with-verification.ts
import { inngest } from "@/inngest/client";
 
export const onboardingWithVerification = inngest.createFunction(
  {
    id: "onboarding-with-verification",
  },
  { event: "user/signup.completed" },
  async ({ event, step }) => {
    // الخطوة 1: إرسال بريد التحقق
    await step.run("send-verification-email", async () => {
      console.log(`Sending verification email to ${event.data.email}`);
      return { sent: true };
    });
 
    // الخطوة 2: الانتظار حتى 24 ساعة لتحقق المستخدم
    const verificationEvent = await step.waitForEvent(
      "wait-for-email-verification",
      {
        event: "user/email.verified",
        match: "data.userId",
        timeout: "24h",
      }
    );
 
    if (!verificationEvent) {
      // انتهت المهلة — المستخدم لم يتحقق
      await step.run("send-reminder", async () => {
        console.log(`User ${event.data.userId} did not verify — sending reminder`);
        return { reminded: true };
      });
      return { status: "unverified", reminded: true };
    }
 
    // المستخدم تحقق — متابعة الإعداد
    await step.run("activate-full-access", async () => {
      console.log(`User ${event.data.userId} verified — activating full access`);
      return { activated: true };
    });
 
    return { status: "verified", activated: true };
  }
);

// src/inngest/functions/sync-to-crm.ts
import { inngest } from "@/inngest/client";
 
export const syncToCRM = inngest.createFunction(
  {
    id: "sync-to-crm",
    concurrency: {
      limit: 5,
      key: "event.data.crmProvider",
    },
    retries: 10,
    backoff: {
      type: "exponential",
      minDelay: "1s",
      maxDelay: "5m",
    },
  },
  { event: "user/signup.completed" },
  async ({ event, step }) => {
    await step.run("push-to-crm", async () => {
      console.log(`Syncing user ${event.data.userId} to CRM`);
      return { synced: true };
    });
  }
);

// src/inngest/functions/__tests__/provision-account.test.ts
import { describe, it, expect } from "vitest";
 
describe("provisionAccount", () => {
  it("should create user and workspace", async () => {
    const mockEvent = {
      data: {
        userId: "test_user_1",
        email: "test@example.com",
        name: "Test User",
        plan: "free" as const,
      },
    };
 
    const user = {
      id: mockEvent.data.userId,
      email: mockEvent.data.email,
      name: mockEvent.data.name,
      plan: mockEvent.data.plan,
      createdAt: expect.any(String),
    };
 
    expect(user.email).toBe("test@example.com");
    expect(user.plan).toBe("free");
  });
});

# .env.production
INNGEST_SIGNING_KEY=signkey-prod-xxxxx
INNGEST_EVENT_KEY=eventkey-xxxxx

docker run -p 8288:8288 inngest/inngest:latest