carnet api
This commit is contained in:
parent
45142b4eb7
commit
cb818d1ab7
@ -3,75 +3,10 @@ import { getServerSession } from 'next-auth';
|
|||||||
import { authOptions } from '@/app/api/auth/[...nextauth]/route';
|
import { authOptions } from '@/app/api/auth/[...nextauth]/route';
|
||||||
import { DOMParser } from '@xmldom/xmldom';
|
import { DOMParser } from '@xmldom/xmldom';
|
||||||
|
|
||||||
// Simple in-memory cache for Nextcloud tokens
|
|
||||||
const tokenCache = new Map<string, { token: string; expires: number }>();
|
|
||||||
|
|
||||||
async function sleep(ms: number) {
|
async function sleep(ms: number) {
|
||||||
return new Promise(resolve => setTimeout(resolve, ms));
|
return new Promise(resolve => setTimeout(resolve, ms));
|
||||||
}
|
}
|
||||||
|
|
||||||
async function establishNextcloudSession(nextcloudUrl: string, keycloakToken: string, maxRetries = 3) {
|
|
||||||
// Check cache first
|
|
||||||
const cacheKey = `${nextcloudUrl}:${keycloakToken}`;
|
|
||||||
const cached = tokenCache.get(cacheKey);
|
|
||||||
if (cached && cached.expires > Date.now()) {
|
|
||||||
return cached.token;
|
|
||||||
}
|
|
||||||
|
|
||||||
let lastError;
|
|
||||||
for (let attempt = 0; attempt < maxRetries; attempt++) {
|
|
||||||
try {
|
|
||||||
// Add exponential backoff
|
|
||||||
if (attempt > 0) {
|
|
||||||
await sleep(Math.pow(2, attempt) * 1000);
|
|
||||||
}
|
|
||||||
|
|
||||||
const sessionResponse = await fetch(`${nextcloudUrl}/index.php/apps/oauth2/api/v1/token`, {
|
|
||||||
method: 'POST',
|
|
||||||
headers: {
|
|
||||||
'Content-Type': 'application/x-www-form-urlencoded',
|
|
||||||
'Authorization': `Bearer ${keycloakToken}`,
|
|
||||||
},
|
|
||||||
body: new URLSearchParams({
|
|
||||||
grant_type: 'urn:ietf:params:oauth:grant-type:token-exchange',
|
|
||||||
subject_token: keycloakToken,
|
|
||||||
subject_token_type: 'urn:ietf:params:oauth:token-type:access_token',
|
|
||||||
client_id: process.env.NEXTCLOUD_CLIENT_ID || '',
|
|
||||||
client_secret: process.env.NEXTCLOUD_CLIENT_SECRET || '',
|
|
||||||
}).toString(),
|
|
||||||
});
|
|
||||||
|
|
||||||
if (sessionResponse.status === 429) {
|
|
||||||
// Rate limited, wait and retry
|
|
||||||
const retryAfter = sessionResponse.headers.get('Retry-After');
|
|
||||||
await sleep((retryAfter ? parseInt(retryAfter) : 5) * 1000);
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!sessionResponse.ok) {
|
|
||||||
const errorText = await sessionResponse.text();
|
|
||||||
console.error('Failed to establish Nextcloud session:', errorText);
|
|
||||||
throw new Error('Failed to establish Nextcloud session');
|
|
||||||
}
|
|
||||||
|
|
||||||
const sessionData = await sessionResponse.json();
|
|
||||||
|
|
||||||
// Cache the token for 5 minutes
|
|
||||||
tokenCache.set(cacheKey, {
|
|
||||||
token: sessionData.access_token,
|
|
||||||
expires: Date.now() + 5 * 60 * 1000
|
|
||||||
});
|
|
||||||
|
|
||||||
return sessionData.access_token;
|
|
||||||
} catch (error) {
|
|
||||||
lastError = error;
|
|
||||||
console.error(`Attempt ${attempt + 1} failed:`, error);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
throw lastError || new Error('Failed to establish Nextcloud session after retries');
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function GET() {
|
export async function GET() {
|
||||||
try {
|
try {
|
||||||
const session = await getServerSession(authOptions);
|
const session = await getServerSession(authOptions);
|
||||||
@ -103,13 +38,16 @@ export async function GET() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// Get user's folders using WebDAV with Keycloak token
|
// Get user's folders using WebDAV with OIDC token
|
||||||
const webdavUrl = `${nextcloudUrl}/remote.php/dav/files/${encodeURIComponent(session.user.email)}/`;
|
const webdavUrl = `${nextcloudUrl}/remote.php/dav/files/${encodeURIComponent(session.user.email)}/`;
|
||||||
console.log('Requesting WebDAV URL:', webdavUrl);
|
console.log('Requesting WebDAV URL:', webdavUrl);
|
||||||
|
|
||||||
const foldersResponse = await fetch(webdavUrl, {
|
const foldersResponse = await fetch(webdavUrl, {
|
||||||
headers: {
|
headers: {
|
||||||
'Authorization': `Bearer ${session.accessToken}`,
|
'Authorization': `Bearer ${session.accessToken}`,
|
||||||
|
'OIDC_CLAIM_sub': session.user.id, // Keycloak subject ID
|
||||||
|
'OIDC_CLAIM_email': session.user.email,
|
||||||
|
'OIDC_CLAIM_preferred_username': session.user.username,
|
||||||
'Depth': '1',
|
'Depth': '1',
|
||||||
'Content-Type': 'application/xml',
|
'Content-Type': 'application/xml',
|
||||||
},
|
},
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user