pavel/pinkmine
1
0
Fork 0
Code Issues 1 Pull requests Projects Releases Packages Wiki Activity Actions

Logger added in events gateway

Browse source
This commit is contained in:
Pavel Gnedov 2022-05-01 22:46:17 +07:00
parent 38070c3811
commit f111702c7c
1 changed files with 18 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
libs/event-emitter/src/events/redmine-events.gateway.ts
View file

@ -17,6 +17,7 @@ import axios from 'axios';
import { WebhookConfigItemModel } from '../models/webhook-config-item-model'; import { WebhookConfigItemModel } from '../models/webhook-config-item-model';
import { RssListener } from '../rsslistener/rsslistener'; import { RssListener } from '../rsslistener/rsslistener';
import { EventsListener } from './events-listener'; import { EventsListener } from './events-listener';
import { Logger } from '@nestjs/common';
type IssuesChangesQueueParams = { type IssuesChangesQueueParams = {
updateInterval: number; updateInterval: number;
@ -32,6 +33,7 @@ export class RedmineEventsGateway {
private issueNumberParser: RegExp; private issueNumberParser: RegExp;
private issuesChangesQueueParams: IssuesChangesQueueParams; private issuesChangesQueueParams: IssuesChangesQueueParams;
private logger = new Logger(RedmineEventsGateway.name);
constructor( constructor(
private config: ConfigService, private config: ConfigService,
@ -60,7 +62,9 @@ export class RedmineEventsGateway {
try { try {
res = await this.redmineDataLoader.loadIssues(issueNumbers); res = await this.redmineDataLoader.loadIssues(issueNumbers);
} catch (e) { } catch (e) {
console.error('Error load issues:', e, 'for issues:', issueNumbers); this.logger.error(
'Error load issues:' + e.message + 'for issues:' + issueNumbers,
);
return []; return [];
} }
return res; return res;
@ -158,10 +162,21 @@ export class RedmineEventsGateway {
queue.queue.subscribe((data) => this.sendWebHookFullDataEvents(data)); queue.queue.subscribe((data) => this.sendWebHookFullDataEvents(data));
} }
private initChangesLogging(): void {
if (this.listener) {
this.getIssuesChangesQueue().queue.subscribe((data) => {
const issues = data.map((issue) => {
return `${issue['id']} - ${issue['subject']}`;
});
this.logger.debug('Changed issues: ' + JSON.stringify(issues));
});
}
}
private initRedmineEventsGateway(): boolean { private initRedmineEventsGateway(): boolean {
const listener = this.getMainListener(); const listener = this.getMainListener();
if (!listener) { if (!listener) {
console.error('Listener not created'); this.logger.error('Listener not created');
return false; return false;
} }
const issuesChangesQueue = this.getIssuesChangesQueue(); const issuesChangesQueue = this.getIssuesChangesQueue();
@ -170,6 +185,7 @@ export class RedmineEventsGateway {
}); });
this.initWebSocketsSendData(); this.initWebSocketsSendData();
this.initWebHooksSendData(); this.initWebHooksSendData();
this.initChangesLogging();
return true; return true;
} }
} }