D3 demo WIP

Author: ericallam

pnpm-lock.yaml

@@ -1,5 +1,5 @@
 {
-  "name": "references-agent-loop",
+  "name": "references-d3-demo",
   "version": "0.1.0",
   "private": true,
   "scripts": {
@@ -8,10 +8,18 @@
     "start": "next start",
     "lint": "next lint",
     "dev:trigger": "trigger dev",
-    "deploy": "trigger deploy"
+    "deploy": "pnpm run python:compile-requirements && trigger deploy",
+    "python:install-requirements": "uv pip sync requirements.txt",
+    "python:compile-requirements": "uv pip compile requirements.in -o requirements.txt",
+    "python:install": "pnpm run python:compile-requirements && pnpm run python:install-requirements",
+    "python:create-env": "uv venv .venv"
   },
   "dependencies": {
     "@ai-sdk/openai": "1.3.3",
+    "@trigger.dev/react-hooks": "workspace:*",
+    "@trigger.dev/sdk": "workspace:*",
+    "@trigger.dev/python": "workspace:*",
+    "ai": "4.2.5",
     "class-variance-authority": "^0.7.1",
     "clsx": "^2.1.1",
     "lucide-react": "^0.484.0",
@@ -20,18 +28,17 @@
     "react-dom": "^19.0.0",
     "tailwind-merge": "^3.0.2",
     "tw-animate-css": "^1.2.4",
-    "@trigger.dev/react-hooks": "workspace:*",
-    "@trigger.dev/sdk": "workspace:*",
-    "ai": "4.2.5",
-    "zod": "3.23.8"
+    "zod": "3.23.8",
+    "zod-to-json-schema": "^3.24.5"
   },
   "devDependencies": {
     "@tailwindcss/postcss": "^4",
     "@types/node": "^20",
     "@types/react": "^19",
     "@types/react-dom": "^19",
     "tailwindcss": "^4.0.17",
-    "typescript": "^5",
-    "trigger.dev": "workspace:*"
+    "trigger.dev": "workspace:*",
+    "@trigger.dev/build": "workspace:*",
+    "typescript": "^5"
   }
 }

references/agent-loop/src/trigger/schemas.ts

@@ -0,0 +1,4 @@
+crawl4ai
+playwright
+openai-agents
+urllib3<2.0.0

references/agent-loop/trigger.config.ts

