search.ts

import { Hono } from "hono";
import type { HonoContext } from "../../types/env";
import { authMiddleware } from "../lib/auth";
import { validator, getValidated } from "../lib/validator";
import { rakutenSearchSchema, isbnSearchSchema } from "./schemas";
import type { RakutenSearchInput } from "./schemas/auth";
import { errorResponse, successResponse } from "../lib/response";
import { isValidISBN } from "../lib/validation";
import * as rakutenService from "../services/rakuten";
import { searchRateLimiter } from "../lib/rate-limit";
import { rankTechBooks } from "../domain/tech-book-search";

const app = new Hono<HonoContext>();

// 認証ミドルウェア適用
app.use("*", authMiddleware);

// 検索APIにRate Limiting適用（外部API呼び出しのため厳しめにする）
app.use("*", searchRateLimiter);

/**
 * 楽天ブックス検索
 * GET /api/search/books
 */
app.get("/books", validator("query", rakutenSearchSchema), async (c) => {
  // バリデーション済みのデータを取得
  const { query, limit, page, debug } = getValidated<RakutenSearchInput>(c, "query");

  // queryがundefinedの場合はエラーを返す
  if (!query) {
    return errorResponse(c, "検索クエリが指定されていません", "VALIDATION_ERROR", 400);
  }

  const { results, hits, pageCount } = await rakutenService.searchBooks(
    query,
    c.env.RAKUTEN_APP_ID,
    c.env.RAKUTEN_ACCESS_KEY,
    c.env.RAKUTEN_REQUEST_ORIGIN,
    limit ?? 20,
    page ?? 1,
  );

  const sortedResults = rankTechBooks(results, query, {
    includeReasons: debug === "1" || debug === "true",
  });

  return successResponse(c, {
    results: sortedResults,
    hits,
    pageCount,
    currentPage: page ?? 1,
  });
});

/**
 * ISBN検索
 * GET /api/search/isbn/:isbn
 */
app.get("/isbn/:isbn", validator("param", isbnSearchSchema), async (c) => {
  const isbn = c.req.param("isbn");
  if (!isValidISBN(isbn)) {
    return errorResponse(c, "Validation failed", "VALIDATION_ERROR", 400, "Invalid ISBN");
  }

  const result = await rakutenService.searchByISBN(
    isbn,
    c.env.RAKUTEN_APP_ID,
    c.env.RAKUTEN_ACCESS_KEY,
    c.env.RAKUTEN_REQUEST_ORIGIN,
  );

  if (!result) {
    return successResponse(c, null);
  }

  return successResponse(c, result);
});

export default app;