nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mcgil...@apache.org
Subject incubator-nifi git commit: NIFI-258: - Ensuring connection stays up to date when processor configuration changes.
Date Tue, 13 Jan 2015 21:00:07 GMT
Repository: incubator-nifi
Updated Branches:
  refs/heads/develop b142d7a9b -> 80793ccbb


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/develop
Commit: 80793ccbb829e079ef8cc2fe703bad6397a71d48
Parents: b142d7a
Author: Matt Gilman <matt.c.gilman@gmail.com>
Authored: Tue Jan 13 15:54:21 2015 -0500
Committer: Matt Gilman <matt.c.gilman@gmail.com>
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);
                                     });
                                 };
 


Mime
View raw message