Initial work on allowing ports to decline new connections, refs #74

build/dataflow.build.js

@@ -1,4 +1,4 @@
-/*! dataflow.js - v0.0.7 - 2013-10-02 (5:27:30 PM GMT+0200)
+/*! dataflow.js - v0.0.7 - 2013-10-02 (6:20:43 PM GMT+0200)
 * Copyright (c) 2013 Forrest Oliphant; Licensed MIT, GPL */
 // Thanks bobnice http://stackoverflow.com/a/1583281/592125
 
@@ -710,7 +710,8 @@ CircularBuffer.IndexError= {};
       id: "input",
       description: "",
       label: "",
-      type: "all"
+      type: "all",
+      multiple: true
     },
     initialize: function() {
       this.parentNode = this.get("parentNode");
@@ -719,7 +720,18 @@ CircularBuffer.IndexError= {};
       }
       this.connected = [];
     },
+    canConnect: function (edge) {
+      if (!this.get('multiple') && this.connected.length) {
+        // This port doesn't allow multiple connections and
+        // there is a connection already, decline
+        return false;
+      }
+      return true;
+    },
     connect: function(edge){
+      if (!this.canConnect(edge)) {
+        return;
+      }
       this.connected.push(edge);
       this.connected = _.uniq(this.connected);
       this.trigger('connected');
@@ -757,7 +769,8 @@ CircularBuffer.IndexError= {};
       id: "output",
       label: "",
       type: "all",
-      description: ""
+      description: "",
+      multiple: true
     }
   });
 
@@ -1924,6 +1937,11 @@ CircularBuffer.IndexError= {};
         return false;
       }
 
+      if (!this.model.canConnect()) {
+        // Port declined the connection, abort
+        return;
+      }
+
       var route = 0;
       if (ui.helper.data("route") !== undefined) {
         route = ui.helper.data("route");
@@ -2226,6 +2244,11 @@ CircularBuffer.IndexError= {};
         return false;
       }
 
+      if (!this.model.canConnect()) {
+        // Port declined the connection, abort
+        return;
+      }
+
       var route = 0;
       if (ui.helper.data("route") !== undefined) {
         route = ui.helper.data("route");

debug.html

@@ -113,6 +113,8 @@
           data: 'random'
         });
       }, 500);
+      // Set one port to decline multiple connections
+      dataflow.graph.get('nodes').at(2).inputs.at(1).set('multiple', false);
 
       window.d = $(".dataflow").data("dataflow");
   });

src/modules/input-view.js

@@ -389,6 +389,11 @@
         return false;
       }
 
+      if (!this.model.canConnect()) {
+        // Port declined the connection, abort
+        return;
+      }
+
       var route = 0;
       if (ui.helper.data("route") !== undefined) {
         route = ui.helper.data("route");

src/modules/input.js

@@ -7,7 +7,8 @@
       id: "input",
       description: "",
       label: "",
-      type: "all"
+      type: "all",
+      multiple: true
     },
     initialize: function() {
       this.parentNode = this.get("parentNode");
@@ -16,7 +17,18 @@
       }
       this.connected = [];
     },
+    canConnect: function (edge) {
+      if (!this.get('multiple') && this.connected.length) {
+        // This port doesn't allow multiple connections and
+        // there is a connection already, decline
+        return false;
+      }
+      return true;
+    },
     connect: function(edge){
+      if (!this.canConnect(edge)) {
+        return;
+      }
       this.connected.push(edge);
       this.connected = _.uniq(this.connected);
       this.trigger('connected');

src/modules/output-view.js

@@ -214,6 +214,11 @@
         return false;
       }
 
+      if (!this.model.canConnect()) {
+        // Port declined the connection, abort
+        return;
+      }
+
       var route = 0;
       if (ui.helper.data("route") !== undefined) {
         route = ui.helper.data("route");

src/modules/output.js

@@ -9,7 +9,8 @@
       id: "output",
       label: "",
       type: "all",
-      description: ""
+      description: "",
+      multiple: true
     }
   });