mirror of
https://github.com/grpc/grpc-node.git
synced 2025-12-08 18:23:54 +00:00
grpc-js: Fix status check when connecting to proxy
This commit is contained in:
parent
7eef1efd65
commit
6e59160c2c
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@grpc/grpc-js",
|
||||
"version": "0.7.7",
|
||||
"version": "0.7.8",
|
||||
"description": "gRPC Library for Node - pure JS implementation",
|
||||
"homepage": "https://grpc.io/",
|
||||
"repository": "https://github.com/grpc/grpc-node/tree/master/packages/grpc-js",
|
||||
|
||||
@ -58,7 +58,7 @@ function getProxyInfo(): ProxyInfo {
|
||||
try {
|
||||
proxyUrl = new URL(proxyEnv);
|
||||
} catch (e) {
|
||||
log(LogVerbosity.INFO, `cannot parse value of "${envVar}" env var`);
|
||||
log(LogVerbosity.ERROR, `cannot parse value of "${envVar}" env var`);
|
||||
return {};
|
||||
}
|
||||
if (proxyUrl.protocol !== 'http:') {
|
||||
@ -145,17 +145,17 @@ export function getProxiedConnection(target: string, subchannelAddress: Subchann
|
||||
request.once('connect', (res, socket, head) => {
|
||||
request.removeAllListeners();
|
||||
socket.removeAllListeners();
|
||||
if (res.statusCode === http.STATUS_CODES.OK) {
|
||||
if (res.statusCode === 200) {
|
||||
trace('Successfully connected to ' + subchannelAddress + ' through proxy ' + PROXY_INFO.address);
|
||||
resolve(socket);
|
||||
} else {
|
||||
trace('Failed to connect to ' + subchannelAddress + ' through proxy ' + PROXY_INFO.address);
|
||||
log(LogVerbosity.ERROR, 'Failed to connect to ' + subchannelAddress + ' through proxy ' + PROXY_INFO.address);
|
||||
reject();
|
||||
}
|
||||
});
|
||||
request.once('error', (err) => {
|
||||
request.removeAllListeners();
|
||||
trace('Failed to connect to proxy ' + PROXY_INFO.address);
|
||||
log(LogVerbosity.ERROR, 'Failed to connect to proxy ' + PROXY_INFO.address);
|
||||
reject();
|
||||
});
|
||||
});
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user