Files
goodgo-platform/apps/web/lib/du-an-server.ts
Ho Ngoc Hai dfc01c3bee
Some checks failed
CI / Lint → Typecheck → Test → Build (22) (push) Failing after 10s
CI / E2E Tests (push) Has been skipped
CodeQL Analysis / CodeQL (javascript-typescript) (push) Failing after 31s
E2E Tests / Playwright E2E (push) Failing after 7s
Security Scanning / Dependency Audit (pnpm) (push) Failing after 3s
Security Scanning / Trivy Scan — API Image (push) Failing after 34s
Security Scanning / Trivy Scan — Web Image (push) Failing after 23s
Security Scanning / Trivy Scan — AI Services Image (push) Failing after 25s
Security Scanning / Trivy Filesystem Scan (push) Failing after 26s
Deploy / Smoke Test Staging (push) Has been skipped
Deploy / Deploy to Production (push) Has been skipped
Deploy / Build API Image (push) Failing after 16s
Deploy / Build Web Image (push) Failing after 9s
Deploy / Build AI Services Image (push) Failing after 8s
Deploy / Deploy to Staging (push) Has been skipped
Deploy / Smoke Test Production (push) Has been skipped
Security Scanning / Security Gate (push) Failing after 0s
Deploy / Rollback Staging (push) Has been skipped
Deploy / Rollback Production (push) Has been skipped
fix: align Project status enum to Prisma + cascade child records on listing delete
Project status was declared on the frontend as
UPCOMING/SELLING/HANDOVER/COMPLETED but the Prisma enum
ProjectDevelopmentStatus is PLANNING/UNDER_CONSTRUCTION/HANDOVER/
COMPLETED — CREATE failed with "status must be one of …". Aligned the
TypeScript union + PROJECT_STATUS_LABELS/COLORS, filter options on
/projects list, and both new + edit forms. Updated the
normalizeProjectDetail fallback and the du-an test spec to match.

Listings DELETE was blocked by FK references (Inquiry, SavedListing,
PriceHistory, Order, Transaction have no onDelete: Cascade in schema).
Wrapped the Prisma listing delete in a $transaction that removes the
child rows first, then the listing itself, so CRUD from the dashboard
actually lands instead of returning "Referenced record does not exist".

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
2026-04-19 13:36:46 +07:00

146 lines
5.4 KiB
TypeScript

