Fixed timing difference between graph and roundtrip in grpc controller.

Author: danst3in

src/client/controllers/grpcController.js

@@ -110,7 +110,7 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
 
         // Open Connection and set time sent for Unary
         reqResObj.connection = 'open';
-        
+
         time.timeSent = Date.now();
         // make Unary call
         client[rpc](query, meta, (err, data)=> {
@@ -155,11 +155,13 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
         else {
           //Close Connection for client Stream
           reqResObj.connection = 'closed';
-          let curTime = Date.now()
+          let curTime = Date.now();
+          console.log('curTime client stream: ', curTime);
           reqResObj.response.times.forEach(time => {
             time.timeReceived = curTime;
+            console.log('time.timeReceived client stream: ', time.timeReceived);
             reqResObj.timeReceived = time.timeReceived;
-            reqResObj.response.events.push(time)
+            // reqResObj.response.times.push(time)
 
           })
           reqResObj.response.events.push(response)
@@ -186,7 +188,8 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
           reqResObj.connection = 'pending';
 
 
-          time.timeSent = timeSent
+          time.timeSent = timeSent;
+          console.log('time.timeSent client stream: ', time.timeSent );
           reqResObj.response.times.push(time)
 
 
@@ -206,18 +209,12 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
         call.on("data", resp => {
           let time = {};
           time.timeReceived = Date.now();
+          console.log('time.timeReceived Server Stream: ', time.timeReceived);
           time.timeSent = reqResObj.timeSent;
           // add server response to reqResObj and dispatch to state/store
           reqResObj.response.events.push(resp)
-
           reqResObj.response.times.push(time)
-
-
-         // timesArr.push(Date.now())
-          //console.log('new time pushed: ', timesArr)
-          // console.log('data response server stream',resp)
-          // console.log(reqResObj.response.events)
-
+          reqResObj.timeReceived = time.timeReceived; //  overwritten on each call to get the final value
 
           store.default.dispatch(actions.reqResUpdate(reqResObj));
         })
@@ -229,11 +226,8 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
           // Close Connection for SERVER Stream
           reqResObj.connection = 'closed';
 
-          reqResObj.timeReceived = Date.now();
-
-         // reqResObj.connectionType = 'plain';
-         // reqResObj.timeReceived =Date.now();
-         // reqResObj.timesArr = timesArr
+          // reqResObj.timeReceived = Date.now();
+          // console.log('reqResObj.timeReceived Server Stream: ', reqResObj.timeReceived);
 
           // no need to push response to reqResObj, no event expected from on 'end'
           store.default.dispatch(actions.reqResUpdate(reqResObj));
@@ -260,6 +254,8 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
         reqResObj.connection = 'pending';
         curTimeObj.timeReceived = Date.now();
         reqResObj.timeReceived = curTimeObj.timeReceived;
+        console.log('curTimeObj.timeReceived BIDI on data: ', curTimeObj.timeReceived);
+        console.log('reqResObj.timeReceived BIDI on data: ', reqResObj.timeReceived);
         reqResObj.response.events.push(response);
         reqResObj.response.times.push(curTimeObj);
         store.default.dispatch(actions.reqResUpdate(reqResObj));
@@ -281,7 +277,8 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
         call.on('end', (data)=> {
           //Close Final Server Connection for BIDIRECTIONAL Stream
           reqResObj.connection = 'closed';
-          reqResObj.timeReceived = Date.now();
+          // reqResObj.timeReceived = Date.now();
+          // console.log('reqResObj.timeReceived BIDI on end: ', reqResObj.timeReceived);
           // no need to push response to reqResObj, no event expected from on 'end'
           store.default.dispatch(actions.reqResUpdate(reqResObj));
         });
@@ -296,14 +293,17 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
             reqResObj.connection = 'pending';
           }
           time.timeSent = Date.now();
+          console.log('time.timeSent open connection for BIDI: ', time.timeSent);
           reqResObj.timeSent = time.timeSent;
+          console.log('reqResObj.timeSent open connection for BIDI: ', reqResObj.timeSent);
           reqResObj.response.times.push(time)
           call.write(query);
         }
         call.end();
       }
-    reqResObj.connection = 'closed';
-    reqResObj.timeReceived = Date.now();
+    // reqResObj.connection = 'closed';
+    // reqResObj.timeReceived = Date.now();
+    // console.log('reqResObj.timeReceived end of controller unspecified: ', reqResObj.timeReceived);
     store.default.dispatch(actions.reqResUpdate(reqResObj));
 };
 export default grpcController;