database wf 4

app/api/auth/[...nextauth]/route.ts

@@ -1,6 +1,5 @@
 import NextAuth, { NextAuthOptions } from "next-auth";
-import { prisma } from '@/lib/prisma';
+import KeycloakProvider from "next-auth/providers/keycloak";
-import CredentialsProvider from 'next-auth/providers/credentials';
 
 declare module "next-auth" {
   interface Session {
@@ -28,73 +27,116 @@ declare module "next-auth" {
   }
 }
 
-const authOptions: NextAuthOptions = {
+function getRequiredEnvVar(name: string): string {
+  const value = process.env[name];
+  if (!value) {
+    throw new Error(`Missing required environment variable: ${name}`);
+  }
+  return value;
+}
+
+export const authOptions: NextAuthOptions = {
   providers: [
-    CredentialsProvider({
+    KeycloakProvider({
-      name: 'Credentials',
+      clientId: getRequiredEnvVar("KEYCLOAK_CLIENT_ID"),
-      credentials: {
+      clientSecret: getRequiredEnvVar("KEYCLOAK_CLIENT_SECRET"),
-        email: { label: 'Email', type: 'email' },
+      issuer: getRequiredEnvVar("KEYCLOAK_ISSUER"),
-        password: { label: 'Password', type: 'password' }
+      profile(profile) {
-      },
+        return {
-      async authorize(credentials) {
+          id: profile.sub,
-        if (!credentials?.email || !credentials?.password) {
+          name: profile.name ?? profile.preferred_username,
-          return null;
+          email: profile.email,
+          first_name: profile.given_name ?? '',
+          last_name: profile.family_name ?? '',
+          username: profile.preferred_username ?? profile.email?.split('@')[0] ?? '',
+          role: profile.groups ?? [],
         }
+      },
+    }),
+  ],
+  session: {
+    strategy: "jwt",
+    maxAge: 30 * 24 * 60 * 60, // 30 days
+  },
+  callbacks: {
+    async jwt({ token, account, profile }) {
+      if (account && profile) {
+        token.accessToken = account.access_token ?? '';
+        token.refreshToken = account.refresh_token ?? '';
+        token.accessTokenExpires = (account.expires_at ?? 0) * 1000;
+        token.role = (profile as any).groups ?? [];
+        token.username = (profile as any).preferred_username ?? profile.email?.split('@')[0] ?? '';
+        token.first_name = (profile as any).given_name ?? '';
+        token.last_name = (profile as any).family_name ?? '';
+      }
 
-        const user = await prisma.user.findUnique({
+      // Return previous token if not expired
-          where: { email: credentials.email },
+      if (Date.now() < (token.accessTokenExpires as number)) {
-        });
+        return token;
+      }
 
-        if (!user) {
+      try {
-          return null;
+        const clientId = getRequiredEnvVar("KEYCLOAK_CLIENT_ID");
+        const clientSecret = getRequiredEnvVar("KEYCLOAK_CLIENT_SECRET");
+
+        const response = await fetch(
+          `${process.env.KEYCLOAK_BASE_URL}/realms/${process.env.KEYCLOAK_REALM}/protocol/openid-connect/token`,
+          {
+            method: "POST",
+            headers: {
+              "Content-Type": "application/x-www-form-urlencoded",
+            },
+            body: new URLSearchParams({
+              grant_type: "refresh_token",
+              client_id: clientId,
+              client_secret: clientSecret,
+              refresh_token: token.refreshToken as string,
+            }),
+          }
+        );
+
+        const tokens = await response.json();
+
+        if (!response.ok) {
+          throw new Error("RefreshAccessTokenError");
         }
 
         return {
-          id: user.id,
+          ...token,
-          email: user.email,
+          accessToken: tokens.access_token,
-          username: user.username || user.email.split('@')[0],
+          refreshToken: tokens.refresh_token ?? token.refreshToken,
-          first_name: user.first_name || '',
+          accessTokenExpires: Date.now() + tokens.expires_in * 1000,
-          last_name: user.last_name || '',
+        };
-          role: user.role || [],
+      } catch (error) {
+        return {
+          ...token,
+          error: "RefreshAccessTokenError",
         };
       }
-    })
-  ],
-  session: {
-    strategy: 'jwt' as const,
-  },
-  pages: {
-    signIn: '/login',
-  },
-  callbacks: {
-    async jwt({ token, user }: { token: any; user: any }) {
-      if (user) {
-        token.id = user.id;
-        token.email = user.email;
-        token.username = user.username;
-        token.first_name = user.first_name;
-        token.last_name = user.last_name;
-        token.role = user.role;
-      }
-      return token;
     },
-    async session({ session, token }: { session: any; token: any }) {
+    async session({ session, token }) {
-      if (token) {
+      if (token.error) {
-        session.user = {
+        throw new Error("RefreshAccessTokenError");
-          id: token.id as string,
-          email: token.email as string | null,
-          name: token.name as string | null,
-          image: token.picture as string | null,
-          username: token.username as string,
-          first_name: token.first_name as string,
-          last_name: token.last_name as string,
-          role: token.role as string[],
-        };
-        session.accessToken = token.accessToken as string;
       }
+
+      session.accessToken = token.accessToken;
+      session.user = {
+        ...session.user,
+        id: token.sub as string,
+        first_name: token.first_name ?? '',
+        last_name: token.last_name ?? '',
+        username: token.username ?? '',
+        role: token.role ?? [],
+      };
+
       return session;
     }
-  }
+  },
+  pages: {
+    signIn: '/signin',
+    error: '/signin',
+  },
+  debug: process.env.NODE_ENV === 'development',
 };
 
 const handler = NextAuth(authOptions);

lib/env.ts

@@ -3,7 +3,7 @@ import { z } from "zod";
 const envSchema = z.object({
   NODE_ENV: z.enum(["development", "test", "production"]).default("development"),
   DATABASE_URL: z.string().url(),
-  NEWSDB_URL: z.string().url(),
+  NEWSDB_URL: z.string().url().optional(),
   KEYCLOAK_CLIENT_ID: z.string(),
   KEYCLOAK_CLIENT_SECRET: z.string(),
   KEYCLOAK_REALM: z.string(),