import NextAuth, { NextAuthOptions } from "next-auth"; import KeycloakProvider from "next-auth/providers/keycloak"; import { jwtDecode } from "jwt-decode"; interface KeycloakProfile { sub: string; email?: string; name?: string; roles?: string[]; preferred_username?: string; given_name?: string; family_name?: string; realm_access?: { roles: string[]; }; } interface DecodedToken { realm_access?: { roles: string[]; }; [key: string]: any; } declare module "next-auth" { interface Session { user: { id: string; name?: string | null; email?: string | null; image?: string | null; username: string; first_name: string; last_name: string; role: string[]; nextcloudInitialized?: boolean; }; accessToken?: string; } interface JWT { sub?: string; accessToken?: string; refreshToken?: string; accessTokenExpires?: number; role?: string[]; username?: string; first_name?: string; last_name?: string; error?: string; email?: string | null; name?: string | null; } } function getRequiredEnvVar(name: string): string { const value = process.env[name]; if (!value) { throw new Error(`Missing required environment variable: ${name}`); } return value; } async function refreshAccessToken(token: JWT) { try { console.log('Attempting to refresh access token'); const response = await fetch(`${process.env.KEYCLOAK_ISSUER}/protocol/openid-connect/token`, { headers: { "Content-Type": "application/x-www-form-urlencoded" }, body: new URLSearchParams({ client_id: process.env.KEYCLOAK_CLIENT_ID!, client_secret: process.env.KEYCLOAK_CLIENT_SECRET!, grant_type: "refresh_token", refresh_token: token.refreshToken, }), method: "POST", }); const refreshedTokens = await response.json(); if (!response.ok) { console.error('Token refresh failed with status:', response.status); console.error('Error response:', refreshedTokens); throw refreshedTokens; } console.log('Token refresh successful'); return { ...token, accessToken: refreshedTokens.access_token, refreshToken: refreshedTokens.refresh_token ?? token.refreshToken, accessTokenExpires: Date.now() + refreshedTokens.expires_in * 1000, error: undefined, // Clear any previous errors }; } catch (error) { console.error("Error refreshing access token:", error); return { ...token, error: "RefreshAccessTokenError", }; } } export const authOptions: NextAuthOptions = { providers: [ KeycloakProvider({ clientId: getRequiredEnvVar("KEYCLOAK_CLIENT_ID"), clientSecret: getRequiredEnvVar("KEYCLOAK_CLIENT_SECRET"), issuer: getRequiredEnvVar("KEYCLOAK_ISSUER"), authorization: { params: { scope: "openid profile email roles" } }, profile(profile) { console.log('Keycloak profile callback:', { rawProfile: profile, rawRoles: profile.roles, realmAccess: profile.realm_access, groups: profile.groups }); // Get roles from realm_access const roles = profile.realm_access?.roles || []; console.log('Profile callback raw roles:', roles); // Clean up roles by removing ROLE_ prefix and converting to lowercase const cleanRoles = roles.map((role: string) => role.replace(/^ROLE_/, '').toLowerCase() ); console.log('Profile callback cleaned roles:', cleanRoles); return { id: profile.sub, name: profile.name ?? profile.preferred_username, email: profile.email, first_name: profile.given_name ?? '', last_name: profile.family_name ?? '', username: profile.preferred_username ?? profile.email?.split('@')[0] ?? '', role: cleanRoles, } }, }), ], session: { strategy: "jwt", maxAge: 30 * 24 * 60 * 60, // 30 days }, cookies: { sessionToken: { name: `next-auth.session-token`, options: { httpOnly: true, sameSite: 'none', path: '/', secure: true, domain: process.env.NEXTAUTH_COOKIE_DOMAIN || undefined, }, }, }, jwt: { // Add explicit max size to prevent chunking maxAge: 30 * 24 * 60 * 60, // 30 days }, callbacks: { async jwt({ token, account, profile }) { // Initial sign in if (account && profile) { const keycloakProfile = profile as KeycloakProfile; const roles = keycloakProfile.realm_access?.roles || []; const cleanRoles = roles.map((role: string) => role.replace(/^ROLE_/, '').toLowerCase() ); // Store minimal data in the token token.accessToken = account.access_token ?? ''; token.refreshToken = account.refresh_token ?? ''; token.accessTokenExpires = account.expires_at ?? 0; token.sub = keycloakProfile.sub; token.role = cleanRoles; token.username = keycloakProfile.preferred_username ?? ''; token.error = undefined; // Clear any errors // Only store these if they're short if (keycloakProfile.given_name && keycloakProfile.given_name.length < 30) { token.first_name = keycloakProfile.given_name; } if (keycloakProfile.family_name && keycloakProfile.family_name.length < 30) { token.last_name = keycloakProfile.family_name; } return token; } // Check if token has expired const tokenExpiresAt = token.accessTokenExpires ? token.accessTokenExpires as number : 0; const currentTime = Date.now(); const hasExpired = currentTime >= tokenExpiresAt; // If the token is still valid, return it if (!hasExpired) { return token; } // If refresh token is missing, force sign in if (!token.refreshToken) { console.warn('No refresh token available, session cannot be refreshed'); return { ...token, error: "RefreshAccessTokenError" }; } // Try to refresh the token const refreshedToken = await refreshAccessToken(token as JWT); // If there was an error refreshing, mark token for re-authentication if (refreshedToken.error) { console.warn('Token refresh failed, user will need to reauthenticate'); return { ...refreshedToken, error: "RefreshAccessTokenError" }; } return refreshedToken; }, async session({ session, token }) { try { // Handle the error from jwt callback if (token.error === "RefreshAccessTokenError") { console.warn("Session encountered a refresh token error, redirecting to login"); // Return minimal session with error flag that will trigger re-auth in client return { ...session, error: "RefreshTokenError", user: { ...session.user, id: token.sub ?? '' } }; } const userRoles = Array.isArray(token.role) ? token.role : []; // Create a minimal user object session.user = { id: token.sub ?? '', email: token.email ?? null, name: token.name ?? null, image: null, username: token.username ?? '', first_name: token.first_name ?? '', last_name: token.last_name ?? '', role: userRoles, nextcloudInitialized: false, }; // Only store access token, not the entire token session.accessToken = token.accessToken; return session; } catch (error) { console.error("Error in session callback:", error); // Return minimal session with error flag return { ...session, error: "SessionError", user: { ...session.user, id: token.sub ?? '' } }; } } }, pages: { signIn: '/signin', error: '/signin', }, debug: process.env.NODE_ENV === 'development', }; const handler = NextAuth(authOptions); export { handler as GET, handler as POST }; interface JWT { accessToken: string; refreshToken: string; accessTokenExpires: number; } interface Profile { sub?: string; email?: string; name?: string; roles?: string[]; }