104 lines
3.3 KiB
JavaScript
104 lines
3.3 KiB
JavaScript
const DeviceService = require('../services/device.service');
|
|
const { deviceSchema } = require('../helpers/validation');
|
|
const { setResponse } = require('../helpers/utils');
|
|
|
|
class DeviceController {
|
|
// Get all devices
|
|
static async getAll(req, res) {
|
|
try {
|
|
const devices = await DeviceService.getAllDevices();
|
|
return res.status(200).json(
|
|
setResponse(devices, 'Devices retrieved successfully', 200)
|
|
);
|
|
} catch (err) {
|
|
return res.status(err.statusCode || 500).json(
|
|
setResponse([], err.message || 'Failed to get devices', err.statusCode || 500)
|
|
);
|
|
}
|
|
}
|
|
|
|
// Get device by ID
|
|
static async getById(req, res) {
|
|
try {
|
|
const { id } = req.params;
|
|
const device = await DeviceService.getDeviceById(id);
|
|
return res.status(200).json(
|
|
setResponse(device, 'Device retrieved successfully', 200)
|
|
);
|
|
} catch (err) {
|
|
return res.status(err.statusCode || 500).json(
|
|
setResponse([], err.message || 'Failed to get device', err.statusCode || 500)
|
|
);
|
|
}
|
|
}
|
|
|
|
// Create device
|
|
static async create(req, res) {
|
|
try {
|
|
const { error, value } = deviceSchema.validate(req.body || {}, { abortEarly: false });
|
|
if (error) {
|
|
const errors = error.details.reduce((acc, cur) => {
|
|
const field = Array.isArray(cur.path) ? cur.path.join('.') : String(cur.path);
|
|
if (!acc[field]) acc[field] = [];
|
|
acc[field].push(cur.message);
|
|
return acc;
|
|
}, {});
|
|
return res.status(400).json(setResponse(errors, 'Validation failed', 400));
|
|
}
|
|
|
|
const newDevice = await DeviceService.createDevice(value, req.user.userId);
|
|
return res.status(201).json(
|
|
setResponse(newDevice, 'Device created successfully', 201)
|
|
);
|
|
} catch (err) {
|
|
return res.status(err.statusCode || 500).json(
|
|
setResponse([], err.message || 'Failed to create device', err.statusCode || 500)
|
|
);
|
|
}
|
|
}
|
|
|
|
// Update device
|
|
static async update(req, res) {
|
|
try {
|
|
const { id } = req.params;
|
|
const { error, value } = deviceSchema.validate(req.body || {}, { abortEarly: false });
|
|
if (error) {
|
|
const errors = error.details.reduce((acc, cur) => {
|
|
const field = Array.isArray(cur.path) ? cur.path.join('.') : String(cur.path);
|
|
if (!acc[field]) acc[field] = [];
|
|
acc[field].push(cur.message);
|
|
return acc;
|
|
}, {});
|
|
return res.status(400).json(setResponse(errors, 'Validation failed', 400));
|
|
}
|
|
|
|
await DeviceService.updateDevice(id, value, req.user.userId);
|
|
return res.status(200).json(
|
|
setResponse([], 'Device updated successfully', 200)
|
|
);
|
|
} catch (err) {
|
|
return res.status(err.statusCode || 500).json(
|
|
setResponse([], err.message || 'Failed to update device', err.statusCode || 500)
|
|
);
|
|
}
|
|
}
|
|
|
|
// Soft delete device
|
|
static async delete(req, res) {
|
|
try {
|
|
const { id } = req.params;
|
|
|
|
await DeviceService.deleteDevice(id, req.user.userId);
|
|
return res.status(200).json(
|
|
setResponse([], 'Device deleted successfully', 200)
|
|
);
|
|
} catch (err) {
|
|
return res.status(err.statusCode || 500).json(
|
|
setResponse([], err.message || 'Failed to delete device', err.statusCode || 500)
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = DeviceController;
|