Introduction

Key Features

Architecture

├── apps/│   ├── web/         # Next.js web application│   └── desktop/     # Desktop application│└── packages/    ├── ai/          # AI models and workflow orchestration    ├── actions/     # Shared actions and API handlers    ├── common/      # Common utilities and hooks    ├── orchestrator/# Workflow engine and task management    ├── prisma/      # Database schema and client    ├── shared/      # Shared types and constants    ├── ui/          # Reusable UI components    ├── tailwind-config/ # Shared Tailwind configuration    └── typescript-config/ # Shared TypeScript configuration

Workflow Orchestration

1. Define Event and Context Types

// Define the events emitted by each tasktypeAgentEvents={taskPlanner:{tasks:string[];query:string;};informationGatherer:{searchResults:string[];};informationAnalyzer:{analysis:string;insights:string[];};reportGenerator:{report:string;};};// Define the shared context between taskstypeAgentContext={query:string;tasks:string[];searchResults:string[];analysis:string;insights:string[];report:string;};

2. Initialize Core Components

import{OpenAI}from'openai';import{createTask}from'task';import{WorkflowBuilder}from'./builder';import{Context}from'./context';import{TypedEventEmitter}from'./events';// Initialize event emitter with proper typingconstevents=newTypedEventEmitter<AgentEvents>();// Create the workflow builder with proper contextconstbuilder=newWorkflowBuilder<AgentEvents,AgentContext>('research-agent',{    events,context:newContext<AgentContext>({query:'',tasks:[],searchResults:[],analysis:'',insights:[],report:'',}),});// Initialize LLM clientconstllm=newOpenAI({apiKey:process.env.OPENAI_API_KEY,});

3. Define Research Tasks

Planning Task

// Task Planner: Breaks down a research query into specific tasksconsttaskPlanner=createTask({name:'taskPlanner',execute:async({ context, data})=>{constuserQuery=data?.query||'Research the impact of AI on healthcare';constplanResponse=awaitllm.chat.completions.create({model:'gpt-4o',messages:[{role:'system',content:'You are a task planning assistant that breaks down research queries into specific search tasks.',},{role:'user',content:`Break down this research query into specific search tasks: "${userQuery}". Return a JSON array of tasks.`,},],response_format:{type:'json_object'},});constcontent=planResponse.choices[0].message.content||'{"tasks": []}';constparsedContent=JSON.parse(content);consttasks=parsedContent.tasks||[];context?.set('query',userQuery);context?.set('tasks',tasks);return{            tasks,query:userQuery,};},route:()=>'informationGatherer',});

Information Gathering Task

// Information Gatherer: Searches for information based on tasksconstinformationGatherer=createTask({name:'informationGatherer',dependencies:['taskPlanner'],execute:async({ context, data})=>{consttasks=data.taskPlanner.tasks;constsearchResults:string[]=[];// Process each task to gather informationfor(consttaskoftasks){constsearchResponse=awaitllm.chat.completions.create({model:'gpt-4o',messages:[{role:'system',content:'You are a search engine that returns factual information.',},{role:'user',content:`Search for information about:${task}. Return relevant facts and data.`,},],});constresult=searchResponse.choices[0].message.content||'';if(result){searchResults.push(result);}}context?.set('searchResults',searchResults);return{            searchResults,};},route:()=>'informationAnalyzer',});

Analysis Task

// Information Analyzer: Analyzes gathered information for insightsconstinformationAnalyzer=createTask({name:'informationAnalyzer',dependencies:['informationGatherer'],execute:async({ context, data})=>{constsearchResults=data.informationGatherer.searchResults;constquery=context?.get('query')||'';constanalysisResponse=awaitllm.chat.completions.create({model:'gpt-4o',messages:[{role:'system',content:'You are an analytical assistant that identifies patterns and extracts insights from information.',},{role:'user',content:`Analyze the following information regarding "${query}" and provide a coherent analysis with key insights:\n\n${searchResults.join('\n\n')}`,},],response_format:{type:'json_object'},});constcontent=analysisResponse.choices[0].message.content||'{"analysis": "", "insights": []}';constparsedContent=JSON.parse(content);constanalysis=parsedContent.analysis||'';constinsights=parsedContent.insights||[];context?.set('analysis',analysis);context?.set('insights',insights);return{            analysis,            insights,};},route:()=>'reportGenerator',});

Report Generation Task

// Report Generator: Creates a comprehensive reportconstreportGenerator=createTask({name:'reportGenerator',dependencies:['informationAnalyzer'],execute:async({ context, data})=>{const{ analysis, insights}=data.informationAnalyzer;const{ query, searchResults}=context?.getAll()||{query:'',searchResults:[]};constreportResponse=awaitllm.chat.completions.create({model:'gpt-4o',messages:[{role:'system',content:'You are a report writing assistant that creates comprehensive, well-structured reports.',},{role:'user',content:`Create a comprehensive report on "${query}" using the following analysis and insights.\n\nAnalysis:${analysis}\n\nInsights:${insights.join('\n- ')}\n\nStructure the report with an executive summary, key findings, detailed analysis, and conclusions.`,},],});constreport=reportResponse.choices[0].message.content||'';context?.set('report',report);return{            report,};},route:()=>'end',});

4. Build and Execute the Workflow

// Add all tasks to the workflowbuilder.addTask(taskPlanner);builder.addTask(informationGatherer);builder.addTask(informationAnalyzer);builder.addTask(reportGenerator);// Build the workflowconstworkflow=builder.build();// Start the workflow with an initial queryworkflow.start('taskPlanner',{query:'Research the impact of AI on healthcare'});// Export the workflow for external useexportconstresearchAgent=workflow;

Local Storage

Tech Stack

Frontend

Development

Getting Started

Prerequisites

Installation

git clone https://github.com/your-repo/llmchat.gitcd llmchat

bun install# oryarn install

bun dev# oryarn dev