forked from grpc/grpc-node
/
common.js
366 lines (327 loc) · 10.8 KB
/
common.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
/**
* @license
* Copyright 2015 gRPC authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
*/
'use strict';
var constants = require('./constants');
/**
* Wrap a function to pass null-like values through without calling it. If no
* function is given, just uses the identity.
* @private
* @param {?function} func The function to wrap
* @return {function} The wrapped function
*/
exports.wrapIgnoreNull = function wrapIgnoreNull(func) {
if (!func) {
return x => x;
}
return function(arg) {
if (arg === null || arg === undefined) {
return null;
}
return func(arg);
};
};
/**
* The logger object for the gRPC module. Defaults to console.
* @private
*/
exports.logger = console;
/**
* The current logging verbosity. 0 corresponds to logging everything
* @private
*/
exports.logVerbosity = 0;
/**
* Log a message if the severity is at least as high as the current verbosity
* @private
* @param {Number} severity A value of the grpc.logVerbosity map
* @param {String} message The message to log
*/
exports.log = function log(severity, message) {
if (severity >= exports.logVerbosity) {
exports.logger.error(message);
}
};
/**
* Default options for loading proto files into gRPC
* @alias grpc~defaultLoadOptions
*/
exports.defaultGrpcOptions = {
convertFieldsToCamelCase: false,
binaryAsBase64: false,
longsAsStrings: true,
enumsAsStrings: true,
deprecatedArgumentOrder: false
};
/**
* Create an Error object from a status object
* @param {grpc~StatusObject} status The status object
* @return {Error} The resulting Error
*/
exports.createStatusError = function(status) {
let inverted = Object.keys(constants.status)
.reduce((acc, key) => {
acc[constants.status[key]] = key;
return acc;
}, {});
let statusName = inverted[status.code];
let message = `${status.code} ${statusName}: ${status.details}`;
let error = new Error(message);
error.code = status.code;
error.metadata = status.metadata;
error.details = status.details;
return error;
};
/**
* Get a method's type from its definition
* @param {grpc~MethodDefinition} method_definition
* @return {number}
*/
exports.getMethodType = function(method_definition) {
if (method_definition.requestStream) {
if (method_definition.responseStream) {
return constants.methodTypes.BIDI_STREAMING;
} else {
return constants.methodTypes.CLIENT_STREAMING;
}
} else {
if (method_definition.responseStream) {
return constants.methodTypes.SERVER_STREAMING;
} else {
return constants.methodTypes.UNARY;
}
}
};
/**
* Iterate over a collection of items, and run the given handler.
* Return the results as a flattened array of values.
*
* @private
*
* @param {Array} collection Array of items to process
* @param {Function} handler The function to call on each element in the array
* @return {Array} A flattened array of results.
*/
exports.flatMap = function(collection, handler) {
const mapped = collection.map(handler);
return mapped.reduce((acc, curr) => acc.concat(curr), []);
}
/**
* Given an array of property names and an array of values,
* combine the two into an object map.
* Equivalent to _.zipObject.
*
* @private
*
* @param props {Array<String>} Array of property names
* @param values {Array} Array of property values
* @return {Object} An object with the combined values
*/
exports.zipObject = function(props, values) {
return props.reduce((acc, curr, idx) => {
return Object.assign(acc, { [curr]: values[idx] });
}, {});
}
/**
* Returns true, if given key is included in the blacklisted
* keys.
* @param key {String} key for check, string.
* @return {Boolean}
*/
exports.isPrototypePolluted = function(key) {
return ['__proto__', 'prototype', 'constructor'].indexOf(key) >= 0;
}
// JSDoc definitions that are used in multiple other modules
/**
* Represents the status of a completed request. If `code` is
* {@link grpc.status}.OK, then the request has completed successfully.
* Otherwise, the request has failed, `details` will contain a description of
* the error. Either way, `metadata` contains the trailing response metadata
* sent by the server when it finishes processing the call.
* @typedef {object} grpc~StatusObject
* @property {number} code The error code, a key of {@link grpc.status}
* @property {string} details Human-readable description of the status
* @property {grpc.Metadata} metadata Trailing metadata sent with the status,
* if applicable
*/
/**
* Describes how a request has failed. The member `message` will be the same as
* `details` in {@link grpc~StatusObject}, and `code` and `metadata` are the
* same as in that object.
* @typedef {Error} grpc~ServiceError
* @property {number} code The error code, a key of {@link grpc.status} that is
* not `grpc.status.OK`
* @property {grpc.Metadata} metadata Trailing metadata sent with the status,
* if applicable
*/
/**
* The EventEmitter class in the event standard module
* @external EventEmitter
* @see https://nodejs.org/api/events.html#events_class_eventemitter
*/
/**
* The Readable class in the stream standard module
* @external Readable
* @see https://nodejs.org/api/stream.html#stream_readable_streams
*/
/**
* The Writable class in the stream standard module
* @external Writable
* @see https://nodejs.org/api/stream.html#stream_writable_streams
*/
/**
* The Duplex class in the stream standard module
* @external Duplex
* @see https://nodejs.org/api/stream.html#stream_class_stream_duplex
*/
/**
* A serialization function
* @callback grpc~serialize
* @param {*} value The value to serialize
* @return {Buffer} The value serialized as a byte sequence
*/
/**
* A deserialization function
* @callback grpc~deserialize
* @param {Buffer} data The byte sequence to deserialize
* @return {*} The data deserialized as a value
*/
/**
* The deadline of an operation. If it is a date, the deadline is reached at
* the date and time specified. If it is a finite number, it is treated as
* a number of milliseconds since the Unix Epoch. If it is Infinity, the
* deadline will never be reached. If it is -Infinity, the deadline has already
* passed.
* @typedef {(number|Date)} grpc~Deadline
*/
/**
* An object that completely defines a service method signature.
* @typedef {Object} grpc~MethodDefinition
* @property {string} path The method's URL path
* @property {boolean} requestStream Indicates whether the method accepts
* a stream of requests
* @property {boolean} responseStream Indicates whether the method returns
* a stream of responses
* @property {grpc~serialize} requestSerialize Serialization
* function for request values
* @property {grpc~serialize} responseSerialize Serialization
* function for response values
* @property {grpc~deserialize} requestDeserialize Deserialization
* function for request data
* @property {grpc~deserialize} responseDeserialize Deserialization
* function for repsonse data
*/
/**
* @function MetadataListener
* @param {grpc.Metadata} metadata The response metadata.
* @param {function} next Passes metadata to the next interceptor.
*/
/**
* @function MessageListener
* @param {jspb.Message} message The response message.
* @param {function} next Passes a message to the next interceptor.
*/
/**
* @function StatusListener
* @param {grpc~StatusObject} status The response status.
* @param {function} next Passes a status to the next interceptor.
*/
/**
* A set of interceptor functions triggered by responses
* @typedef {object} grpc~Listener
* @property {MetadataListener=} onReceiveMetadata A function triggered by
* response metadata.
* @property {MessageListener=} onReceiveMessage A function triggered by a
* response message.
* @property {StatusListener=} onReceiveStatus A function triggered by a
* response status.
*/
/**
* @function MetadataRequester
* @param {grpc.Metadata} metadata The request metadata.
* @param {grpc~Listener} listener A listener wired to the previous layers
* in the interceptor stack.
* @param {function} next Passes metadata and a listener to the next
* interceptor.
*/
/**
* @function MessageRequester
* @param {jspb.Message} message The request message.
* @param {function} next Passes a message to the next interceptor.
*/
/**
* @function CloseRequester
* @param {function} next Calls the next interceptor.
*/
/**
* @function CancelRequester
* @param {function} next Calls the next interceptor.
*/
/**
* @function GetPeerRequester
* @param {function} next Calls the next interceptor.
* @return {string}
*/
/**
* @typedef {object} grpc~Requester
* @param {MetadataRequester=} start A function triggered when the call begins.
* @param {MessageRequester=} sendMessage A function triggered by the request
* message.
* @param {CloseRequester=} halfClose A function triggered when the client
* closes the call.
* @param {CancelRequester=} cancel A function triggered when the call is
* cancelled.
* @param {GetPeerRequester=} getPeer A function triggered when the endpoint is
* requested.
*/
/**
* An object that completely defines a service.
* @typedef {Object.<string, grpc~MethodDefinition>} grpc~ServiceDefinition
*/
/**
* An object that defines a protobuf type
* @typedef {object} grpc~ProtobufTypeDefinition
* @param {string} format The format of the type definition object
* @param {*} type The type definition object
* @param {Buffer[]} fileDescriptorProtos Binary protobuf file
* descriptors for all files loaded to construct this type
*/
/**
* An object that defines a package hierarchy with multiple services
* @typedef {Object.<string, grpc~ServiceDefinition|grpc~ProtobufTypeDefinition>} grpc~PackageDefinition
*/
/**
* A function for dynamically assigning an interceptor to a call.
* @function InterceptorProvider
* @param {grpc~MethodDefinition} method_definition The method to provide
* an interceptor for.
* @return {Interceptor|null} The interceptor to provide or nothing
*/
/**
* A function which can modify call options and produce methods to intercept
* RPC operations.
* @function Interceptor
* @param {object} options The grpc call options
* @param {NextCall} nextCall
* @return {InterceptingCall}
*/
/**
* A function which produces the next InterceptingCall.
* @function NextCall
* @param {object} options The grpc call options
* @return {InterceptingCall|null}
*/