grpc-code-gen
Advanced tools
Comparing version 4.2.1 to 4.3.0
@@ -379,4 +379,10 @@ "use strict"; | ||
options?: { timeout?: number; flags?: number; host?: string; }, | ||
callback?: (err: Error, response: ${responseType}) => void, | ||
callback?: (err: Error, response: ${responseType}, metadata: Metadata) => void, | ||
): Promise<${responseType}>; | ||
${method.name}( | ||
request: ${requestType}, | ||
metadata: Metadata, | ||
options?: { timeout?: number; flags?: number; host?: string; }, | ||
callback?: (err: Error, response: ${responseType}, metadata: Metadata) => void, | ||
): Promise<${responseType}>; | ||
`; | ||
@@ -388,2 +394,3 @@ }); | ||
fileTip, | ||
`import { Metadata } from "@grpc/grpc-js";`, | ||
`import { get } from 'lodash';`, | ||
@@ -411,3 +418,3 @@ `import grpcObject from '${getImportPath(servicePath, grpcObjPath)}';\n`, | ||
const methodId = origin.path.replace(/\\//g, '.').replace(/^\\./, ''); | ||
Service.prototype[key] = promisify(function(this: any, request: any, options: any, callback: any) { | ||
Service.prototype[key] = promisify(function(this: any, request: any, metadata: Metadata, options: any, callback: any) { | ||
let count = 0; | ||
@@ -428,3 +435,3 @@ | ||
const start = Date.now(); | ||
(origin as any).apply(self, [request, options, function(err: any, response: any) { | ||
(origin as any).apply(self, [request, metadata, options, function(err: any, response: any, metadataRes: Metadata) { | ||
if (!logOptions.disable) { | ||
@@ -444,3 +451,3 @@ const duration = (Date.now() - start) / 1000; | ||
} else { | ||
callback(err, response); | ||
callback(err, response, metadataRes); | ||
} | ||
@@ -476,3 +483,3 @@ }]); | ||
const methodId = origin.path.replace(/\\//g, '.').replace(/^\\./, ''); | ||
${service.name}.prototype[key] = promisify(function(request, options, callback) { | ||
${service.name}.prototype[key] = promisify(function(request, metadata, options, callback) { | ||
let count = 0; | ||
@@ -493,3 +500,3 @@ | ||
const start = Date.now(); | ||
origin.apply(self, [request, options, function(err, response) { | ||
origin.apply(self, [request, options, function(err, response, metadata) { | ||
if (!logOptions.disable) { | ||
@@ -509,3 +516,3 @@ const duration = (Date.now() - start) / 1000; | ||
} else { | ||
callback(err, response); | ||
callback(err, response, metadata); | ||
} | ||
@@ -512,0 +519,0 @@ }]); |
{ | ||
"name": "grpc-code-gen", | ||
"version": "4.2.1", | ||
"version": "4.3.0", | ||
"license": "MIT", | ||
@@ -5,0 +5,0 @@ "repository": "https://github.com/yunkeCN/grpc-code-gen.git", |
@@ -457,4 +457,10 @@ import * as fs from 'fs-extra'; | ||
options?: { timeout?: number; flags?: number; host?: string; }, | ||
callback?: (err: Error, response: ${responseType}) => void, | ||
callback?: (err: Error, response: ${responseType}, metadata: Metadata) => void, | ||
): Promise<${responseType}>; | ||
${method.name}( | ||
request: ${requestType}, | ||
metadata: Metadata, | ||
options?: { timeout?: number; flags?: number; host?: string; }, | ||
callback?: (err: Error, response: ${responseType}, metadata: Metadata) => void, | ||
): Promise<${responseType}>; | ||
` | ||
@@ -467,2 +473,3 @@ }); | ||
fileTip, | ||
`import { Metadata } from "@grpc/grpc-js";`, | ||
`import { get } from 'lodash';`, | ||
@@ -490,3 +497,3 @@ `import grpcObject from '${getImportPath(servicePath, grpcObjPath)}';\n`, | ||
const methodId = origin.path.replace(/\\//g, '.').replace(/^\\./, ''); | ||
Service.prototype[key] = promisify(function(this: any, request: any, options: any, callback: any) { | ||
Service.prototype[key] = promisify(function(this: any, request: any, metadata: Metadata, options: any, callback: any) { | ||
let count = 0; | ||
@@ -507,3 +514,3 @@ | ||
const start = Date.now(); | ||
(origin as any).apply(self, [request, options, function(err: any, response: any) { | ||
(origin as any).apply(self, [request, metadata, options, function(err: any, response: any, metadataRes: Metadata) { | ||
if (!logOptions.disable) { | ||
@@ -523,3 +530,3 @@ const duration = (Date.now() - start) / 1000; | ||
} else { | ||
callback(err, response); | ||
callback(err, response, metadataRes); | ||
} | ||
@@ -554,3 +561,3 @@ }]); | ||
const methodId = origin.path.replace(/\\//g, '.').replace(/^\\./, ''); | ||
${service.name}.prototype[key] = promisify(function(request, options, callback) { | ||
${service.name}.prototype[key] = promisify(function(request, metadata, options, callback) { | ||
let count = 0; | ||
@@ -571,3 +578,3 @@ | ||
const start = Date.now(); | ||
origin.apply(self, [request, options, function(err, response) { | ||
origin.apply(self, [request, options, function(err, response, metadata) { | ||
if (!logOptions.disable) { | ||
@@ -587,3 +594,3 @@ const duration = (Date.now() - start) / 1000; | ||
} else { | ||
callback(err, response); | ||
callback(err, response, metadata); | ||
} | ||
@@ -590,0 +597,0 @@ }]); |
Sorry, the diff of this file is not supported yet
131916
1972