Skip to content

Commit

Permalink
next-auth nexturl
Browse files Browse the repository at this point in the history
  • Loading branch information
@pratyush3124
pratyush3124 committed Mar 16, 2024
1 parent 69d6784 commit 427483c
Showing 1 changed file with 143 additions and 143 deletions.
286 changes: 143 additions & 143 deletions app/api/auth/[...nextauth]/route.js
View file
Original file line number Diff line number Diff line change
@@ -1,163 +1,163 @@
import { connectMongoDB } from "@/lib/mongodb";
import { Users } from "@/models/user.model";
import { connectMongoDB } from '@/lib/mongodb';
import { Users } from '@/models/user.model';
import { OAuth2Client } from 'google-auth-library';
import NextAuth from "next-auth/next";
import NextAuth from 'next-auth/next';
import GoogleProvider from 'next-auth/providers/google';
import { NextResponse } from "next/server";
import { generateTokens } from "../../login/generateTokensUser/route";
import { NextResponse } from 'next/server';
import { generateTokens } from '../../login/generateTokensUser/route';

const client = new OAuth2Client(process.env.GOOGLE_CLIENT_ID);

const GOOGLE_AUTHORIZATION_URL =
"https://accounts.google.com/o/oauth2/v2/auth?" +
'https://accounts.google.com/o/oauth2/v2/auth?' +
new URLSearchParams({
prompt: "consent",
access_type: "offline",
response_type: "code",
prompt: 'consent',
access_type: 'offline',
response_type: 'code',
});

const gettokenfrombackend=async (user,account)=>{
await connectMongoDB()
const token=account.id_token;
const email=user.email;
//console.log("------",email);
const ticket = await client.verifyIdToken({
idToken: token,
audience: process.env.GOOGLE_CLIENT_ID,
});
const user1=await Users.findOne({email:email});
console.log(user1);
const { accessToken, refreshToken } = await generateTokens(user1);
console.log(accessToken);
return accessToken;

//const { email } = ticket.getPayload();



}


