관리받고 싶은 블로그, 이렇게 붙입니다

/**
 * POST /api/blog/ingest — Trina 가 보내는 글을 받는다.
 *
 * 계약: docs/integration/blog-ingest.md
 */
import { NextResponse } from "next/server";
import { Pool } from "pg";

export const runtime = "nodejs";
export const dynamic = "force-dynamic";

const pool = new Pool({ connectionString: process.env.DATABASE_URL });

/**
 * 위험한 마크업을 **벗기지 않고 거절한다.**
 *
 * 허용목록 sanitizer 로 털면 본문이 싣고 온 인라인 스타일까지 날아가서 글이
 * 조용히 못생겨진다 (가이드 ④). 그래서 읽을 때 거르지 않고 쓸 때 검사한다.
 */
function findForbiddenMarkup(html: string): string | null {
  const checks: [RegExp, string][] = [
    [/<\s*script\b/i, "script"],
    [/<\s*iframe\b/i, "iframe"],
    [/<\s*object\b/i, "object"],
    [/<\s*embed\b/i, "embed"],
    [/\son[a-z]+\s*=/i, "event handler"],
    [/javascript\s*:/i, "javascript: URL"],
  ];
  for (const [re, name] of checks) if (re.test(html)) return name;
  return null;
}

export async function POST(request: Request) {
  // 토큰이 없으면 열지 않는다 — 배포 실수가 공개 쓰기가 되면 안 된다 (가이드 ⑤).
  const expected = process.env.BLOG_INGEST_SECRET?.trim();
  const provided = (request.headers.get("authorization") ?? "")
    .replace(/^Bearer\s+/i, "")
    .trim();
  if (!expected || !provided || provided !== expected) {
    return NextResponse.json({ message: "Unauthorized" }, { status: 401 });
  }

  const body = await request.json().catch(() => null);
  const slug = String(body?.slug ?? "").trim();
  const title = String(body?.title ?? "").trim();
  const content = String(body?.content ?? "").trim();
  if (!slug || !title || !content) {
    return NextResponse.json(
      { message: "slug, title, content 는 필수입니다" },
      { status: 400 },
    );
  }

  const forbidden = findForbiddenMarkup(content);
  if (forbidden) {
    // 무엇이 걸렸는지 알려준다 — 보내는 쪽이 고칠 수 있어야 한다.
    return NextResponse.json(
      { message: `본문에 허용되지 않는 마크업이 있습니다: ${forbidden}` },
      { status: 400 },
    );
  }

  try {
    // slug 로 upsert — 재전송이 글을 둘로 만들면 안 된다 (가이드 ②).
    await pool.query(
      `insert into blog_posts
         (slug, title, content, excerpt, cover_image_url, tags, status, updated_at)
       values ($1, $2, $3, $4, $5, $6, $7, now())
       on conflict (slug) do update set
         title = excluded.title,
         content = excluded.content,
         excerpt = excluded.excerpt,
         cover_image_url = excluded.cover_image_url,
         tags = excluded.tags,
         status = excluded.status,
         updated_at = now()`,
      [
        slug,
        title,
        content,
        String(body?.excerpt ?? ""),
        body?.cover_image_url ?? null,
        Array.isArray(body?.tags) ? body.tags : [],
        body?.status === "draft" ? "draft" : "published",
      ],
    );
  } catch (err) {
    console.error("[blog/ingest]", err);
    return NextResponse.json({ message: "저장하지 못했습니다" }, { status: 500 });
  }

  // 받은 slug 를 **그대로** 돌려준다. 다르면 보내는 쪽이 기록한 주소가
  // 거짓이 되고, 성과 측정이 조용히 끊긴다 (가이드 ①).
  return NextResponse.json({ ok: true, post: { slug } });
}