feat: add pagination

Author: bangtutorial

app.js

@@ -568,25 +568,69 @@ app.get('/settings', isAuthenticated, async (req, res) => {
 app.get('/history', isAuthenticated, async (req, res) => {
   try {
     const db = require('./db/database').db;
+    const page = parseInt(req.query.page) || 1;
+    const limit = parseInt(req.query.limit) || 10;
+    const sort = req.query.sort === 'oldest' ? 'ASC' : 'DESC';
+    const platform = req.query.platform || 'all';
+    const search = req.query.search || '';
+    const offset = (page - 1) * limit;
+
+    let whereClause = 'WHERE h.user_id = ?';
+    const params = [req.session.userId];
+
+    if (platform !== 'all') {
+      whereClause += ' AND h.platform = ?';
+      params.push(platform);
+    }
+
+    if (search) {
+      whereClause += ' AND h.title LIKE ?';
+      params.push(`%${search}%`);
+    }
+
+    const totalCount = await new Promise((resolve, reject) => {
+      db.get(
+        `SELECT COUNT(*) as count FROM stream_history h ${whereClause}`,
+        params,
+        (err, row) => {
+          if (err) reject(err);
+          else resolve(row.count);
+        }
+      );
+    });
+
     const history = await new Promise((resolve, reject) => {
       db.all(
         `SELECT h.*, v.thumbnail_path 
          FROM stream_history h 
          LEFT JOIN videos v ON h.video_id = v.id 
-         WHERE h.user_id = ? 
-         ORDER BY h.start_time DESC`,
-        [req.session.userId],
+         ${whereClause}
+         ORDER BY h.start_time ${sort}
+         LIMIT ? OFFSET ?`,
+        [...params, limit, offset],
         (err, rows) => {
           if (err) reject(err);
           else resolve(rows);
         }
       );
     });
+
+    const totalPages = Math.ceil(totalCount / limit);
+
     res.render('history', {
       active: 'history',
       title: 'Stream History',
       history: history,
-      helpers: app.locals.helpers
+      helpers: app.locals.helpers,
+      pagination: {
+        page,
+        limit,
+        totalCount,
+        totalPages,
+        sort: req.query.sort || 'newest',
+        platform,
+        search
+      }
     });
   } catch (error) {
     console.error('Error fetching stream history:', error);
@@ -2290,4 +2334,4 @@ const server = app.listen(port, '0.0.0.0', async () => {
 
 server.timeout = 30 * 60 * 1000;
 server.keepAliveTimeout = 30 * 60 * 1000;
-server.headersTimeout = 30 * 60 * 1000;
+server.headersTimeout = 30 * 60 * 1000;