39 lines
1.5 KiB
TypeScript
39 lines
1.5 KiB
TypeScript
import { NextRequest, NextResponse } from 'next/server';
|
|
import { db } from '@/app/db/drizzle';
|
|
import { domains, emails } from '@/app/db/schema';
|
|
import { authenticate } from '@/app/lib/utils';
|
|
import { eq, sql } from 'drizzle-orm';
|
|
|
|
export async function GET(req: NextRequest) {
|
|
if (!authenticate(req)) return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
|
|
|
|
const { searchParams } = new URL(req.url);
|
|
const bucket = searchParams.get('bucket');
|
|
const mailbox = searchParams.get('mailbox')?.toLowerCase();
|
|
if (!bucket || !mailbox) return NextResponse.json({ error: 'Missing params' }, { status: 400 });
|
|
|
|
const [domain] = await db.select().from(domains).where(eq(domains.bucket, bucket));
|
|
if (!domain) return NextResponse.json({ error: 'Domain not found' }, { status: 404 });
|
|
|
|
const emailList = await db.select({
|
|
key: emails.s3Key,
|
|
subject: emails.subject,
|
|
date: emails.date,
|
|
processed: emails.processed,
|
|
processedAt: emails.processedAt,
|
|
processedBy: emails.processedBy,
|
|
queuedTo: emails.queuedTo,
|
|
status: emails.status,
|
|
}).from(emails).where(sql`${mailbox} = ANY(${emails.to}) AND ${emails.domainId} = ${domain.id}`);
|
|
|
|
return NextResponse.json(emailList.map(e => ({
|
|
key: e.key,
|
|
subject: e.subject,
|
|
date: e.date?.toISOString(),
|
|
processed: e.processed ? 'true' : 'false',
|
|
processedAt: e.processedAt?.toISOString() || null,
|
|
processedBy: e.processedBy,
|
|
queuedTo: e.queuedTo,
|
|
status: e.status,
|
|
})));
|
|
} |