supermemory/packages/tools/test/chatapp/app/api/stream/route.ts

import { convertToModelMessages, gateway, streamText, type UIMessage } from "ai"
import { withTracing } from "@posthog/ai"
import { withSupermemory } from "../../../../../src/ai-sdk"
import { PostHog } from "posthog-node"

const SUPERMEMORY_USER_ID = "user-1"

const gatewayModel = gateway("google/gemini-2.5-flash")

const supermemoryOptions = {
	containerTag: SUPERMEMORY_USER_ID,
	customId: "stream-session",
	apiKey: process.env.SUPERMEMORY_API_KEY ?? "",
	mode: "full" as const,
	addMemory: "always" as const,
	baseUrl: process.env.SUPERMEMORY_BASE_URL,
}

export async function POST(req: Request) {
	const { messages }: { messages: UIMessage[] } = await req.json()

	const posthogApiKey = process.env.POSTHOG_API_KEY
	const phClient = posthogApiKey
		? new PostHog(posthogApiKey, {
				host: process.env.POSTHOG_HOST ?? "https://us.i.posthog.com",
			})
		: null

	const innerModel = phClient
		? withTracing(gatewayModel, phClient, {
				posthogDistinctId: SUPERMEMORY_USER_ID,
				posthogProperties: { route: "api/stream" },
			})
		: gatewayModel

	const model = withSupermemory(innerModel, supermemoryOptions)

	const result = streamText({
		model,
		system: "You are a helpful assistant.",
		messages: await convertToModelMessages(messages),
		onFinish: phClient
			? async () => {
					await phClient.shutdown()
				}
			: undefined,
	})

	return result.toUIMessageStreamResponse()
}