From 4276ea7c2ee281e369b43d377abee0045ba7d44a Mon Sep 17 00:00:00 2001
From: Pavel <Pavel.Murygin@gmail.com>
Date: Fri, 29 Jan 2021 18:54:54 +0300
Subject: [PATCH] Add logging for particle receive events (#13)

* Add logging for particle receive events

* Better log levels
---
 src/internal/FluenceClientImpl.ts | 15 ++++++++++-----
 src/internal/FluenceConnection.ts |  5 ++---
 src/internal/ParticleProcessor.ts |  9 +++------
 3 files changed, 15 insertions(+), 14 deletions(-)

diff --git a/src/internal/FluenceClientImpl.ts b/src/internal/FluenceClientImpl.ts
index 9041e48a..fce70de6 100644
--- a/src/internal/FluenceClientImpl.ts
+++ b/src/internal/FluenceClientImpl.ts
@@ -221,12 +221,17 @@ export class FluenceClientImpl extends FluenceClientBase implements FluenceClien
                 executingParticle.reject(new Error(`particle ${particle.id} timed out`));
             }
         },
-        onLocalParticleRecieved: (particle: ParticleDto) => {},
-        onExternalParticleRecieved: (particle: ParticleDto) => {},
-        onStepperExecuting: (particle: ParticleDto) => {},
+        onLocalParticleRecieved: (particle: ParticleDto) => {
+            log.debug('local particle received', particle);
+        },
+        onExternalParticleRecieved: (particle: ParticleDto) => {
+            log.debug('external particle received', particle);
+        },
+        onStepperExecuting: (particle: ParticleDto) => {
+            log.debug('stepper executing particle', particle);
+        },
         onStepperExecuted: (stepperOutcome: StepperOutcome) => {
-            log.info('inner interpreter outcome:');
-            log.info(stepperOutcome);
+            log.debug('inner interpreter outcome:', stepperOutcome);
         },
     };
 
diff --git a/src/internal/FluenceConnection.ts b/src/internal/FluenceConnection.ts
index 81dfa0c5..fa1cf115 100644
--- a/src/internal/FluenceConnection.ts
+++ b/src/internal/FluenceConnection.ts
@@ -81,7 +81,7 @@ export class FluenceConnection {
         if (this.status === Status.Initializing) {
             await this.node.start();
 
-            log.debug(`dialing to the node with client's address: ` + this.node.peerId.toB58String());
+            log.trace(`dialing to the node with client's address: ` + this.node.peerId.toB58String());
 
             await this.node.dial(this.address);
 
@@ -92,8 +92,7 @@ export class FluenceConnection {
                     for await (const msg of source) {
                         try {
                             let particle = parseParticle(msg);
-                            log.debug('Particle is received:');
-                            log.debug(JSON.stringify(particle, undefined, 2));
+                            log.trace('Particle is received:', JSON.stringify(particle, undefined, 2));
                             _this.handleParticle(particle);
                         } catch (e) {
                             log.error('error on handling a new incoming message: ' + e);
diff --git a/src/internal/ParticleProcessor.ts b/src/internal/ParticleProcessor.ts
index 1972ef3c..b485b474 100644
--- a/src/internal/ParticleProcessor.ts
+++ b/src/internal/ParticleProcessor.ts
@@ -26,10 +26,10 @@ let magicParticleStorage: Map<string, Map<string, any>> = new Map();
 
 // HACK:: make an api for aqua stepper to accept variables in an easy way!
 export function injectDataIntoParticle(particleId: string, data: Map<string, any>, ttl: number) {
-    log.debug(`setting data for ${particleId}`, data);
+    log.trace(`setting data for ${particleId}`, data);
     magicParticleStorage.set(particleId, data);
     setTimeout(() => {
-        log.debug(`data for ${particleId} is deleted`);
+        log.trace(`data for ${particleId} is deleted`);
         magicParticleStorage.delete(particleId);
     }, ttl);
 }
@@ -215,11 +215,8 @@ export class ParticleProcessor {
         let data: any = particle.data;
         let error: any = data['protocol!error'];
         if (error !== undefined) {
-            log.error('error in external particle: ');
-            log.error(error);
+            log.error('error in external particle: ', error);
         } else {
-            log.info('handle external particle: ');
-            log.info(particle);
             await this.handleParticle(particle);
         }
     }