Trigger.dev v4: مهام الخلفية وتدفقات الموافقة وأدوات الذكاء الاصطناعي في Next.js

npm install @trigger.dev/sdk
npx trigger.dev@latest init

// قبل (v3)
import { task } from "@trigger.dev/sdk/v3";
 
// بعد (v4)
import { task } from "@trigger.dev/sdk";

// trigger.config.ts
import { defineConfig } from "@trigger.dev/sdk/config";
 
export default defineConfig({
  project: "proj_معرف_مشروعك",
  runtime: "node",
  maxDuration: 3600,
  dirs: ["./trigger"],
});

TRIGGER_SECRET_KEY=tr_dev_xxxxxxxxxxxx

// trigger/document-tasks.ts
import { task, logger } from "@trigger.dev/sdk";
 
export const ingestDocument = task({
  id: "ingest-document",
 
  // v4: معامل كائن واحد مُفكَّك لجميع الـ hooks
  onStartAttempt: ({ payload, ctx }) => {
    logger.info("بدء محاولة الاستيعاب", { runId: ctx.run.id });
  },
 
  onSuccess: ({ payload, output, ctx }) => {
    logger.info("نجح الاستيعاب", { docId: output.documentId });
  },
 
  onFailure: ({ payload, error, ctx }) => {
    logger.error("فشل الاستيعاب", { message: error.message });
  },
 
  // توقيع run() لم يتغير عن v3
  run: async (payload: { filename: string; url: string }, { ctx }) => {
    logger.info("معالجة المستند", { filename: payload.filename });
 
    await new Promise(resolve => setTimeout(resolve, 1000));
 
    return {
      documentId: `doc_${Date.now()}`,
      filename: payload.filename,
      status: "ingested",
    };
  },
});

// app/actions/document.ts
"use server";
 
import { tasks } from "@trigger.dev/sdk";
import type { ingestDocument } from "@/trigger/document-tasks";
 
export async function submitDocument(filename: string, url: string) {
  try {
    const handle = await tasks.trigger<typeof ingestDocument>(
      "ingest-document",
      { filename, url }
    );
    return { runId: handle.id };
  } catch (error) {
    return { error: "فشل إضافة المستند إلى قائمة الانتظار" };
  }
}

// app/api/documents/route.ts
import { tasks } from "@trigger.dev/sdk";
import { NextResponse } from "next/server";
import type { ingestDocument } from "@/trigger/document-tasks";
 
export async function POST(request: Request) {
  const { filename, url } = await request.json();
 
  const handle = await tasks.trigger<typeof ingestDocument>(
    "ingest-document",
    { filename, url }
  );
 
  return NextResponse.json({ runId: handle.id });
}

// trigger/analysis-tasks.ts
import { task, queue } from "@trigger.dev/sdk";
 
const processingQueue = queue({
  name: "document-processing",
  concurrencyLimit: 5,
});
 
export const analyzeDocument = task({
  id: "analyze-document",
  queue: processingQueue,
 
  retry: {
    maxAttempts: 3,
    minTimeoutInMs: 1000,
    maxTimeoutInMs: 30000,
    factor: 2,
  },
 
  run: async (payload: { documentId: string; url: string }) => {
    const text = await fetch(payload.url).then(r => r.text());
    const wordCount = text.split(/\s+/).length;
 
    return {
      documentId: payload.documentId,
      wordCount,
      extractedAt: new Date().toISOString(),
    };
  },
});

// توجيه المستخدمين المميزين إلى قائمة انتظار بتزامن أعلى
const handle = await analyzeDocument.trigger(
  { documentId, url },
  { queue: "premium-users" }
);

// trigger/approval-tasks.ts
import { task, wait } from "@trigger.dev/sdk";
 
export const awaitDocumentApproval = task({
  id: "await-document-approval",
  maxDuration: 86400, // توقف مؤقت حتى 24 ساعة
 
  run: async (payload: { documentId: string; reviewerEmail: string }) => {
    // إنشاء رمز مرتبط بهذه التشغيلة
    const token = await wait.createToken({
      timeout: "24h",
      tags: [`doc:${payload.documentId}`],
    });
 
    // إرسال بريد إلكتروني يحتوي على رابط يتضمن token.id
    await notifyReviewer(payload.reviewerEmail, payload.documentId, token.id);
 
    // المهمة تتوقف هنا — تستأنف عند اكتمال الرمز
    const result = await wait.forToken<{ approved: boolean; notes: string }>(token);
 
    if (!result.output.approved) {
      throw new Error(`رُفض المستند: ${result.output.notes}`);
    }
 
    return { approved: true, notes: result.output.notes };
  },
});
 
async function notifyReviewer(email: string, docId: string, tokenId: string) {
  // إرسال بريد مع رابط: /api/review?token=tokenId&doc=docId
  console.log(`تم إرسال رابط الموافقة إلى ${email} للمستند ${docId}`);
}

// app/api/review/route.ts
import { runs } from "@trigger.dev/sdk";
import { NextResponse } from "next/server";
 
