Update index.js

index.js

@@ -9,6 +9,9 @@ const express = require('express')
 const cp = require('child_process')
 const PDFDocument = require('pdfkit')
 const playwright = require('playwright-extra')
+const cookieParser = require('cookie-parser');
+const { Buffer } = require('buffer');
+const querystring = require('querystring');
 // const stealth = require('puppeteer-extra-plugin-stealth')
 // playwright.chromium.use(stealth())
 const { NinexbuddySource, NinexbuddyScraper } = require("./lib/buddy.js")
@@ -18,6 +21,10 @@ const kyou = new NinexbuddyScraper()
 const app = express()
 app.set('json spaces', 4)
 app.use(morgan('dev'))
+app.use(cookieParser());
+
+const CLIENT_ID = process.env.CLIENT_ID || 'your_client_id';
+const CLIENT_SECRET = process.env.CLIENT_SECRET || 'your_client_secret';
 
 const limitSize = '500mb'
 app.use(express.json({ limit: limitSize }))
@@ -37,6 +44,11 @@ app.use((req, res, next) => {
 	next()
 })
 
+
+function getFrontendUri(req) {
+  return `${req.protocol}://${req.get('host')}`;
+}
+
 app.use('/file', express.static(tmpFolder))
 
 app.all('/', (req, res) => {
@@ -85,6 +97,130 @@ app.get('/proxy', async (req, res) => {
   }
 });
 
+// 1. Root route - redirect ke Spotify login
+app.get('/spotify', (req, res) => {
+  const FRONTEND_URI = getFrontendUri(req);
+  const REDIRECT_URI = `${FRONTEND_URI}/callback`;
+  
+  const scopes = ['user-read-recently-played'];
+  const queryParams = querystring.stringify({
+    response_type: 'code',
+    client_id: CLIENT_ID,
+    scope: scopes.join(' '),
+    redirect_uri: REDIRECT_URI,
+    show_dialog: false,
+  });
+  
+  res.redirect(`https://accounts.spotify.com/authorize?${queryParams}`);
+});
+
+// 2. Callback route
+app.get('/callback', async (req, res) => {
+  const FRONTEND_URI = getFrontendUri(req);
+  const REDIRECT_URI = `${FRONTEND_URI}/callback`;
+  
+  const { code, error } = req.query;
+
+  if (error) {
+    console.error('Spotify Auth Error:', error);
+    return res.redirect(`${FRONTEND_URI}/error?message=${encodeURIComponent(error)}`);
+  }
+
+  try {
+    // Dapatkan tokens
+    const authResponse = await axios.post('https://accounts.spotify.com/api/token', 
+      querystring.stringify({
+        grant_type: 'authorization_code',
+        code,
+        redirect_uri: REDIRECT_URI,
+      }), {
+        headers: {
+          'Content-Type': 'application/x-www-form-urlencoded',
+          'Authorization': 'Basic ' + Buffer.from(`${CLIENT_ID}:${CLIENT_SECRET}`).toString('base64'),
+        },
+      });
+
+    const { access_token, refresh_token, expires_in } = authResponse.data;
+    
+    // Simpan tokens di cookie
+    res.cookie('spotify_access', access_token, {
+      httpOnly: true,
+      secure: process.env.NODE_ENV === 'production',
+      maxAge: expires_in * 1000
+    });
+    
+    res.cookie('spotify_refresh', refresh_token, {
+      httpOnly: true,
+      secure: process.env.NODE_ENV === 'production'
+    });
+
+    // Redirect ke endpoint JSON
+    res.redirect(`${FRONTEND_URI}/api/recently-played/json`);
+  } catch (err) {
+    console.error('Callback Error:', err);
+    res.redirect(`${FRONTEND_URI}/error?message=${encodeURIComponent('Authentication failed')}`);
+  }
+});
+
+// 3. Recently Played JSON endpoint
+app.get('/api/recently-played/json', async (req, res) => {
+  const FRONTEND_URI = getFrontendUri(req);
+  const accessToken = req.cookies.spotify_access;
+
+  if (!accessToken) {
+    return res.redirect('/');
+  }
+
+  try {
+    // Get recently played tracks
+    const limit = parseInt(req.query.limit) || 20;
+    const response = await axios.get('https://api.spotify.com/v1/me/player/recently-played', {
+      params: { limit },
+      headers: { 'Authorization': `Bearer ${accessToken}` },
+    });
+
+    const tracks = response.data.items.map(item => ({
+      played_at: item.played_at,
+      track: {
+        id: item.track.id,
+        name: item.track.name,
+        artists: item.track.artists.map(a => ({ id: a.id, name: a.name })),
+        album: {
+          id: item.track.album.id,
+          name: item.track.album.name,
+          images: item.track.album.images,
+          release_date: item.track.album.release_date
+        },
+        duration_ms: item.track.duration_ms,
+        preview_url: item.track.preview_url
+      }
+    }));
+
+    res.json({
+      status: 'success',
+      data: tracks,
+      count: tracks.length
+    });
+  } catch (error) {
+    if (error.response?.status === 401) {
+      // Token expired, redirect ke login
+      return res.redirect('/');
+    }
+    
+    console.error('Recently Played Error:', error);
+    res.status(500).json({ 
+      error: 'Failed to fetch recently played tracks',
+      details: error.response?.data || error.message
+    });
+  }
+});
+
+// Error handler
+app.use((err, req, res, next) => {
+  console.error('Server Error:', err);
+  res.status(500).json({ error: 'Internal server error' });
+});
+
 app.get('/pages', async (req, res) => {
   const targetUrl = req.query.url;