[NestJS] 14. Kakao API 소셜 로그인 기능 구현(OAuth)

npm i passport passport-kakao

npm install @nestjs/axios

import { Injectable } from '@nestjs/common'; import { PassportStrategy } from '@nestjs/passport'; import { Strategy } from 'passport-kakao'; import { AuthService } from './auth.service'; @Injectable() export class KakaoStrategy extends PassportStrategy(Strategy, 'kakao') { constructor(private readonly authService: AuthService) { super({ clientID: process.env.KAKAO_CLIENT_ID, callbackURL: process.env.KAKAO_CALLBACK_URL, }); } }

import { Module } from '@nestjs/common'; import { AuthController } from './auth.controller'; import { AuthService } from './auth.service'; import { TypeOrmModule } from '@nestjs/typeorm'; import { User } from "src/user/user.entity"; import { JwtModule } from '@nestjs/jwt'; import { PassportModule } from '@nestjs/passport'; import * as dotenv from 'dotenv'; import { JwtStrategy } from './jwt.strategy'; import { HttpModule } from '@nestjs/axios'; import { KakaoStrategy } from './kakao.strategy'; dotenv.config(); @Module({ imports: [ PassportModule.register({ defaultStrategy: 'jwt' }), JwtModule.register({ secret: process.env.JWT_SECRET, signOptions:{ expiresIn: parseInt(process.env.JWT_EXPIRATION, 10) } }), TypeOrmModule.forFeature([User]), HttpModule, ], controllers: [AuthController], providers: [AuthService, JwtStrategy, KakaoStrategy], exports: [JwtModule, PassportModule], }) export class AuthModule {}

