Add a reference project that showcases the new waitpoint primitive

This reference project shows a possible approach to implement workflows using Trigger.dev and ReactFlow. It makes use of the Trigger.dev Realtime API and the new waitpoint primitive to implement a human-in-the-loop approach for approving the result of an AI workflow.

Author: myftija

pnpm-lock.yaml

@@ -3,7 +3,7 @@ import { rscExtension } from "@trigger.dev/rsc";
 import { AISDKExporter } from "langsmith/vercel";
 
 export default defineConfig({
-  project: "proj_bzhdaqhlymtuhlrcgbqy",
+  project: "proj_jlodmrnldlncmkmscdyu",
   dirs: ["./src/trigger"],
   telemetry: {
     exporters: [new AISDKExporter()],

references/nextjs-realtime/trigger.config.ts

@@ -0,0 +1,11 @@
+TRIGGER_SECRET_KEY=
+TRIGGER_API_URL=
+NEXT_PUBLIC_TRIGGER_API_URL=
+OPENAI_API_KEY=
+ELEVENLABS_API_KEY=
+AWS_ACCESS_KEY_ID=
+AWS_SECRET_ACCESS_KEY=
+AWS_ENDPOINT_URL_S3=
+AWS_ENDPOINT_URL_IAM=
+AWS_REGION=
+SLACK_WEBHOOK_URL=

references/waitpoint-tokens/.env.example

@@ -0,0 +1,44 @@
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+/.pnp
+.pnp.*
+.yarn/*
+!.yarn/patches
+!.yarn/plugins
+!.yarn/releases
+!.yarn/versions
+
+# testing
+/coverage
+
+# next.js
+/.next/
+/out/
+
+# production
+/build
+
+# misc
+.DS_Store
+*.pem
+
+# debug
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+.pnpm-debug.log*
+
+# env files (can opt-in for committing if needed)
+.env*
+!.env.example
+
+# vercel
+.vercel
+
+# typescript
+*.tsbuildinfo
+next-env.d.ts
+
+.trigger

references/waitpoint-tokens/.gitignore

@@ -0,0 +1,64 @@
+# An AI workflow with a human-in-the-loop approval step
+
+This reference project shows a possible approach to implement workflows using Trigger.dev and [ReactFlow](https://reactflow.dev/).
+It makes use of the Trigger.dev Realtime API and the new waitpoint token feature to implement a human-in-the-loop workflow.
+
+## Getting Started
+
+This guide assumes that you have followed the [Contributing.md](https://github.com/triggerdotdev/trigger.dev/blob/main/CONTRIBUTING.md#setup) instructions to set up a local Trigger.dev instance. If not, please complete the setup before continuing.
+
+1. Run the main Trigger.dev webapp:
+
+    ```bash
+    pnpm run dev --filter webapp
+    ```
+
+2. Optionally, build the CLI and SDK if you are working on them and applying changes:
+
+    ```bash
+    pnpm run dev --filter trigger.dev --filter "@trigger.dev/*"
+    ```
+
+3. Login with the CLI:
+
+    ```bash
+    cd references/trigger-flow
+    pnpm exec trigger login -a http://localhost:3030
+    ```
+
+    Optionally, you can use the `profile` flag to create a new profile:
+
+    ```bash
+    pnpm exec trigger login -a http://localhost:3030 --profile local
+    ```
+
+    Note that you'll need to use this profile for the subsequent commands.
+
+4. Run the CLI
+
+    ```bash
+    pnpm exec trigger dev
+    ```
+
+    You should see now the `dev` command spitting out messages, including that it's started a background worker.
+
+5. Run the Trigger Flow app:
+
+    ```bash
+    pnpm run dev
+    ```
+
+    Open [http://localhost:3000](http://localhost:3000) on your browser to checkout the workflow.
+
+## Learn More
+
+To learn more about the technologies used in this project, check out the following resources:
+
+- [Trigger.dev Docs](https://trigger.dev/docs) - learn about Trigger.dev and its features
+- [Trigger.dev Waitpoint Token Docs](https://trigger.dev/docs/wait-for-token) - learn about waitpoint tokens in Trigger.dev and human-in-the-loop flows
+- [Trigger.dev Realtime Docs](https://trigger.dev/docs/realtime) - learn about the Realtime feature of Trigger.dev
+- [Trigger.dev Realtime Streams](https://trigger.dev/docs/realtime/streams) - learn about the different types of streams available in Trigger.dev
+- [ReactFlow Docs](https://reactflow.dev/learn) - learn about building interactive diagrams using ReactFlow
+- [React Hooks for Trigger.dev](https://trigger.dev/docs/frontend/react-hooks) - learn about the React hooks provided by Trigger.dev
+- [ElevenLabs SDK](https://elevenlabs.io/docs/overview) - learn about ElevenLabs' AI audio capabilities
+- [AI SDK Documentation](https://sdk.vercel.ai/docs/introduction) - learn about the AI SDK for working with LLMs

references/waitpoint-tokens/README.md

@@ -0,0 +1,7 @@
+import type { NextConfig } from "next";
+
+const nextConfig: NextConfig = {
+  /* config options here */
+};
+
+export default nextConfig;

references/waitpoint-tokens/next.config.ts

@@ -0,0 +1,41 @@
+{
+  "name": "waitpoint-tokens",
+  "version": "0.1.0",
+  "private": true,
+  "scripts": {
+    "dev": "next dev --turbopack",
+    "trigger:dev": "trigger dev",
+    "build": "next build",
+    "start": "next start",
+    "lint": "next lint"
+  },
+  "dependencies": {
+    "@ai-sdk/openai": "^1.3.4",
+    "@aws-sdk/client-s3": "^3.777.0",
+    "@aws-sdk/s3-request-presigner": "^3.777.0",
+    "@trigger.dev/react-hooks": "workspace:*",
+    "@trigger.dev/sdk": "workspace:*",
+    "@xyflow/react": "^12.4.4",
+    "ai": "^4.2.8",
+    "clsx": "^2.1.1",
+    "elevenlabs": "^1.55.0",
+    "html-to-text": "^9.0.5",
+    "lucide-react": "^0.484.0",
+    "next": "15.2.4",
+    "react": "^19.0.0",
+    "react-dom": "^19.0.0",
+    "react-tippy": "^1.4.0",
+    "tailwind-merge": "^3.2.0"
+  },
+  "devDependencies": {
+    "@tailwindcss/postcss": "^4",
+    "@trigger.dev/build": "workspace:*",
+    "@types/html-to-text": "^9.0.4",
+    "@types/node": "^20",
+    "@types/react": "^19",
+    "@types/react-dom": "^19",
+    "tailwindcss": "^4",
+    "trigger.dev": "workspace:*",
+    "typescript": "^5"
+  }
+}

references/waitpoint-tokens/package.json

@@ -0,0 +1,5 @@
+const config = {
+  plugins: ["@tailwindcss/postcss"],
+};
+
+export default config;

references/waitpoint-tokens/postcss.config.mjs

@@ -0,0 +1,72 @@
+"use server";
+
+import type { articleWorkflow } from "@/trigger/articleWorkflow";
+import type { ReviewPayload } from "@/trigger/reviewSummary";
+import { tasks, wait } from "@trigger.dev/sdk/v3";
+
+// A user identifier that could be fetched from your auth mechanism.
+// This is out of scope for this example, so we just hardcode it.
+const user = "reactflowtest";
+const userTag = `user_${user}`;
+
+const randomStr = (length: number) =>
+  [...Array(length)]
+    .map(
+      () =>
+        "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789"[
+          Math.floor(Math.random() * 62)
+        ]
+    )
+    .join("");
+
+export async function triggerArticleWorkflow(prevState: any, formData: FormData) {
+  const articleUrl = formData.get("articleUrl") as string;
+  const uniqueTag = `reactflow_${randomStr(20)}`;
+
+  const reviewWaitpointToken = await wait.createToken({
+    tags: [uniqueTag, userTag],
+    timeout: "1h",
+    idempotencyKey: `review-summary-${uniqueTag}`,
+  });
+
+  const handle = await tasks.trigger<typeof articleWorkflow>(
+    "article-workflow",
+    {
+      articleUrl,
+      approvalWaitpointTokenId: reviewWaitpointToken.id,
+    },
+    {
+      tags: [uniqueTag, userTag],
+    }
+  );
+
+  return {
+    articleUrl,
+    runId: handle.id,
+    runTag: uniqueTag,
+    reviewWaitpointTokenId: reviewWaitpointToken.id,
+  };
+}
+
+export async function approveArticleSummary(tokenId: string) {
+  await wait.completeToken<ReviewPayload>(
+    { id: tokenId },
+    {
+      approved: true,
+      approvedAt: new Date(),
+      approvedBy: user,
+    }
+  );
+}
+
+export async function rejectArticleSummary(tokenId: string) {
+  await wait.completeToken<ReviewPayload>(
+    { id: tokenId },
+    {
+      approved: false,
+      rejectedAt: new Date(),
+      rejectedBy: user,
+      reason: "It's no good",
+    }
+  );
+}