From f111702c7c9b013fb48785eaf29892dd4d030ef1 Mon Sep 17 00:00:00 2001
From: Pavel Gnedov <pavel@gnedov.info>
Date: Sun, 1 May 2022 22:46:17 +0700
Subject: [PATCH] Logger added in events gateway

---
 .../src/events/redmine-events.gateway.ts      | 20 +++++++++++++++++--
 1 file changed, 18 insertions(+), 2 deletions(-)

diff --git a/libs/event-emitter/src/events/redmine-events.gateway.ts b/libs/event-emitter/src/events/redmine-events.gateway.ts
index 788a61f..778a345 100644
--- a/libs/event-emitter/src/events/redmine-events.gateway.ts
+++ b/libs/event-emitter/src/events/redmine-events.gateway.ts
@@ -17,6 +17,7 @@ import axios from 'axios';
 import { WebhookConfigItemModel } from '../models/webhook-config-item-model';
 import { RssListener } from '../rsslistener/rsslistener';
 import { EventsListener } from './events-listener';
+import { Logger } from '@nestjs/common';
 
 type IssuesChangesQueueParams = {
   updateInterval: number;
@@ -32,6 +33,7 @@ export class RedmineEventsGateway {
 
   private issueNumberParser: RegExp;
   private issuesChangesQueueParams: IssuesChangesQueueParams;
+  private logger = new Logger(RedmineEventsGateway.name);
 
   constructor(
     private config: ConfigService,
@@ -60,7 +62,9 @@ export class RedmineEventsGateway {
           try {
             res = await this.redmineDataLoader.loadIssues(issueNumbers);
           } catch (e) {
-            console.error('Error load issues:', e, 'for issues:', issueNumbers);
+            this.logger.error(
+              'Error load issues:' + e.message + 'for issues:' + issueNumbers,
+            );
             return [];
           }
           return res;
@@ -158,10 +162,21 @@ export class RedmineEventsGateway {
     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 {
     const listener = this.getMainListener();
     if (!listener) {
-      console.error('Listener not created');
+      this.logger.error('Listener not created');
       return false;
     }
     const issuesChangesQueue = this.getIssuesChangesQueue();
@@ -170,6 +185,7 @@ export class RedmineEventsGateway {
     });
     this.initWebSocketsSendData();
     this.initWebHooksSendData();
+    this.initChangesLogging();
     return true;
   }
 }