Teste um componente do Flow isoladamente com Flow.test()
Flow.test(name, source, [config], [init]) constrói um fluxo com um componente (o source é o seu código, como na receita de FlowStream, e config substitui a sua configuração) e um componente fictício que recolhe as suas saídas. init(test) é chamado quando o fluxo está pronto, com o objeto test:
test.send(inputid, data)(tambémtest.input) envia uma mensagem para uma entrada do componente e devolve-a.test.message = function($, data): chamado com cada mensagem que o componente envia para qualquer uma das suas saídas;$é a mensagem edataos seus dados.test.reconfigure(config)altera a configuração;test.configure = function(config)é chamado depois.test.variables(object)define as variáveis do fluxo.test.assert(ok, message),test.ok(message)etest.fail(message)imprimem[OK]ou[NO]com a data, e uma falha lança uma exceção. As funções são propriedades normais: substituatest.oketest.failpara enviar o resultado para outro lado, como faz o exemplo.- O fluxo de teste tem sempre o id
test: apenas umFlow.test()de cada vez.
Destina-se aos testes de um componente escrito para um Flow, executados com node index.js numa pequena aplicação própria.
MAIN.results = [];
const source = `<script total>
exports.id = 'tax';
exports.name = 'Tax';
exports.inputs = [{ id: 'input', name: 'Input' }];
exports.outputs = [{ id: 'output', name: 'Output' }];
exports.config = { rate: 21 };
exports.make = function(instance, config) {
instance.message = function($) {
$.send('output', { net: $.data, total: Math.round($.data * (100 + config.rate)) / 100 });
};
};
</script>`;
ON('ready', function() {
Flow.test('tax', source, { rate: 10 }, function(test) {
test.ok = message => MAIN.results.push('ok: ' + message);
test.fail = message => MAIN.results.push('no: ' + message);
test.message = function($, data) {
test.assert(data.net === 100, 'the net amount comes back');
test.assert(data.total === 110, 'the configuration of the test (10 %) is used, got ' + data.total);
MAIN.results.push('message: ' + JSON.stringify(data));
};
test.send('input', 100);
});
});exports.install = function() {
ROUTE('GET /results/', results);
};
function results($) {
$.json(MAIN.results);
}