From 25e862694e8aad5402439fdf57f5eb00f43d1bdb Mon Sep 17 00:00:00 2001 From: Hyungi Ahn Date: Mon, 3 Nov 2025 10:50:54 +0900 Subject: [PATCH] =?UTF-8?q?refactor:=20workerController.js=20=EC=83=88?= =?UTF-8?q?=EB=A1=9C=EC=9A=B4=20=EC=9C=A0=ED=8B=B8=EB=A6=AC=ED=8B=B0=20?= =?UTF-8?q?=EC=A0=81=EC=9A=A9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 새로운 에러 처리 시스템 적용: * asyncHandler로 비동기 함수 래핑 * ApiError 클래스로 유효성 검사 에러 처리 * handleDatabaseError로 DB 에러 표준화 * handleNotFoundError로 404 에러 표준화 - 새로운 응답 포맷터 적용: * res.created() - 작업자 생성 성공 응답 * res.list() - 작업자 목록 조회 응답 * res.success() - 단일 작업자 조회 응답 * res.updated() - 작업자 수정 성공 응답 * res.deleted() - 작업자 삭제 성공 응답 - 유효성 검사 시스템 적용: * validateSchema로 스키마 기반 검증 * schemas.createWorker 스키마 사용 * ID 파라미터 유효성 검사 추가 - 함수별 개선사항: * createWorker: 스키마 검증 및 생성 응답 포맷터 * getAllWorkers: 목록 응답 포맷터 적용 * getWorkerById: ID 검증 및 404 처리 개선 * updateWorker: ID 검증 및 수정 응답 포맷터 * removeWorker: ID 검증 및 삭제 응답 포맷터 --- .../controllers/workerController.js | 92 +++++++++++++------ 1 file changed, 64 insertions(+), 28 deletions(-) diff --git a/api.hyungi.net/controllers/workerController.js b/api.hyungi.net/controllers/workerController.js index 98f7d6f..9260799 100644 --- a/api.hyungi.net/controllers/workerController.js +++ b/api.hyungi.net/controllers/workerController.js @@ -1,24 +1,31 @@ // controllers/workerController.js const workerModel = require('../models/workerModel'); +const { ApiError, asyncHandler, handleDatabaseError, handleNotFoundError } = require('../utils/errorHandler'); +const { validateSchema, schemas } = require('../utils/validator'); // 1. 작업자 생성 -exports.createWorker = async (req, res) => { +exports.createWorker = asyncHandler(async (req, res) => { + const workerData = req.body; + + // 스키마 기반 유효성 검사 + validateSchema(workerData, schemas.createWorker); + try { - const workerData = req.body; const lastID = await new Promise((resolve, reject) => { workerModel.create(workerData, (err, id) => { if (err) reject(err); else resolve(id); }); }); - res.json({ success: true, worker_id: lastID }); + + res.created({ worker_id: lastID }, '작업자가 성공적으로 생성되었습니다.'); } catch (err) { - res.status(500).json({ error: err.message || String(err) }); + handleDatabaseError(err, '작업자 생성'); } -}; +}); // 2. 전체 작업자 조회 -exports.getAllWorkers = async (req, res) => { +exports.getAllWorkers = asyncHandler(async (req, res) => { try { const rows = await new Promise((resolve, reject) => { workerModel.getAll((err, data) => { @@ -26,60 +33,89 @@ exports.getAllWorkers = async (req, res) => { else resolve(data); }); }); - res.json(rows); + + res.list(rows, '작업자 목록 조회 성공'); } catch (err) { - res.status(500).json({ error: err.message || String(err) }); + handleDatabaseError(err, '작업자 목록 조회'); } -}; +}); // 3. 단일 작업자 조회 -exports.getWorkerById = async (req, res) => { +exports.getWorkerById = asyncHandler(async (req, res) => { + const id = parseInt(req.params.worker_id, 10); + + if (isNaN(id)) { + throw new ApiError('유효하지 않은 작업자 ID입니다.', 400); + } + try { - const id = parseInt(req.params.worker_id, 10); const row = await new Promise((resolve, reject) => { workerModel.getById(id, (err, data) => { if (err) reject(err); else resolve(data); }); }); - if (!row) return res.status(404).json({ error: 'Worker 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.updateWorker = async (req, res) => { +exports.updateWorker = asyncHandler(async (req, res) => { + const id = parseInt(req.params.worker_id, 10); + + if (isNaN(id)) { + throw new ApiError('유효하지 않은 작업자 ID입니다.', 400); + } + + const workerData = { ...req.body, worker_id: id }; + try { - const id = parseInt(req.params.worker_id, 10); - const workerData = { ...req.body, worker_id: id }; const changes = await new Promise((resolve, reject) => { workerModel.update(workerData, (err, affected) => { if (err) reject(err); else resolve(affected); }); }); - if (changes === 0) return res.status(404).json({ error: 'Worker 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.removeWorker = async (req, res) => { +exports.removeWorker = asyncHandler(async (req, res) => { + const id = parseInt(req.params.worker_id, 10); + + if (isNaN(id)) { + throw new ApiError('유효하지 않은 작업자 ID입니다.', 400); + } + try { - const id = parseInt(req.params.worker_id, 10); const changes = await new Promise((resolve, reject) => { workerModel.remove(id, (err, affected) => { if (err) reject(err); else resolve(affected); }); }); - if (changes === 0) return res.status(404).json({ error: 'Worker 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