fix: sync issue between db and es #817
Conversation
![github-actions[bot]](https://avatars.githubusercontent.com/in/15368?s=60&v=4){kind=small}
| @@ -233,6 +233,15 @@ module.exports = [ | |||
| transaction: t, | |||
| }); | |||
|
|
|||
| const invitesToBeUpdated = await models.ProjectMemberInvite.findAll({ | |||
There was a problem hiding this comment.
Consider adding error handling for the findAll operation to ensure that any issues during database retrieval are properly managed.
| const invitesToBeUpdated = await models.ProjectMemberInvite.findAll({ | ||
| where: { | ||
| applicationId: { | ||
| [Op.in]: copilotApplications.map(item => item.id), |
There was a problem hiding this comment.
Ensure that copilotApplications is defined and contains valid data before using it in the query. This will prevent potential runtime errors if copilotApplications is undefined or empty.
| @@ -245,6 +254,15 @@ module.exports = [ | |||
| }, | |||
| transaction: t, | |||
| }); | |||
|
|
|||
| invitesToBeUpdated.forEach((inviteToBeUpdated) => { | |||
There was a problem hiding this comment.
Consider adding error handling for the forEach loop to ensure that any issues with sending resources to the Kafka bus do not cause the entire transaction to fail.
|
|
||
| invitesToBeUpdated.forEach((inviteToBeUpdated) => { | ||
| req.log.info(inviteToBeUpdated.toJSON(), 'invite to be updated') | ||
| util.sendResourceToKafkaBus( |
There was a problem hiding this comment.
Ensure that util.sendResourceToKafkaBus handles potential errors internally or consider wrapping it in a try-catch block to handle any exceptions that might occur during the operation.
No description provided.