feat(api): add componentInstances to componentVersion

internal/api/graphql/gqlgen.yml

@@ -133,6 +133,8 @@ models:
         resolver: true
       issues:
         resolver: true
+      componentInstances:
+        resolver: true
   Service:
     fields:
       owners:

internal/api/graphql/graph/baseResolver/component_instance.go

@@ -67,6 +67,7 @@ func ComponentInstanceBaseResolver(app app.Heureka, ctx context.Context, filter
 
 	var imId []*int64
 	var serviceId []*int64
+	var copmonentVersionId []*int64
 	if parent != nil {
 		parentId := parent.Parent.GetID()
 		pid, err := ParseCursor(&parentId)
@@ -80,6 +81,8 @@ func ComponentInstanceBaseResolver(app app.Heureka, ctx context.Context, filter
 			imId = []*int64{pid}
 		case model.ServiceNodeName:
 			serviceId = []*int64{pid}
+		case model.ComponentVersionNodeName:
+			copmonentVersionId = []*int64{pid}
 		}
 	}
 
@@ -88,9 +91,10 @@ func ComponentInstanceBaseResolver(app app.Heureka, ctx context.Context, filter
 	}
 
 	f := &entity.ComponentInstanceFilter{
-		Paginated:    entity.Paginated{First: first, After: afterId},
-		IssueMatchId: imId,
-		ServiceId:    serviceId,
+		Paginated:          entity.Paginated{First: first, After: afterId},
+		IssueMatchId:       imId,
+		ServiceId:          serviceId,
+		ComponentVersionId: copmonentVersionId,
 	}
 
 	opt := GetListOptions(requestedFields)

internal/api/graphql/graph/queryCollection/componentVersion/directRelations.graphql

@@ -33,6 +33,16 @@ query ($filter: ComponentVersionFilter, $first: Int, $after: String) {
                         nextPageAfter
                     }
                 }
+                componentInstances { 
+                    totalCount
+                    edges { 
+                        node { 
+                            id
+                            ccrn
+                            componentVersionId
+                        }
+                    }
+                }
             }
             cursor
         }

internal/api/graphql/graph/schema/component_version.graphqls

@@ -7,6 +7,7 @@ type ComponentVersion implements Node {
     componentId: String
     component: Component
     issues(first: Int, after: String): IssueConnection
+    componentInstances(first: Int, after: String): ComponentInstanceConnection
 }
 
 input ComponentVersionInput {

internal/database/mariadb/component_instance.go

@@ -40,6 +40,7 @@ func (s *SqlDatabase) getComponentInstanceFilterString(filter *entity.ComponentI
 	fl = append(fl, buildFilterQuery(filter.Id, "CI.componentinstance_id = ?", OP_OR))
 	fl = append(fl, buildFilterQuery(filter.IssueMatchId, "IM.issuematch_id = ?", OP_OR))
 	fl = append(fl, buildFilterQuery(filter.ServiceId, "CI.componentinstance_service_id = ?", OP_OR))
+	fl = append(fl, buildFilterQuery(filter.ComponentVersionId, "CI.componentinstance_component_version_id = ?", OP_OR))
 	fl = append(fl, "CI.componentinstance_deleted_at IS NULL")
 
 	filterStr := combineFilterQueries(fl, OP_AND)
@@ -113,6 +114,7 @@ func (s *SqlDatabase) buildComponentInstanceStatement(baseQuery string, filter *
 	filterParameters = buildQueryParameters(filterParameters, filter.Id)
 	filterParameters = buildQueryParameters(filterParameters, filter.IssueMatchId)
 	filterParameters = buildQueryParameters(filterParameters, filter.ServiceId)
+	filterParameters = buildQueryParameters(filterParameters, filter.ComponentVersionId)
 	if withCursor {
 		filterParameters = append(filterParameters, cursor.Value)
 		filterParameters = append(filterParameters, cursor.Limit)

internal/database/mariadb/component_instance_test.go

@@ -97,6 +97,32 @@ var _ = Describe("ComponentInstance - ", Label("database", "ComponentInstance"),
 						Expect(entries[0]).To(BeEquivalentTo(ciId))
 					})
 				})
+				It("can filter by a single componentVersion id that does exist", func() {
+					// select a component version
+					cvRow := seedCollection.ComponentVersionRows[rand.Intn(len(seedCollection.ComponentVersionRows))]
+
+					// collect all componentInstance ids that belong to the component version
+					ciIds := []int64{}
+					for _, ciRow := range seedCollection.ComponentInstanceRows {
+						if ciRow.ComponentVersionId.Int64 == cvRow.Id.Int64 {
+							ciIds = append(ciIds, ciRow.ServiceId.Int64)
+						}
+					}
+
+					filter := &entity.ComponentInstanceFilter{
+						ComponentVersionId: []*int64{&cvRow.Id.Int64},
+					}
+
+					entries, err := db.GetAllComponentInstanceIds(filter)
+
+					By("throwing no error", func() {
+						Expect(err).To(BeNil())
+					})
+
+					By("returning expected elements", func() {
+						Expect(len(entries)).To(BeEquivalentTo(len(ciIds)))
+					})
+				})
 			})
 		})
 	})

internal/e2e/component_version_query_test.go

@@ -163,6 +163,14 @@ var _ = Describe("Getting ComponentVersions via API", Label("e2e", "ComponentVer
 						Expect(issueFound).To(BeTrue(), "attached issue does exist and belongs to componentVersion")
 					}
 
+					for _, ci := range cv.Node.ComponentInstances.Edges {
+						Expect(ci.Node.ID).ToNot(BeNil(), "componentInstance has a ID set")
+						Expect(ci.Node.Ccrn).ToNot(BeNil(), "componentInstance has ccrn set")
+
+						Expect(*ci.Node.ComponentVersionID).To(BeEquivalentTo(cv.Node.ID))
+
+					}
+
 					if cv.Node.Component != nil {
 						Expect(cv.Node.Component.ID).ToNot(BeNil(), "component has a ID set")
 						Expect(cv.Node.Component.Name).ToNot(BeNil(), "component has a name set")

internal/entity/component_instance.go

@@ -7,9 +7,10 @@ import "time"
 
 type ComponentInstanceFilter struct {
 	Paginated
-	IssueMatchId []*int64 `json:"issue_match_id"`
-	ServiceId    []*int64 `json:"service_id"`
-	Id           []*int64 `json:"id"`
+	IssueMatchId       []*int64 `json:"issue_match_id"`
+	ServiceId          []*int64 `json:"service_id"`
+	ComponentVersionId []*int64 `json:"component_version_id"`
+	Id                 []*int64 `json:"id"`
 }
 
 type ComponentInstanceAggregations struct{}