get flow with the latest build status

Author: gy2006

src/main/java/com/flowci/flow/model/FlowWithBuildStatus.java

@@ -0,0 +1,22 @@
+package com.flowci.flow.model;
+
+import com.flowci.build.model.Build;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Entity
+@AllArgsConstructor
+@NoArgsConstructor
+public class FlowWithBuildStatus {
+
+    @Id
+    private Long id;
+
+    private String name;
+
+    private Build.Status lastBuildStatus;
+}

src/main/java/com/flowci/flow/repo/FlowRepo.java

@@ -1,6 +1,7 @@
 package com.flowci.flow.repo;
 
 import com.flowci.flow.model.Flow;
+import com.flowci.flow.model.FlowWithBuildStatus;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
@@ -18,4 +19,10 @@ public interface FlowRepo extends JpaRepository<Flow, Long> {
             "and f.parentId = ?1 " +
             "order by f.createdAt")
     List<Flow> findAllByParentIdAndUserIdOrderByCreatedAt(Long parentId, Long userId);
+
+    @Query("select new FlowWithBuildStatus(f.id, f.name, b.status) " +
+            "from Flow f " +
+            "inner join Build b on f.id = b.flowId " +
+            "where f.id = ?1")
+    FlowWithBuildStatus findFlowWithBuildStatusByUserId(Long flowId);
 }

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

@@ -71,7 +71,7 @@ BEGIN
 
     SELECT COALESCE(MAX(build_sequence) + 1, 1)
     INTO NEW.build_sequence
-    FROM "build"
+    FROM "builds"
     WHERE flow_id = NEW.flow_id
       AND build_date = NEW.build_date;
 

src/test/java/com/flowci/flow/repo/FlowRepoTest.java

@@ -1,6 +1,8 @@
 package com.flowci.flow.repo;
 
 import com.flowci.SpringTestWithDB;
+import com.flowci.build.model.Build;
+import com.flowci.build.repo.BuildRepo;
 import com.flowci.flow.model.Flow;
 import com.flowci.flow.model.FlowUser;
 import org.instancio.InstancioApi;
@@ -20,6 +22,9 @@ class FlowRepoTest extends SpringTestWithDB {
     @Autowired
     private FlowUserRepo flowUserRepo;
 
+    @Autowired
+    private BuildRepo buildRepo;
+
     @Test
     void givenFlow_whenSaving_thenIdAndTimestampCreated() {
         var flow = mockFlow().create();
@@ -70,6 +75,23 @@ void whenFindFlowsByParentIdAndUserId_thenReturnListOfFlows() {
         assertEquals(1, flowsForUser2.size());
     }
 
+    @Test
+    void whenFindFlowWithBuildStatus_thenReturn() {
+        var flow = mockFlow().create();
+        flowRepo.save(flow);
+
+        var build = newDummyInstance(Build.class)
+                .ignore(field(Build::getId))
+                .set(field(Build::getFlowId), flow.getId())
+                .set(field(Build::getStatus), Build.Status.QUEUED)
+                .create();
+        buildRepo.save(build);
+
+        var entity = flowRepo.findFlowWithBuildStatusByUserId(flow.getId());
+        assertNotNull(entity);
+        assertEquals(Build.Status.QUEUED, entity.getLastBuildStatus());
+    }
+
     private InstancioApi<Flow> mockFlow() {
         return newDummyInstance(Flow.class).ignore(field(Flow::getId));
     }