add flow name to env

Author: Yang Guo

platform-api/src/main/java/com/flow/platform/api/envs/FlowEnvs.java

@@ -25,6 +25,8 @@
  */
 public enum FlowEnvs implements EnvKey {
 
+    FLOW_NAME(true, false, null),
+
     /**
      * Indicate flow is configured for git
      */

platform-api/src/main/java/com/flow/platform/api/service/node/NodeServiceImpl.java

@@ -206,6 +206,7 @@ public Node createEmptyFlow(final String flowName) {
         }
 
         // init env variables
+        flow.putEnv(FlowEnvs.FLOW_NAME, flowName);
         flow.putEnv(FlowEnvs.FLOW_STATUS, StatusValue.PENDING);
         flow.putEnv(FlowEnvs.FLOW_YML_STATUS, YmlStatusValue.NOT_FOUND);
         flow.putEnv(GitEnvs.FLOW_GIT_WEBHOOK, hooksUrl(flow));

platform-api/src/test/java/com/flow/platform/api/test/service/NodeServiceTest.java

@@ -194,7 +194,8 @@ public void should_save_node_env() throws Throwable {
         // then:
         String webhook = HttpURL.build(apiDomain).append("/hooks/git").append(emptyFlow.getName()).toString();
         Node loaded = nodeService.find("flow1").root();
-        Assert.assertEquals(15, loaded.getEnvs().size());
+        Assert.assertEquals(16, loaded.getEnvs().size());
+        Assert.assertEquals("flow1", loaded.getEnv(FlowEnvs.FLOW_NAME));
         Assert.assertEquals("hello", loaded.getEnv("FLOW_NEW_1"));
         Assert.assertEquals("world", loaded.getEnv("FLOW_NEW_2"));
         Assert.assertEquals("done", loaded.getEnv("FLOW_NEW_3"));
@@ -213,7 +214,7 @@ public void should_save_node_env() throws Throwable {
 
         // check env been sync with yml
         Node flow = flowDao.get("flow1");
-        Assert.assertEquals(15, flow.getEnvs().size());
+        Assert.assertEquals(16, flow.getEnvs().size());
         Assert.assertEquals("hello", flow.getEnv("FLOW_NEW_1"));
         Assert.assertEquals("world", flow.getEnv("FLOW_NEW_2"));
         Assert.assertEquals("done", flow.getEnv("FLOW_NEW_3"));