diff --git a/api.hyungi.net/controllers/taskController.js b/api.hyungi.net/controllers/taskController.js index 9ac6142..c0d6f79 100644 --- a/api.hyungi.net/controllers/taskController.js +++ b/api.hyungi.net/controllers/taskController.js @@ -1,69 +1,102 @@ const taskModel = require('../models/taskModel'); +const { ApiError, asyncHandler, handleDatabaseError, handleNotFoundError } = require('../utils/errorHandler'); +const { validateSchema, schemas } = require('../utils/validator'); // 1. 생성 -exports.createTask = async (req, res) => { +exports.createTask = asyncHandler(async (req, res) => { + const taskData = req.body; + try { - const taskData = req.body; const lastID = await new Promise((resolve, reject) => { taskModel.create(taskData, (err, id) => (err ? reject(err) : resolve(id))); }); - res.json({ success: true, task_id: lastID }); + + res.created({ task_id: lastID }, '작업이 성공적으로 생성되었습니다.'); } catch (err) { - res.status(500).json({ error: err.message || String(err) }); + handleDatabaseError(err, '작업 생성'); } -}; +}); // 2. 전체 조회 -exports.getAllTasks = async (req, res) => { +exports.getAllTasks = asyncHandler(async (req, res) => { try { const rows = await new Promise((resolve, reject) => { taskModel.getAll((err, data) => (err ? reject(err) : resolve(data))); }); - res.json(rows); + + res.list(rows, '작업 목록 조회 성공'); } catch (err) { - res.status(500).json({ error: err.message || String(err) }); + handleDatabaseError(err, '작업 목록 조회'); } -}; +}); // 3. 단일 조회 -exports.getTaskById = async (req, res) => { +exports.getTaskById = asyncHandler(async (req, res) => { + const id = parseInt(req.params.task_id, 10); + + if (isNaN(id)) { + throw new ApiError('유효하지 않은 작업 ID입니다.', 400); + } + try { - const id = parseInt(req.params.task_id, 10); const row = await new Promise((resolve, reject) => { taskModel.getById(id, (err, data) => (err ? reject(err) : resolve(data))); }); - if (!row) return res.status(404).json({ error: 'Task not found' }); - res.json(row); + + if (!row) { + handleNotFoundError('작업', id); + } + + res.success(row, '작업 조회 성공'); } catch (err) { - res.status(500).json({ error: err.message || String(err) }); + handleDatabaseError(err, '작업 조회'); } -}; +}); // 4. 수정 -exports.updateTask = async (req, res) => { +exports.updateTask = asyncHandler(async (req, res) => { + const id = parseInt(req.params.task_id, 10); + + if (isNaN(id)) { + throw new ApiError('유효하지 않은 작업 ID입니다.', 400); + } + + const taskData = { ...req.body, task_id: id }; + try { - const id = parseInt(req.params.task_id, 10); - const taskData = { ...req.body, task_id: id }; const changes = await new Promise((resolve, reject) => { taskModel.update(taskData, (err, ch) => (err ? reject(err) : resolve(ch))); }); - if (changes === 0) return res.status(404).json({ error: 'Task not found or no change' }); - res.json({ success: true, changes }); + + if (changes === 0) { + handleNotFoundError('작업', id); + } + + res.updated({ changes }, '작업 정보가 성공적으로 수정되었습니다.'); } catch (err) { - res.status(500).json({ error: err.message || String(err) }); + handleDatabaseError(err, '작업 수정'); } -}; +}); // 5. 삭제 -exports.removeTask = async (req, res) => { +exports.removeTask = asyncHandler(async (req, res) => { + const id = parseInt(req.params.task_id, 10); + + if (isNaN(id)) { + throw new ApiError('유효하지 않은 작업 ID입니다.', 400); + } + try { - const id = parseInt(req.params.task_id, 10); const changes = await new Promise((resolve, reject) => { taskModel.remove(id, (err, ch) => (err ? reject(err) : resolve(ch))); }); - if (changes === 0) return res.status(404).json({ error: 'Task not found' }); - res.json({ success: true, changes }); + + if (changes === 0) { + handleNotFoundError('작업', id); + } + + res.deleted('작업이 성공적으로 삭제되었습니다.'); } catch (err) { - res.status(500).json({ error: err.message || String(err) }); + handleDatabaseError(err, '작업 삭제'); } -}; \ No newline at end of file +}); \ No newline at end of file