102 lines
2.4 KiB
JavaScript
102 lines
2.4 KiB
JavaScript
|
/**
|
||
|
|
* 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}`);
|
||
|
|
});
|