Fix event handling in HTTP components so it doesn't leak

components/HTTP/BasicAuth.coffee

@@ -4,19 +4,21 @@
 connect = require "connect"
 
 outSocket = null
+inRequest = null
 
 authenticate = (login, password) ->
     login is "user" and password is "pass"
 
 exports.getInputs = ->
     in: (socket) ->
         socket.on "data", (request) ->
+            inRequest = request
             connect.basicAuth(authenticate) request.req, request.res, () ->
-                outSocket.on "connect", ->
-                    outSocket.send request
-                    outSocket.disconnect()
-
                 outSocket.connect()
 
 exports.getOutputs = ->
-    out: (socket) -> outSocket = socket
+    out: (socket) ->
+        outSocket = socket
+        socket.on "connect", ->
+            socket.send inRequest
+            socket.disconnect()

components/HTTP/Profiler.coffee

@@ -4,16 +4,18 @@
 connect = require "connect"
 
 outSocket = null
+inRequest = null
 
 exports.getInputs = ->
     in: (socket) ->
         socket.on "data", (request) ->
+            inRequest = request
             connect.profiler() request.req, request.res, () ->
-                outSocket.on "connect", ->
-                    outSocket.send request
-                    outSocket.disconnect()
-
                 outSocket.connect()
 
 exports.getOutputs = ->
-    out: (socket) -> outSocket = socket
+    out: (socket) ->
+        outSocket = socket
+        socket.on "connect", ->
+            socket.send inRequest
+            socket.disconnect()

components/HTTP/SendResponse.coffee

@@ -3,5 +3,8 @@
 
 exports.getInputs = ->
     in: (socket) ->
+        sendRequest = null
         socket.on "data", (request) ->
-            request.res.end()
+            sendRequest = request
+        socket.on "disconnect", (request) ->
+            sendRequest.res.end()

components/HTTP/WriteResponse.coffee

@@ -1,21 +1,24 @@
 # This component receives a request and a string on the input ports, writes
 # that string to the request's response and forwards the request
 
-outSocket = null
 string = ""
+inRequest = null
+outSocket = null
 
 exports.getInputs = ->
     string: (socket) ->
         socket.on "data", (data) ->
             string += data
     in: (socket) ->
         socket.on "data", (request) ->
-            request.res.write string
-            socket.on "disconnect", ->
-                outSocket.on "connect", ->
-                    outSocket.send request
-                    outSocket.disconnect()
-                outSocket.connect()
+            inRequest = request
+            inRequest.res.write string
+        socket.on "disconnect", ->
+            outSocket.connect()
 
 exports.getOutputs = ->
-    out: (socket) -> outSocket = socket
+    out: (socket) ->
+        outSocket = socket
+        socket.on "connect", ->
+            socket.send inRequest
+            socket.disconnect()

noflo.coffee

@@ -57,6 +57,15 @@ class NoFlo
     addEdge: (edge) ->
         socket = internalSocket.createSocket()
 
+        # logSocket = (message) ->
+        #     console.error "#{socket.connection} #{edge.from.node}:#{socket.from.port} -> #{edge.to.node}:#{socket.to.port} #{message}"
+        # socket.on "connect", ->
+        #     logSocket "CONN"
+        # socket.on "disconnect", ->
+        #     logSocket "DISC"
+        # socket.on "data", ->
+        #     logSocket "DATA"
+
         from = @getNode edge.from.node
         unless from
             throw new Error "No process defined for outbound node #{edge.from.node}"