import { NextRequest, NextResponse } from 'next/server' import { google } from 'googleapis' import { getPayload } from 'payload' import config from '@payload-config' const oauth2Client = new google.auth.OAuth2( process.env.YOUTUBE_OAUTH_CLIENT_ID, process.env.YOUTUBE_OAUTH_CLIENT_SECRET, 'http://localhost:3000/api/auth/youtube/callback' ) export async function GET(req: NextRequest) { // we'll need our searchParams const searchParams = req.nextUrl.searchParams // to get the code and potentially the error from the params const code = searchParams.get('code') const error = searchParams.get('error') // if there is an error, we'll shut down the operation with a status of 400 if (error) { return NextResponse.json({ error: 'Authorization denied' }, { status: 400 }) } // if there's no code, we'll say no code is provided if (!code) { return NextResponse.json({ error: 'No authorization code provided' }, { status: 400 }) } try { // Exchange code for tokens const { tokens } = await oauth2Client.getToken(code) oauth2Client.setCredentials(tokens) // I'm using Payload for this project, so I can use payload methods to store the necessary information into a field I defined. // Store the refresh token in the database const payload = await getPayload({ config }) // Update or create the YouTube settings try { await payload.updateGlobal({ slug: 'youtube-settings', data: { channelId: process.env.YOUTUBE_CHANNEL_ID || '', refreshToken: tokens.refresh_token, lastAuthorized: new Date().toISOString(), }, }) console.log('Refresh token saved to database') } catch (e) { console.error('Failed to save refresh token to database:', e) } // we'll return a NextResponse that will be an html string indicating that the authorization was a success return new NextResponse(` YouTube Authorization Success

YouTube Authorization Successful!

`, { headers: { 'Content-Type': 'text/html' }, }) // otherwise we'll catch our error } catch (e) { console.error('OAuth callback error:', e) // and return a JSON response of 500, saying there was an error return NextResponse.json({ error: 'Failed to exchange authorization code', details: e instanceof Error ? e.message : 'Unknown error' }, { status: 500 }) } }