@ozonru/mountebank-grpc
Advanced tools
Comparing version 0.2.2 to 0.2.3
{ | ||
"name": "@ozonru/mountebank-grpc", | ||
"version": "0.2.2", | ||
"version": "0.2.3", | ||
"description": "gRPC client for mountebank", | ||
@@ -5,0 +5,0 @@ "main": "src/index.js", |
@@ -77,10 +77,2 @@ 'use strict' | ||
const mbResponse = await mb.sendRequest(mbOptions.callbackURL, {request: request}); | ||
let response = mbResponse.response; | ||
if (!response.value) { | ||
response.error = { | ||
status: 'INTERNAL', | ||
message: `Not found stub for request ${request.path}.`, | ||
} | ||
return server.sendUnaryResponse(response, call, callback); | ||
} | ||
if (mbResponse.proxy) { | ||
@@ -92,7 +84,17 @@ const clientOptions = { | ||
}; | ||
response = await client.sendUnaryUnaryCall(clientOptions, mbResponse.request); | ||
let response = await client.sendUnaryUnaryCall(clientOptions, mbResponse.request); | ||
log.debug(`proxy_response='%s'`, JSON.stringify(response)); | ||
await mb.sendRequest(mbResponse.callbackURL, {proxyResponse: response}); | ||
return server.sendUnaryResponse(response, call, callback); | ||
} | ||
server.sendUnaryResponse(response, call, callback); | ||
let response = mbResponse.response; | ||
if (!response.value && response.value !== {} && !response.error) { | ||
response.error = { | ||
status: 'INTERNAL', | ||
message: `Not found stub for request ${request.path}.`, | ||
} | ||
return server.sendUnaryResponse(response, call, callback); | ||
} | ||
return server.sendUnaryResponse(response, call, callback); | ||
})(); | ||
@@ -99,0 +101,0 @@ } |
27250
597