feat: implement AI city scan proxy route and add premium dark theme dashboard styling
This commit is contained in:
@@ -6,12 +6,12 @@ import {
|
|||||||
|
|
||||||
const API_BASE = process.env.POLYWEATHER_API_BASE_URL;
|
const API_BASE = process.env.POLYWEATHER_API_BASE_URL;
|
||||||
const SCAN_AI_PROXY_TIMEOUT_MS = Math.max(
|
const SCAN_AI_PROXY_TIMEOUT_MS = Math.max(
|
||||||
35_000,
|
85_000,
|
||||||
Number(process.env.POLYWEATHER_SCAN_AI_PROXY_TIMEOUT_MS || "55000") || 55_000,
|
Number(process.env.POLYWEATHER_SCAN_AI_PROXY_TIMEOUT_MS || "85000") || 85_000,
|
||||||
);
|
);
|
||||||
|
|
||||||
export const dynamic = "force-dynamic";
|
export const dynamic = "force-dynamic";
|
||||||
export const maxDuration = 60;
|
export const maxDuration = 90;
|
||||||
|
|
||||||
export async function POST(req: NextRequest) {
|
export async function POST(req: NextRequest) {
|
||||||
if (!API_BASE) {
|
if (!API_BASE) {
|
||||||
@@ -30,18 +30,20 @@ export async function POST(req: NextRequest) {
|
|||||||
|
|
||||||
let auth: Awaited<ReturnType<typeof buildBackendRequestHeaders>> | null = null;
|
let auth: Awaited<ReturnType<typeof buildBackendRequestHeaders>> | null = null;
|
||||||
const controller = new AbortController();
|
const controller = new AbortController();
|
||||||
|
const startedAt = Date.now();
|
||||||
const timeoutId = setTimeout(() => controller.abort(), SCAN_AI_PROXY_TIMEOUT_MS);
|
const timeoutId = setTimeout(() => controller.abort(), SCAN_AI_PROXY_TIMEOUT_MS);
|
||||||
|
const requestBody = body && typeof body === "object" ? body as Record<string, unknown> : {};
|
||||||
|
|
||||||
try {
|
try {
|
||||||
auth = await buildBackendRequestHeaders(req);
|
auth = await buildBackendRequestHeaders(req);
|
||||||
const headers = new Headers(auth.headers);
|
const headers = new Headers(auth.headers);
|
||||||
headers.set("Content-Type", "application/json");
|
headers.set("Content-Type", "application/json");
|
||||||
headers.set("Accept", "application/json");
|
headers.set("Accept", "application/json");
|
||||||
const requestBody = body && typeof body === "object" ? body as Record<string, unknown> : {};
|
|
||||||
console.info("[scan-ai-city] proxy request", {
|
console.info("[scan-ai-city] proxy request", {
|
||||||
city: requestBody.city,
|
city: requestBody.city,
|
||||||
force_refresh: requestBody.force_refresh === true,
|
force_refresh: requestBody.force_refresh === true,
|
||||||
locale: requestBody.locale,
|
locale: requestBody.locale,
|
||||||
|
timeout_ms: SCAN_AI_PROXY_TIMEOUT_MS,
|
||||||
});
|
});
|
||||||
const res = await fetch(`${API_BASE}/api/scan/terminal/ai-city`, {
|
const res = await fetch(`${API_BASE}/api/scan/terminal/ai-city`, {
|
||||||
method: "POST",
|
method: "POST",
|
||||||
@@ -68,6 +70,7 @@ export async function POST(req: NextRequest) {
|
|||||||
city: data?.city,
|
city: data?.city,
|
||||||
model: data?.model,
|
model: data?.model,
|
||||||
cached: data?.cached === true,
|
cached: data?.cached === true,
|
||||||
|
elapsed_ms: Date.now() - startedAt,
|
||||||
});
|
});
|
||||||
const response = NextResponse.json(data, {
|
const response = NextResponse.json(data, {
|
||||||
headers: {
|
headers: {
|
||||||
@@ -77,12 +80,23 @@ export async function POST(req: NextRequest) {
|
|||||||
return applyAuthResponseCookies(response, auth.response);
|
return applyAuthResponseCookies(response, auth.response);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
const timedOut = controller.signal.aborted;
|
const timedOut = controller.signal.aborted;
|
||||||
|
const elapsedMs = Date.now() - startedAt;
|
||||||
|
console.warn("[scan-ai-city] proxy failed", {
|
||||||
|
city: requestBody.city,
|
||||||
|
timed_out: timedOut,
|
||||||
|
elapsed_ms: elapsedMs,
|
||||||
|
timeout_ms: SCAN_AI_PROXY_TIMEOUT_MS,
|
||||||
|
error: String(error),
|
||||||
|
});
|
||||||
const response = NextResponse.json(
|
const response = NextResponse.json(
|
||||||
{
|
{
|
||||||
error: timedOut
|
error: timedOut
|
||||||
? "City AI request timed out"
|
? "City AI request timed out"
|
||||||
: "Failed to fetch city AI data",
|
: "Failed to fetch city AI data",
|
||||||
detail: String(error),
|
detail: String(error),
|
||||||
|
elapsed_ms: elapsedMs,
|
||||||
|
timeout_ms: SCAN_AI_PROXY_TIMEOUT_MS,
|
||||||
|
city: requestBody.city,
|
||||||
},
|
},
|
||||||
{ status: timedOut ? 504 : 500 },
|
{ status: timedOut ? 504 : 500 },
|
||||||
);
|
);
|
||||||
|
|||||||
@@ -11149,9 +11149,9 @@
|
|||||||
}
|
}
|
||||||
|
|
||||||
.root :global(.scan-ai-city-body) {
|
.root :global(.scan-ai-city-body) {
|
||||||
padding: 18px;
|
padding: 18px 18px 36px;
|
||||||
max-height: clamp(420px, 58vh, 760px);
|
max-height: none;
|
||||||
overflow-y: auto;
|
overflow: visible;
|
||||||
overscroll-behavior: contain;
|
overscroll-behavior: contain;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -652,7 +652,26 @@ function AiPinnedCityCard({
|
|||||||
})
|
})
|
||||||
.then(async (response) => {
|
.then(async (response) => {
|
||||||
if (!response.ok) {
|
if (!response.ok) {
|
||||||
throw new Error(`HTTP ${response.status}`);
|
let detail = "";
|
||||||
|
try {
|
||||||
|
const errorPayload = await response.json();
|
||||||
|
const message = String(errorPayload?.error || "").trim();
|
||||||
|
const rawDetail = String(errorPayload?.detail || "").trim();
|
||||||
|
const elapsed = Number(errorPayload?.elapsed_ms);
|
||||||
|
const timeout = Number(errorPayload?.timeout_ms);
|
||||||
|
detail = [
|
||||||
|
message,
|
||||||
|
rawDetail,
|
||||||
|
Number.isFinite(elapsed) && Number.isFinite(timeout)
|
||||||
|
? `elapsed ${Math.round(elapsed / 1000)}s / timeout ${Math.round(timeout / 1000)}s`
|
||||||
|
: "",
|
||||||
|
]
|
||||||
|
.filter(Boolean)
|
||||||
|
.join(" · ");
|
||||||
|
} catch {
|
||||||
|
detail = "";
|
||||||
|
}
|
||||||
|
throw new Error(detail ? `HTTP ${response.status} · ${detail}` : `HTTP ${response.status}`);
|
||||||
}
|
}
|
||||||
return response.json() as Promise<AiCityForecastPayload>;
|
return response.json() as Promise<AiCityForecastPayload>;
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user