diff --git a/libs/event-emitter/src/event-emitter.module.ts b/libs/event-emitter/src/event-emitter.module.ts index 0ddf58e..ecdf887 100644 --- a/libs/event-emitter/src/event-emitter.module.ts +++ b/libs/event-emitter/src/event-emitter.module.ts @@ -183,7 +183,13 @@ export class EventEmitterModule implements OnModuleInit { subj.subscribe(async (issues: RedmineTypes.Issue[]) => { this.logger.debug( `Changed issues - ` + - issues.map((i) => `#${i.id} (${i.subject})`).join(', '), + issues.map( + (i) => { + return (i && i.id && i.subject) + ? `#${i.id} (${i.subject})` + : ''; + } + ).join(', '), ); for (let i = 0; i < issues.length; i++) { diff --git a/libs/event-emitter/src/events/redmine-events.gateway.ts b/libs/event-emitter/src/events/redmine-events.gateway.ts index 932bfbb..ff7dff3 100644 --- a/libs/event-emitter/src/events/redmine-events.gateway.ts +++ b/libs/event-emitter/src/events/redmine-events.gateway.ts @@ -177,7 +177,9 @@ export class RedmineEventsGateway { if (this.listeners && this.listeners.length > 0) { this.getIssuesChangesQueue().queue.subscribe((data) => { const issues = data.map((issue) => { - return `${issue['id']} - ${issue['subject']}`; + return (issue && issue.id && issue.subject) + ? `${issue['id']} - ${issue['subject']}` + : ''; }); this.logger.debug('Changed issues: ' + JSON.stringify(issues)); });