@ozonru/mountebank-grpc
Advanced tools
Comparing version 0.2.0 to 0.2.1
{ | ||
"name": "@ozonru/mountebank-grpc", | ||
"version": "0.2.0", | ||
"version": "0.2.1", | ||
"description": "gRPC client for mountebank", | ||
@@ -5,0 +5,0 @@ "main": "src/index.js", |
@@ -5,5 +5,5 @@ 'use strict' | ||
const grpc = require('grpc'), | ||
transform = require('./transform'), | ||
metadata = require('./metadata'); | ||
const grpc = require('grpc') | ||
const transform = require('./transform') | ||
const metadata = require('./metadata') | ||
@@ -59,6 +59,7 @@ | ||
const t = (d) => transform.bufferToBase64(d); | ||
const error = t(response.error), | ||
value = t(response.value), | ||
md = t(response.metadata); | ||
const error = t(response.error) | ||
const value = t(response.value) | ||
const md = t(response.metadata) | ||
const mtd = (md && md.trailing) ? metadata.mapToMetadata(md.trailing) : new grpc.Metadata() | ||
if (md && md.initial) { | ||
@@ -69,9 +70,9 @@ call.sendMetadata(metadata.mapToMetadata(md.initial)); | ||
if (error) { | ||
callback({ | ||
return callback({ | ||
code: grpc.status[error.status || 'INTERNAL'], | ||
message: error.message || 'error message', | ||
metadata: (md && md.trailing) ? metadata.mapToMetadata(md.trailing) : undefined | ||
metadata: mtd | ||
}); | ||
} else { | ||
callback(null, value, (md && md.trailing) ? metadata.mapToMetadata(md.trailing) : undefined); | ||
return callback(null, value, mtd); | ||
} | ||
@@ -78,0 +79,0 @@ }; |
@@ -78,2 +78,9 @@ 'use strict' | ||
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) { | ||
@@ -80,0 +87,0 @@ const clientOptions = { |
27119
596