diff --git a/packages/grpc-js/package.json b/packages/grpc-js/package.json index 97d7e275..87a75d79 100644 --- a/packages/grpc-js/package.json +++ b/packages/grpc-js/package.json @@ -1,6 +1,6 @@ { "name": "@grpc/grpc-js", - "version": "1.3.5", + "version": "1.3.6", "description": "gRPC Library for Node - pure JS implementation", "homepage": "https://grpc.io/", "repository": "https://github.com/grpc/grpc-node/tree/master/packages/grpc-js", diff --git a/packages/grpc-js/src/http_proxy.ts b/packages/grpc-js/src/http_proxy.ts index 8c461d4f..6e62eddd 100644 --- a/packages/grpc-js/src/http_proxy.ts +++ b/packages/grpc-js/src/http_proxy.ts @@ -254,6 +254,12 @@ export function getProxiedConnection( reject(); }); } else { + trace( + 'Successfully established a plaintext connection to ' + + options.path + + ' through proxy ' + + proxyAddressString + ); resolve({ socket, realTarget: parsedTarget, diff --git a/packages/grpc-js/src/subchannel.ts b/packages/grpc-js/src/subchannel.ts index 8991ee3b..cb1650dc 100644 --- a/packages/grpc-js/src/subchannel.ts +++ b/packages/grpc-js/src/subchannel.ts @@ -303,6 +303,11 @@ export class Subchannel { } private createSession(proxyConnectionResult: ProxyConnectionResult) { + if (proxyConnectionResult.realTarget) { + trace(this.subchannelAddressString + ' creating HTTP/2 session through proxy to ' + proxyConnectionResult.realTarget); + } else { + trace(this.subchannelAddressString + ' creating HTTP/2 session'); + } const targetAuthority = getDefaultAuthority( proxyConnectionResult.realTarget ?? this.channelTarget ); @@ -403,6 +408,7 @@ export class Subchannel { }); session.once('close', () => { if (this.session === session) { + trace(this.subchannelAddressString + ' connection closed'); this.transitionToState( [ConnectivityState.CONNECTING], ConnectivityState.TRANSIENT_FAILURE