diff --git a/app/api/auth/[...nextauth]/route.ts b/app/api/auth/[...nextauth]/route.ts index 829d8276..4adfbb40 100644 --- a/app/api/auth/[...nextauth]/route.ts +++ b/app/api/auth/[...nextauth]/route.ts @@ -178,6 +178,97 @@ export const authOptions: NextAuthOptions = { return token; } + // If we have a username but no Rocket.Chat credentials, fetch them + if (token.username && (!token.rocketChatToken || !token.rocketChatUserId)) { + console.log('Fetching Rocket.Chat credentials for existing user:', token.username); + + // Get user info from Rocket.Chat using the admin token + const userInfoResponse = await fetch(`${process.env.ROCKET_CHAT_URL}/api/v1/users.info?username=${token.username}`, { + headers: { + 'X-Auth-Token': process.env.ROCKET_CHAT_ADMIN_TOKEN as string, + 'X-User-Id': process.env.ROCKET_CHAT_ADMIN_USER_ID as string, + }, + }); + + if (!userInfoResponse.ok) { + console.error('Failed to get user info:', { + status: userInfoResponse.status, + statusText: userInfoResponse.statusText, + username: token.username + }); + return token; + } + + const userInfo = await userInfoResponse.json(); + console.log('User info response:', userInfo); + + if (!userInfo.user || !userInfo.user._id) { + console.error('Invalid user info response:', userInfo); + return token; + } + + // Set the user's Rocket.Chat ID + token.rocketChatUserId = userInfo.user._id; + console.log('Set Rocket.Chat user ID:', token.rocketChatUserId); + + // Get personal access tokens for the user + const tokensResponse = await fetch(`${process.env.ROCKET_CHAT_URL}/api/v1/users.getPersonalAccessTokens`, { + headers: { + 'X-Auth-Token': process.env.ROCKET_CHAT_ADMIN_TOKEN as string, + 'X-User-Id': process.env.ROCKET_CHAT_ADMIN_USER_ID as string, + }, + }); + + if (!tokensResponse.ok) { + console.error('Failed to get personal access tokens:', { + status: tokensResponse.status, + statusText: tokensResponse.statusText, + username: token.username + }); + return token; + } + + const tokensData = await tokensResponse.json(); + console.log('Personal access tokens response:', tokensData); + + // Find existing token or create a new one + let personalAccessToken = tokensData.tokens?.find((t: any) => t.name === 'NextAuth'); + if (!personalAccessToken) { + console.log('No existing token found, creating new one'); + const createTokenResponse = await fetch(`${process.env.ROCKET_CHAT_URL}/api/v1/users.generatePersonalAccessToken`, { + method: 'POST', + headers: { + 'Content-Type': 'application/json', + 'X-Auth-Token': process.env.ROCKET_CHAT_ADMIN_TOKEN as string, + 'X-User-Id': process.env.ROCKET_CHAT_ADMIN_USER_ID as string, + }, + body: JSON.stringify({ + tokenName: 'NextAuth', + bypassTwoFactor: true, + }), + }); + + if (!createTokenResponse.ok) { + console.error('Failed to create personal access token:', { + status: createTokenResponse.status, + statusText: createTokenResponse.statusText, + username: token.username + }); + return token; + } + + const createTokenData = await createTokenResponse.json(); + console.log('Create token response:', createTokenData); + personalAccessToken = createTokenData.token; + } + + // Set the personal access token + token.rocketChatToken = personalAccessToken.token; + console.log('Set Rocket.Chat token:', token.rocketChatToken); + + return token; + } + // Return previous token if it has Rocket.Chat credentials if (token.rocketChatToken && token.rocketChatUserId) { return token;