pages s3
This commit is contained in:
parent
b7c16cab7d
commit
8884081071
63
app/api/storage/init/folder/route.ts
Normal file
63
app/api/storage/init/folder/route.ts
Normal file
@ -0,0 +1,63 @@
|
||||
import { NextResponse } from 'next/server';
|
||||
import { getServerSession } from 'next-auth';
|
||||
import { authOptions } from '@/app/api/auth/[...nextauth]/route';
|
||||
import { putObject } from '@/lib/s3';
|
||||
import { S3_CONFIG } from '@/lib/s3';
|
||||
|
||||
/**
|
||||
* API endpoint to create a specific folder for a user
|
||||
* POST /api/storage/init/folder
|
||||
*/
|
||||
export async function POST(request: Request) {
|
||||
try {
|
||||
// Get session
|
||||
const session = await getServerSession(authOptions);
|
||||
if (!session?.user?.id) {
|
||||
return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
|
||||
}
|
||||
|
||||
// Parse request body
|
||||
let reqBody;
|
||||
try {
|
||||
reqBody = await request.json();
|
||||
} catch (error) {
|
||||
return NextResponse.json({ error: 'Invalid request body' }, { status: 400 });
|
||||
}
|
||||
|
||||
const { folder } = reqBody;
|
||||
|
||||
if (!folder || typeof folder !== 'string') {
|
||||
return NextResponse.json({ error: 'Missing or invalid folder name' }, { status: 400 });
|
||||
}
|
||||
|
||||
// Normalize folder name
|
||||
const folderLowercase = folder.toLowerCase();
|
||||
const userId = session.user.id;
|
||||
|
||||
console.log(`Creating folder ${folderLowercase} for user ${userId}`);
|
||||
|
||||
try {
|
||||
// Create the folder path (just a prefix in S3)
|
||||
const key = `user-${userId}/${folderLowercase}/`;
|
||||
await putObject(key, '', 'application/x-directory');
|
||||
|
||||
// Create a placeholder file to ensure the folder exists and is visible
|
||||
const placeholderKey = `user-${userId}/${folderLowercase}/.placeholder`;
|
||||
await putObject(placeholderKey, 'Folder placeholder', 'text/plain');
|
||||
|
||||
console.log(`Successfully created folder: ${key}`);
|
||||
|
||||
// Return success
|
||||
return NextResponse.json({
|
||||
success: true,
|
||||
message: `Folder ${folderLowercase} created successfully`
|
||||
});
|
||||
} catch (error) {
|
||||
console.error(`Error creating folder ${folderLowercase}:`, error);
|
||||
return NextResponse.json({ error: 'Failed to create folder' }, { status: 500 });
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error in folder creation endpoint:', error);
|
||||
return NextResponse.json({ error: 'Internal server error' }, { status: 500 });
|
||||
}
|
||||
}
|
||||
@ -387,12 +387,34 @@ export default function CarnetPage() {
|
||||
}
|
||||
};
|
||||
|
||||
const handleFolderSelect = (folder: string) => {
|
||||
const handleFolderSelect = async (folder: string) => {
|
||||
console.log('Selected folder:', folder);
|
||||
setSelectedFolder(folder);
|
||||
setLayoutMode("item-selection");
|
||||
|
||||
// Reset selected contact when changing folders
|
||||
setSelectedContact(null);
|
||||
|
||||
// Ensure folder exists in storage before fetching
|
||||
try {
|
||||
// Create the folder if it doesn't exist
|
||||
const lowerFolder = folder.toLowerCase();
|
||||
console.log(`Ensuring folder exists: ${lowerFolder}`);
|
||||
|
||||
const response = await fetch(`/api/storage/init/folder`, {
|
||||
method: 'POST',
|
||||
headers: {
|
||||
'Content-Type': 'application/json'
|
||||
},
|
||||
body: JSON.stringify({ folder: lowerFolder })
|
||||
});
|
||||
|
||||
if (!response.ok) {
|
||||
console.warn(`Failed to create folder ${lowerFolder}: ${await response.text()}`);
|
||||
}
|
||||
} catch (error) {
|
||||
console.error('Error creating folder:', error);
|
||||
}
|
||||
};
|
||||
|
||||
const handleContactSelect = (contact: Contact) => {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user