가입부터 첫 글 발행까지,
한 번에 보는 Trina 연동 안내

# 1. 준비된 글 목록 (본문 없이, 최신순)
curl -H "Authorization: Bearer trn_live_..." \
  "https://trina.app/api/v1/posts?status=ready"

# 2. 글 하나 (본문을 markdown · html 두 가지로)
curl -H "Authorization: Bearer trn_live_..." \
  "https://trina.app/api/v1/posts/<id>"

# 3. 사이트에 올린 뒤 게시 주소 알려 주기
curl -X POST -H "Authorization: Bearer trn_live_..." \
  -H "Content-Type: application/json" \
  -d '{"url":"https://<회사도메인>/blog/<slug>"}' \
  "https://trina.app/api/v1/posts/<id>/published"

# 경로는 자유롭게 정하세요
POST https://<회사도메인>/api/blog/ingest
Authorization: Bearer <공유 토큰>
Content-Type: application/json

{
  "title": "매물 소개서 잘 쓰는 법",
  "content": "<h2 style=\"font-size:1.45em\">방법</h2><p style=\"line-height:1.85\">본문…</p>",
  "slug": "how-to-write-a-listing",
  "status": "published",
  "excerpt": "실무에서 바로 쓰는 요령.",
  "cover_image_url": null,
  "tags": []
}

{ "ok": true, "post": { "slug": "how-to-write-a-listing" } }

insert into blog_posts (...) values (...)
on conflict (slug) do update set ...

# 토큰 하나를 새로 만들어 양쪽에 같은 값을 넣어요
openssl rand -base64 32

# 고객사 서버 환경변수
BLOG_INGEST_SECRET=<위 값>

// 저장에 성공한 다음, 수신 엔드포인트가 직접 부른다
await fetch(process.env.DEPLOY_HOOK_URL!, { method: "POST" });

/**
 * 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;
}

/**
 * 토큰을 읽는다. **두 이름을 다 받는다.**
 *
 * 규격상 이름은 `BLOG_INGEST_SECRET` 이지만 `BLOG_INGEST_TOKEN` 으로 넣는
 * 실수가 실제로 났다(2026-09-16). 증상이 401 이 아니라 "왜 안 되는지
 * 모르겠다" 였고, 원인을 찾는 데 왕복이 여러 번 들었다. 이름 하나 때문에
 * 그 왕복이 생기는 것보다 둘 다 받는 쪽이 싸다.
 *
 * `secretEnvName()` 을 손으로 짐작해서 터진 것과 같은 클래스의 문제다.
 */
function ingestSecret(): string {
  return (
    process.env.BLOG_INGEST_SECRET?.trim() ||
    process.env.BLOG_INGEST_TOKEN?.trim() ||
    ""
  );
}

export async function POST(request: Request) {
  // 토큰이 없으면 열지 않는다 — 배포 실수가 공개 쓰기가 되면 안 된다 (가이드 ⑤).
  const expected = ingestSecret();
  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 } });
}

/**
 * `GET` 은 405 로 답한다.
 *
 * Trina 콘솔의 "연동 확인하기" 가 `GET` 을 한 번 보내고 **405 를 '살아 있음'
 * 으로 읽는다**(`client/src/lib/publish-verify.ts`). App Router 가 알아서
 * 405 를 주기도 하지만, 명시해 두면 판정이 스택에 따라 흔들리지 않는다.
 * 200 을 주면 콘솔이 "토큰까지 확인됐다" 로 표시하므로 200 은 틀린 답이다.
 */
export function GET() {
  return NextResponse.json({ message: "Method Not Allowed" }, { status: 405 });
}