const gettokenfrombackend = async (user, account) => {
await connectMongoDB();
const token = account.id_token;
const email = user.email;
//console.log("------",email);
const ticket = await client.verifyIdToken({
idToken: token,
audience: process.env.GOOGLE_CLIENT_ID,
});
const user1 = await Users.findOne({ email: email });
console.log(user1);
const { accessToken, refreshToken } = await generateTokens(user1);
console.log(accessToken);
return accessToken;

const authOptions={
providers:[
GoogleProvider({
clientId:process.env.GOOGLE_CLIENT_ID,
clientSecret:process.env.GOOGLE_CLIENT_SECRET
}),
],
callbacks:{

async signIn({user,account}){
const{name,email}=user;
console.log("User",user)
console.log("Account",account);
if(account.provider==='google'){
try{
await connectMongoDB()
const userExists=await Users.findOne({email});
console.log(userExists)
if(!userExists){
const res=await fetch("http://localhost:3001/api/register",{
method:"POST",
headers:{
"Content-Type":"application/json"
},
body:JSON.stringify({
name,email
})
})
if(res.ok){
return user;
}
}else{
console.log("User has already registerd");
return NextResponse.json({ message: "User has already registered", status: 200 });
}
//const { email } = ticket.getPayload();
};


}catch(error){
console.log(error);
}
}
},



async jwt({ token, user, account }) {
if (account && user) {
return {
idToken: account.id_token,
accessToken: account.access_token,
accessTokenExpires: account.expires_at * 1000,
refreshToken: account.refresh_token,
accessTokenFromBackend: await gettokenfrombackend(user, account),
user,
};
const authOptions = {
providers: [
GoogleProvider({
clientId: process.env.GOOGLE_CLIENT_ID,
clientSecret: process.env.GOOGLE_CLIENT_SECRET,
}),
],
callbacks: {
async signIn({ user, account }) {
const { name, email } = user;
console.log('User', user);
console.log('Account', account);
if (account.provider === 'google') {
try {
await connectMongoDB();
const userExists = await Users.findOne({ email });
console.log(userExists);
if (!userExists) {
const res = await fetch(
`${process.env.NEXTAUTH_URL}/api/register`,
{
method: 'POST',
headers: {
'Content-Type': 'application/json',
},
body: JSON.stringify({
name,
email,
}),
}
if (Date.now() < token.accessTokenExpires) {
return token;
}
// Access token has expired, try to update it
return refreshAccessToken(token);
},
async session({ session, token, user }) {

session.user = token.user;
session.accessToken = token.accessToken;
session.accessTokenBackend = token.accessTokenFromBackend;
session.error = token.error;
session.idToken = token.idToken;
if (token.accessTokenFromBackend) {
return session;
}
return null;
);
if (res.ok) {
return user;
}
} else {
console.log('User has already registerd');
return NextResponse.json({
message: 'User has already registered',
status: 200,
});
}
} catch (error) {
console.log(error);
}
}
},



}
async jwt({ token, user, account }) {
if (account && user) {
return {
idToken: account.id_token,
accessToken: account.access_token,
accessTokenExpires: account.expires_at * 1000,
refreshToken: account.refresh_token,
accessTokenFromBackend: await gettokenfrombackend(
user,
account
),
user,
};
}
if (Date.now() < token.accessTokenExpires) {
return token;
}
// Access token has expired, try to update it
return refreshAccessToken(token);
},
async session({ session, token, user }) {
session.user = token.user;
session.accessToken = token.accessToken;
session.accessTokenBackend = token.accessTokenFromBackend;
session.error = token.error;
session.idToken = token.idToken;
if (token.accessTokenFromBackend) {
return session;
}
return null;
},
},
};

async function refreshAccessToken(token) {
try {
const url =
"https://oauth2.googleapis.com/token?" +
new URLSearchParams({
client_id: process.env.GOOGLE_CLIENT_ID,
client_secret: process.env.GOOGLE_CLIENT_SECRET,
grant_type: "refresh_token",
refresh_token: token.refreshToken,
});

const response = await fetch(url, {
headers: {
"Content-Type": "application/x-www-form-urlencoded",
},
method: "POST",
try {
const url =
'https://oauth2.googleapis.com/token?' +
new URLSearchParams({
client_id: process.env.GOOGLE_CLIENT_ID,
client_secret: process.env.GOOGLE_CLIENT_SECRET,
grant_type: 'refresh_token',
refresh_token: token.refreshToken,
});

const refreshedTokens = await response.json();

if (!response.ok) {
throw refreshedTokens;
}

return {
...token,
idToken: refreshedTokens.id_token,
accessToken: refreshedTokens.access_token,
accessTokenExpires: Date.now() + refreshedTokens.expires_in * 1000,
refreshToken: refreshedTokens.refresh_token ?? token.refreshToken, // Fall back to old refresh token
};
} catch (error) {
console.error(error);

return {
...token,
error: "RefreshAccessTokenError",
};

const response = await fetch(url, {
headers: {
'Content-Type': 'application/x-www-form-urlencoded',
},
method: 'POST',
});

const refreshedTokens = await response.json();

if (!response.ok) {
throw refreshedTokens;
}

return {
...token,
idToken: refreshedTokens.id_token,
accessToken: refreshedTokens.access_token,
accessTokenExpires:
Date.now() + refreshedTokens.expires_in * 1000,
refreshToken:
refreshedTokens.refresh_token ?? token.refreshToken, // Fall back to old refresh token
};
} catch (error) {
console.error(error);

return {
...token,
error: 'RefreshAccessTokenError',
};
}
}

const handler = NextAuth(authOptions);
const handler = NextAuth(authOptions);

export { handler as GET, handler as POST };
export { handler as GET, handler as POST };

0 comments on commit 427483c

Please sign in to comment.