From fd0f1fc1f79c779f66c4782dfba66807501637b2 Mon Sep 17 00:00:00 2001
From: Pavel Gnedov <pavel@gnedov.info>
Date: Fri, 27 May 2022 11:56:22 +0700
Subject: [PATCH] =?UTF-8?q?=D0=98=D1=81=D0=BF=D1=80=D0=B0=D0=B2=D0=BB?=
 =?UTF-8?q?=D0=B5=D0=BD=D1=8B=20=D0=BE=D1=88=D0=B8=D0=B1=D0=BA=D0=B8=20?=
 =?UTF-8?q?=D0=B8=20=D0=B4=D0=BE=D0=B1=D0=B0=D0=B2=D0=BB=D0=B5=D0=BD=20?=
 =?UTF-8?q?=D0=BB=D0=BE=D0=B3=D0=B3=D0=B5=D1=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../redmine-issues-cache-writer.service.ts    | 19 ++++++++++++++-----
 1 file changed, 14 insertions(+), 5 deletions(-)

diff --git a/libs/redmine-issues-cache-writer/src/redmine-issues-cache-writer.service.ts b/libs/redmine-issues-cache-writer/src/redmine-issues-cache-writer.service.ts
index 4049a46..d2f2e12 100644
--- a/libs/redmine-issues-cache-writer/src/redmine-issues-cache-writer.service.ts
+++ b/libs/redmine-issues-cache-writer/src/redmine-issues-cache-writer.service.ts
@@ -1,10 +1,12 @@
-import { Inject, Injectable } from '@nestjs/common';
+import { Inject, Injectable, Logger } from '@nestjs/common';
 import { RedmineTypes } from 'libs/redmine-types';
 import nano from 'nano';
 import { SaveResponse } from './save-response';
 
 @Injectable()
 export class RedmineIssuesCacheWriterService {
+  private logger = new Logger(RedmineIssuesCacheWriterService.name);
+
   constructor(
     @Inject('ISSUE_DOCUMENT_SCOPE')
     private issueDbProvider: () => Promise<
@@ -13,6 +15,9 @@ export class RedmineIssuesCacheWriterService {
   ) {}
 
   async saveIssue(issue: any): Promise<SaveResponse> {
+    this.logger.debug(
+      `Saving issue ${issue?.id || '-'} - ${issue?.subject || '-'}`,
+    );
     const id = Number(issue['id']);
     let prevIssue: (nano.DocumentGetResponse & RedmineTypes.Issue) | null;
     const issueDb = await this.issueDbProvider();
@@ -32,11 +37,15 @@ export class RedmineIssuesCacheWriterService {
       newIssue._rev = prevIssue._rev;
       await issueDb.insert(newIssue);
     }
-    return {
+    const res = {
       prev: prevIssue,
       current: newIssue,
       journalsDiff: this.getJournalsDiff(prevIssue, newIssue),
     };
+    this.logger.debug(
+      `Saving issue success ${issue?.id || '-'} - ${issue?.subject || '-'}`,
+    );
+    return res;
   }
 
   getJournalsDiff(
@@ -45,11 +54,11 @@ export class RedmineIssuesCacheWriterService {
   ): RedmineTypes.Journal[] {
     if (
       (!prev || !prev.journals || prev.journals.length === 0) &&
-      current.journals
+      current?.journals
     ) {
       return current.journals;
-    } else if (prev.journals && current.journals) {
-      return this.calcJournalsDiff(prev.journals, current.journals);
+    } else if (prev?.journals && current?.journals) {
+      return this.calcJournalsDiff(prev?.journals, current?.journals);
     }
     return [];
   }