42 lines
1.4 KiB
TypeScript
42 lines
1.4 KiB
TypeScript
// src/app/api/search/route.ts
|
|
import { NextResponse } from "next/server";
|
|
import { Redis } from "@/lib/Redis";
|
|
|
|
export async function GET(request: Request) {
|
|
// 1. 검색어(query) 가져오기
|
|
const { searchParams } = new URL(request.url);
|
|
const query = searchParams.get("q");
|
|
|
|
if (!query) {
|
|
return NextResponse.json({ error: "검색어가 없습니다." }, { status: 400 });
|
|
}
|
|
|
|
// 2. 고유한 요청 ID 생성 (예: 1690001234567-abc)
|
|
const requestId = `${Date.now()}-${Math.random().toString(36).substring(7)}`;
|
|
const resultKey = `search:${requestId}`;
|
|
|
|
// 3. 봇에게 'site-bot' 채널로 검색 명령 발송 (Publish)
|
|
await Redis.publish("site-bot", JSON.stringify({
|
|
action: "search",
|
|
query: query,
|
|
requestId: requestId,
|
|
}));
|
|
|
|
// 4. 결과가 올라올 때까지 기다리기 (Polling)
|
|
// 최대 10번(약 10초) 동안 1.0초 간격으로 확인합니다.
|
|
for (let i=0; i<10; i++) {
|
|
// 1.0초 대기
|
|
await new Promise(resolve => setTimeout(resolve, 1000));
|
|
|
|
// Redis 게시판 확인
|
|
const resultData = await Redis.get(resultKey);
|
|
|
|
if (resultData) {
|
|
// 🌟 봇이 결과를 올렸다면! 데이터를 돌려주고 종료
|
|
return NextResponse.json(JSON.parse(resultData));
|
|
}
|
|
}
|
|
|
|
// 5초가 지나도 응답이 없으면 타임아웃
|
|
return NextResponse.json({ error: "봇이 검색에 응답하지 않습니다." }, { status: 504 });
|
|
} |