Skip to content

Commit

Permalink
Merge pull request #120 from shikshalokam/ED-599-Integration
Browse files Browse the repository at this point in the history
kafka push object prototype issue resolve
  • Loading branch information
aks30 authored May 15, 2023
2 parents 14dcafb + 4a78181 commit 2afc34a
Showing 1 changed file with 7 additions and 5 deletions.
12 changes: 7 additions & 5 deletions module/programs/helper.js
Original file line number Diff line number Diff line change
Expand Up @@ -1082,13 +1082,15 @@ module.exports = class ProgramsHelper {
}
}
console.log("kafka push status :",pushProgramUsersDetailsToKafka)
let joinProgramDetails = joinProgram.toObject();

if ( pushProgramUsersDetailsToKafka ) {
joinProgram.programName = programData[0].name;
joinProgram.programExternalId = programData[0].externalId;
joinProgram.requestForPIIConsent = programData[0].requestForPIIConsent;

joinProgramDetails.programName = programData[0].name;
joinProgramDetails.programExternalId = programData[0].externalId;
joinProgramDetails.requestForPIIConsent = programData[0].requestForPIIConsent;
// push programUsers details to kafka
await kafkaProducersHelper.pushProgramUsersToKafka(joinProgram);
await kafkaProducersHelper.pushProgramUsersToKafka(joinProgramDetails);
}

return resolve({
Expand Down

0 comments on commit 2afc34a

Please sign in to comment.