Otteri.ai

$ tree --source-code
├── apps/
│   ├── web/
│   │   ├── app/
│   │   │   ├── page.tsx
│   │   │   ├── layout.tsx
│   │   │   └── providers.tsx
│   │   ├── lib/
│   │   │   ├── ai-service.ts
│   │   │   └── langchain.ts
│   │   └── package.json
│   └── api/
│       ├── src/
│       │   ├── routes/
│       │   └── middleware/
│       └── package.json
├── packages/
│   ├── ui/
│   ├── shared/
│   └── plugins/
├── turbo.json
└── package.json

import { Anthropic } from '@anthropic-ai/sdk'
import { ChatOpenAI } from '@langchain/openai'
import type { ModelProvider, ChatRequest } from '@otteri/shared'

const providers: Record<ModelProvider, () => BaseChatModel> = {
  anthropic: () => new Anthropic({ apiKey: env.ANTHROPIC_KEY }),
  openai: () => new ChatOpenAI({ modelName: 'gpt-4o' }),
  gemini: () => new ChatGoogleGenerativeAI({ model: 'gemini-pro' }),
}

export async function streamChat(req: ChatRequest) {
  const model = providers[req.provider]()
  const chain = model.pipe(new StringOutputParser())
  return chain.stream(req.messages)
}