import { apiError } from "@/lib/auth";
import { runtimeEnv } from "@/lib/db";
import { publishDuePosts } from "@/lib/publish";

export async function POST(request: Request) {
  try {
    const secret = runtimeEnv().SCHEDULER_SECRET;
    if (!secret || request.headers.get("authorization") !== `Bearer ${secret}`) {
      return Response.json({ error: "Unauthorized" }, { status: 401 });
    }
    return Response.json({ results: await publishDuePosts() });
  } catch (error) { return apiError(error); }
}