/**
* Server-side project data fetching for Next.js Server Components.
*
* Uses `fetch` directly (no browser-only helpers) so it can run
* inside `generateMetadata`, `generateStaticParams`, `sitemap()`, etc.
*/
import type {
ProjectDetail,
ProjectMedia,
ProjectSummary,
PaginatedResult,
} from './du-an-api';
const API_BASE_URL = process.env['NEXT_PUBLIC_API_URL'] || 'http://localhost:3001/api/v1';
/**
* The backend detail endpoint currently returns a thin projection: the
* repository's raw row run through `shapeProject`, which strips `media` and
* omits the richer fields (`blocks`, `amenities`, `priceRanges`, …) that the
* frontend detail page consumes.
*
* Until the backend detail endpoint is enriched, normalize the payload here
* so the UI never crashes on missing arrays or mis-keyed developer fields.
*/
function normalizeProjectDetail(raw: unknown): ProjectDetail | null {
if (!raw || typeof raw !== 'object') return null;
const r = raw as Record<string, unknown>;
// Developer: backend currently returns `{ id, name, logo }`; frontend expects
// `{ id, name, logoUrl, totalProjects }`.
const rawDeveloper = (r['developer'] ?? {}) as Record<string, unknown>;
const developer = {
id: typeof rawDeveloper['id'] === 'string' ? rawDeveloper['id'] : '',
name: typeof rawDeveloper['name'] === 'string' ? rawDeveloper['name'] : '',
logoUrl:
(rawDeveloper['logoUrl'] as string | null | undefined) ??
(rawDeveloper['logo'] as string | null | undefined) ??
null,
totalProjects:
typeof rawDeveloper['totalProjects'] === 'number' ? rawDeveloper['totalProjects'] : 0,
};
// Media: may be absent (stripped by backend), or present as a raw JSON array.
const rawMedia = Array.isArray(r['media']) ? (r['media'] as Record<string, unknown>[]) : [];
const media: ProjectMedia[] = rawMedia.map((m, idx) => ({
id: typeof m['id'] === 'string' ? m['id'] : `media-${idx}`,
url: typeof m['url'] === 'string' ? m['url'] : '',
type:
m['type'] === 'video' ||
m['type'] === 'master_plan' ||
m['type'] === 'document' ||
m['type'] === 'image'
? (m['type'] as ProjectMedia['type'])
: 'image',
order: typeof m['order'] === 'number' ? m['order'] : idx,
caption: typeof m['caption'] === 'string' ? m['caption'] : null,
}));
const asArray = <T>(v: unknown): T[] => (Array.isArray(v) ? (v as T[]) : []);
return {
id: String(r['id'] ?? ''),
slug: String(r['slug'] ?? ''),
name: String(r['name'] ?? ''),
status: (r['status'] as ProjectDetail['status']) ?? 'PLANNING',
developer,
city: String(r['city'] ?? ''),
district: String(r['district'] ?? ''),
address: String(r['address'] ?? ''),
latitude: typeof r['latitude'] === 'number' ? (r['latitude'] as number) : null,
longitude: typeof r['longitude'] === 'number' ? (r['longitude'] as number) : null,
thumbnailUrl:
(r['thumbnailUrl'] as string | null | undefined) ??
media[0]?.url ??
null,
totalArea: typeof r['totalArea'] === 'number' ? (r['totalArea'] as number) : 0,
totalUnits: typeof r['totalUnits'] === 'number' ? (r['totalUnits'] as number) : 0,
propertyTypes: asArray<ProjectDetail['propertyTypes'][number]>(r['propertyTypes']),
minPrice: (r['minPrice'] as string | null | undefined) ?? null,
maxPrice: (r['maxPrice'] as string | null | undefined) ?? null,
completionDate: (r['completionDate'] as string | null | undefined) ?? null,
createdAt: String(r['createdAt'] ?? new Date().toISOString()),
description: typeof r['description'] === 'string' ? (r['description'] as string) : '',
media,
blocks: asArray(r['blocks']),
amenities: asArray(r['amenities']),
priceRanges: asArray(r['priceRanges']),
priceHistory: asArray(r['priceHistory']),
neighborhoodScores: asArray(r['neighborhoodScores']),
pois: asArray(r['pois']),
documents: asArray(r['documents']),
linkedListingCount:
typeof r['linkedListingCount'] === 'number' ? (r['linkedListingCount'] as number) : 0,
};
}
/**
* Fetch a single project by slug — server-only.
* Returns `null` when the project is not found (404) so callers can `notFound()`.
*/
export async function fetchProjectBySlug(slug: string): Promise<ProjectDetail | null> {
try {
const res = await fetch(`${API_BASE_URL}/projects/${slug}`, {
next: { revalidate: 300 }, // ISR: re-validate every 5 min
});
if (!res.ok) return null;
const raw = (await res.json()) as unknown;
return normalizeProjectDetail(raw);
} catch {
return null;
}
}
/**
* Fetch active projects — server-only, used by the dynamic sitemap.
*/
export async function fetchProjects(params: {
page?: number;
limit?: number;
city?: string;
status?: string;
}): Promise<PaginatedResult<ProjectSummary>> {
const query = new URLSearchParams({
page: String(params.page ?? 1),
limit: String(params.limit ?? 100),
});
if (params.city) query.append('city', params.city);
if (params.status) query.append('status', params.status);
try {
const res = await fetch(`${API_BASE_URL}/projects?${query}`, {
next: { revalidate: 3600 }, // re-validate every hour for sitemap
});
if (!res.ok) {
return { data: [], total: 0, page: 1, limit: 100, totalPages: 0 };
}
return (await res.json()) as PaginatedResult<ProjectSummary>;
} catch {
return { data: [], total: 0, page: 1, limit: 100, totalPages: 0 };
}
}