@@ -97,6 +97,7 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
9797 // create client requested metadata key and value pair for each type of streaming
9898 let meta = new grpc . Metadata ( )
9999 let metaArr = reqResObj . request . headers ;
100+ console . log ( "metaArr from grpcController line 100:" , metaArr )
100101 for ( let i = 0 ; i < metaArr . length ; i += 1 ) {
101102 let currentHeader = metaArr [ i ] ;
102103 meta . add ( currentHeader . key , currentHeader . value )
@@ -174,7 +175,7 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
174175 // request without overwrite
175176 reqResObj . connection = 'pending' ;
176177 reqResObj . connectionType = 'plain' ;
177- reqResObj . timeSent = Date . now ( ) ;
178+ reqResObj . timeReceived = Date . now ( ) ;
178179 call . write ( query ) ;
179180 // add console log for completed write?
180181 }
@@ -214,6 +215,7 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
214215 let key = keys [ i ] ;
215216 reqResObj . response . headers [ key ] = metadata . _internal_repr [ key ] [ 0 ] ;
216217 // console.log('reqred headers are now', reqResObj.response.headers)
218+
217219 }
218220 store . default . dispatch ( actions . reqResUpdate ( reqResObj ) )
219221 } )
@@ -239,7 +241,9 @@ grpcController.openGrpcConnection = (reqResObj, connectionArray) => {
239241 for ( let i = 0 ; i < keys . length ; i += 1 ) {
240242 let key = keys [ i ] ;
241243 reqResObj . response . headers [ key ] = metadata . _internal_repr [ key ] [ 0 ] ;
244+
242245 // console.log('reqred headers are now', reqResObj.response.headers)
246+
243247 }
244248 store . default . dispatch ( actions . reqResUpdate ( reqResObj ) )
245249 } ) ;
0 commit comments