export async function POST(request: Request) {
  const { tokenId, approved, notes } = await request.json();
 
  // إكمال نقطة الانتظار — المهمة تستأنف فوراً
  await runs.completeToken(tokenId, { approved, notes });
 
  return NextResponse.json({ ok: true });
}

// trigger/ai-tasks.ts
import { schemaTask } from "@trigger.dev/sdk";
import { z } from "zod";
 
export const summarizeDocument = schemaTask({
  id: "summarize-document",
  description: "استخراج ملخص والموضوعات الرئيسية من رابط مستند",
  schema: z.object({
    documentId: z.string(),
    url: z.string().url(),
    maxWords: z.number().int().min(50).max(500).default(200),
  }),
  run: async ({ documentId, url, maxWords }) => {
    const text = await fetch(url).then(r => r.text());
    const words = text.split(/\s+/).slice(0, maxWords);
    return {
      documentId,
      summary: words.join(" "),
      topicCount: Math.min(3, Math.floor(words.length / 50)),
    };
  },
});

// lib/document-agent.ts
import { generateText, tool } from "ai";
import { anthropic } from "@ai-sdk/anthropic";
import { ai } from "@trigger.dev/sdk/ai";
import { summarizeDocument } from "@/trigger/ai-tasks";
 
const summarizeTool = tool({
  description: summarizeDocument.description ?? "تلخيص مستند",
  inputSchema: summarizeDocument.schema!,
  execute: ai.toolExecute(summarizeDocument),
});
 
export async function runDocumentAgent(userPrompt: string) {
  const { text } = await generateText({
    model: anthropic("claude-sonnet-5"),
    prompt: userPrompt,
    tools: { summarizeDocument: summarizeTool },
    maxSteps: 5,
  });
  return text;
}

// trigger/scheduled-tasks.ts
import { schedules } from "@trigger.dev/sdk";
 
export const dailyCleanup = schedules.task({
  id: "daily-cleanup",
  cron: "0 2 * * *", // 02:00 UTC كل يوم
 
  run: async (payload) => {
    const { timestamp, lastTimestamp } = payload;
 
    const cutoff = new Date(timestamp);
    cutoff.setDate(cutoff.getDate() - 30);
 
    // payload.lastTimestamp غير معرّف في التشغيل الأول
    const since = lastTimestamp ?? cutoff;
 
    const deleted = await deleteDocumentsOlderThan(cutoff);
    return { deleted, runAt: timestamp.toISOString(), since: since.toISOString() };
  },
});
 
async function deleteDocumentsOlderThan(cutoff: Date): Promise<number> {
  // استعلام قاعدة البيانات هنا
  return 0;
}

// trigger/monitored-task.ts
import { task, logger } from "@trigger.dev/sdk";
 
export const monitoredTask = task({
  id: "monitored-task",
 
  // تُطلَق عند دخول التشغيلة في نقطة انتظار
  onWait: ({ payload, ctx }) => {
    logger.info("المهمة متوقفة مؤقتاً عند نقطة انتظار", { runId: ctx.run.id });
  },
 
  // تُطلَق عند حل نقطة الانتظار واستئناف التشغيلة
  onResume: ({ payload, ctx }) => {
    logger.info("المهمة استؤنفت من نقطة الانتظار", { runId: ctx.run.id });
  },
 
  // تُطلَق بعد العودة الناجحة من دالة run
  onComplete: ({ payload, output, ctx }) => {
    logger.info("اكتملت المهمة", { runId: ctx.run.id, output });
  },
 
  // تُطلَق عند إلغاء التشغيلة عبر لوحة التحكم أو API
  onCancel: ({ payload, ctx }) => {
    logger.warn("تم إلغاء المهمة", { runId: ctx.run.id });
  },
 
  run: async (payload: { documentId: string }) => {
    return { processed: payload.documentId };
  },
});

import { tasks, batch } from "@trigger.dev/sdk";
import type { ingestDocument } from "@/trigger/document-tasks";
 
const documents = [
  { filename: "تقرير-أ.pdf", url: "https://example.com/a.pdf" },
  { filename: "تقرير-ب.pdf", url: "https://example.com/b.pdf" },
  { filename: "تقرير-ج.pdf", url: "https://example.com/c.pdf" },
];
 
const batchHandle = await tasks.batchTrigger(
  documents.map(doc => [ingestDocument, doc] as const)
);
 
// v3: batchHandle.runs — مُزال في v4
// v4: استرجاع منفصل
const batchResult = await batch.retrieve(batchHandle.batchId);
console.log(`تم إضافة ${batchResult.runs.length} تشغيلات إلى قائمة الانتظار`);

npx trigger.dev@latest dev

npx trigger.dev@latest deploy

- name: نشر مهام Trigger.dev
  run: npx trigger.dev@latest deploy --ci
  env:
    TRIGGER_SECRET_KEY: ${{ secrets.TRIGGER_SECRET_KEY }}