feat: add prediction big change

.env.example

@@ -23,3 +23,9 @@ AUTH_GOOGLE_ID=
 AUTH_GOOGLE_SECRET=
 AUTH_GITHUB_ID=
 AUTH_GITHUB_SECRET=
+
+# Stripe (optional) — astro coin purchases on /dashboard
+# Dashboard: https://dashboard.stripe.com/apikeys
+STRIPE_SECRET_KEY=
+# Webhook signing secret (Stripe CLI local: stripe listen --forward-to localhost:8066/api/stripe/webhook)
+STRIPE_WEBHOOK_SECRET=

Makefile

@@ -1,19 +1,35 @@
-.PHONY: dev server generate build start lint typecheck test coverage check install clean
+.PHONY: dev server generate migrate migrate-dev predict-build build start lint typecheck test coverage check install clean
 
-# Development server (alias: dev)
+# Development server. Stops whatever is bound to 8066 (usually a stray `next dev`)
+# and clears a stale Turbopack lock so a fresh server can start.
 dev:
+	@for pid in $$(lsof -ti:8066 2>/dev/null); do kill $$pid 2>/dev/null || true; done
+	@sleep 0.4
+	@rm -f .next/dev/lock
 	npm run dev
 
 # Prisma
 generate:
 	npx prisma generate
 
+# Generate predict runtime JSON from source strings.
+predict-build:
+	npm run predict:build
+
+# Apply pending migrations (production / CI). Requires DIRECT_URL or DATABASE_URL in .env.
+migrate:
+	npx prisma migrate deploy
+
+# Create/apply migrations in development (interactive). Requires DIRECT_URL or DATABASE_URL.
+migrate-dev:
+	npx prisma migrate dev
+
 # Build and run
 build:
 	npx prisma generate
 	npm run build
 
-server:
+server:build
 	npm run start
 
 # Lint and typecheck

README.md

