src/modules/plugin.ts

@@ -32,10 +32,12 @@ class PluginAPI extends EventEmitter2 {
 
   constructor({
     config,
+    logger,
     server,
     swarm,
   }: {
     config: Config;
+    logger: Logger;
     server: RPCServer;
     swarm: any;
   }) {
@@ -45,6 +47,7 @@ class PluginAPI extends EventEmitter2 {
       maxListeners: 0,
     });
     this._config = config;
+    this._logger = logger;
     this._server = server;
     this._swarm = swarm;
   }
@@ -71,8 +74,10 @@ class PluginAPI extends EventEmitter2 {
     throw new Error("not implemented and should not be called");
   }
 
+  private _logger: Logger;
+
   get logger(): Logger {
-    throw new Error("not implemented and should not be called");
+    return this._logger;
   }
 
   get rpcServer(): RPCServer {
@@ -110,6 +115,7 @@ export function getPluginAPI(): PluginAPI {
   if (!pluginAPI) {
     pluginAPI = new PluginAPI({
       config,
+      logger: log,
       server: getRpcServer(),
       swarm: getSwarm(),
     });
@@ -206,10 +212,6 @@ export class PluginAPIManager {
               });
             }
 
-            if (prop === "logger") {
-              return log.child({ plugin: plugin.name });
-            }
-
             return (target as any)[prop];
           },
         })

src/modules/swarm.ts

@@ -71,7 +71,7 @@ export class ProtocolManager {
     this._swarm.on("connection", (peer: any) => {
       for (const protocol of this._protocols) {
         Protomux.from(peer).pair(
-          { protocol: protocol[0] },
+          protocol[0],
           this.handler.bind(this, protocol[0], peer)
         );
       }