@@ -0,0 +1,256 @@
+# This file was autogenerated by uv via the following command:
+#    uv pip compile requirements.in -o requirements.txt
+aiofiles==24.1.0
+    # via crawl4ai
+aiohappyeyeballs==2.6.1
+    # via aiohttp
+aiohttp==3.11.14
+    # via
+    #   crawl4ai
+    #   litellm
+aiosignal==1.3.2
+    # via aiohttp
+aiosqlite==0.21.0
+    # via crawl4ai
+annotated-types==0.7.0
+    # via pydantic
+anyio==4.9.0
+    # via
+    #   httpx
+    #   mcp
+    #   openai
+    #   sse-starlette
+    #   starlette
+attrs==25.3.0
+    # via
+    #   aiohttp
+    #   jsonschema
+    #   referencing
+beautifulsoup4==4.13.3
+    # via crawl4ai
+certifi==2025.1.31
+    # via
+    #   httpcore
+    #   httpx
+    #   requests
+cffi==1.17.1
+    # via cryptography
+charset-normalizer==3.4.1
+    # via requests
+click==8.1.8
+    # via
+    #   crawl4ai
+    #   litellm
+    #   nltk
+    #   uvicorn
+colorama==0.4.6
+    # via
+    #   crawl4ai
+    #   griffe
+crawl4ai==0.5.0.post8
+    # via -r requirements.in
+cryptography==44.0.2
+    # via pyopenssl
+cssselect==1.3.0
+    # via crawl4ai
+distro==1.9.0
+    # via openai
+fake-http-header==0.3.5
+    # via tf-playwright-stealth
+fake-useragent==2.1.0
+    # via crawl4ai
+faust-cchardet==2.1.19
+    # via crawl4ai
+filelock==3.18.0
+    # via huggingface-hub
+frozenlist==1.5.0
+    # via
+    #   aiohttp
+    #   aiosignal
+fsspec==2025.3.0
+    # via huggingface-hub
+greenlet==3.1.1
+    # via playwright
+griffe==1.6.3
+    # via openai-agents
+h11==0.14.0
+    # via
+    #   httpcore
+    #   uvicorn
+httpcore==1.0.7
+    # via httpx
+httpx==0.28.1
+    # via
+    #   crawl4ai
+    #   litellm
+    #   mcp
+    #   openai
+httpx-sse==0.4.0
+    # via mcp
+huggingface-hub==0.29.3
+    # via tokenizers
+humanize==4.12.2
+    # via crawl4ai
+idna==3.10
+    # via
+    #   anyio
+    #   httpx
+    #   requests
+    #   yarl
+importlib-metadata==8.6.1
+    # via litellm
+jinja2==3.1.6
+    # via litellm
+jiter==0.9.0
+    # via openai
+joblib==1.4.2
+    # via nltk
+jsonschema==4.23.0
+    # via litellm
+jsonschema-specifications==2024.10.1
+    # via jsonschema
+litellm==1.64.1
+    # via crawl4ai
+lxml==5.3.1
+    # via crawl4ai
+markdown-it-py==3.0.0
+    # via rich
+markupsafe==3.0.2
+    # via jinja2
+mcp==1.5.0
+    # via openai-agents
+mdurl==0.1.2
+    # via markdown-it-py
+multidict==6.2.0
+    # via
+    #   aiohttp
+    #   yarl
+nltk==3.9.1
+    # via crawl4ai
+numpy==2.2.4
+    # via
+    #   crawl4ai
+    #   rank-bm25
+openai==1.68.2
+    # via
+    #   litellm
+    #   openai-agents
+openai-agents==0.0.7
+    # via -r requirements.in
+packaging==24.2
+    # via huggingface-hub
+pillow==10.4.0
+    # via crawl4ai
+playwright==1.51.0
+    # via
+    #   -r requirements.in
+    #   crawl4ai
+    #   tf-playwright-stealth
+propcache==0.3.1
+    # via
+    #   aiohttp
+    #   yarl
+psutil==7.0.0
+    # via crawl4ai
+pycparser==2.22
+    # via cffi
+pydantic==2.10.6
+    # via
+    #   crawl4ai
+    #   litellm
+    #   mcp
+    #   openai
+    #   openai-agents
+    #   pydantic-settings
+pydantic-core==2.27.2
+    # via pydantic
+pydantic-settings==2.8.1
+    # via mcp
+pyee==12.1.1
+    # via playwright
+pygments==2.19.1
+    # via rich
+pyopenssl==25.0.0
+    # via crawl4ai
+pyperclip==1.9.0
+    # via crawl4ai
+python-dotenv==1.1.0
+    # via
+    #   crawl4ai
+    #   litellm
+    #   pydantic-settings
+pyyaml==6.0.2
+    # via huggingface-hub
+rank-bm25==0.2.2
+    # via crawl4ai
+referencing==0.36.2
+    # via
+    #   jsonschema
+    #   jsonschema-specifications
+regex==2024.11.6
+    # via
+    #   nltk
+    #   tiktoken
+requests==2.32.3
+    # via
+    #   crawl4ai
+    #   huggingface-hub
+    #   openai-agents
+    #   tiktoken
+rich==13.9.4
+    # via crawl4ai
+rpds-py==0.24.0
+    # via
+    #   jsonschema
+    #   referencing
+sniffio==1.3.1
+    # via
+    #   anyio
+    #   openai
+snowballstemmer==2.2.0
+    # via crawl4ai
+soupsieve==2.6
+    # via beautifulsoup4
+sse-starlette==2.2.1
+    # via mcp
+starlette==0.46.1
+    # via
+    #   mcp
+    #   sse-starlette
+tf-playwright-stealth==1.1.2
+    # via crawl4ai
+tiktoken==0.9.0
+    # via litellm
+tokenizers==0.21.1
+    # via litellm
+tqdm==4.67.1
+    # via
+    #   huggingface-hub
+    #   nltk
+    #   openai
+types-requests==2.31.0.6
+    # via openai-agents
+types-urllib3==1.26.25.14
+    # via types-requests
+typing-extensions==4.13.0
+    # via
+    #   aiosqlite
+    #   beautifulsoup4
+    #   huggingface-hub
+    #   openai
+    #   openai-agents
+    #   pydantic
+    #   pydantic-core
+    #   pyee
+urllib3==1.26.20
+    # via
+    #   -r requirements.in
+    #   requests
+uvicorn==0.34.0
+    # via mcp
+xxhash==3.5.0
+    # via crawl4ai
+yarl==1.18.3
+    # via aiohttp
+zipp==3.21.0
+    # via importlib-metadata

