diff --git a/app/lib/common-libs/parsers/GenericParser.ts b/app/lib/common-libs/parsers/GenericParser.ts index f87ddaadc66dd16c8acb32cc2e36dfd73f74b5ba..551e80345566e3d7c6db2452b5edc6bf3a055aba 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 89cf2d09cd2f8311dd99a3ff96c38531c28c18c4..2f7fbc5c166fa0bc90875727e58b2d333c25716f 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) }