openreader/src/app/api/user/state/progress/route.ts

import { NextRequest, NextResponse } from 'next/server';
import { and, eq, sql } from 'drizzle-orm';
import { db } from '@/db';
import { userDocumentProgress } from '@/db/schema';
import type { ReaderType } from '@/types/user-state';
import { isValidDocumentId } from '@/lib/server/documents-blobstore';
import { resolveUserStateScope } from '@/lib/server/user-state-scope';

export const dynamic = 'force-dynamic';

function nowForDb(): Date | number {
  return process.env.POSTGRES_URL ? new Date() : Date.now();
}

function normalizeReaderType(value: unknown): ReaderType | null {
  if (value === 'pdf' || value === 'epub' || value === 'html') return value;
  return null;
}

function normalizeClientUpdatedAtMs(value: unknown): number {
  if (!Number.isFinite(value)) return Date.now();
  const normalized = Number(value);
  if (normalized <= 0) return Date.now();
  return Math.floor(normalized);
}

function toUpdatedAtMs(value: unknown): number {
  if (typeof value === 'number' && Number.isFinite(value)) return value;
  if (value instanceof Date) return value.getTime();
  return Date.now();
}

export async function GET(req: NextRequest) {
  try {
    const scope = await resolveUserStateScope(req);
    if (scope instanceof Response) return scope;

    const documentId = (new URL(req.url).searchParams.get('documentId') || '').trim().toLowerCase();
    if (!isValidDocumentId(documentId)) {
      return NextResponse.json({ error: 'Invalid documentId' }, { status: 400 });
    }

    const rows = await db
      .select({
        documentId: userDocumentProgress.documentId,
        readerType: userDocumentProgress.readerType,
        location: userDocumentProgress.location,
        progress: userDocumentProgress.progress,
        clientUpdatedAtMs: userDocumentProgress.clientUpdatedAtMs,
        updatedAt: userDocumentProgress.updatedAt,
      })
      .from(userDocumentProgress)
      .where(and(
        eq(userDocumentProgress.userId, scope.ownerUserId),
        eq(userDocumentProgress.documentId, documentId),
      ))
      .limit(1);

    const row = rows[0];
    if (!row) {
      return NextResponse.json({ progress: null });
    }

    return NextResponse.json({
      progress: {
        documentId: row.documentId,
        readerType: row.readerType,
        location: row.location,
        progress: row.progress == null ? null : Number(row.progress),
        clientUpdatedAtMs: Number(row.clientUpdatedAtMs ?? 0),
        updatedAtMs: toUpdatedAtMs(row.updatedAt),
      },
    });
  } catch (error) {
    console.error('Error loading user progress:', error);
    return NextResponse.json({ error: 'Failed to load user progress' }, { status: 500 });
  }
}

export async function PUT(req: NextRequest) {
  try {
    const scope = await resolveUserStateScope(req);
    if (scope instanceof Response) return scope;

    const body = (await req.json().catch(() => null)) as
      | {
        documentId?: unknown;
        readerType?: unknown;
        location?: unknown;
        progress?: unknown;
        clientUpdatedAtMs?: unknown;
      }
      | null;

    const documentId = typeof body?.documentId === 'string' ? body.documentId.trim().toLowerCase() : '';
    if (!isValidDocumentId(documentId)) {
      return NextResponse.json({ error: 'Invalid documentId' }, { status: 400 });
    }

    const readerType = normalizeReaderType(body?.readerType);
    if (!readerType) {
      return NextResponse.json({ error: "Invalid readerType. Expected 'pdf', 'epub', or 'html'." }, { status: 400 });
    }

    const location = typeof body?.location === 'string' ? body.location.trim() : '';
    if (!location) {
      return NextResponse.json({ error: 'Invalid location' }, { status: 400 });
    }

    const progress =
      body?.progress == null
        ? null
        : Number.isFinite(body.progress)
          ? Math.max(0, Math.min(1, Number(body.progress)))
          : null;
    const clientUpdatedAtMs = normalizeClientUpdatedAtMs(body?.clientUpdatedAtMs);

    const existingRows = await db
      .select({
        clientUpdatedAtMs: userDocumentProgress.clientUpdatedAtMs,
        location: userDocumentProgress.location,
        readerType: userDocumentProgress.readerType,
        progress: userDocumentProgress.progress,
        updatedAt: userDocumentProgress.updatedAt,
      })
      .from(userDocumentProgress)
      .where(and(
        eq(userDocumentProgress.userId, scope.ownerUserId),
        eq(userDocumentProgress.documentId, documentId),
      ))
      .limit(1);
    const existing = existingRows[0];
    const existingUpdated = Number(existing?.clientUpdatedAtMs ?? 0);

    if (existing && clientUpdatedAtMs < existingUpdated) {
      return NextResponse.json({
        progress: {
          documentId,
          readerType: existing.readerType,
          location: existing.location,
          progress: existing.progress == null ? null : Number(existing.progress),
          clientUpdatedAtMs: existingUpdated,
          updatedAtMs: toUpdatedAtMs(existing.updatedAt),
        },
        applied: false,
      });
    }

    const updatedAt = nowForDb();
    await db
      .insert(userDocumentProgress)
      .values({
        userId: scope.ownerUserId,
        documentId,
        readerType,
        location,
        progress,
        clientUpdatedAtMs,
        updatedAt,
      })
      .onConflictDoUpdate({
        target: [userDocumentProgress.userId, userDocumentProgress.documentId],
        set: {
          readerType,
          location,
          progress,
          clientUpdatedAtMs,
          updatedAt,
        },
        setWhere: sql`${userDocumentProgress.clientUpdatedAtMs} <= ${clientUpdatedAtMs}`,
      });

    return NextResponse.json({
      progress: {
        documentId,
        readerType,
        location,
        progress,
        clientUpdatedAtMs,
        updatedAtMs: toUpdatedAtMs(updatedAt),
      },
      applied: true,
    });
  } catch (error) {
    console.error('Error updating user progress:', error);
    return NextResponse.json({ error: 'Failed to update user progress' }, { status: 500 });
  }
}