updated task

task_4/app.js

@@ -0,0 +1,102 @@
+/**
+ * TODO:
+ * - create basic express server
+ * - connect to mysql database
+ * - create proper docker compose file and dockerfile to setup mysql, express server
+ * - make api to look like this:
+ * /v1/api/rest/video/PAGINATE
+Method POST
+
+body
+{
+    "payload": {},
+    "page": 1,
+    "limit": 10
+}
+Response
+http code 200
+{
+    "error": false,
+    "list": [
+        {
+            "id": 1,
+            "title": "Rune raises $100,000 for marketing through NFT butterflies sale",
+            "photo": "https://picsum.photos/200/200",
+            "user_id": 1,
+            "username": "boss",
+            "create_at": "2022-01-01",
+            "update_at": "2022-01-01T04:00:00.000Z",
+            "like": 10
+        }
+    ],
+    "page": 1,
+    "limit": 10,
+    "total": 112,
+    "num_pages": 12
+}
+
+ */
+
+const express = require('express');
+const mysql = require('mysql2/promise');
+const app = express();
+
+// Middleware to parse JSON bodies
+app.use(express.json());
+
+// Database connection configuration
+const dbConfig = {
+  host: process.env.DB_HOST || 'mysql',
+  user: process.env.DB_USER || 'user',
+  password: process.env.DB_PASSWORD || 'password',
+  database: process.env.DB_NAME || 'videodb'
+};
+
+// API endpoint for video pagination
+app.get('/', async (req, res) => {
+    res.send('Hello World');
+});
+
+app.post('/v1/api/rest/video/PAGINATE', async (req, res) => {
+  try {
+    const page = parseInt(req.body.page) || 1;
+    const limit = parseInt(req.body.limit) || 10;
+    const offset = (page - 1) * limit;
+
+    const connection = await mysql.createConnection(dbConfig);
+
+    // Get total count
+    const [countResult] = await connection.execute(
+      'SELECT COUNT(*) as total FROM videos'
+    );
+    const total = countResult[0].total;
+
+    // Fix: Use a different query format for LIMIT
+    const [rows] = await connection.query(
+      `SELECT 
+        v.id, v.title, v.photo, v.user_id,
+        v.created_at, v.updated_at, v.likes
+      FROM videos v
+      LIMIT ${offset}, ${limit}`
+    );
+
+    await connection.end();
+
+    res.json({
+      error: false,
+      list: rows,
+      page: page,
+      limit: limit,
+      total,
+      num_pages: Math.ceil(total / limit)
+    });
+  } catch (error) {
+    console.error('Error:', error);
+    res.status(500).json({ error: true, message: 'Internal server error' });
+  }
+});
+
+const PORT = process.env.PORT || 3000;
+app.listen(PORT, () => {
+  console.log(`Server running on port ${PORT}`);
+});