Changed object keys to valid identifier names

pull/2630/head
murgatroid99 10 years ago
parent 6a7418cd20
commit a627d8939d
  1. 8
      src/node/ext/call.cc
  2. 2
      src/node/ext/server.cc
  3. 2
      src/node/src/server.js
  4. 4
      src/node/test/call_test.js
  5. 110
      src/node/test/end_to_end_test.js

@ -192,7 +192,7 @@ class SendMetadataOp : public Op {
} }
protected: protected:
std::string GetTypeString() const { std::string GetTypeString() const {
return "send metadata"; return "send_metadata";
} }
}; };
@ -216,7 +216,7 @@ class SendMessageOp : public Op {
} }
protected: protected:
std::string GetTypeString() const { std::string GetTypeString() const {
return "send message"; return "send_message";
} }
}; };
@ -232,7 +232,7 @@ class SendClientCloseOp : public Op {
} }
protected: protected:
std::string GetTypeString() const { std::string GetTypeString() const {
return "client close"; return "client_close";
} }
}; };
@ -276,7 +276,7 @@ class SendServerStatusOp : public Op {
} }
protected: protected:
std::string GetTypeString() const { std::string GetTypeString() const {
return "send status"; return "send_status";
} }
}; };

@ -108,7 +108,7 @@ class NewCallOp : public Op {
protected: protected:
std::string GetTypeString() const { std::string GetTypeString() const {
return "new call"; return "new_call";
} }
}; };

@ -544,7 +544,7 @@ function Server(options) {
if (err) { if (err) {
return; return;
} }
var details = event['new call']; var details = event.new_call;
var call = details.call; var call = details.call;
var method = details.method; var method = details.method;
var metadata = details.metadata; var metadata = details.metadata;

@ -132,7 +132,7 @@ describe('call', function() {
'key2': ['value2']}; 'key2': ['value2']};
call.startBatch(batch, function(err, resp) { call.startBatch(batch, function(err, resp) {
assert.ifError(err); assert.ifError(err);
assert.deepEqual(resp, {'send metadata': true}); assert.deepEqual(resp, {'send_metadata': true});
done(); done();
}); });
}); });
@ -147,7 +147,7 @@ describe('call', function() {
}; };
call.startBatch(batch, function(err, resp) { call.startBatch(batch, function(err, resp) {
assert.ifError(err); assert.ifError(err);
assert.deepEqual(resp, {'send metadata': true}); assert.deepEqual(resp, {'send_metadata': true});
done(); done();
}); });
}); });

