create flow group service

Author: gy2006

core/src/main/java/com/flowci/core/flow/dao/FlowGroupDao.java

@@ -4,6 +4,16 @@
 import org.springframework.data.mongodb.repository.MongoRepository;
 import org.springframework.stereotype.Repository;
 
+import java.util.Collection;
+import java.util.List;
+import java.util.Optional;
+
 @Repository
 public interface FlowGroupDao extends MongoRepository<FlowGroup, String> {
+
+    Optional<FlowGroup> findByName(String name);
+
+    List<FlowGroup> findAllByIdIn(Collection<String> id);
+
+    void deleteByName(String name);
 }

core/src/main/java/com/flowci/core/flow/dao/FlowItemDao.java

@@ -17,8 +17,10 @@
 package com.flowci.core.flow.domain;
 
 import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.flowci.core.common.domain.Mongoable;
 import com.flowci.core.common.domain.Variables;
 import com.flowci.domain.StringVars;
+import com.flowci.domain.TypedVars;
 import com.flowci.domain.VarValue;
 import com.flowci.domain.Vars;
 import com.flowci.exception.ArgumentException;
@@ -28,6 +30,7 @@
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.Setter;
+import org.springframework.data.mongodb.core.index.Indexed;
 import org.springframework.data.mongodb.core.mapping.Document;
 
 import java.util.Objects;
@@ -39,7 +42,7 @@
 @Setter
 @NoArgsConstructor
 @Document(collection = "flow")
-public final class Flow extends FlowItem implements Pathable {
+public final class Flow extends Mongoable implements Pathable {
 
     public static Pathable path(String id) {
         Flow flow = new Flow();
@@ -60,6 +63,11 @@ public enum Status {
         CONFIRMED
     }
 
+    @Indexed(name = "index_flow_name")
+    private String name;
+
+    private Vars<VarValue> vars = new TypedVars();
+
     private String groupId;
 
     private Status status = Status.PENDING;

core/src/main/java/com/flowci/core/flow/domain/Flow.java

@@ -1,13 +1,22 @@
 package com.flowci.core.flow.domain;
 
 
+import com.flowci.core.common.domain.Mongoable;
+import com.flowci.domain.TypedVars;
+import com.flowci.domain.VarValue;
+import com.flowci.domain.Vars;
 import lombok.Getter;
 import lombok.Setter;
+import org.springframework.data.mongodb.core.index.Indexed;
 import org.springframework.data.mongodb.core.mapping.Document;
 
 @Setter
 @Getter
 @Document(collection = "flow_group")
-public class FlowGroup extends FlowItem {
+public class FlowGroup extends Mongoable {
 
+    @Indexed(name = "index_group_name")
+    protected String name;
+
+    protected Vars<VarValue> vars = new TypedVars();
 }

core/src/main/java/com/flowci/core/flow/domain/FlowGroup.java

@@ -0,0 +1,17 @@
+package com.flowci.core.flow.service;
+
+import com.flowci.core.flow.domain.FlowGroup;
+
+import java.util.Collection;
+import java.util.List;
+
+public interface FlowGroupService {
+
+    FlowGroup get(String name);
+
+    List<FlowGroup> list(Collection<String> ids);
+
+    FlowGroup create(String name);
+
+    void delete(String name);
+}

core/src/main/java/com/flowci/core/flow/domain/FlowItem.java

@@ -0,0 +1,53 @@
+package com.flowci.core.flow.service;
+
+import com.flowci.core.flow.dao.FlowGroupDao;
+import com.flowci.core.flow.domain.FlowGroup;
+import com.flowci.exception.DuplicateException;
+import com.flowci.exception.NotFoundException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.DuplicateKeyException;
+import org.springframework.stereotype.Service;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Optional;
+
+@Service
+public class FlowGroupServiceImpl implements FlowGroupService {
+
+    private final FlowGroupDao flowGroupDao;
+
+    public FlowGroupServiceImpl(FlowGroupDao flowGroupDao) {
+        this.flowGroupDao = flowGroupDao;
+    }
+
+    @Override
+    public FlowGroup get(String name) {
+        Optional<FlowGroup> optional = flowGroupDao.findByName(name);
+        if (optional.isEmpty()) {
+            throw new NotFoundException("Group {0} not found", name);
+        }
+        return optional.get();
+    }
+
+    @Override
+    public List<FlowGroup> list(Collection<String> ids) {
+        return flowGroupDao.findAllByIdIn(ids);
+    }
+
+    @Override
+    public FlowGroup create(String name) {
+        try {
+            var group = new FlowGroup();
+            group.setName(name);
+            return flowGroupDao.save(group);
+        } catch (DuplicateKeyException e) {
+            throw new DuplicateException("Group {0} already exists", name);
+        }
+    }
+
+    @Override
+    public void delete(String name) {
+        flowGroupDao.deleteByName(name);
+    }
+}

core/src/main/java/com/flowci/core/flow/service/FlowGroupService.java

@@ -161,10 +161,6 @@ public Flow create(String name, String groupId) {
         Flow.validateName(name);
         String email = sessionManager.getUserEmail();
 
-        if (exist(name)) {
-            throw new DuplicateException("Flow {0} already exists", name);
-        }
-
         if (groupId != null) {
             if (!flowGroupDao.existsById(groupId)) {
                 throw new NotFoundException("The group id {0} not found", groupId);