import { NextResponse } from "next/server"; import type { DashboardMarketHubResponse } from "@/features/dashboard/types/dashboard.types"; import { hasKisConfig, normalizeTradingEnv } from "@/lib/kis/config"; import { getDomesticDashboardMarketHub } from "@/lib/kis/dashboard"; import { hasKisApiSession } from "@/app/api/kis/_session"; import { createKisApiErrorResponse, KIS_API_ERROR_CODE, toKisApiErrorMessage, } from "@/app/api/kis/_response"; import { readKisCredentialsFromHeaders } from "@/app/api/kis/domestic/_shared"; /** * @file app/api/kis/domestic/market-hub/route.ts * @description 국내주식 시장 허브(급등/인기/뉴스) 조회 API */ /** * 대시보드 시장 허브 조회 API * @returns 급등주식/인기종목/주요뉴스 목록 * @remarks UI 흐름: DashboardContainer -> useDashboardData -> /api/kis/domestic/market-hub -> MarketHubSection 렌더링 */ export async function GET(request: Request) { const hasSession = await hasKisApiSession(); if (!hasSession) { return createKisApiErrorResponse({ status: 401, code: KIS_API_ERROR_CODE.AUTH_REQUIRED, message: "로그인이 필요합니다.", }); } const credentials = readKisCredentialsFromHeaders(request.headers); if (!hasKisConfig(credentials)) { return createKisApiErrorResponse({ status: 400, code: KIS_API_ERROR_CODE.CREDENTIAL_REQUIRED, message: "KIS API 키 설정이 필요합니다.", }); } try { const result = await getDomesticDashboardMarketHub(credentials); const response: DashboardMarketHubResponse = { source: "kis", tradingEnv: normalizeTradingEnv(credentials.tradingEnv), gainers: result.gainers, losers: result.losers, popularByVolume: result.popularByVolume, popularByValue: result.popularByValue, news: result.news, pulse: result.pulse, warnings: result.warnings, fetchedAt: new Date().toISOString(), }; return NextResponse.json(response, { headers: { "cache-control": "no-store", }, }); } catch (error) { return createKisApiErrorResponse({ status: 500, code: KIS_API_ERROR_CODE.UPSTREAM_FAILURE, message: toKisApiErrorMessage( error, "시장 허브 조회 중 오류가 발생했습니다.", ), }); } }