|
@@ -172,9 +172,9 @@ func (s *FlowSession) Document(c *websocket.Conn) error {
|
|
|
return c.WriteJSON(flowmsg.SendMessage{OP: "document", Data: json.RawMessage(s.RawDoc)})
|
|
|
}
|
|
|
|
|
|
-// NodeRun a node triggering results
|
|
|
+// NodeProcess a node triggering results
|
|
|
// Build a flow and run
|
|
|
-func (s *FlowSession) NodeRun(c *websocket.Conn, data []byte) error {
|
|
|
+func (s *FlowSession) NodeProcess(c *websocket.Conn, data []byte) error {
|
|
|
ID := string(data[1 : len(data)-1]) // remove " instead of unmarshalling json
|
|
|
if s.flow != nil {
|
|
|
s.Notify("a node is already running")
|
|
@@ -276,6 +276,7 @@ func (s *FlowSession) NodeRun(c *websocket.Conn, data []byte) error {
|
|
|
return err
|
|
|
}
|
|
|
log.Println("Operation finish")
|
|
|
+ log.Println("Flow now:", s.flow)
|
|
|
return nil
|
|
|
}
|
|
|
|