@ -85,37 +85,37 @@ describe('end-to-end', function() {
call.startBatch(client_batch, function(err, response) { call.startBatch(client_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert.deepEqual(response, { assert.deepEqual(response, {
'send metadata': true, send_metadata: true,
'client close': true, client_close: true,
'metadata': {}, metadata: {},
'status': { status: {
'code': grpc.status.OK, code: grpc.status.OK,
'details': status_text, details: status_text,
'metadata': {} metadata: {}
} }
}); });
done(); done();
}); });
server.requestCall(function(err, call_details) { server.requestCall(function(err, call_details) {
var new_call = call_details['new call']; var new_call = call_details.new_call;
assert.notEqual(new_call, null); assert.notEqual(new_call, null);
var server_call = new_call.call; var server_call = new_call.call;
assert.notEqual(server_call, null); assert.notEqual(server_call, null);
var server_batch = {}; var server_batch = {};
server_batch[grpc.opType.SEND_INITIAL_METADATA] = {}; server_batch[grpc.opType.SEND_INITIAL_METADATA] = {};
server_batch[grpc.opType.SEND_STATUS_FROM_SERVER] = { server_batch[grpc.opType.SEND_STATUS_FROM_SERVER] = {
'metadata': {}, metadata: {},
'code': grpc.status.OK, code: grpc.status.OK,
'details': status_text details: status_text
}; };
server_batch[grpc.opType.RECV_CLOSE_ON_SERVER] = true; server_batch[grpc.opType.RECV_CLOSE_ON_SERVER] = true;
server_call.startBatch(server_batch, function(err, response) { server_call.startBatch(server_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert.deepEqual(response, { assert.deepEqual(response, {
'send metadata': true, send_metadata: true,
'send status': true, send_status: true,
'cancelled': false cancelled: false
}); });
done(); done();
}); });
@ -131,7 +131,7 @@ describe('end-to-end', function() {
Infinity); Infinity);
var client_batch = {}; var client_batch = {};
client_batch[grpc.opType.SEND_INITIAL_METADATA] = { client_batch[grpc.opType.SEND_INITIAL_METADATA] = {
'client_key': ['client_value'] client_key: ['client_value']
}; };
client_batch[grpc.opType.SEND_CLOSE_FROM_CLIENT] = true; client_batch[grpc.opType.SEND_CLOSE_FROM_CLIENT] = true;
client_batch[grpc.opType.RECV_INITIAL_METADATA] = true; client_batch[grpc.opType.RECV_INITIAL_METADATA] = true;
@ -139,18 +139,18 @@ describe('end-to-end', function() {
call.startBatch(client_batch, function(err, response) { call.startBatch(client_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert.deepEqual(response,{ assert.deepEqual(response,{
'send metadata': true, send_metadata: true,
'client close': true, client_close: true,
metadata: {server_key: ['server_value']}, metadata: {server_key: ['server_value']},
status: {'code': grpc.status.OK, status: {code: grpc.status.OK,
'details': status_text, details: status_text,
'metadata': {}} metadata: {}}
}); });
done(); done();
}); });
server.requestCall(function(err, call_details) { server.requestCall(function(err, call_details) {
var new_call = call_details['new call']; var new_call = call_details.new_call;
assert.notEqual(new_call, null); assert.notEqual(new_call, null);
assert.strictEqual(new_call.metadata.client_key[0], assert.strictEqual(new_call.metadata.client_key[0],
'client_value'); 'client_value');
@ -158,20 +158,20 @@ describe('end-to-end', function() {
assert.notEqual(server_call, null); assert.notEqual(server_call, null);
var server_batch = {}; var server_batch = {};
server_batch[grpc.opType.SEND_INITIAL_METADATA] = { server_batch[grpc.opType.SEND_INITIAL_METADATA] = {
'server_key': ['server_value'] server_key: ['server_value']
}; };
server_batch[grpc.opType.SEND_STATUS_FROM_SERVER] = { server_batch[grpc.opType.SEND_STATUS_FROM_SERVER] = {
'metadata': {}, metadata: {},
'code': grpc.status.OK, code: grpc.status.OK,
'details': status_text details: status_text
}; };
server_batch[grpc.opType.RECV_CLOSE_ON_SERVER] = true; server_batch[grpc.opType.RECV_CLOSE_ON_SERVER] = true;
server_call.startBatch(server_batch, function(err, response) { server_call.startBatch(server_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert.deepEqual(response, { assert.deepEqual(response, {
'send metadata': true, send_metadata: true,
'send status': true, send_status: true,
'cancelled': false cancelled: false
}); });
done(); done();
}); });
@ -196,19 +196,19 @@ describe('end-to-end', function() {
client_batch[grpc.opType.RECV_STATUS_ON_CLIENT] = true; client_batch[grpc.opType.RECV_STATUS_ON_CLIENT] = true;
call.startBatch(client_batch, function(err, response) { call.startBatch(client_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert(response['send metadata']); assert(response.send_metadata);
assert(response['client close']); assert(response.client_close);
assert.deepEqual(response.metadata, {}); assert.deepEqual(response.metadata, {});
assert(response['send message']); assert(response.send_message);
assert.strictEqual(response.read.toString(), reply_text); assert.strictEqual(response.read.toString(), reply_text);
assert.deepEqual(response.status, {'code': grpc.status.OK, assert.deepEqual(response.status, {code: grpc.status.OK,
'details': status_text, details: status_text,
'metadata': {}}); metadata: {}});
done(); done();
}); });
server.requestCall(function(err, call_details) { server.requestCall(function(err, call_details) {
var new_call = call_details['new call']; var new_call = call_details.new_call;
assert.notEqual(new_call, null); assert.notEqual(new_call, null);
var server_call = new_call.call; var server_call = new_call.call;
assert.notEqual(server_call, null); assert.notEqual(server_call, null);
@ -217,18 +217,18 @@ describe('end-to-end', function() {
server_batch[grpc.opType.RECV_MESSAGE] = true; server_batch[grpc.opType.RECV_MESSAGE] = true;
server_call.startBatch(server_batch, function(err, response) { server_call.startBatch(server_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert(response['send metadata']); assert(response.send_metadata);
assert.strictEqual(response.read.toString(), req_text); assert.strictEqual(response.read.toString(), req_text);
var response_batch = {}; var response_batch = {};
response_batch[grpc.opType.SEND_MESSAGE] = new Buffer(reply_text); response_batch[grpc.opType.SEND_MESSAGE] = new Buffer(reply_text);
response_batch[grpc.opType.SEND_STATUS_FROM_SERVER] = { response_batch[grpc.opType.SEND_STATUS_FROM_SERVER] = {
'metadata': {}, metadata: {},
'code': grpc.status.OK, code: grpc.status.OK,
'details': status_text details: status_text
}; };
response_batch[grpc.opType.RECV_CLOSE_ON_SERVER] = true; response_batch[grpc.opType.RECV_CLOSE_ON_SERVER] = true;
server_call.startBatch(response_batch, function(err, response) { server_call.startBatch(response_batch, function(err, response) {
assert(response['send status']); assert(response.send_status);
assert(!response.cancelled); assert(!response.cancelled);
done(); done();
}); });
@ -251,9 +251,9 @@ describe('end-to-end', function() {
call.startBatch(client_batch, function(err, response) { call.startBatch(client_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert.deepEqual(response, { assert.deepEqual(response, {
'send metadata': true, send_metadata: true,
'send message': true, send_message: true,
'metadata': {} metadata: {}
}); });
var req2_batch = {}; var req2_batch = {};
req2_batch[grpc.opType.SEND_MESSAGE] = new Buffer(requests[1]); req2_batch[grpc.opType.SEND_MESSAGE] = new Buffer(requests[1]);
@ -262,12 +262,12 @@ describe('end-to-end', function() {
call.startBatch(req2_batch, function(err, resp) { call.startBatch(req2_batch, function(err, resp) {
assert.ifError(err); assert.ifError(err);
assert.deepEqual(resp, { assert.deepEqual(resp, {
'send message': true, send_message: true,
'client close': true, client_close: true,
'status': { status: {
'code': grpc.status.OK, code: grpc.status.OK,
'details': status_text, details: status_text,
'metadata': {} metadata: {}
} }
}); });
done(); done();
@ -275,7 +275,7 @@ describe('end-to-end', function() {
}); });
server.requestCall(function(err, call_details) { server.requestCall(function(err, call_details) {
var new_call = call_details['new call']; var new_call = call_details.new_call;
assert.notEqual(new_call, null); assert.notEqual(new_call, null);
var server_call = new_call.call; var server_call = new_call.call;
assert.notEqual(server_call, null); assert.notEqual(server_call, null);
@ -284,7 +284,7 @@ describe('end-to-end', function() {
server_batch[grpc.opType.RECV_MESSAGE] = true; server_batch[grpc.opType.RECV_MESSAGE] = true;
server_call.startBatch(server_batch, function(err, response) { server_call.startBatch(server_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert(response['send metadata']); assert(response.send_metadata);
assert.strictEqual(response.read.toString(), requests[0]); assert.strictEqual(response.read.toString(), requests[0]);
var snd_batch = {}; var snd_batch = {};
snd_batch[grpc.opType.RECV_MESSAGE] = true; snd_batch[grpc.opType.RECV_MESSAGE] = true;
@ -294,13 +294,13 @@ describe('end-to-end', function() {
var end_batch = {}; var end_batch = {};
end_batch[grpc.opType.RECV_CLOSE_ON_SERVER] = true; end_batch[grpc.opType.RECV_CLOSE_ON_SERVER] = true;
end_batch[grpc.opType.SEND_STATUS_FROM_SERVER] = { end_batch[grpc.opType.SEND_STATUS_FROM_SERVER] = {
'metadata': {}, metadata: {},
'code': grpc.status.OK, code: grpc.status.OK,
'details': status_text details: status_text
}; };
server_call.startBatch(end_batch, function(err, response) { server_call.startBatch(end_batch, function(err, response) {
assert.ifError(err); assert.ifError(err);
assert(response['send status']); assert(response.send_status);
assert(!response.cancelled); assert(!response.cancelled);
done(); done();
}); });

Loading…
Cancel
Save