create agent

Author: gy2006

src/main/java/com/flowci/agent/AgentController.java

@@ -0,0 +1,13 @@
+package com.flowci.agent;
+
+import io.swagger.v3.oas.annotations.tags.Tag;
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/v2/agents")
+@Tag(name = "agent")
+@AllArgsConstructor
+public class AgentController {
+}

src/main/java/com/flowci/agent/business/CreateAgent.java

@@ -0,0 +1,9 @@
+package com.flowci.agent.business;
+
+import com.flowci.agent.model.Agent;
+
+import java.util.List;
+
+public interface CreateAgent {
+    Agent invoke(String alias, List<String> tags);
+}

src/main/java/com/flowci/agent/business/CreateAgentImpl.java

@@ -0,0 +1,25 @@
+package com.flowci.agent.business;
+
+import com.flowci.agent.model.Agent;
+import com.flowci.agent.repo.AgentRepo;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class CreateAgentImpl implements CreateAgent {
+
+    private final AgentRepo agentRepo;
+
+    @Override
+    public Agent invoke(String alias, List<String> tags) {
+        var agent = new Agent();
+        agent.setAlias(alias);
+        agent.setTags(tags.toArray(new String[0]));
+        return agentRepo.save(agent);
+    }
+}

src/main/java/com/flowci/agent/events/AgentIdleEvent.java

@@ -0,0 +1,15 @@
+package com.flowci.agent.events;
+
+import lombok.Getter;
+import org.springframework.context.ApplicationEvent;
+
+@Getter
+public class AgentIdleEvent extends ApplicationEvent {
+
+    private final Long agentId;
+
+    public AgentIdleEvent(Object source, Long agentId) {
+        super(source);
+        this.agentId = agentId;
+    }
+}

src/main/java/com/flowci/agent/model/Agent.java

@@ -0,0 +1,38 @@
+package com.flowci.agent.model;
+
+import com.flowci.common.model.EntityBase;
+import io.hypersistence.utils.hibernate.type.array.StringArrayType;
+import jakarta.persistence.*;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@Data
+@EqualsAndHashCode(callSuper = false, of = {"id"})
+@Entity
+@Table(name = "agents")
+public class Agent extends EntityBase {
+
+    public enum Status {
+        OFFLINE,
+        ONLINE_BUSY,
+        ONLINE_IDLE,
+        DISABLED,
+    }
+
+    @Id
+    private Long id;
+
+    private String alias;
+
+    // generated
+    private String token;
+
+    // updated when agent online
+    private String os;
+
+    @org.hibernate.annotations.Type(StringArrayType.class)
+    private String[] tags;
+
+    @Enumerated(EnumType.STRING)
+    private Status status;
+}

src/main/java/com/flowci/agent/package-info.java

@@ -0,0 +1 @@
+package com.flowci.agent;

src/main/java/com/flowci/agent/repo/AgentRepo.java

@@ -0,0 +1,9 @@
+package com.flowci.agent.repo;
+
+import com.flowci.agent.model.Agent;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface AgentRepo extends JpaRepository<Agent, Long> {
+}

src/main/java/com/flowci/build/model/Build.java

@@ -16,7 +16,7 @@
 @Data
 @EqualsAndHashCode(callSuper = false, of = {"id"})
 @Entity
-@Table(name = "build")
+@Table(name = "builds")
 public class Build extends EntityBase {
 
     public enum Trigger {
@@ -51,7 +51,7 @@ public enum Status {
 
     @Id
     @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "build_id_gen")
-    @SequenceGenerator(name = "build_id_gen", sequenceName = "build_id_sequence", allocationSize = 1)
+    @SequenceGenerator(name = "build_id_gen", sequenceName = "builds_id_sequence", allocationSize = 1)
     private Long id;
 
     private Long flowId;

src/main/java/com/flowci/build/model/BuildYaml.java

@@ -12,7 +12,7 @@
 
 @Data
 @Entity
-@Table(name = "build_yaml")
+@Table(name = "builds_yaml")
 @EqualsAndHashCode(callSuper = false, of = "id")
 public class BuildYaml extends EntityBase {
 

src/main/resources/db/migration/V1__Init.sql

@@ -41,7 +41,7 @@ CREATE TABLE flows_user
 
 -- build related tables --
 
-CREATE TABLE build
+CREATE TABLE builds
 (
     id             BIGSERIAL PRIMARY KEY,
     flow_id        BIGINT                      NOT NULL,
@@ -60,8 +60,8 @@ CREATE TABLE build
     UNIQUE (flow_id, build_date, build_sequence)
 );
 
-DROP SEQUENCE IF EXISTS build_id_sequence;
-CREATE SEQUENCE build_id_sequence START 10000 INCREMENT 1 OWNED BY build.id;
+DROP SEQUENCE IF EXISTS builds_id_sequence;
+CREATE SEQUENCE builds_id_sequence START 10000 INCREMENT 1 OWNED BY builds.id;
 
 -- trigger function to create build_date, build_sequence and build_alias on insert
 CREATE OR REPLACE FUNCTION auto_build_sequence() RETURNS trigger AS
@@ -84,11 +84,11 @@ $build_sequence$ LANGUAGE plpgsql;
 -- add trigger on insert
 CREATE TRIGGER build_sequence_trigger
     BEFORE INSERT
-    ON "build"
+    ON "builds"
     FOR EACH ROW
 EXECUTE PROCEDURE auto_build_sequence();
 
-CREATE TABLE build_yaml
+CREATE TABLE builds_yaml
 (
     id         BIGINT PRIMARY KEY,
     variables  json                        NOT NULL,