Page logic dang
This commit is contained in:
parent
df039ae99c
commit
9fbeb08462
@ -4,6 +4,7 @@ import { PrismaClient } from '@prisma/client';
|
|||||||
import { authOptions } from '@/app/api/auth/[...nextauth]/route';
|
import { authOptions } from '@/app/api/auth/[...nextauth]/route';
|
||||||
import { createClient } from 'webdav';
|
import { createClient } from 'webdav';
|
||||||
import { prisma } from '@/lib/prisma';
|
import { prisma } from '@/lib/prisma';
|
||||||
|
import { Buffer } from 'buffer';
|
||||||
|
|
||||||
// Use a single PrismaClient instance
|
// Use a single PrismaClient instance
|
||||||
declare global {
|
declare global {
|
||||||
@ -64,40 +65,84 @@ export async function GET(request: Request) {
|
|||||||
return NextResponse.json({ error: 'Nextcloud credentials not found' }, { status: 404 });
|
return NextResponse.json({ error: 'Nextcloud credentials not found' }, { status: 404 });
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create WebDAV client
|
const nextcloudUrl = process.env.NEXTCLOUD_URL;
|
||||||
const client = createClient(process.env.NEXTCLOUD_URL!, {
|
if (!nextcloudUrl) {
|
||||||
username: credentials.username,
|
return NextResponse.json({ error: 'Nextcloud URL not configured' }, { status: 500 });
|
||||||
password: credentials.password,
|
}
|
||||||
|
|
||||||
|
const path = `/files/${credentials.username}/Private/${folder}`;
|
||||||
|
const url = `${nextcloudUrl}/remote.php/dav${path}`;
|
||||||
|
|
||||||
|
// Make PROPFIND request to get directory contents
|
||||||
|
const response = await fetch(url, {
|
||||||
|
method: 'PROPFIND',
|
||||||
|
headers: {
|
||||||
|
'Authorization': `Basic ${Buffer.from(`${credentials.username}:${credentials.password}`).toString('base64')}`,
|
||||||
|
'Depth': '1',
|
||||||
|
'Content-Type': 'application/xml',
|
||||||
|
},
|
||||||
|
body: '<?xml version="1.0" encoding="UTF-8"?><d:propfind xmlns:d="DAV:"><d:prop><d:resourcetype/><d:getlastmodified/><d:getcontentlength/><d:getcontenttype/><d:getetag/></d:prop></d:propfind>',
|
||||||
});
|
});
|
||||||
|
|
||||||
try {
|
if (!response.ok) {
|
||||||
const path = `/files/${credentials.username}/Private/${folder}`;
|
console.error('Error fetching directory contents:', response.status, response.statusText);
|
||||||
const files = await client.getDirectoryContents(path);
|
return NextResponse.json({ error: 'Failed to fetch directory contents' }, { status: response.status });
|
||||||
|
|
||||||
// For Contacts folder, return all files
|
|
||||||
if (folder === 'Contacts') {
|
|
||||||
return NextResponse.json(files);
|
|
||||||
}
|
|
||||||
|
|
||||||
// For other folders, filter markdown files
|
|
||||||
const markdownFiles = files
|
|
||||||
.filter((file: any) => file.basename.endsWith('.md'))
|
|
||||||
.map((file: any) => ({
|
|
||||||
id: file.filename,
|
|
||||||
title: file.basename.replace('.md', ''),
|
|
||||||
lastModified: new Date(file.lastmod).toISOString(),
|
|
||||||
size: file.size,
|
|
||||||
type: 'file',
|
|
||||||
mime: file.mime,
|
|
||||||
etag: file.etag
|
|
||||||
}));
|
|
||||||
|
|
||||||
return NextResponse.json(markdownFiles);
|
|
||||||
} catch (error) {
|
|
||||||
// Log error without sensitive information
|
|
||||||
console.error('Error listing directory contents:', error instanceof Error ? error.message : 'Unknown error');
|
|
||||||
return NextResponse.json({ error: 'Failed to list directory contents' }, { status: 500 });
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const text = await response.text();
|
||||||
|
const parser = new DOMParser();
|
||||||
|
const xmlDoc = parser.parseFromString(text, 'text/xml');
|
||||||
|
|
||||||
|
const files: any[] = [];
|
||||||
|
const responses = xmlDoc.getElementsByTagName('d:response');
|
||||||
|
|
||||||
|
for (let i = 0; i < responses.length; i++) {
|
||||||
|
const response = responses[i];
|
||||||
|
const href = response.getElementsByTagName('d:href')[0]?.textContent;
|
||||||
|
const propstat = response.getElementsByTagName('d:propstat')[0];
|
||||||
|
|
||||||
|
if (href && propstat) {
|
||||||
|
const prop = propstat.getElementsByTagName('d:prop')[0];
|
||||||
|
if (prop) {
|
||||||
|
const type = prop.getElementsByTagName('d:resourcetype')[0];
|
||||||
|
const lastmod = prop.getElementsByTagName('d:getlastmodified')[0]?.textContent;
|
||||||
|
const size = prop.getElementsByTagName('d:getcontentlength')[0]?.textContent;
|
||||||
|
const mime = prop.getElementsByTagName('d:getcontenttype')[0]?.textContent;
|
||||||
|
const etag = prop.getElementsByTagName('d:getetag')[0]?.textContent;
|
||||||
|
|
||||||
|
if (type && !type.getElementsByTagName('d:collection').length) {
|
||||||
|
const filename = href.split('/').pop() || '';
|
||||||
|
|
||||||
|
// For Contacts folder, return all files
|
||||||
|
if (folder === 'Contacts') {
|
||||||
|
files.push({
|
||||||
|
filename: href,
|
||||||
|
basename: filename,
|
||||||
|
lastmod,
|
||||||
|
size,
|
||||||
|
type: 'file',
|
||||||
|
etag,
|
||||||
|
mime
|
||||||
|
});
|
||||||
|
}
|
||||||
|
// For other folders, only return markdown files
|
||||||
|
else if (filename.endsWith('.md')) {
|
||||||
|
files.push({
|
||||||
|
id: href,
|
||||||
|
title: filename.replace('.md', ''),
|
||||||
|
lastModified: new Date(lastmod || '').toISOString(),
|
||||||
|
size,
|
||||||
|
type: 'file',
|
||||||
|
mime,
|
||||||
|
etag
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return NextResponse.json(files);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
// Log error without sensitive information
|
// Log error without sensitive information
|
||||||
console.error('Error fetching files:', error instanceof Error ? error.message : 'Unknown error');
|
console.error('Error fetching files:', error instanceof Error ? error.message : 'Unknown error');
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user