From c30fcd6421a10443545a2beec14fb65ac0243e49 Mon Sep 17 00:00:00 2001
From: cgeek <cem.moreau@gmail.com>
Date: Sat, 28 Oct 2017 10:45:36 +0200
Subject: [PATCH] [enh] refactoring: logs on document receiving

---
 app/lib/common-libs/parsers/GenericParser.ts |  5 ++++-
 server.ts                                    | 14 +++++++-------
 2 files changed, 11 insertions(+), 8 deletions(-)

diff --git a/app/lib/common-libs/parsers/GenericParser.ts b/app/lib/common-libs/parsers/GenericParser.ts
index f87ddaadc..551e80345 100644
--- a/app/lib/common-libs/parsers/GenericParser.ts
+++ b/app/lib/common-libs/parsers/GenericParser.ts
@@ -1,6 +1,9 @@
 import {CommonConstants} from "../../../lib/common-libs/constants"
 import * as stream from "stream"
 import {hashf} from "../../../lib/common"
+import {NewLogger} from "../../logger"
+
+const logger = NewLogger()
 
 export abstract class GenericParser extends stream.Transform {
 
@@ -21,7 +24,7 @@ export abstract class GenericParser extends stream.Transform {
     return;
   }
 
-  syncWrite(str:string, logger:any = null): any {
+  syncWrite(str:string): any {
     let error = ""
     const obj = {};
     this._parse(str, obj);
diff --git a/server.ts b/server.ts
index 89cf2d09c..2f7fbc5c1 100644
--- a/server.ts
+++ b/server.ts
@@ -211,7 +211,7 @@ export class Server extends stream.Duplex implements HookableServer {
   }
 
   async writeRawBlock(raw:string): Promise<BlockDTO> {
-    const obj = parsers.parseBlock.syncWrite(raw, logger)
+    const obj = parsers.parseBlock.syncWrite(raw)
     return await this.writeBlock(obj)
   }
 
@@ -224,7 +224,7 @@ export class Server extends stream.Duplex implements HookableServer {
   }
 
   async writeRawIdentity(raw:string): Promise<DBIdentity> {
-    const obj = parsers.parseIdentity.syncWrite(raw, logger)
+    const obj = parsers.parseIdentity.syncWrite(raw)
     return await this.writeIdentity(obj)
   }
 
@@ -237,7 +237,7 @@ export class Server extends stream.Duplex implements HookableServer {
   }
 
   async writeRawCertification(raw:string): Promise<CertificationDTO> {
-    const obj = parsers.parseCertification.syncWrite(raw, logger)
+    const obj = parsers.parseCertification.syncWrite(raw)
     return await this.writeCertification(obj)
   }
 
@@ -250,7 +250,7 @@ export class Server extends stream.Duplex implements HookableServer {
   }
 
   async writeRawMembership(raw:string): Promise<MembershipDTO> {
-    const obj = parsers.parseMembership.syncWrite(raw, logger)
+    const obj = parsers.parseMembership.syncWrite(raw)
     return await this.writeMembership(obj)
   }
 
@@ -263,7 +263,7 @@ export class Server extends stream.Duplex implements HookableServer {
   }
 
   async writeRawRevocation(raw:string): Promise<RevocationDTO> {
-    const obj = parsers.parseRevocation.syncWrite(raw, logger)
+    const obj = parsers.parseRevocation.syncWrite(raw)
     return await this.writeRevocation(obj)
   }
 
@@ -276,7 +276,7 @@ export class Server extends stream.Duplex implements HookableServer {
   }
 
   async writeRawTransaction(raw:string): Promise<TransactionDTO> {
-    const obj = parsers.parseTransaction.syncWrite(raw, logger)
+    const obj = parsers.parseTransaction.syncWrite(raw)
     return await this.writeTransaction(obj)
   }
 
@@ -289,7 +289,7 @@ export class Server extends stream.Duplex implements HookableServer {
   }
 
   async writeRawPeer(raw:string): Promise<PeerDTO> {
-    const obj = parsers.parsePeer.syncWrite(raw, logger)
+    const obj = parsers.parsePeer.syncWrite(raw)
     return await this.writePeer(obj)
   }
 
-- 
GitLab