references/agent-loop/.gitignore renamed to references/d3-demo/.gitignore

@@ -2,7 +2,7 @@ import MainApp from "@/components/main-app";
 import { auth } from "@trigger.dev/sdk";
 
 export default async function Home() {
-  const publicAccessToken = await auth.createTriggerPublicToken("agent-loop-example");
+  const publicAccessToken = await auth.createTriggerPublicToken("chat-example");
 
   return <MainApp publicAccessToken={publicAccessToken} />;
 }

references/agent-loop/README.md renamed to references/d3-demo/README.md

@@ -7,7 +7,7 @@ import { Send } from "lucide-react";
 import ChatInterface from "@/components/chat-interface";
 import InitialPrompt from "@/components/initial-prompt";
 import { useRealtimeTaskTriggerWithStreams, useWaitToken } from "@trigger.dev/react-hooks";
-import type { agentLoopExample } from "@/trigger/agent";
+import type { chatExample } from "@/trigger/chat";
 import { AgentLoopMetadata } from "@/trigger/schemas";
 import type { TextStreamPart } from "ai";
 
@@ -17,14 +17,14 @@ type ResponseStreams = {
   [K in `responses.${number | string}`]: TextStreamPart<{}>;
 };
 
-export function useAgentLoop({ publicAccessToken }: { publicAccessToken: string }) {
-  const triggerInstance = useRealtimeTaskTriggerWithStreams<
-    typeof agentLoopExample,
-    ResponseStreams
-  >("agent-loop-example", {
-    accessToken: publicAccessToken,
-    baseURL: process.env.NEXT_PUBLIC_TRIGGER_API_URL,
-  });
+export function useChat({ publicAccessToken }: { publicAccessToken: string }) {
+  const triggerInstance = useRealtimeTaskTriggerWithStreams<typeof chatExample, ResponseStreams>(
+    "chat-example",
+    {
+      accessToken: publicAccessToken,
+      baseURL: process.env.NEXT_PUBLIC_TRIGGER_API_URL,
+    }
+  );
   const [conversation, setConversation] = useState<ChatConversation>([]);
   const [isLoading, setIsLoading] = useState(false);
   const [waitToken, setWaitToken] = useState<AgentLoopMetadata | null>(null);
@@ -86,7 +86,7 @@ export function useAgentLoop({ publicAccessToken }: { publicAccessToken: string
 }
 
 export default function MainApp({ publicAccessToken }: { publicAccessToken: string }) {
-  const { continueConversation, conversation, isLoading } = useAgentLoop({ publicAccessToken });
+  const { continueConversation, conversation, isLoading } = useChat({ publicAccessToken });
   const [input, setInput] = useState("");
 
   const handleSubmit = (e: React.FormEvent) => {