grpc
/
grpc-node
mirror of https://github.com/grpc/grpc-node.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

grpc-js: all client interceptors tests pass with minor modifications

This commit is contained in:
murgatroid99 2019-11-14 15:09:51 -08:00
parent f963c5e8cc
commit 0c61981ffc
1 changed files with 9 additions and 95 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
test/api/client_interceptors_test.js
View File

@ -93,7 +93,7 @@ CallRegistry.prototype.maybeCallDone = function() {
} }
}; };
describe.only(`${anyGrpc.clientName} client -> ${anyGrpc.serverName} server`, function() { describe(`${anyGrpc.clientName} client -> ${anyGrpc.serverName} server`, function() {
describe('Client interceptors', function() { describe('Client interceptors', function() {
var echo_server; var echo_server;
var echo_port; var echo_port;
@ -996,12 +996,16 @@ describe.only(`${anyGrpc.clientName} client -> ${anyGrpc.serverName} server`, fu
}); });
}); });
it.skip('will reject conflicting interceptor options at invocation', it('will reject conflicting interceptor options at invocation',
function(done) { function(done) {
const interceptor = (options, nextCall) => {
new InterceptingCall(nextCall(options));
};
const interceptorProvider = methodDefinition => interceptor
try { try {
client.echo('message', { client.echo('message', {
interceptors: [], interceptors: [interceptor],
interceptor_providers: [] interceptor_providers: [interceptorProvider]
}, function () {}); }, function () {});
} catch (e) { } catch (e) {
assert.equal(e.name, 'InterceptorConfigurationError'); assert.equal(e.name, 'InterceptorConfigurationError');
@ -1379,7 +1383,7 @@ describe.only(`${anyGrpc.clientName} client -> ${anyGrpc.serverName} server`, fu
}); });
}); });
it('with client streaming call', function(done) { it('with client streaming call', function(done) {
registry = new CallRegistry(done, expected_calls, true, true); registry = new CallRegistry(done, expected_calls, true);
var message = {value: originalValue}; var message = {value: originalValue};
var client_stream = client.echoClientStream(metadata, options, var client_stream = client.echoClientStream(metadata, options,
function (err, response) { function (err, response) {
@ -1817,95 +1821,5 @@ describe.only(`${anyGrpc.clientName} client -> ${anyGrpc.serverName} server`, fu
bidi_stream.end(); bidi_stream.end();
}); });
}); });
describe.skip('order of operations enforced for async interceptors', function() {
it('with unary call', function(done) {
var expected_calls = [
'close_b',
'message_b',
'start_b',
'done'
];
var registry = new CallRegistry(done, expected_calls, true);
var message = {value: 'foo'};
var interceptor_a = function(options, nextCall) {
return new InterceptingCall(nextCall(options), {
start: function(metadata, listener, next) {
setTimeout(function() { next(metadata, listener); }, 50);
},
sendMessage: function(message, next) {
setTimeout(function () { next(message); }, 10);
}
});
};
var interceptor_b = function(options, nextCall) {
return new InterceptingCall(nextCall(options), {
start: function(metadata, listener, next) {
registry.addCall('start_b');
next(metadata, listener);
},
sendMessage: function(message, next) {
registry.addCall('message_b');
next(message);
},
halfClose: function(next) {
registry.addCall('close_b');
next();
}
});
};
var options = {
interceptors: [interceptor_a, interceptor_b]
};
client.echo(message, options, function(err, response) {
assert.strictEqual(err, null);
registry.addCall('done');
});
});
it('with serverStreaming call', function(done) {
var expected_calls = [
'close_b',
'message_b',
'start_b',
'done'
];
var registry = new CallRegistry(done, expected_calls, true);
var message = {value: 'foo'};
var interceptor_a = function(options, nextCall) {
return new InterceptingCall(nextCall(options), {
start: function(metadata, listener, next) {
setTimeout(function() { next(metadata, listener); }, 50);
},
sendMessage: function(message, next) {
setTimeout(function () { next(message); }, 10);
}
});
};
var interceptor_b = function(options, nextCall) {
return new InterceptingCall(nextCall(options), {
start: function(metadata, listener, next) {
registry.addCall('start_b');
next(metadata, listener);
},
sendMessage: function(message, next) {
registry.addCall('message_b');
next(message);
},
halfClose: function(next) {
registry.addCall('close_b');
next();
}
});
};
var options = {
interceptors: [interceptor_a, interceptor_b]
};
var stream = client.echoServerStream(message, options);
stream.on('data', function(response) {
assert.strictEqual(response.value, 'foo');
registry.addCall('done');
});
});
});
}); });
}); });