feat: add logger for decoder/encoder options (#111)

sofastack · May 22, 2023 · 2115ffb · 2115ffb
1 parent 91ba177
commit 2115ffb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/lib/client/connection/rpc.js b/lib/client/connection/rpc.js
@@ -96,11 +96,13 @@ class RpcConnection extends Base {
       sentReqs: this._sentReqs,
       classCache: this.options.classCache || new Map(),
       address: this.address,
+      logger: this.options.logger,
     };
     const decodeOpts = {
       sentReqs: this._sentReqs,
       classCache: this.options.classCache || new Map(),
       address: this.address,
+      logger: this.options.logger,
     };
 
     // 针对 classMap 针对 hessian, proto 针对 protobuf

diff --git a/lib/server/connection.js b/lib/server/connection.js
@@ -28,10 +28,12 @@ class RpcConnection extends Base {
     const encodeOpts = {
       sentReqs: this._sentReqs,
       classCache: this.options.classCache || new Map(),
+      logger: this.options.logger,
     };
     const decodeOpts = {
       sentReqs: this._sentReqs,
       classCache: this.options.classCache || new Map(),
+      logger: this.options.logger,
     };
     // 针对 classMap 针对 hessian, proto 针对 protobuf
     // 因为可能需要同时支持，所以分开设置（一般通过全局设置，所以这里要判断是否有值）