mirror of https://github.com/grpc/grpc.git
murgatroid99
8 years ago
parent
3cafec2f55
commit
b5b5f020a3
15 changed files with 493 additions and 230 deletions
@ -0,0 +1,167 @@ |
||||
/* |
||||
* |
||||
* Copyright 2017, Google Inc. |
||||
* All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are |
||||
* met: |
||||
* |
||||
* * Redistributions of source code must retain the above copyright |
||||
* notice, this list of conditions and the following disclaimer. |
||||
* * Redistributions in binary form must reproduce the above |
||||
* copyright notice, this list of conditions and the following disclaimer |
||||
* in the documentation and/or other materials provided with the |
||||
* distribution. |
||||
* * Neither the name of Google Inc. nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* |
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
* |
||||
*/ |
||||
|
||||
'use strict'; |
||||
|
||||
var _ = require('lodash'); |
||||
var client = require('./client'); |
||||
|
||||
/** |
||||
* Get a function that deserializes a specific type of protobuf. |
||||
* @param {function()} cls The constructor of the message type to deserialize |
||||
* @param {bool=} binaryAsBase64 Deserialize bytes fields as base64 strings |
||||
* instead of Buffers. Defaults to false |
||||
* @param {bool=} longsAsStrings Deserialize long values as strings instead of |
||||
* objects. Defaults to true |
||||
* @return {function(Buffer):cls} The deserialization function |
||||
*/ |
||||
exports.deserializeCls = function deserializeCls(cls, binaryAsBase64, |
||||
longsAsStrings) { |
||||
/** |
||||
* Deserialize a buffer to a message object |
||||
* @param {Buffer} arg_buf The buffer to deserialize |
||||
* @return {cls} The resulting object |
||||
*/ |
||||
return function deserialize(arg_buf) { |
||||
// Convert to a native object with binary fields as Buffers (first argument)
|
||||
// and longs as strings (second argument)
|
||||
return cls.decode(arg_buf).toRaw(binaryAsBase64, longsAsStrings); |
||||
}; |
||||
}; |
||||
|
||||
var deserializeCls = exports.deserializeCls; |
||||
|
||||
/** |
||||
* Get a function that serializes objects to a buffer by protobuf class. |
||||
* @param {function()} Cls The constructor of the message type to serialize |
||||
* @return {function(Cls):Buffer} The serialization function |
||||
*/ |
||||
exports.serializeCls = function serializeCls(Cls) { |
||||
/** |
||||
* Serialize an object to a Buffer |
||||
* @param {Object} arg The object to serialize |
||||
* @return {Buffer} The serialized object |
||||
*/ |
||||
return function serialize(arg) { |
||||
return new Buffer(new Cls(arg).encode().toBuffer()); |
||||
}; |
||||
}; |
||||
|
||||
var serializeCls = exports.serializeCls; |
||||
|
||||
/** |
||||
* Get the fully qualified (dotted) name of a ProtoBuf.Reflect value. |
||||
* @param {ProtoBuf.Reflect.Namespace} value The value to get the name of |
||||
* @return {string} The fully qualified name of the value |
||||
*/ |
||||
exports.fullyQualifiedName = function fullyQualifiedName(value) { |
||||
if (value === null || value === undefined) { |
||||
return ''; |
||||
} |
||||
var name = value.name; |
||||
var parent_name = fullyQualifiedName(value.parent); |
||||
if (parent_name !== '') { |
||||
name = parent_name + '.' + name; |
||||
} |
||||
return name; |
||||
}; |
||||
|
||||
var fullyQualifiedName = exports.fullyQualifiedName; |
||||
|
||||
/** |
||||
* Return a map from method names to method attributes for the service. |
||||
* @param {ProtoBuf.Reflect.Service} service The service to get attributes for |
||||
* @param {Object=} options Options to apply to these attributes |
||||
* @return {Object} The attributes map |
||||
*/ |
||||
exports.getProtobufServiceAttrs = function getProtobufServiceAttrs(service, |
||||
options) { |
||||
var prefix = '/' + fullyQualifiedName(service) + '/'; |
||||
var binaryAsBase64, longsAsStrings; |
||||
if (options) { |
||||
binaryAsBase64 = options.binaryAsBase64; |
||||
longsAsStrings = options.longsAsStrings; |
||||
} |
||||
/* This slightly awkward construction is used to make sure we only use |
||||
lodash@3.10.1-compatible functions. A previous version used |
||||
_.fromPairs, which would be cleaner, but was introduced in lodash |
||||
version 4 */ |
||||
return _.zipObject(_.map(service.children, function(method) { |
||||
return _.camelCase(method.name); |
||||
}), _.map(service.children, function(method) { |
||||
return { |
||||
path: prefix + method.name, |
||||
requestStream: method.requestStream, |
||||
responseStream: method.responseStream, |
||||
requestType: method.resolvedRequestType, |
||||
responseType: method.resolvedResponseType, |
||||
requestSerialize: serializeCls(method.resolvedRequestType.build()), |
||||
requestDeserialize: deserializeCls(method.resolvedRequestType.build(), |
||||
binaryAsBase64, longsAsStrings), |
||||
responseSerialize: serializeCls(method.resolvedResponseType.build()), |
||||
responseDeserialize: deserializeCls(method.resolvedResponseType.build(), |
||||
binaryAsBase64, longsAsStrings) |
||||
}; |
||||
})); |
||||
}; |
||||
|
||||
var getProtobufServiceAttrs = exports.getProtobufServiceAttrs; |
||||
|
||||
/** |
||||
* Load a gRPC object from an existing ProtoBuf.Reflect object. |
||||
* @param {ProtoBuf.Reflect.Namespace} value The ProtoBuf object to load. |
||||
* @param {Object=} options Options to apply to the loaded object |
||||
* @return {Object<string, *>} The resulting gRPC object |
||||
*/ |
||||
exports.loadObject = function loadObject(value, options) { |
||||
var result = {}; |
||||
if (!value) { |
||||
return value; |
||||
} |
||||
if (value.hasOwnProperty('ns')) { |
||||
return loadObject(value.ns, options); |
||||
} |
||||
if (value.className === 'Namespace') { |
||||
_.each(value.children, function(child) { |
||||
result[child.name] = loadObject(child, options); |
||||
}); |
||||
return result; |
||||
} else if (value.className === 'Service') { |
||||
return client.makeClientConstructor(getProtobufServiceAttrs(value, options), |
||||
options); |
||||
} else if (value.className === 'Message' || value.className === 'Enum') { |
||||
return value.build(); |
||||
} else { |
||||
return value; |
||||
} |
||||
}; |
||||
@ -0,0 +1,154 @@ |
||||
/* |
||||
* |
||||
* Copyright 2017, Google Inc. |
||||
* All rights reserved. |
||||
* |
||||
* Redistribution and use in source and binary forms, with or without |
||||
* modification, are permitted provided that the following conditions are |
||||
* met: |
||||
* |
||||
* * Redistributions of source code must retain the above copyright |
||||
* notice, this list of conditions and the following disclaimer. |
||||
* * Redistributions in binary form must reproduce the above |
||||
* copyright notice, this list of conditions and the following disclaimer |
||||
* in the documentation and/or other materials provided with the |
||||
* distribution. |
||||
* * Neither the name of Google Inc. nor the names of its |
||||
* contributors may be used to endorse or promote products derived from |
||||
* this software without specific prior written permission. |
||||
* |
||||
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
||||
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
||||
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
||||
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
||||
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
||||
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
||||
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
||||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
||||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
||||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
||||
* |
||||
*/ |
||||
|
||||
'use strict'; |
||||
|
||||
var _ = require('lodash'); |
||||
var client = require('./client'); |
||||
|
||||
/** |
||||
* Get a function that deserializes a specific type of protobuf. |
||||
* @param {function()} cls The constructor of the message type to deserialize |
||||
* @param {bool=} binaryAsBase64 Deserialize bytes fields as base64 strings |
||||
* instead of Buffers. Defaults to false |
||||
* @param {bool=} longsAsStrings Deserialize long values as strings instead of |
||||
* objects. Defaults to true |
||||
* @return {function(Buffer):cls} The deserialization function |
||||
*/ |
||||
exports.deserializeCls = function deserializeCls(cls, options) { |
||||
var conversion_options = { |
||||
defaults: true, |
||||
bytes: options.binaryAsBase64 ? String : Buffer, |
||||
longs: options.longsAsStrings ? String : null, |
||||
enums: String |
||||
}; |
||||
/** |
||||
* Deserialize a buffer to a message object |
||||
* @param {Buffer} arg_buf The buffer to deserialize |
||||
* @return {cls} The resulting object |
||||
*/ |
||||
return function deserialize(arg_buf) { |
||||
return cls.decode(arg_buf).toObject(conversion_options); |
||||
}; |
||||
}; |
||||
|
||||
var deserializeCls = exports.deserializeCls; |
||||
|
||||
/** |
||||
* Get a function that serializes objects to a buffer by protobuf class. |
||||
* @param {function()} Cls The constructor of the message type to serialize |
||||
* @return {function(Cls):Buffer} The serialization function |
||||
*/ |
||||
exports.serializeCls = function serializeCls(cls) { |
||||
/** |
||||
* Serialize an object to a Buffer |
||||
* @param {Object} arg The object to serialize |
||||
* @return {Buffer} The serialized object |
||||
*/ |
||||
return function serialize(arg) { |
||||
return cls.encode(arg).finish(); |
||||
}; |
||||
}; |
||||
|
||||
var serializeCls = exports.serializeCls; |
||||
|
||||
/** |
||||
* Get the fully qualified (dotted) name of a ProtoBuf.Reflect value. |
||||
* @param {ProtoBuf.ReflectionObject} value The value to get the name of |
||||
* @return {string} The fully qualified name of the value |
||||
*/ |
||||
exports.fullyQualifiedName = function fullyQualifiedName(value) { |
||||
if (value === null || value === undefined) { |
||||
return ''; |
||||
} |
||||
var name = value.name; |
||||
var parent_fqn = fullyQualifiedName(value.parent); |
||||
if (parent_fqn !== '') { |
||||
name = parent_fqn + '.' + name; |
||||
} |
||||
return name; |
||||
}; |
||||
|
||||
var fullyQualifiedName = exports.fullyQualifiedName; |
||||
|
||||
/** |
||||
* Return a map from method names to method attributes for the service. |
||||
* @param {ProtoBuf.Service} service The service to get attributes for |
||||
* @param {Object=} options Options to apply to these attributes |
||||
* @return {Object} The attributes map |
||||
*/ |
||||
exports.getProtobufServiceAttrs = function getProtobufServiceAttrs(service, |
||||
options) { |
||||
var prefix = '/' + fullyQualifiedName(service) + '/'; |
||||
service.resolveAll(); |
||||
return _.zipObject(_.map(service.methods, function(method) { |
||||
return _.camelCase(method.name); |
||||
}), _.map(service.methods, function(method) { |
||||
return { |
||||
path: prefix + method.name, |
||||
requestStream: !!method.requestStream, |
||||
responseStream: !!method.responseStream, |
||||
requestType: method.resolvedRequestType, |
||||
responseType: method.resolvedResponseType, |
||||
requestSerialize: serializeCls(method.resolvedRequestType), |
||||
requestDeserialize: deserializeCls(method.resolvedRequestType, options), |
||||
responseSerialize: serializeCls(method.resolvedResponseType), |
||||
responseDeserialize: deserializeCls(method.resolvedResponseType, options) |
||||
}; |
||||
})); |
||||
}; |
||||
|
||||
var getProtobufServiceAttrs = exports.getProtobufServiceAttrs; |
||||
|
||||
exports.loadObject = function loadObject(value, options) { |
||||
var result = {}; |
||||
if (!value) { |
||||
return value; |
||||
} |
||||
if (value.hasOwnProperty('methods')) { |
||||
// It's a service object
|
||||
var service_attrs = getProtobufServiceAttrs(value, options); |
||||
return client.makeClientConstructor(service_attrs); |
||||
} |
||||
|
||||
if (value.hasOwnProperty('nested')) { |
||||
// It's a namespace or root object
|
||||
_.each(value.nested, function(nested, name) { |
||||
result[name] = loadObject(nested, options); |
||||
}); |
||||
return result; |
||||
} |
||||
|
||||
// Otherwise, it's not something we need to change
|
||||
return value; |
||||
}; |
||||
Loading…
Reference in new issue