import { ConflictException, Injectable, UnauthorizedException, Logger } from '@nestjs/common'; import { InjectRepository } from '@nestjs/typeorm'; import { User } from "src/user/user.entity"; import { Repository } from 'typeorm'; import { SignUpRequestDto } from './dto/sign-up-request.dto'; import * as bcrypt from 'bcryptjs'; import { SignInRequestDto } from './dto/sign-in-request.dto'; import { JwtService } from '@nestjs/jwt'; import { HttpService } from '@nestjs/axios'; import { firstValueFrom } from 'rxjs'; import { v4 as uuidv4 } from 'uuid'; @Injectable() export class AuthService { private readonly logger = new Logger(AuthService.name); constructor( @InjectRepository(User) private usersRepository: Repository<User>, private jwtService: JwtService, private httpService: HttpService ){} // 회원 가입 async signUp(signUpRequestDto: SignUpRequestDto): Promise<User> { const { username, password, email, role, postalCode, address, detailAddress } = signUpRequestDto; this.logger.verbose(`Attempting to sign up user with email: ${email}`); // 이메일 중복 확인 await this.checkEmailExists(email); // 비밀번호 해싱 const hashedPassword = await this.hashPassword(password); const newUser = this.usersRepository.create({ username, password: hashedPassword, // 해싱된 비밀번호 사용 email, role, postalCode, address, detailAddress, }); const savedUser = await this.usersRepository.save(newUser); this.logger.verbose(`User signed up successfully with email: ${email}`); this.logger.debug(`User details: ${JSON.stringify(savedUser)}`); return savedUser; } // 로그인 async signIn(signInRequestDto: SignInRequestDto): Promise<{ jwtToken: string, user: User }> { const { email, password } = signInRequestDto; this.logger.verbose(`Attempting to sign in user with email: ${email}`); try { const existingUser = await this.findUserByEmail(email); if (!existingUser || !(await bcrypt.compare(password, existingUser.password))) { this.logger.warn(`Failed login attempt for email: ${email}`); throw new UnauthorizedException('Incorrect email or password.'); } // [1] JWT 토큰 생성 (Secret + Payload) const jwtToken = await this.generateJwtToken(existingUser); // [2] 사용자 정보 반환 return { jwtToken, user: existingUser }; } catch (error) { this.logger.error('Signin failed', error.stack); throw error; } } // 이메일 중복 확인 메서드 private async checkEmailExists(email: string): Promise<void> { this.logger.verbose(`Checking if email exists: ${email}`); const existingUser = await this.findUserByEmail(email); if (existingUser) { this.logger.warn(`Email already exists: ${email}`); throw new ConflictException('Email already exists'); } this.logger.verbose(`Email is available: ${email}`); } // 이메일로 유저 찾기 메서드 private async findUserByEmail(email: string): Promise<User | undefined> { return await this.usersRepository.findOne({ where: { email } }); } // 비밀번호 해싱 암호화 메서드 private async hashPassword(password: string): Promise<string> { this.logger.verbose(`Hashing password`); const salt = await bcrypt.genSalt(); // 솔트 생성 return await bcrypt.hash(password, salt); // 비밀번호 해싱 } // 카카오 정보 회원 가입 async signUpWithKakao(kakaoId: string, profile: any): Promise<User> { const kakaoAccount = profile.kakao_account; const kakaoUsername = kakaoAccount.name; const kakaoEmail = kakaoAccount.email; // 카카오 프로필 데이터를 기반으로 사용자 찾기 또는 생성 로직을 구현 const existingUser = await this.usersRepository.findOne({ where: { email: kakaoEmail } }); if (existingUser) { return existingUser; } // 비밀번호 필드에 랜덤 문자열 생성 const temporaryPassword = uuidv4(); // 랜덤 문자열 생성 const hashedPassword = await this.hashPassword(temporaryPassword); // 새 사용자 생성 로직 const newUser = this.usersRepository.create({ username: kakaoUsername, email: kakaoEmail, password: hashedPassword, // 해싱된 임시 비밀번호 사용 // 기타 필요한 필드 설정 }); return this.usersRepository.save(newUser); } // 카카오 로그인 async signInWithKakao(kakaoAuthResCode: string): Promise<{ jwtToken: string, user: User }> { // Authorization Code로 Kakao API에 Access Token 요청 const accessToken = await this.getKakaoAccessToken(kakaoAuthResCode); // Access Token으로 Kakao 사용자 정보 요청 const kakaoUserInfo = await this.getKakaoUserInfo(accessToken); // 카카오 사용자 정보를 기반으로 회원가입 또는 로그인 처리 const user = await this.signUpWithKakao(kakaoUserInfo.id.toString(), kakaoUserInfo); // [1] JWT 토큰 생성 (Secret + Payload) const jwtToken = await this.generateJwtToken(user); // [2] 사용자 정보 반환 return { jwtToken, user }; } // Kakao Authorization Code로 Access Token 요청 async getKakaoAccessToken(code: string): Promise<string> { const tokenUrl = 'https://kauth.kakao.com/oauth/token'; const payload = { grant_type: 'authorization_code', client_id: process.env.KAKAO_CLIENT_ID, // Kakao REST API Key redirect_uri: process.env.KAKAO_REDIRECT_URI, code, client_secret: process.env.KAKAO_CLIENT_SECRET // 필요시 사용 }; const response = await firstValueFrom(this.httpService.post(tokenUrl, null, { params: payload, headers: { 'Content-Type': 'application/x-www-form-urlencoded' } })); return response.data.access_token; // Access Token 반환 } // Access Token으로 Kakao 사용자 정보 요청 async getKakaoUserInfo(accessToken: string): Promise<any> { const userInfoUrl = 'https://kapi.kakao.com/v2/user/me'; const response = await firstValueFrom(this.httpService.get(userInfoUrl, { headers: { Authorization: `Bearer ${accessToken}` } })); this.logger.debug(`Kakao User Info: ${JSON.stringify(response.data)}`); // 데이터 확인 return response.data; } // JWT 생성 공통 메서드 async generateJwtToken(user: User): Promise<string> { // [1] JWT 토큰 생성 (Secret + Payload) const payload = { email: user.email, userId: user.id, role: user.role }; const accessToken = await this.jwtService.sign(payload); this.logger.debug(`Generated JWT Token: ${accessToken}`); this.logger.debug(`User details: ${JSON.stringify(user)}`); return accessToken; } }

import { Body, Controller, Get, Logger, Post, Query, Req, Res, UseGuards } from '@nestjs/common'; import { Response } from 'express'; import { AuthService } from './auth.service'; import { SignUpRequestDto } from './dto/sign-up-request.dto'; import { User } from "src/user/user.entity"; import { SignInRequestDto } from './dto/sign-in-request.dto'; import { AuthGuard } from '@nestjs/passport'; import { GetUser } from './get-user.decorator'; import { UserResponseDto } from './dto/user-response.dto'; import { ApiResponse } from 'src/common/api-response.dto'; @Controller('api/auth') export class AuthController { private readonly logger = new Logger(AuthController.name); // Logger 인스턴스 생성 constructor(private authService: AuthService){} // 회원 가입 기능 @Post('/signup') async signUp(@Body() signUpRequestDto: SignUpRequestDto): Promise<ApiResponse<UserResponseDto>> { this.logger.verbose(`Attempting to sign up user with email: ${signUpRequestDto.email}`); const user = await this.authService.signUp(signUpRequestDto); const userResponseDto = new UserResponseDto(user); this.logger.verbose(`User signed up successfully: ${JSON.stringify(userResponseDto)}`); return new ApiResponse(true, 201, 'User signed up successfully', userResponseDto); } // 로그인 기능 @Post('/signin') async signIn(@Body() signInRequestDto: SignInRequestDto, @Res() res: Response): Promise<void> { this.logger.verbose(`Attempting to sign in user with email: ${signInRequestDto.email}`); const { jwtToken, user } = await this.authService.signIn(signInRequestDto); const userResponseDto = new UserResponseDto(user); this.logger.verbose(`User signed in successfully: ${JSON.stringify(userResponseDto)}`); // [3] 쿠키 설정 res.cookie('Authorization', jwtToken, { httpOnly: true, // 클라이언트 측 스크립트에서 쿠키 접근 금지 secure: false, // HTTPS에서만 쿠키 전송, 임시 비활성화 maxAge: 3600000, // 1시간 sameSite: 'none', // CSRF 공격 방어 }); res.status(200).json(new ApiResponse(true, 200, 'Sign in successful', { jwtToken, user: userResponseDto })); } // 인증된 회원이 들어갈 수 있는 테스트 URL 경로 @Post('/test') @UseGuards(AuthGuard()) // @UseGuards : 핸들러는 지정한 인증 가드가 적용됨 -> AuthGuard()의 'jwt'는 기본값으로 생략가능 async testForAuth(@GetUser() user: User): Promise<ApiResponse<UserResponseDto>> { this.logger.verbose(`Authenticated user accessing test route: ${user.email}`); const userResponseDto = new UserResponseDto(user); return new ApiResponse(true, 200, 'You are authenticated', userResponseDto); } // 카카오 로그인 페이지 요청 @Get('/kakao') @UseGuards(AuthGuard('kakao')) async kakaoLogin(@Req() req: Request) { // 이 부분은 Passport의 AuthGuard에 의해 카카오 로그인 페이지로 리다이렉트 } // 카카오 로그인 콜백 엔드포인트 @Get('kakao/callback') async kakaoCallback(@Query('code') kakaoAuthResCode: string, @Res() res: Response) { // Authorization Code 받기 const { jwtToken, user } = await this.authService.signInWithKakao(kakaoAuthResCode); // 쿠키에 JWT 설정 res.cookie('Authorization', jwtToken, { httpOnly: true, // 클라이언트 측 스크립트에서 쿠키 접근 금지 secure: false, // HTTPS에서만 쿠키 전송, 임시 비활성화 maxAge: 3600000, // 1시간 // sameSite: 'none', // CSRF 공격 방어 }); const userResponseDto = new UserResponseDto(user); this.logger.verbose(`User signed in successfully: ${JSON.stringify(userResponseDto)}`); res.status(200).json(new ApiResponse(true, 200, 'Sign in successful', { jwtToken, user: userResponseDto })); } }