Skip to content

Commit d1ee884

Browse files
add futher logic
1 parent 77c1eeb commit d1ee884

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

src/eventHandlers/JobCandidateEventHandler.js

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,9 @@ async function withDrawnJobCandidates (payload) {
133133
*/
134134
async function processCreate (payload) {
135135
await inReviewJob(payload)
136-
await withDrawnJobCandidates(payload)
136+
if (payload.value.status === 'placed') {
137+
await withDrawnJobCandidates(payload)
138+
}
137139
}
138140

139141
/**
@@ -144,7 +146,9 @@ async function processCreate (payload) {
144146
*/
145147
async function processUpdate (payload) {
146148
await inReviewJob(payload)
147-
await withDrawnJobCandidates(payload)
149+
if (payload.value.status === 'placed' && payload.options.oldValue.status !== 'placed') {
150+
await withDrawnJobCandidates(payload)
151+
}
148152
}
149153

150154
module.exports = {

src/services/JobCandidateService.js

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,7 @@ createJobCandidate.schema = Joi.object().keys({
144144
*/
145145
async function updateJobCandidate (currentUser, id, data) {
146146
const jobCandidate = await JobCandidate.findById(id)
147+
const oldValue = jobCandidate.toJSON()
147148
const userId = await helper.getUserId(currentUser.userId)
148149

149150
// check user permission
@@ -155,7 +156,7 @@ async function updateJobCandidate (currentUser, id, data) {
155156
data.updatedBy = userId
156157

157158
const updated = await jobCandidate.update(data)
158-
await helper.postEvent(config.TAAS_JOB_CANDIDATE_UPDATE_TOPIC, updated.toJSON())
159+
await helper.postEvent(config.TAAS_JOB_CANDIDATE_UPDATE_TOPIC, updated.toJSON(), { oldValue: oldValue })
159160
const result = _.assign(jobCandidate.dataValues, data)
160161
return result
161162
}

0 commit comments

Comments
 (0)