/**
 * Supabase Edge Function — Trina 가 보내는 글을 받는다.
 *
 * 계약: docs/integration/blog-ingest.md
 * 배포:  supabase functions deploy blog-ingest --no-verify-jwt
 *
 * ─────────────────────────────────────────────────────────────────────────
 * ⚠️ 먼저 읽으세요 — 이걸 모르면 첫 발행이 401 로 죽습니다
 * ─────────────────────────────────────────────────────────────────────────
 * `functions/v1/*` 는 기본적으로 **게이트웨이가 `Authorization` 헤더를
 * Supabase JWT 로 검증**합니다. Trina 는 그 헤더에 우리가 주고받기로 한 공유
 * 토큰을 넣어 보내므로, JWT 검증을 켜 둔 채로는 **이 함수 코드가 실행되기도
 * 전에** 401 이 납니다. 로그에도 함수 호출 기록이 안 남아서 원인 찾기가
 * 어렵습니다.
 *
 * 그래서 검증을 끄고, 토큰은 **함수 안에서 직접** 비교합니다:
 *
 *   # supabase/config.toml
 *   [functions.blog-ingest]
 *   verify_jwt = false
 *
 * 끄는 대신 아래 ①이 유일한 자물쇠가 되므로, 토큰 검사를 빼지 마세요.
 */
import { createClient } from "jsr:@supabase/supabase-js@2";

/**
 * 위험한 마크업을 **벗기지 않고 거절한다.**
 *
 * 허용목록 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;
}

const json = (body: unknown, status = 200) =>
  new Response(JSON.stringify(body), {
    status,
    headers: { "content-type": "application/json" },
  });

Deno.serve(async (request: Request) => {
  if (request.method !== "POST") return json({ message: "POST only" }, 405);

  // ① 토큰이 없으면 열지 않는다 — 배포 실수가 공개 쓰기가 되면 안 됩니다
  //    (가이드 ⑤). verify_jwt 를 껐으므로 이 검사가 유일한 자물쇠입니다.
  // 두 이름을 다 받는다 — `BLOG_INGEST_TOKEN` 으로 넣는 실수가 실제로 났고
  // (2026-09-16), 증상이 401 이 아니라 원인을 못 찾는 침묵이었다.
  const expected =
    Deno.env.get("BLOG_INGEST_SECRET")?.trim() ||
    Deno.env.get("BLOG_INGEST_TOKEN")?.trim() ||
    "";
  const provided = (request.headers.get("authorization") ?? "")
    .replace(/^Bearer\s+/i, "")
    .trim();
  if (!expected || !provided || provided !== expected) {
    return json({ message: "Unauthorized" }, 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 json({ message: "slug, title, content 는 필수입니다" }, 400);
  }

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

  const supabase = createClient(
    Deno.env.get("SUPABASE_URL")!,
    // service_role 이어야 RLS 를 지나 씁니다. 이 함수는 위 ①로 이미 잠겨
    // 있으므로 여기서 익명 키를 쓰면 저장만 실패합니다.
    Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!,
  );

  // slug 로 upsert — 재전송이 글을 둘로 만들면 안 됩니다 (가이드 ②).
  const { error } = await supabase.from("blog_posts").upsert(
    {
      slug,
      title,
      content,
      excerpt: String(body?.excerpt ?? ""),
      cover_image_url: body?.cover_image_url ?? null,
      tags: Array.isArray(body?.tags) ? body.tags : [],
      status: body?.status === "draft" ? "draft" : "published",
      updated_at: new Date().toISOString(),
    },
    { onConflict: "slug" },
  );
  if (error) {
    console.error("[blog-ingest]", error);
    return json({ message: "저장하지 못했습니다" }, 500);
  }

  // 정적 사이트라면 여기서 재빌드를 트리거합니다. 훅 URL 은 **받는 쪽이**
  // 들고 있습니다 — Trina 에게 주지 마세요. 자세한 것은 blog-ingest.md §6.
  //
  // await fetch(Deno.env.get("DEPLOY_HOOK_URL")!, { method: "POST" });

  // 받은 slug 를 **그대로** 돌려줍니다. 다르면 보내는 쪽이 기록한 주소가
  // 거짓이 되고, 성과 측정이 조용히 끊깁니다 (가이드 ①).
  // 형태도 이대로 두세요 — Trina 는 `post.slug` 를 읽습니다.
  return json({ ok: true, post: { slug } });
});