db (site có database)

{
  "citely": "receiver",
  "protocol": 1,
  "profile": "runtime-db",
  "storageAdapter": "db",
  "accepts": ["html"],
  "locales": ["vi", "en"],
  "async": false
}

// app/api/citely/ingest/route.ts
export async function GET() {
  return Response.json({
    citely: 'receiver', protocol: 1, profile: 'runtime-db',
    storageAdapter: 'db', accepts: ['html'], locales: ['vi', 'en'], async: false,
  });
}

export async function POST(req: Request) {
  const raw = await req.text(); // RAW body trước khi parse
  const h = Object.fromEntries(req.headers) as Record<string, string>;
  if (!verify(process.env.CITELY_WEBHOOK_SECRET!, raw, h)) {
    return Response.json({ error: 'CPP_SIG_INVALID' }, { status: 401 });
  }

  const a = JSON.parse(raw);
  if (a.version !== 1) {
    return Response.json({ error: 'CPP_VERSION_UNSUPPORTED' }, { status: 400 });
  }
  if (a.test === true) {
    return Response.json({ ok: true });
  }

  try {
    const post = await db.posts.upsert({
      where: a.externalId ? { id: a.externalId } : { slug: a.slug },
      create: {
        title: a.title, slug: a.slug, body: a.html, excerpt: a.excerpt,
        jsonLd: a.jsonLd, cover: a.cover, locale: a.locale,
        translationKey: a.translationKey, tags: a.tags,
        author: a.author?.name, publishedAt: a.publishedAt, noindex: a.noindex,
      },
      update: {
        title: a.title, body: a.html, excerpt: a.excerpt,
        jsonLd: a.jsonLd, cover: a.cover, tags: a.tags, modifiedAt: a.modifiedAt,
      },
    });
    return Response.json({ id: String(post.id), url: `https://site.com/blog/${a.slug}`, status: 'live' });
  } catch (e) {
    return Response.json({ error: 'CPP_STORAGE_FAILED', message: String(e) }, { status: 500 });
  }
}