Skip to content

Commit 8abcafd

Browse files
committed
update project phase delete
1 parent e0c40ee commit 8abcafd

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

src/services/ProcessorServicePhase.js

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,10 @@ const helper = require('../common/helper')
1414
*/
1515
function createIdSchema () {
1616
return Joi.object().keys({
17-
id: Joi.number().integer().positive().required(),
17+
id: Joi.alternatives(
18+
Joi.number().integer().positive().required(),
19+
Joi.array().items(Joi.number().integer().positive()).required()
20+
),
1821
projectId: Joi.number().integer().positive().required()
1922
}).unknown(true).required()
2023
}
@@ -107,7 +110,7 @@ update.schema = {
107110
async function deleteMessage (message) {
108111
// handle ES Update
109112
async function updateDocPromise (doc) {
110-
const phases = _.filter(doc._source.phases, single => single.id !== message.id)
113+
const phases = _.filter(doc._source.phases, single => _.isArray(message.id) ? !_.includes(message.id, single.id) : single.id !== message.id)
111114
return _.assign(doc._source, { phases })
112115
}
113116

0 commit comments

Comments
 (0)