+
+ )
+}
diff --git a/src/app/(app)/bartender/page.tsx b/src/app/(app)/bartender/page.tsx
new file mode 100644
index 0000000..54d7a64
--- /dev/null
+++ b/src/app/(app)/bartender/page.tsx
@@ -0,0 +1,88 @@
+"use client"
+
+import { Suspense, useState } from "react"
+import { Header } from "@/components/layout/header"
+import { Skeleton } from "@/components/ui/skeleton"
+import { RecreateTab } from "@/components/bartender/recreate-tab"
+import { SuggestTab } from "@/components/bartender/suggest-tab"
+import { SavedRecipesTab } from "@/components/bartender/saved-recipes-tab"
+import { Search, Sparkles, BookOpen } from "lucide-react"
+import { cn } from "@/lib/utils"
+
+export default function BartenderPage() {
+ return (
+
+
+
+ {/* Add Item Dialog */}
+
+
+ {/* Edit Item Dialog */}
+
+
+
+
+ {isLoading ? (
+
+
+
+ My Bar
++ {totalItems > 0 + ? `${totalItems} item${totalItems !== 1 ? "s" : ""} in your bar` + : "Your bar inventory"} +
+
+ {Array.from({ length: 3 }, (_, i) => (
+
+ ) : error ? (
+
+
+ ))}
+
+ {Array.from({ length: 4 }, (_, j) => (
+
+
+
+ ) : totalItems === 0 ? (
+ + Failed to load bar items. Please try again. +
+
+
+ ) : (
+
+
+
+ Your bar is empty
++ Add your first item to get started. +
+
+ {CATEGORY_ORDER.filter((cat) => groupedItems[cat]?.length > 0).map(
+ (cat) => (
+
+ )}
+
+
+ )
+}
+
+type Tab = "recreate" | "suggest" | "saved"
+
+const TABS: { id: Tab; label: string; icon: typeof Search }[] = [
+ { id: "recreate", label: "Recreate", icon: Search },
+ { id: "suggest", label: "Suggest", icon: Sparkles },
+ { id: "saved", label: "Saved", icon: BookOpen },
+]
+
+function BartenderContent() {
+ const [activeTab, setActiveTab] = useState
+
+
+ {Array.from({ length: 4 }, (_, i) => (
+
+
+
+ )
+}
diff --git a/src/app/(app)/drinks/[id]/page.tsx b/src/app/(app)/drinks/[id]/page.tsx
index ec590b9..152211c 100644
--- a/src/app/(app)/drinks/[id]/page.tsx
+++ b/src/app/(app)/drinks/[id]/page.tsx
@@ -74,6 +74,15 @@ export default async function DrinkDetailPage({
Back to Collection
+ {/* Drink Image */}
+ {drink.imageUrl && (
+
+
+
+
+
+ {/* Tab switcher */}
+ Bartender
++ AI-powered cocktail recipes based on your bar inventory. +
+
+ {TABS.map((tab) => {
+ const Icon = tab.icon
+ return (
+
+ )
+ })}
+
+
+ {/* Tab content */}
+ {activeTab === "recreate" &&
+
+ )
+}
+
+function RecommendContent() {
+ const {
+ data: profileData,
+ isLoading: profileLoading,
+ error: profileError,
+ } = useFlavorProfile()
+
+ const generateProfile = useGenerateFlavorProfile()
+
+ const { data: drinksData, isLoading: drinksLoading } = useDrinks({
+ limit: 500,
+ sort: "name",
+ })
+
+ const profile = profileData?.profile ?? null
+ const hasProfile = !!profile
+
+ const drinkOptions = (drinksData?.drinks ?? []).map((d) => ({
+ id: d.id,
+ name: d.name,
+ type: d.type,
+ }))
+
+ return (
+
+
+
+
+ )
+}
diff --git a/src/app/api/bar/[id]/route.ts b/src/app/api/bar/[id]/route.ts
new file mode 100644
index 0000000..1109eed
--- /dev/null
+++ b/src/app/api/bar/[id]/route.ts
@@ -0,0 +1,91 @@
+import { NextRequest, NextResponse } from "next/server"
+import { auth } from "@/lib/auth"
+import { prisma } from "@/lib/prisma"
+import { barItemUpdateSchema } from "@/lib/validators"
+
+export async function PUT(
+ request: NextRequest,
+ { params }: { params: { id: string } }
+) {
+ try {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ // Check ownership
+ const existing = await prisma.barItem.findUnique({
+ where: { id: params.id },
+ select: { userId: true },
+ })
+
+ if (!existing) {
+ return NextResponse.json({ error: "Bar item not found" }, { status: 404 })
+ }
+
+ if (existing.userId !== session.user.id) {
+ return NextResponse.json({ error: "Forbidden" }, { status: 403 })
+ }
+
+ const body = await request.json()
+ const parsed = barItemUpdateSchema.safeParse(body)
+
+ if (!parsed.success) {
+ return NextResponse.json(
+ { error: "Validation failed", issues: parsed.error.issues },
+ { status: 400 }
+ )
+ }
+
+ const item = await prisma.barItem.update({
+ where: { id: params.id },
+ data: parsed.data,
+ })
+
+ return NextResponse.json(item)
+ } catch (error) {
+ console.error("PUT /api/bar/[id] error:", error)
+ return NextResponse.json(
+ { error: "Internal server error" },
+ { status: 500 }
+ )
+ }
+}
+
+export async function DELETE(
+ request: NextRequest,
+ { params }: { params: { id: string } }
+) {
+ try {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ // Check ownership
+ const existing = await prisma.barItem.findUnique({
+ where: { id: params.id },
+ select: { userId: true },
+ })
+
+ if (!existing) {
+ return NextResponse.json({ error: "Bar item not found" }, { status: 404 })
+ }
+
+ if (existing.userId !== session.user.id) {
+ return NextResponse.json({ error: "Forbidden" }, { status: 403 })
+ }
+
+ await prisma.barItem.delete({
+ where: { id: params.id },
+ })
+
+ return NextResponse.json({ success: true })
+ } catch (error) {
+ console.error("DELETE /api/bar/[id] error:", error)
+ return NextResponse.json(
+ { error: "Internal server error" },
+ { status: 500 }
+ )
+ }
+}
diff --git a/src/app/api/bar/route.ts b/src/app/api/bar/route.ts
new file mode 100644
index 0000000..4e753f7
--- /dev/null
+++ b/src/app/api/bar/route.ts
@@ -0,0 +1,60 @@
+import { NextRequest, NextResponse } from "next/server"
+import { auth } from "@/lib/auth"
+import { prisma } from "@/lib/prisma"
+import { barItemCreateSchema } from "@/lib/validators"
+
+export async function GET() {
+ try {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ const items = await prisma.barItem.findMany({
+ where: { userId: session.user.id },
+ orderBy: [{ category: "asc" }, { name: "asc" }],
+ })
+
+ return NextResponse.json({ items })
+ } catch (error) {
+ console.error("GET /api/bar error:", error)
+ return NextResponse.json(
+ { error: "Internal server error" },
+ { status: 500 }
+ )
+ }
+}
+
+export async function POST(request: NextRequest) {
+ try {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ const body = await request.json()
+ const parsed = barItemCreateSchema.safeParse(body)
+
+ if (!parsed.success) {
+ return NextResponse.json(
+ { error: "Validation failed", issues: parsed.error.issues },
+ { status: 400 }
+ )
+ }
+
+ const item = await prisma.barItem.create({
+ data: {
+ ...parsed.data,
+ userId: session.user.id,
+ },
+ })
+
+ return NextResponse.json(item, { status: 201 })
+ } catch (error) {
+ console.error("POST /api/bar error:", error)
+ return NextResponse.json(
+ { error: "Internal server error" },
+ { status: 500 }
+ )
+ }
+}
diff --git a/src/app/api/bartender/recreate/route.ts b/src/app/api/bartender/recreate/route.ts
new file mode 100644
index 0000000..b204936
--- /dev/null
+++ b/src/app/api/bartender/recreate/route.ts
@@ -0,0 +1,93 @@
+import { NextResponse } from "next/server"
+import { auth } from "@/lib/auth"
+import { prisma } from "@/lib/prisma"
+import { decrypt } from "@/lib/encryption"
+import { createProvider } from "@/lib/ai/provider-factory"
+import { rateLimit } from "@/lib/rate-limit"
+import { COCKTAIL_RECIPE_PROMPT, buildBarInventoryString } from "@/lib/ai/prompts"
+import { z } from "zod"
+
+const recreateSchema = z.object({
+ cocktailName: z.string().min(1).max(200),
+ drinkId: z.string().optional(),
+})
+
+export async function POST(request: Request) {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ const { success: withinLimit } = rateLimit(`bartender-recreate:${session.user.id}`, 10, 60000)
+ if (!withinLimit) {
+ return NextResponse.json(
+ { error: "Too many requests. Please wait a moment." },
+ { status: 429 }
+ )
+ }
+
+ try {
+ const body = await request.json()
+ const parsed = recreateSchema.safeParse(body)
+ if (!parsed.success) {
+ return NextResponse.json({ error: "Invalid request" }, { status: 400 })
+ }
+
+ const apiKeyRecord = await prisma.userApiKey.findFirst({
+ where: { userId: session.user.id, isActive: true },
+ })
+
+ if (!apiKeyRecord) {
+ return NextResponse.json(
+ { error: "No AI provider configured. Add an API key in Settings." },
+ { status: 400 }
+ )
+ }
+
+ const barItems = await prisma.barItem.findMany({
+ where: {
+ userId: session.user.id,
+ quantity: { not: "EMPTY" },
+ },
+ select: { name: true, category: true, quantity: true },
+ })
+
+ const inventoryString = buildBarInventoryString(barItems)
+ const prompt = COCKTAIL_RECIPE_PROMPT.replace("{barInventory}", inventoryString)
+
+ const apiKey = decrypt(apiKeyRecord.encryptedKey, apiKeyRecord.iv)
+ const provider = createProvider(apiKeyRecord.provider, apiKey)
+
+ const rawResponse = await provider.sendTextRequest(
+ prompt,
+ `Generate a recipe for: ${parsed.data.cocktailName}`
+ )
+
+ // Parse JSON from response
+ let recipe
+ try {
+ recipe = JSON.parse(rawResponse)
+ } catch {
+ // Try to extract from markdown code blocks or find JSON object
+ const codeBlockMatch = rawResponse.match(/```(?:json)?\s*\n?([\s\S]*?)\n?```/)
+ if (codeBlockMatch) {
+ recipe = JSON.parse(codeBlockMatch[1].trim())
+ } else {
+ const objectMatch = rawResponse.match(/\{[\s\S]*\}/)
+ if (objectMatch) {
+ recipe = JSON.parse(objectMatch[0])
+ } else {
+ throw new Error("Could not parse recipe from AI response")
+ }
+ }
+ }
+
+ return NextResponse.json(recipe)
+ } catch (error) {
+ console.error("Bartender recreate error:", error)
+ return NextResponse.json(
+ { error: "Failed to generate recipe. Please try again." },
+ { status: 500 }
+ )
+ }
+}
diff --git a/src/app/api/bartender/suggest/route.ts b/src/app/api/bartender/suggest/route.ts
new file mode 100644
index 0000000..fe24c7a
--- /dev/null
+++ b/src/app/api/bartender/suggest/route.ts
@@ -0,0 +1,91 @@
+import { NextResponse } from "next/server"
+import { auth } from "@/lib/auth"
+import { prisma } from "@/lib/prisma"
+import { decrypt } from "@/lib/encryption"
+import { createProvider } from "@/lib/ai/provider-factory"
+import { rateLimit } from "@/lib/rate-limit"
+import { WHAT_CAN_I_MAKE_PROMPT, buildBarInventoryString } from "@/lib/ai/prompts"
+
+export async function POST() {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ const { success: withinLimit } = rateLimit(`bartender-suggest:${session.user.id}`, 5, 60000)
+ if (!withinLimit) {
+ return NextResponse.json(
+ { error: "Too many requests. Please wait a moment." },
+ { status: 429 }
+ )
+ }
+
+ try {
+ const apiKeyRecord = await prisma.userApiKey.findFirst({
+ where: { userId: session.user.id, isActive: true },
+ })
+
+ if (!apiKeyRecord) {
+ return NextResponse.json(
+ { error: "No AI provider configured. Add an API key in Settings." },
+ { status: 400 }
+ )
+ }
+
+ const barItems = await prisma.barItem.findMany({
+ where: {
+ userId: session.user.id,
+ quantity: { not: "EMPTY" },
+ },
+ select: { name: true, category: true, quantity: true },
+ })
+
+ if (barItems.length === 0) {
+ return NextResponse.json(
+ { error: "No items in your bar inventory. Add items to your bar first." },
+ { status: 400 }
+ )
+ }
+
+ const inventoryString = buildBarInventoryString(barItems)
+ const prompt = WHAT_CAN_I_MAKE_PROMPT.replace("{barInventory}", inventoryString)
+
+ const apiKey = decrypt(apiKeyRecord.encryptedKey, apiKeyRecord.iv)
+ const provider = createProvider(apiKeyRecord.provider, apiKey)
+
+ const rawResponse = await provider.sendTextRequest(
+ prompt,
+ "What cocktails can I make with my bar inventory?"
+ )
+
+ // Parse JSON from response
+ let suggestions
+ try {
+ suggestions = JSON.parse(rawResponse)
+ } catch {
+ const codeBlockMatch = rawResponse.match(/```(?:json)?\s*\n?([\s\S]*?)\n?```/)
+ if (codeBlockMatch) {
+ suggestions = JSON.parse(codeBlockMatch[1].trim())
+ } else {
+ const arrayMatch = rawResponse.match(/\[[\s\S]*\]/)
+ if (arrayMatch) {
+ suggestions = JSON.parse(arrayMatch[0])
+ } else {
+ throw new Error("Could not parse suggestions from AI response")
+ }
+ }
+ }
+
+ if (!Array.isArray(suggestions)) {
+ suggestions = []
+ }
+
+ return NextResponse.json({ suggestions })
+ } catch (error) {
+ console.error("Bartender suggest error:", error)
+ return NextResponse.json(
+ { error: "Failed to generate suggestions. Please try again." },
+ { status: 500 }
+ )
+ }
+}
diff --git a/src/app/api/recipes/[id]/route.ts b/src/app/api/recipes/[id]/route.ts
new file mode 100644
index 0000000..afc6428
--- /dev/null
+++ b/src/app/api/recipes/[id]/route.ts
@@ -0,0 +1,40 @@
+import { NextRequest, NextResponse } from "next/server"
+import { auth } from "@/lib/auth"
+import { prisma } from "@/lib/prisma"
+
+export async function DELETE(
+ request: NextRequest,
+ { params }: { params: { id: string } }
+) {
+ try {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ const existing = await prisma.recipe.findUnique({
+ where: { id: params.id },
+ select: { userId: true },
+ })
+
+ if (!existing) {
+ return NextResponse.json({ error: "Recipe not found" }, { status: 404 })
+ }
+
+ if (existing.userId !== session.user.id) {
+ return NextResponse.json({ error: "Forbidden" }, { status: 403 })
+ }
+
+ await prisma.recipe.delete({
+ where: { id: params.id },
+ })
+
+ return NextResponse.json({ success: true })
+ } catch (error) {
+ console.error("DELETE /api/recipes/[id] error:", error)
+ return NextResponse.json(
+ { error: "Internal server error" },
+ { status: 500 }
+ )
+ }
+}
diff --git a/src/app/api/recipes/route.ts b/src/app/api/recipes/route.ts
new file mode 100644
index 0000000..2a9ad11
--- /dev/null
+++ b/src/app/api/recipes/route.ts
@@ -0,0 +1,72 @@
+import { NextResponse } from "next/server"
+import { auth } from "@/lib/auth"
+import { prisma } from "@/lib/prisma"
+import { recipeCreateSchema } from "@/lib/validators"
+import type { Prisma } from "@prisma/client"
+
+export async function GET() {
+ try {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ const recipes = await prisma.recipe.findMany({
+ where: { userId: session.user.id },
+ orderBy: { createdAt: "desc" },
+ include: {
+ sourceDrink: {
+ select: { name: true, type: true },
+ },
+ },
+ })
+
+ return NextResponse.json({ recipes })
+ } catch (error) {
+ console.error("GET /api/recipes error:", error)
+ return NextResponse.json(
+ { error: "Internal server error" },
+ { status: 500 }
+ )
+ }
+}
+
+export async function POST(request: Request) {
+ try {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ const body = await request.json()
+ const parsed = recipeCreateSchema.safeParse(body)
+
+ if (!parsed.success) {
+ return NextResponse.json(
+ { error: "Validation failed", issues: parsed.error.issues },
+ { status: 400 }
+ )
+ }
+
+ const recipe = await prisma.recipe.create({
+ data: {
+ userId: session.user.id,
+ title: parsed.data.title,
+ ingredients: parsed.data.ingredients as unknown as Prisma.InputJsonValue,
+ steps: parsed.data.steps as unknown as Prisma.InputJsonValue,
+ garnish: parsed.data.garnish || null,
+ glassware: parsed.data.glassware || null,
+ sourceDrinkId: parsed.data.sourceDrinkId || null,
+ notes: parsed.data.notes || null,
+ },
+ })
+
+ return NextResponse.json(recipe, { status: 201 })
+ } catch (error) {
+ console.error("POST /api/recipes error:", error)
+ return NextResponse.json(
+ { error: "Internal server error" },
+ { status: 500 }
+ )
+ }
+}
diff --git a/src/app/api/recommend/profile/route.ts b/src/app/api/recommend/profile/route.ts
new file mode 100644
index 0000000..d794595
--- /dev/null
+++ b/src/app/api/recommend/profile/route.ts
@@ -0,0 +1,192 @@
+import { NextResponse } from "next/server"
+import { auth } from "@/lib/auth"
+import { prisma } from "@/lib/prisma"
+import { decrypt } from "@/lib/encryption"
+import { createProvider } from "@/lib/ai/provider-factory"
+import { rateLimit } from "@/lib/rate-limit"
+import { FLAVOR_PROFILE_PROMPT, buildDrinkHistoryString } from "@/lib/ai/prompts"
+import type { Prisma } from "@prisma/client"
+
+export async function GET() {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ try {
+ const profile = await prisma.flavorProfile.findUnique({
+ where: { userId: session.user.id },
+ })
+
+ if (!profile) {
+ return NextResponse.json({ profile: null })
+ }
+
+ // Check staleness by comparing stored ratingCount to current count
+ const currentRatingCount = await prisma.rating.count({
+ where: { userId: session.user.id },
+ })
+
+ return NextResponse.json({
+ profile: {
+ id: profile.id,
+ profileText: profile.profileText,
+ profileData: profile.profileData,
+ generatedAt: profile.generatedAt,
+ ratingCount: profile.ratingCount,
+ isStale: currentRatingCount !== profile.ratingCount,
+ currentRatingCount,
+ },
+ })
+ } catch (error) {
+ console.error("Flavor profile fetch error:", error)
+ return NextResponse.json(
+ { error: "Failed to fetch flavor profile." },
+ { status: 500 }
+ )
+ }
+}
+
+export async function POST() {
+ const session = await auth()
+ if (!session?.user?.id) {
+ return NextResponse.json({ error: "Unauthorized" }, { status: 401 })
+ }
+
+ // Rate limit: 5 profile generations per minute
+ const { success: withinLimit } = rateLimit(
+ `recommend-profile:${session.user.id}`,
+ 5,
+ 60 * 1000
+ )
+ if (!withinLimit) {
+ return NextResponse.json(
+ { error: "Too many requests. Please wait a moment." },
+ { status: 429 }
+ )
+ }
+
+ try {
+ // Get user's AI provider
+ const apiKeyRecord = await prisma.userApiKey.findFirst({
+ where: { userId: session.user.id, isActive: true },
+ })
+
+ if (!apiKeyRecord) {
+ return NextResponse.json(
+ { error: "No AI provider configured. Add an API key in Settings." },
+ { status: 400 }
+ )
+ }
+
+ // Fetch all drinks with ratings
+ const drinks = await prisma.drink.findMany({
+ where: { userId: session.user.id },
+ include: {
+ ratings: {
+ where: { userId: session.user.id },
+ },
+ },
+ })
+
+ // Build drink summaries with computed avg rating
+ const drinkSummaries = drinks
+ .filter((d) => d.ratings.length > 0)
+ .map((d) => {
+ const avgRating =
+ d.ratings.reduce((sum, r) => sum + r.score, 0) / d.ratings.length
+ const wouldReorder = d.ratings.some((r) => r.wouldReorder)
+ return {
+ name: d.name,
+ type: d.type,
+ subType: d.subType,
+ brewery: d.brewery,
+ avgRating: Math.round(avgRating * 10) / 10,
+ ratingCount: d.ratings.length,
+ wouldReorder,
+ }
+ })
+
+ if (drinkSummaries.length < 3) {
+ return NextResponse.json(
+ {
+ error:
+ "You need at least 3 rated drinks to generate a flavor profile. Keep rating drinks!",
+ },
+ { status: 400 }
+ )
+ }
+
+ const drinkHistory = buildDrinkHistoryString(drinkSummaries)
+ const prompt = FLAVOR_PROFILE_PROMPT.replace("{drinkHistory}", drinkHistory)
+
+ const apiKey = decrypt(apiKeyRecord.encryptedKey, apiKeyRecord.iv)
+ const provider = createProvider(apiKeyRecord.provider, apiKey)
+
+ const rawResponse = await provider.sendTextRequest(
+ prompt,
+ "Analyze my drink history and build my flavor profile."
+ )
+
+ // Parse the JSON response
+ let profileData: Record
+ generateProfile.mutate()}
+ />
+
+
+
+
+
+
+
+
+
+ + AI-powered drink suggestions tailored to your taste. +
+
+
+ )
+}
diff --git a/src/components/bar/bar-item-card.tsx b/src/components/bar/bar-item-card.tsx
new file mode 100644
index 0000000..d5ddc78
--- /dev/null
+++ b/src/components/bar/bar-item-card.tsx
@@ -0,0 +1,105 @@
+"use client"
+
+import { Card, CardContent } from "@/components/ui/card"
+import { Badge } from "@/components/ui/badge"
+import { Button } from "@/components/ui/button"
+import { Pencil, Trash2 } from "lucide-react"
+import { cn } from "@/lib/utils"
+import type { BarItem } from "@/hooks/use-bar"
+
+const CATEGORY_COLORS: Record
+
+ + {CATEGORY_LABELS[category] || category} +
+ + ({items.length}) + +
+ {items.map((item) => (
+
+
+
+
+ + {item.name} +
+
+
+
+
+
+
+ {CATEGORY_LABELS[item.category] || item.category}
+
+
+ {QUANTITY_LABELS[item.quantity] || item.quantity}
+
+
+
+ {item.notes && (
+ + {item.notes} +
+ )} +