Custom Website Integration

import { NextRequest, NextResponse } from 'next/server';
import { db } from '@/lib/db';

function authenticate(req: NextRequest) {
  const auth = req.headers.get('authorization') || '';
  if (!auth.startsWith('Basic '))
    return null;
  const [user, pass] = atob(auth.slice(6)).split(':');
  return validateUser(user, pass); // returns user object or null
}

// GET /wp-json/wp/v2/posts — List posts
export async function GET(req: NextRequest) {
  const user = authenticate(req);
  if (!user) return NextResponse.json(
    { code: 'rest_not_logged_in', message: 'Unauthorized', data: { status: 401 } },
    { status: 401 }
  );

  const { searchParams } = new URL(req.url);
  const perPage = parseInt(searchParams.get('per_page') || '10');
  const page = parseInt(searchParams.get('page') || '1');

  const { posts, total } = await db.posts.list({ perPage, page });
  return NextResponse.json(posts, {
    headers: {
      'X-WP-Total': total.toString(),
      'X-WP-TotalPages': Math.ceil(total / perPage).toString(),
    }
  });
}

// POST /wp-json/wp/v2/posts — Create post
export async function POST(req: NextRequest) {
  const user = authenticate(req);
  if (!user) return NextResponse.json(
    { code: 'rest_not_logged_in', message: 'Unauthorized', data: { status: 401 } },
    { status: 401 }
  );

  const body = await req.json();
  const post = await db.posts.create({
    title: body.title,
    content: body.content,
    status: body.status || 'draft',
    excerpt: body.excerpt,
    slug: body.slug || slugify(body.title),
    categories: body.categories || [],
    tags: body.tags || [],
    featured_media: body.featured_media,
  });

  return NextResponse.json({
    id: post.id,
    title: { raw: post.title, rendered: post.title },
    slug: post.slug,
    link: `${process.env.SITE_URL}/${post.slug}`,
    status: post.status,
  }, { status: 201 });
}

RewriteEngine On
RewriteRule ^wp-json/wp/v2/(.*)$ api-bridge.php?route=$1 [QSA,L]

from fastapi import FastAPI, Header, UploadFile, File, Form, HTTPException
from fastapi.responses import JSONResponse
import base64, math

app = FastAPI()

def authenticate(authorization: str = Header(None)):
    if not authorization or not authorization.startswith("Basic "):
        raise HTTPException(401, {"code": "rest_not_logged_in", "message": "Unauthorized"})
    decoded = base64.b64decode(authorization[6:]).decode()
    user, password = decoded.split(":", 1)
    # TODO: validate against your database
    db_user = validate_user(user, password)
    if not db_user:
        raise HTTPException(401, {"code": "rest_not_logged_in", "message": "Invalid credentials"})
    return db_user

@app.get("/wp-json/wp/v2/users/me")
def auth_test(user=Depends(authenticate)):
    return {"id": user.id, "name": user.name, "slug": user.slug, "roles": ["administrator"]}

@app.post("/wp-json/wp/v2/posts", status_code=201)
def create_post(body: dict, user=Depends(authenticate)):
    post = db.posts.create(
        title=body["title"], content=body["content"],
        status=body.get("status", "draft"), slug=body.get("slug"),
        categories=body.get("categories", []), tags=body.get("tags", []),
        featured_media=body.get("featured_media"),
    )
    return {
        "id": post.id,
        "title": {"raw": post.title, "rendered": post.title},
        "slug": post.slug,
        "link": f"https://yoursite.com/{post.slug}/",
        "status": post.status,
    }

@app.get("/wp-json/wp/v2/posts")
def list_posts(per_page: int = 10, page: int = 1, user=Depends(authenticate)):
    posts, total = db.posts.list(per_page=per_page, page=page)
    return JSONResponse(
        content=posts,
        headers={
            "X-WP-Total": str(total),
            "X-WP-TotalPages": str(math.ceil(total / per_page)),
        }
    )

@app.post("/wp-json/wp/v2/media", status_code=201)
async def upload_media(
    file: UploadFile = File(...),
    title: str = Form(""), alt_text: str = Form(""), post: int = Form(None),
    user=Depends(authenticate),
):
    # TODO: save file to disk, record in DB
    media = save_media(await file.read(), file.filename, title, alt_text, post)
    return {"id": media.id, "source_url": media.public_url}

@app.post("/wp-json/wp/v2/categories", status_code=201)
def create_category(body: dict, user=Depends(authenticate)):
    existing = db.categories.find_by_slug(body.get("slug") or slugify(body["name"]))
    if existing:
        raise HTTPException(400, {"code": "term_exists", "data": {"term_id": existing.id}})
    cat = db.categories.create(name=body["name"], slug=body.get("slug"))
    return {"id": cat.id, "name": cat.name, "slug": cat.slug, "count": 0}

@app.post("/wp-json/wp/v2/tags", status_code=201)
def create_tag(body: dict, user=Depends(authenticate)):
    existing = db.tags.find_by_name(body["name"])
    if existing:
        raise HTTPException(400, {"code": "term_exists", "data": {"term_id": existing.id}})
    tag = db.tags.create(name=body["name"])
    return {"id": tag.id, "name": tag.name, "slug": tag.slug}