Initial Commit

frontend/app/api/files/[token]/download/route.ts

@@ -0,0 +1,39 @@
+import { NextResponse } from 'next/server'
+import { getFile, getUploadPath } from '@/lib/store'
+import fs from 'fs'
+
+export async function GET(
+  _request: Request,
+  { params }: { params: Promise<{ token: string }> },
+) {
+  const { token } = await params
+  const record = await getFile(token)
+  if (!record) {
+    return NextResponse.json({ error: 'Not found' }, { status: 404 })
+  }
+
+  const filePath = getUploadPath(token, record.originalName)
+  if (!fs.existsSync(filePath)) {
+    return NextResponse.json({ error: 'File missing on disk' }, { status: 404 })
+  }
+
+  const stream = fs.createReadStream(filePath)
+  const webStream = new ReadableStream({
+    start(controller) {
+      stream.on('data', (chunk) => controller.enqueue(chunk))
+      stream.on('end', () => controller.close())
+      stream.on('error', (err) => controller.error(err))
+    },
+    cancel() {
+      stream.destroy()
+    },
+  })
+
+  return new Response(webStream, {
+    headers: {
+      'Content-Type': 'application/octet-stream',
+      'Content-Disposition': `attachment; filename="${record.originalName}"`,
+      'Content-Length': String(record.size),
+    },
+  })
+}

frontend/app/api/files/[token]/route.ts

@@ -0,0 +1,14 @@
+import { NextResponse } from 'next/server'
+import { getFile } from '@/lib/store'
+
+export async function GET(
+  _request: Request,
+  { params }: { params: Promise<{ token: string }> },
+) {
+  const { token } = await params
+  const record = await getFile(token)
+  if (!record) {
+    return NextResponse.json({ error: 'Not found' }, { status: 404 })
+  }
+  return NextResponse.json(record)
+}

frontend/app/api/files/route.ts

@@ -0,0 +1,7 @@
+import { NextResponse } from 'next/server'
+import { readMeta } from '@/lib/store'
+
+export async function GET() {
+  const records = await readMeta()
+  return NextResponse.json(records)
+}