init nextjs example

Author: darkoatanasovski

examples/nextjs-ai-chatbot

@@ -0,0 +1,42 @@
+# See https://help.github.com/articles/ignoring-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+/.pnp
+.pnp.*
+.yarn/*
+yalc.lock
+!.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*
+
+# vercel
+.vercel
+
+# typescript
+*.tsbuildinfo
+next-env.d.ts

examples/nextjs-ai-chatbot/.gitignore

@@ -0,0 +1,56 @@
+This is a [Next.js](https://nextjs.org) project bootstrapped with [`create-next-app`](https://nextjs.org/docs/app/api-reference/cli/create-next-app).
+
+## Getting Started
+
+### Environment Variables
+
+Create a `.env.local` file in the root directory and add the following environment variables:
+
+```bash
+# Required
+STREAM_API_KEY=your_stream_api_key
+STREAM_API_SECRET=your_stream_api_secret
+
+# Optional for AI models
+OPENAI_API_KEY=your_openai_api_key
+XAI_API_KEY=your_xai_api_key
+GOOGLE_GENERATIVE_AI_API_KEY=your_google_api_key
+
+# Optional for tools
+OPENWEATHER_API_KEY=your_openweather_api_key
+```
+
+### Running the Development Server
+
+First, run the development server:
+
+```bash
+npm run dev
+# or
+yarn dev
+# or
+pnpm dev
+# or
+bun dev
+```
+
+Open [http://localhost:3000](http://localhost:3000) with your browser to see the result.
+
+You can start editing the page by modifying `app/page.tsx`. The page auto-updates as you edit the file.
+
+This project uses [`next/font`](https://nextjs.org/docs/app/building-your-application/optimizing/fonts) to automatically optimize and load [Geist](https://vercel.com/font), a new font family for Vercel.
+
+## Learn More
+
+To learn more about Next.js, take a look at the following resources:
+
+- [Next.js Documentation](https://nextjs.org/docs) - learn about Next.js features and API.
+- [Learn Next.js](https://nextjs.org/learn) - an interactive Next.js tutorial.
+
+You can check out [the Next.js GitHub repository](https://github.com/vercel/next.js) - your feedback and contributions are welcome!
+
+## Deploy on Vercel
+
+The easiest way to deploy your Next.js app is to use the [Vercel Platform](https://vercel.com/new?utm_medium=default-template&filter=next.js&utm_source=create-next-app&utm_campaign=create-next-app-readme) from the creators of Next.js.
+
+Check out our [Next.js deployment documentation](https://nextjs.org/docs/app/building-your-application/deploying) for more details.

examples/nextjs-ai-chatbot/README.md

@@ -0,0 +1,7 @@
+"use client";
+
+import Messages from "@/components/messages";
+
+export default function ChatPage() {
+  return <Messages />;
+}

examples/nextjs-ai-chatbot/app/[id]/page.tsx

@@ -0,0 +1,16 @@
+import { NextResponse } from "next/server";
+import { createStreamStorageClient } from "@stream-io/ai-sdk-storage";
+import { createConfigFromEnv } from "@stream-io/ai-sdk-storage/dist/utils";
+
+const storage = createStreamStorageClient(createConfigFromEnv());
+
+export async function GET(req: Request, { params }: any) {
+  const { id } = await params;
+  try {
+    return NextResponse.json(
+      await storage.streamStorage.getChannelMessages(id)
+    );
+  } catch (error) {
+    return NextResponse.json([], { status: 404 });
+  }
+}

examples/nextjs-ai-chatbot/app/api/chats/[id]/route.ts

@@ -0,0 +1,63 @@
+import { convertToModelMessages, streamText } from "ai";
+import { NextResponse } from "next/server";
+import { GetModel, MODELS } from "@/utils/models";
+import { createStreamStorageClient } from "@stream-io/ai-sdk-storage";
+import { createConfigFromEnv } from "@stream-io/ai-sdk-storage/dist/utils";
+import { tools } from "@/utils/tools";
+
+const storage = createStreamStorageClient(createConfigFromEnv());
+
+export async function POST(req: Request) {
+  const { messages, id, user_id, model = MODELS[0].id } = await req.json();
+
+  const { processUserMessage, processAIResponse } =
+    await storage.aiSDKStreamStorage.handleStreamText(
+      id,
+      messages,
+      user_id,
+      async (responseMessage) => {
+        await storage.aiSDKStreamStorage.processAIResponse(id, responseMessage);
+      }
+    );
+
+  // Process the user message (handles attachments automatically)
+  await processUserMessage();
+  const result = streamText({
+    model: GetModel(model),
+    system: "You are a helpful assistant.",
+    messages: convertToModelMessages(messages),
+    tools,
+    onAbort: (error) => {
+      console.error(error, "error");
+    },
+    onError: (error) => {
+      console.error(error, "error");
+    },
+  });
+
+  return result.toUIMessageStreamResponse({
+    originalMessages: messages,
+    onFinish: async ({ responseMessage }) => {
+      await processAIResponse(responseMessage);
+    },
+    onError: (error) => {
+      console.error(error, "error");
+      return "Error: " + error;
+    },
+  });
+}
+
+export async function GET(req: Request) {
+  const { searchParams } = new URL(req.url);
+  const user_id = searchParams.get("user_id");
+  if (!user_id) {
+    return NextResponse.json(
+      {
+        error: "User ID is required",
+      },
+      { status: 400 }
+    );
+  }
+  const channels = await storage.streamStorage.getChannels(user_id);
+  return NextResponse.json(channels?.map((channel) => channel.data) || []);
+}

examples/nextjs-ai-chatbot/app/api/chats/route.ts

@@ -0,0 +1,29 @@
+import { NextRequest } from "next/server";
+import { experimental_transcribe as transcribe } from "ai";
+import { openai } from "@ai-sdk/openai";
+
+export async function POST(req: NextRequest) {
+  try {
+    const form = await req.formData();
+    const file = form.get("audio") as File | null;
+    if (file && file.size < 20000) {
+      return Response.json({ text: "" });
+    }
+    if (!file)
+      return new Response(JSON.stringify({ error: "No audio" }), {
+        status: 400,
+      });
+
+    const result = await transcribe({
+      model: openai.transcription("gpt-4o-transcribe"),
+      audio: new Uint8Array(await file.arrayBuffer()),
+    });
+
+    return Response.json({ text: result.text ?? "" });
+  } catch (err) {
+    console.error(err);
+    return new Response(JSON.stringify({ error: "Transcription failed" }), {
+      status: 500,
+    });
+  }
+}

examples/nextjs-ai-chatbot/app/api/transcribe/route.ts

@@ -0,0 +1,13 @@
+import {
+  createConfigFromEnv,
+  createStreamStorageClient,
+} from "@stream-io/ai-sdk-storage/dist/utils";
+import { NextResponse } from "next/server";
+
+const storage = createStreamStorageClient(createConfigFromEnv());
+
+export async function POST() {
+  const id = await storage.streamStorage.upsertUsers();
+
+  return NextResponse.json({ id });
+}

examples/nextjs-ai-chatbot/app/api/users/route.ts

@@ -0,0 +1,38 @@
+@import "tailwindcss";
+@plugin "@tailwindcss/typography";
+@plugin "daisyui" {
+  themes: dim;
+}
+
+:root {
+  --primary: blue;
+}
+
+.overflow-y-auto {
+  scrollbar-gutter: stable;
+}
+
+pre {
+  display: block !important;
+}
+
+pre pre {
+  border: none !important;
+  background-color: transparent !important;
+  box-shadow: none !important;
+}
+
+.ai-thinking {
+  background: linear-gradient(90deg, #00ffe0, #0072ff, #00ffe0);
+  background-size: 200% auto;
+  color: transparent;
+  background-clip: text;
+  -webkit-background-clip: text;
+  animation: shimmer 2s linear infinite;
+}
+
+@keyframes shimmer {
+  to {
+    background-position: 200% center;
+  }
+}