feat(project): implement filter multi status pada get all projects
This commit is contained in:
@@ -88,10 +88,33 @@ const updateProjectModel = joi.object().keys({
|
||||
});
|
||||
|
||||
const getAllProjectsModel = joi.object().keys({
|
||||
status: joi.string().valid(...PROJECT_STATUS_VALUES).optional().messages({
|
||||
'string.base': 'Project status must be a string.',
|
||||
'any.only': `Project status must be one of: ${PROJECT_STATUS_VALUES.join(', ')}.`,
|
||||
}),
|
||||
status: joi
|
||||
.alternatives()
|
||||
.try(
|
||||
joi.string(),
|
||||
joi.array().items(joi.string())
|
||||
)
|
||||
.optional()
|
||||
.custom((value, helpers) => {
|
||||
const statuses = Array.isArray(value)
|
||||
? value.flatMap((status) => String(status).split(','))
|
||||
: String(value).split(',');
|
||||
|
||||
const invalidStatuses = statuses
|
||||
.map((status) => status.trim().toLowerCase())
|
||||
.filter(Boolean)
|
||||
.filter((status) => !PROJECT_STATUS_VALUES.includes(status));
|
||||
|
||||
if (invalidStatuses.length > 0) {
|
||||
return helpers.error('any.only');
|
||||
}
|
||||
|
||||
return value;
|
||||
})
|
||||
.messages({
|
||||
'alternatives.types': 'Project status must be a string or an array of strings.',
|
||||
'any.only': `Project status must be one of: ${PROJECT_STATUS_VALUES.join(', ')}.`,
|
||||
}),
|
||||
});
|
||||
|
||||
module.exports = {
|
||||
|
||||
@@ -58,11 +58,13 @@ class ProjectRepository {
|
||||
});
|
||||
}
|
||||
|
||||
async findAll({ status, actor }) {
|
||||
async findAll({ statuses, actor }) {
|
||||
const where = {};
|
||||
|
||||
if (status) {
|
||||
where.status = status;
|
||||
if (statuses && statuses.length > 0) {
|
||||
where.status = {
|
||||
in: statuses,
|
||||
};
|
||||
}
|
||||
|
||||
if (actor?.role === "intern") {
|
||||
|
||||
@@ -109,8 +109,13 @@ class ProjectService {
|
||||
|
||||
async getAllProjects(query = {}, actor = {}) {
|
||||
try {
|
||||
const statusFilter = this.parseProjectStatusFilter(query.status);
|
||||
if (statusFilter.err) {
|
||||
return statusFilter;
|
||||
}
|
||||
|
||||
const projects = await projectRepository.findAll({
|
||||
status: query.status,
|
||||
statuses: statusFilter.data,
|
||||
actor,
|
||||
});
|
||||
|
||||
@@ -293,6 +298,40 @@ class ProjectService {
|
||||
return new ForbiddenError("Access denied: invalid role");
|
||||
}
|
||||
|
||||
parseProjectStatusFilter(rawStatus) {
|
||||
if (!rawStatus) {
|
||||
return data(null);
|
||||
}
|
||||
|
||||
const allowedStatuses = ["active", "completed", "archived"];
|
||||
|
||||
const statuses = Array.isArray(rawStatus)
|
||||
? rawStatus.flatMap((status) => String(status).split(","))
|
||||
: String(rawStatus).split(",");
|
||||
|
||||
const cleanedStatuses = [
|
||||
...new Set(
|
||||
statuses
|
||||
.map((status) => status.trim().toLowerCase())
|
||||
.filter(Boolean)
|
||||
),
|
||||
];
|
||||
|
||||
const invalidStatuses = cleanedStatuses.filter(
|
||||
(status) => !allowedStatuses.includes(status)
|
||||
);
|
||||
|
||||
if (invalidStatuses.length > 0) {
|
||||
return error(
|
||||
new BadRequestError(
|
||||
`Invalid project status: ${invalidStatuses.join(", ")}`
|
||||
)
|
||||
);
|
||||
}
|
||||
|
||||
return data(cleanedStatuses);
|
||||
}
|
||||
|
||||
normalizeEmails(emails = []) {
|
||||
return [
|
||||
...new Set(
|
||||
|
||||
Reference in New Issue
Block a user