feat: post saving, instant publish, scheduling, post history per channel

app/api/user-posts/[id]/publish/route.js

@@ -0,0 +1,13 @@
+import { NextResponse } from 'next/server';
+import { requireUser } from '@/lib/session';
+import { engine } from '@/lib/engine';
+
+export async function POST(req, { params }) {
+  const user = await requireUser();
+  if (!user) return NextResponse.json({error:'Unauthorized'},{status:401});
+  const { id } = await params;
+  try {
+    const data = await engine.publishPost(user.id, id);
+    return NextResponse.json(data);
+  } catch (e) { return NextResponse.json({error:e.message},{status:500}); }
+}

app/api/user-posts/[id]/route.js

@@ -0,0 +1,24 @@
+import { NextResponse } from 'next/server';
+import { requireUser } from '@/lib/session';
+import { engine } from '@/lib/engine';
+
+export async function PATCH(req, { params }) {
+  const user = await requireUser();
+  if (!user) return NextResponse.json({error:'Unauthorized'},{status:401});
+  const { id } = await params;
+  const body = await req.json();
+  try {
+    const data = await engine.updatePost(user.id, id, body);
+    return NextResponse.json(data);
+  } catch (e) { return NextResponse.json({error:e.message},{status:500}); }
+}
+
+export async function DELETE(req, { params }) {
+  const user = await requireUser();
+  if (!user) return NextResponse.json({error:'Unauthorized'},{status:401});
+  const { id } = await params;
+  try {
+    await engine.deletePost(user.id, id);
+    return NextResponse.json({ok:true});
+  } catch (e) { return NextResponse.json({error:e.message},{status:500}); }
+}

app/api/user-posts/route.js

@@ -0,0 +1,25 @@
+import { NextResponse } from 'next/server';
+import { requireUser } from '@/lib/session';
+import { engine } from '@/lib/engine';
+
+export async function GET(req) {
+  const user = await requireUser();
+  if (!user) return NextResponse.json({error:'Unauthorized'},{status:401});
+  const { searchParams } = new URL(req.url);
+  const params = {};
+  for (const [k,v] of searchParams) params[k] = v;
+  try {
+    const data = await engine.listUserPosts(user.id, params);
+    return NextResponse.json(data);
+  } catch (e) { return NextResponse.json({error:e.message},{status:500}); }
+}
+
+export async function POST(req) {
+  const user = await requireUser();
+  if (!user) return NextResponse.json({error:'Unauthorized'},{status:401});
+  const body = await req.json();
+  try {
+    const data = await engine.savePost(user.id, body);
+    return NextResponse.json(data);
+  } catch (e) { return NextResponse.json({error:e.message},{status:500}); }
+}