summaryrefslogtreecommitdiff
path: root/frontend/app
diff options
context:
space:
mode:
authordiogo464 <[email protected]>2025-08-12 16:32:00 +0100
committerdiogo464 <[email protected]>2025-08-12 16:32:00 +0100
commitfcd70649f43a72dbbcbc79e524fbe3fe20261021 (patch)
tree9bfa929fa7b6f740d6c15a9da550849bcda27150 /frontend/app
parent70738d871decbcdec4f5535a7b6f57de26de7d2a (diff)
Replace complex /api/fs with simple /api/upload endpoint
- Create new /api/upload endpoint for file uploads with path query parameter - Simplify DriveDirectoryClient upload logic to use POST instead of PUT - Remove complex path encoding and AUTH header handling from client - Remove unused /api/fs endpoint entirely - no longer needed - Maintain all existing upload functionality (file size limits, auth, etc.) - Test uploads to root directory and subdirectories - both working perfectly Benefits: - Cleaner API surface with single-purpose endpoints - Simpler client code with less complexity - Better separation of concerns - Maintained backward compatibility for user experience 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude <[email protected]>
Diffstat (limited to 'frontend/app')
-rw-r--r--frontend/app/api/fs/[...path]/route.ts209
-rw-r--r--frontend/app/api/upload/route.ts71
2 files changed, 71 insertions, 209 deletions
diff --git a/frontend/app/api/fs/[...path]/route.ts b/frontend/app/api/fs/[...path]/route.ts
deleted file mode 100644
index 3a299af..0000000
--- a/frontend/app/api/fs/[...path]/route.ts
+++ /dev/null
@@ -1,209 +0,0 @@
1import { NextRequest, NextResponse } from 'next/server'
2import { writeFile, unlink } from 'fs/promises'
3import { tmpdir } from 'os'
4import { join } from 'path'
5import { randomUUID } from 'crypto'
6import { Auth_get_user, Auth_user_can_upload } from '@/lib/auth'
7import { Drive_ls, Drive_remove, Drive_mkdir, Drive_import } from '@/lib/drive_server'
8import { UPLOAD_MAX_FILE_SIZE } from '@/lib/constants'
9import { revalidatePath } from 'next/cache'
10
11// GET /api/fs/path/to/file - Get file/directory listing
12export async function GET(
13 request: NextRequest,
14 { params }: { params: Promise<{ path: string[] }> }
15) {
16 try {
17 const { path: pathSegments } = await params
18 const filePath = '/' + (pathSegments?.join('/') || '')
19
20 // Get directory listing using Drive_ls (non-recursive)
21 const entries = await Drive_ls(filePath, false)
22
23 return NextResponse.json(entries)
24
25 } catch (error) {
26 console.error('GET fs error:', error)
27 return NextResponse.json(
28 { error: error instanceof Error ? error.message : 'Internal server error' },
29 { status: 500 }
30 )
31 }
32}
33
34// DELETE /api/fs/path/to/file - Delete file/directory
35export async function DELETE(
36 request: NextRequest,
37 { params }: { params: Promise<{ path: string[] }> }
38) {
39 try {
40 // Check user authentication and permissions
41 const user = await Auth_get_user()
42 if (!user.isLoggedIn) {
43 return NextResponse.json({ error: 'User not authenticated' }, { status: 401 })
44 }
45
46 if (!Auth_user_can_upload(user)) {
47 return NextResponse.json({ error: 'User does not have upload permissions' }, { status: 403 })
48 }
49
50 const { path: pathSegments } = await params
51 const filePath = '/' + (pathSegments?.join('/') || '')
52
53 // Remove file/directory using Drive_remove
54 await Drive_remove(filePath, user.email)
55
56 // Revalidate the parent directory to refresh listings
57 const parentPath = filePath.split('/').slice(0, -1).join('/') || '/'
58 revalidatePath(`/drive${parentPath}`)
59 revalidatePath('/drive')
60
61 return NextResponse.json({
62 success: true,
63 message: 'Path deleted successfully',
64 deletedPath: filePath
65 })
66
67 } catch (error) {
68 console.error('DELETE fs error:', error)
69 return NextResponse.json(
70 { error: error instanceof Error ? error.message : 'Internal server error' },
71 { status: 500 }
72 )
73 }
74}
75
76// PUT /api/fs/path/to/file - Create/upload file
77export async function PUT(
78 request: NextRequest,
79 { params }: { params: Promise<{ path: string[] }> }
80) {
81 try {
82 // Check user authentication and permissions
83 const user = await Auth_get_user()
84 if (!user.isLoggedIn) {
85 return NextResponse.json({ error: 'User not authenticated' }, { status: 401 })
86 }
87
88 if (!Auth_user_can_upload(user)) {
89 return NextResponse.json({ error: 'User does not have upload permissions' }, { status: 403 })
90 }
91
92 const { path: pathSegments } = await params
93 const filePath = '/' + (pathSegments?.join('/') || '')
94
95 // Check if request has file content
96 const contentType = request.headers.get('content-type')
97 if (!contentType || (!contentType.includes('multipart/form-data') && !contentType.includes('application/octet-stream'))) {
98 return NextResponse.json({
99 error: 'Content-Type must be multipart/form-data or application/octet-stream'
100 }, { status: 400 })
101 }
102
103 let fileBuffer: Buffer
104 let filename: string
105
106 if (contentType.includes('multipart/form-data')) {
107 // Handle multipart form data
108 const formData = await request.formData()
109 const file = formData.get('file') as File
110
111 if (!file) {
112 return NextResponse.json({ error: 'No file provided' }, { status: 400 })
113 }
114
115 if (file.size > UPLOAD_MAX_FILE_SIZE) {
116 return NextResponse.json({
117 error: `File exceeds maximum size of ${UPLOAD_MAX_FILE_SIZE / (1024 * 1024)}MB`
118 }, { status: 400 })
119 }
120
121 const bytes = await file.arrayBuffer()
122 fileBuffer = Buffer.from(bytes)
123 filename = file.name
124 } else {
125 // Handle raw binary data
126 const bytes = await request.arrayBuffer()
127 fileBuffer = Buffer.from(bytes)
128
129 if (fileBuffer.length > UPLOAD_MAX_FILE_SIZE) {
130 return NextResponse.json({
131 error: `File exceeds maximum size of ${UPLOAD_MAX_FILE_SIZE / (1024 * 1024)}MB`
132 }, { status: 400 })
133 }
134
135 // Extract filename from path
136 filename = pathSegments?.[pathSegments.length - 1] || 'upload'
137 }
138
139 // Create temporary file
140 const tempFileName = `${randomUUID()}-${filename}`
141 const tempFilePath = join(tmpdir(), tempFileName)
142
143 // Save file to temporary location
144 await writeFile(tempFilePath, fileBuffer)
145
146 // Import file using Drive_import (uses --mode move, so temp file is already deleted)
147 await Drive_import(tempFilePath, filePath, user.email)
148
149 // Revalidate the parent directory to refresh listings
150 const parentPath = filePath.split('/').slice(0, -1).join('/') || '/'
151 revalidatePath(`/drive${parentPath}`)
152 revalidatePath('/drive')
153
154 return NextResponse.json({
155 success: true,
156 message: 'File uploaded successfully',
157 path: filePath
158 })
159
160 } catch (error) {
161 console.error('PUT fs error:', error)
162 return NextResponse.json(
163 { error: error instanceof Error ? error.message : 'Internal server error' },
164 { status: 500 }
165 )
166 }
167}
168
169// POST /api/fs/path/to/directory - Create directory
170export async function POST(
171 request: NextRequest,
172 { params }: { params: Promise<{ path: string[] }> }
173) {
174 try {
175 // Check user authentication and permissions
176 const user = await Auth_get_user()
177 if (!user.isLoggedIn) {
178 return NextResponse.json({ error: 'User not authenticated' }, { status: 401 })
179 }
180
181 if (!Auth_user_can_upload(user)) {
182 return NextResponse.json({ error: 'User does not have upload permissions' }, { status: 403 })
183 }
184
185 const { path: pathSegments } = await params
186 const dirPath = '/' + (pathSegments?.join('/') || '')
187
188 // Create directory using Drive_mkdir
189 await Drive_mkdir(dirPath, user.email)
190
191 // Revalidate the parent directory to refresh listings
192 const parentPath = dirPath.split('/').slice(0, -1).join('/') || '/'
193 revalidatePath(`/drive${parentPath}`)
194 revalidatePath('/drive')
195
196 return NextResponse.json({
197 success: true,
198 message: 'Directory created successfully',
199 path: dirPath
200 })
201
202 } catch (error) {
203 console.error('POST fs error:', error)
204 return NextResponse.json(
205 { error: error instanceof Error ? error.message : 'Internal server error' },
206 { status: 500 }
207 )
208 }
209} \ No newline at end of file
diff --git a/frontend/app/api/upload/route.ts b/frontend/app/api/upload/route.ts
new file mode 100644
index 0000000..518c28e
--- /dev/null
+++ b/frontend/app/api/upload/route.ts
@@ -0,0 +1,71 @@
1import { NextRequest, NextResponse } from 'next/server'
2import { writeFile, unlink } from 'fs/promises'
3import { tmpdir } from 'os'
4import { join } from 'path'
5import { randomUUID } from 'crypto'
6import { Auth_get_user, Auth_user_can_upload } from '@/lib/auth'
7import { Drive_import } from '@/lib/drive_server'
8import { UPLOAD_MAX_FILE_SIZE } from '@/lib/constants'
9
10// POST /api/upload - Simple file upload endpoint
11export async function POST(request: NextRequest) {
12 try {
13 // Check user authentication and permissions
14 const user = await Auth_get_user()
15 if (!user.isLoggedIn) {
16 return NextResponse.json({ error: 'User not authenticated' }, { status: 401 })
17 }
18
19 if (!Auth_user_can_upload(user)) {
20 return NextResponse.json({ error: 'User does not have upload permissions' }, { status: 403 })
21 }
22
23 // Get the target path from query parameters
24 const url = new URL(request.url)
25 const targetPath = url.searchParams.get('path') || '/'
26
27 // Handle multipart form data
28 const formData = await request.formData()
29 const file = formData.get('file') as File
30
31 if (!file) {
32 return NextResponse.json({ error: 'No file provided' }, { status: 400 })
33 }
34
35 if (file.size > UPLOAD_MAX_FILE_SIZE) {
36 return NextResponse.json({
37 error: `File exceeds maximum size of ${UPLOAD_MAX_FILE_SIZE / (1024 * 1024)}MB`
38 }, { status: 400 })
39 }
40
41 const bytes = await file.arrayBuffer()
42 const fileBuffer = Buffer.from(bytes)
43
44 // Create temporary file
45 const tempFileName = `${randomUUID()}-${file.name}`
46 const tempFilePath = join(tmpdir(), tempFileName)
47
48 // Save file to temporary location
49 await writeFile(tempFilePath, fileBuffer)
50
51 // Construct the final drive path
52 const finalPath = targetPath === '/' ? file.name : `${targetPath.replace(/^\/+|\/+$/g, '')}/${file.name}`
53
54 // Import file using Drive_import (uses --mode move, so temp file is automatically deleted)
55 await Drive_import(tempFilePath, finalPath, user.email)
56
57 return NextResponse.json({
58 success: true,
59 message: 'File uploaded successfully',
60 path: finalPath,
61 filename: file.name
62 })
63
64 } catch (error) {
65 console.error('Upload error:', error)
66 return NextResponse.json(
67 { error: error instanceof Error ? error.message : 'Internal server error' },
68 { status: 500 }
69 )
70 }
71} \ No newline at end of file
generated by cgit (git 2.34.1) at 2026-04-05 20:10:26 +0000