NIFI-258: - Ensuring connection stays up to date when processor configuration changes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/80793ccb Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/80793ccb Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/80793ccb Branch: refs/heads/NIFI-250 Commit: 80793ccbb829e079ef8cc2fe703bad6397a71d48 Parents: b142d7a Author: Matt Gilman <[email protected]> Authored: Tue Jan 13 15:54:21 2015 -0500 Committer: Matt Gilman <[email protected]> Committed: Tue Jan 13 15:54:21 2015 -0500 ---------------------------------------------------------------------- .../js/nf/canvas/nf-processor-configuration.js | 23 +++++++++++++++++++- 1 file changed, 22 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/80793ccb/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js b/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js index 4dec734..14ffa95 100644 --- a/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js +++ b/nar-bundles/framework-bundle/framework/web/nifi-web-ui/src/main/webapp/js/nf/canvas/nf-processor-configuration.js @@ -363,6 +363,20 @@ nf.ProcessorConfiguration = (function () { return true; } }; + + /** + * Reloads the outgoing connections for the specified processor. + * + * @param {object} processor + */ + var reloadProcessorConnections = function (processor) { + var connections = nf.Connection.getComponentConnections(processor.id); + $.each(connections, function (_, connection) { + if (connection.source.id === processor.id) { + nf.Connection.reload(connection); + } + }); + }; return { /** @@ -601,8 +615,11 @@ nf.ProcessorConfiguration = (function () { // update the revision nf.Client.setRevision(response.revision); - // set the new processor state + // set the new processor state based on the response nf.Processor.set(response.processor); + + // reload the processor's outgoing connections + reloadProcessorConnections(processor); // close the details panel $('#processor-configuration').modal('hide'); @@ -632,7 +649,11 @@ nf.ProcessorConfiguration = (function () { // show the custom ui nf.CustomProcessorUi.showCustomUi($('#processor-id').text(), processor.config.customUiUrl, true).done(function () { + // once the custom ui is closed, reload the processor nf.Processor.reload(processor); + + // and reload the processor's outgoing connections + reloadProcessorConnections(processor); }); };
