aboutsummaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorGravatar murgatroid99 <mlumish@google.com>2015-07-29 10:11:07 -0700
committerGravatar murgatroid99 <mlumish@google.com>2015-07-29 10:11:07 -0700
commit440ed0318ec0118411c1288b293cf2593cb37d4f (patch)
tree18aa55c504bb64bc286d9927f328ed09a6a6c945
parent6f34bad568e6db5f78a908fa63bd08a1304366fa (diff)
Revert "Ensure that client generated methods don't conflict with other properties"
-rw-r--r--src/node/src/client.js27
-rw-r--r--src/node/test/surface_test.js20
2 files changed, 13 insertions, 34 deletions
diff --git a/src/node/src/client.js b/src/node/src/client.js
index 405e2be693..f843669bd0 100644
--- a/src/node/src/client.js
+++ b/src/node/src/client.js
@@ -236,7 +236,7 @@ function makeUnaryRequestFunction(method, serialize, deserialize) {
deadline = Infinity;
}
var emitter = new EventEmitter();
- var call = new grpc.Call(this.$channel, method, deadline);
+ var call = new grpc.Call(this.channel, method, deadline);
if (metadata === null || metadata === undefined) {
metadata = {};
}
@@ -246,7 +246,7 @@ function makeUnaryRequestFunction(method, serialize, deserialize) {
emitter.getPeer = function getPeer() {
return call.getPeer();
};
- this.$updateMetadata(this.$auth_uri, metadata, function(error, metadata) {
+ this.updateMetadata(this.auth_uri, metadata, function(error, metadata) {
if (error) {
call.cancel();
callback(error);
@@ -309,12 +309,12 @@ function makeClientStreamRequestFunction(method, serialize, deserialize) {
if (deadline === undefined) {
deadline = Infinity;
}
- var call = new grpc.Call(this.$channel, method, deadline);
+ var call = new grpc.Call(this.channel, method, deadline);
if (metadata === null || metadata === undefined) {
metadata = {};
}
var stream = new ClientWritableStream(call, serialize);
- this.$updateMetadata(this.$auth_uri, metadata, function(error, metadata) {
+ this.updateMetadata(this.auth_uri, metadata, function(error, metadata) {
if (error) {
call.cancel();
callback(error);
@@ -383,12 +383,12 @@ function makeServerStreamRequestFunction(method, serialize, deserialize) {
if (deadline === undefined) {
deadline = Infinity;
}
- var call = new grpc.Call(this.$channel, method, deadline);
+ var call = new grpc.Call(this.channel, method, deadline);
if (metadata === null || metadata === undefined) {
metadata = {};
}
var stream = new ClientReadableStream(call, deserialize);
- this.$updateMetadata(this.$auth_uri, metadata, function(error, metadata) {
+ this.updateMetadata(this.auth_uri, metadata, function(error, metadata) {
if (error) {
call.cancel();
stream.emit('error', error);
@@ -455,12 +455,12 @@ function makeBidiStreamRequestFunction(method, serialize, deserialize) {
if (deadline === undefined) {
deadline = Infinity;
}
- var call = new grpc.Call(this.$channel, method, deadline);
+ var call = new grpc.Call(this.channel, method, deadline);
if (metadata === null || metadata === undefined) {
metadata = {};
}
var stream = new ClientDuplexStream(call, serialize, deserialize);
- this.$updateMetadata(this.$auth_uri, metadata, function(error, metadata) {
+ this.updateMetadata(this.auth_uri, metadata, function(error, metadata) {
if (error) {
call.cancel();
stream.emit('error', error);
@@ -545,17 +545,14 @@ exports.makeClientConstructor = function(methods, serviceName) {
options = {};
}
options['grpc.primary_user_agent'] = 'grpc-node/' + version;
- this.$channel = new grpc.Channel(address, options);
- this.$server_address = address.replace(/\/$/, '');
- this.$auth_uri = this.$server_address + '/' + serviceName;
- this.$updateMetadata = updateMetadata;
+ this.channel = new grpc.Channel(address, options);
+ this.server_address = address.replace(/\/$/, '');
+ this.auth_uri = this.server_address + '/' + serviceName;
+ this.updateMetadata = updateMetadata;
}
_.each(methods, function(attrs, name) {
var method_type;
- if (_.startsWith(name, '$')) {
- throw new Error('Method names cannot start with $');
- }
if (attrs.requestStream) {
if (attrs.responseStream) {
method_type = 'bidi';
diff --git a/src/node/test/surface_test.js b/src/node/test/surface_test.js
index 1afdb33089..98f9b15bfc 100644
--- a/src/node/test/surface_test.js
+++ b/src/node/test/surface_test.js
@@ -110,24 +110,6 @@ describe('Server.prototype.addProtoService', function() {
});
});
});
-describe('Client constructor building', function() {
- var illegal_service_attrs = {
- $method : {
- path: '/illegal/$method',
- requestStream: false,
- responseStream: false,
- requestSerialize: _.identity,
- requestDeserialize: _.identity,
- responseSerialize: _.identity,
- responseDeserialize: _.identity
- }
- };
- it('Should reject method names starting with $', function() {
- assert.throws(function() {
- grpc.makeGenericClientConstructor(illegal_service_attrs);
- }, /\$/);
- });
-});
describe('Echo service', function() {
var server;
var client;
@@ -362,7 +344,7 @@ describe('Other conditions', function() {
server.shutdown();
});
it('channel.getTarget should be available', function() {
- assert.strictEqual(typeof client.$channel.getTarget(), 'string');
+ assert.strictEqual(typeof client.channel.getTarget(), 'string');
});
describe('Server recieving bad input', function() {
var misbehavingClient;