@@ -1,6 +1,59 @@
-# 🔮 future
+# Future AI
+
+*Natal charts — Western astrology, whole sign houses, tropical zodiac.*
+
+Next.js app: birth date, time, and place → planetary positions, houses, chart wheel, and placement tables.
+
+## Quick start
+
+```bash
+make install
+make dev
+```
+
+Open [http://localhost:8066](http://localhost:8066).
+
+## Development vs production
+
+| Command | What it does |
+|--------|----------------|
+| `make dev` | `next dev` — serves **current source** (hot reload). |
+| `make build` | Production build into `.next` (runs `prisma generate` first). |
+| `make server` | `next start` — serves the **last** production build only. |
+
+`make server` does not compile your latest edits. Run `make build` before `make server` whenever you want production mode to match recent changes:
+
+```bash
+make build && make server
+```
+
+Both dev and production use **port 8066**; only one can listen at a time.
+
+## Common commands
+
+- `make dev` — development server
+- `make build` — production build
+- `make server` — run production server (after `make build`)
+- `make lint` / `make typecheck` / `make test` — quality checks (`make check` runs all three)
+- `make generate` — Prisma client from schema
+- `make migrate` — apply migrations (needs `DATABASE_URL` / `DIRECT_URL` in `.env`)
+- `make migrate-dev` — create/apply migrations in development
+- `make clean` — remove `.next` and `node_modules`
+
+Stripe and Astro Coins setup: [docs/STRIPE.md](docs/STRIPE.md).
+
+## Stack
+
+Next.js 16 (App Router), React 19, TypeScript, Tailwind CSS 4, Prisma, Vitest.
+
+<br>
+
+---
+
+## TODO
 
 <br>
 
-### *"ancient wisdom meets the AI age"*
+- training / fine-tuning the AI for astro
+- infra, deplopyment, etc.
 

app/api/astro-coins/ledger/route.ts

@@ -0,0 +1,39 @@
+import { NextResponse } from 'next/server';
+import { auth } from '@/auth';
+import { prisma } from '@/lib/db';
+
+const DEFAULT_LIMIT = 50;
+const MAX_LIMIT = 100;
+
+export async function GET(request: Request) {
+  const session = await auth();
+  if (!session?.user?.id) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  const { searchParams } = new URL(request.url);
+  const rawLimit = searchParams.get('limit');
+  let limit = DEFAULT_LIMIT;
+  if (rawLimit != null) {
+    const n = Number.parseInt(rawLimit, 10);
+    if (Number.isFinite(n) && n > 0) {
+      limit = Math.min(n, MAX_LIMIT);
+    }
+  }
+
+  const entries = await prisma.astroCoinLedger.findMany({
+    where: { userId: session.user.id },
+    orderBy: { createdAt: 'desc' },
+    take: limit,
+    select: {
+      id: true,
+      delta: true,
+      balanceAfter: true,
+      reason: true,
+      refId: true,
+      createdAt: true,
+    },
+  });
+
+  return NextResponse.json({ entries });
+}

app/api/astro-coins/route.ts

@@ -0,0 +1,32 @@
+import { NextResponse } from 'next/server';
+import { auth } from '@/auth';
+import { prisma } from '@/lib/db';
+import { getStripeSecretKey } from '@/lib/stripe-server';
+
+export const dynamic = 'force-dynamic';
+
+export async function GET() {
+  const session = await auth();
+  if (!session?.user?.id) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  try {
+    const user = await prisma.user.findUnique({
+      where: { id: session.user.id },
+      select: { astroCoins: true },
+    });
+
+    if (!user) {
+      return NextResponse.json({ error: 'Not found' }, { status: 404 });
+    }
+
+    return NextResponse.json({
+      coins: user.astroCoins,
+      stripeEnabled: Boolean(getStripeSecretKey()),
+    });
+  } catch (err) {
+    console.error('[astro-coins] GET', err);
+    return NextResponse.json({ error: 'Database error' }, { status: 500 });
+  }
+}

app/api/charts/route.ts

@@ -34,7 +34,7 @@ export async function POST(request: Request) {
       typeof body.label === 'string'
         ? body.label.trim()
         : isPrimary
-          ? 'My chart'
+          ? 'my chart'
           : '';
     const birthData = body.birthData;
     const chartResult = body.chartResult;

app/api/chat/route.ts

@@ -55,7 +55,12 @@ export async function POST(request: Request) {
 
     if (!res.ok) {
       const err = await res.text();
-      console.error('Anthropic API error', res.status, err);
+      const requestId = res.headers.get('request-id') ?? res.headers.get('x-request-id');
+      console.error('Anthropic API error', {
+        status: res.status,
+        requestId,
+        details: process.env.NODE_ENV === 'development' ? err : undefined,
+      });
       return NextResponse.json(
         {
           error:

app/api/predict/bet/route.ts

@@ -0,0 +1,96 @@
+import { NextResponse } from 'next/server';
+import { auth } from '@/auth';
+import {
+  applyAstroCoinDelta,
+  InsufficientAstroCoinsError,
+} from '@/lib/astro-coins-ledger';
+import { isValidPredictQuestionId, normalizePredictBetSide } from '@/lib/predict-validate';
+import { prisma } from '@/lib/db';
+
+const MAX_COINS_PER_BET = 1_000_000;
+
+export async function POST(request: Request) {
+  const session = await auth();
+  if (!session?.user?.id) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  let body: unknown;
+  try {
+    body = await request.json();
+  } catch {
+    return NextResponse.json({ error: 'Invalid JSON' }, { status: 400 });
+  }
+
+  const questionId =
+    typeof body === 'object' &&
+    body !== null &&
+    'questionId' in body &&
+    typeof (body as { questionId: unknown }).questionId === 'number'
+      ? (body as { questionId: number }).questionId
+      : Number.NaN;
+
+  const sideRaw =
+    typeof body === 'object' &&
+    body !== null &&
+    'side' in body &&
+    typeof (body as { side: unknown }).side === 'string'
+      ? (body as { side: string }).side.trim()
+      : '';
+
+  const coinsRaw =
+    typeof body === 'object' &&
+    body !== null &&
+    'coins' in body &&
+    typeof (body as { coins: unknown }).coins === 'number'
+      ? (body as { coins: number }).coins
+      : Number.NaN;
+
+  const coins = Math.floor(Number(coinsRaw));
+  if (!Number.isFinite(coins) || coins < 1 || coins > MAX_COINS_PER_BET) {
+    return NextResponse.json(
+      { error: `Invest between 1 and ${MAX_COINS_PER_BET} coins` },
+      { status: 400 },
+    );
+  }
+
+  const normalizedSide = normalizePredictBetSide(questionId, sideRaw);
+  if (normalizedSide === null || !isValidPredictQuestionId(questionId)) {
+    return NextResponse.json(
+      { error: 'Unknown question or invalid choice' },
+      { status: 400 },
+    );
+  }
+
+  const refId = `${questionId}:${normalizedSide}`;
+
+  try {
+    const balance = await prisma.$transaction(async tx => {
+      const afterDebit = await applyAstroCoinDelta(
+        tx,
+        session.user.id,
+        -coins,
+        'predict_bet',
+        refId,
+      );
+      await tx.predictBet.create({
+        data: {
+          userId: session.user.id,
+          questionId,
+          side: normalizedSide,
+          coins,
+        },
+      });
+      return afterDebit;
+    });
+    return NextResponse.json({ balance });
+  } catch (e) {
+    if (e instanceof InsufficientAstroCoinsError) {
+      return NextResponse.json(
+        { error: 'Not enough astro coins' },
+        { status: 402 },
+      );
+    }
+    throw e;
+  }
+}