Filter node versions by status.

mapper/node_version.go

@@ -55,7 +55,7 @@ func DbNodeVersionToApiNodeVersion(dbNodeVersion *ent.NodeVersion) *drip.NodeVer
 	id := dbNodeVersion.ID.String()
 	var downloadUrl string
 	status := DbNodeVersionStatusToApiNodeVersionStatus(dbNodeVersion.Status)
-	if dbNodeVersion.Edges.StorageFile != nil && dbNodeVersion.Status == schema.NodeVersionStatusActive {
+	if dbNodeVersion.Edges.StorageFile != nil {
 		downloadUrl = dbNodeVersion.Edges.StorageFile.FileURL
 	}
 
@@ -107,7 +107,8 @@ func ApiNodeVersionStatusesToDbNodeVersionStatuses(status *[]drip.NodeVersionSta
 	}
 
 	for _, s := range *status {
-		nodeVersionStatus = append(nodeVersionStatus, ApiNodeVersionStatusToDbNodeVersionStatus(s))
+		dbNodeVersion := ApiNodeVersionStatusToDbNodeVersionStatus(s)
+		nodeVersionStatus = append(nodeVersionStatus, dbNodeVersion)
 	}
 
 	return nodeVersionStatus
@@ -125,6 +126,8 @@ func ApiNodeVersionStatusToDbNodeVersionStatus(status drip.NodeVersionStatus) sc
 		nodeVersionStatus = schema.NodeVersionStatusDeleted
 	case drip.NodeVersionStatusPending:
 		nodeVersionStatus = schema.NodeVersionStatusPending
+	case drip.NodeVersionStatusFlagged:
+		nodeVersionStatus = schema.NodeVersionStatusFlagged
 	default:
 		nodeVersionStatus = ""
 	}

openapi.yml

@@ -1445,6 +1445,8 @@ paths:
         - in: query
           name: statuses
           required: false
+          style: form
+          explode: true
           schema:
             type: array
             items:

server/implementation/registry.go

@@ -945,6 +945,7 @@ func (s *DripStrictServerImplementation) ListAllNodeVersions(
 		Page:     page,
 		PageSize: pageSize,
 	}
+
 	if request.Params.Statuses != nil {
 		f.Status = mapper.ApiNodeVersionStatusesToDbNodeVersionStatuses(request.Params.Statuses)
 	}
@@ -972,7 +973,7 @@ func (s *DripStrictServerImplementation) ListAllNodeVersions(
 		apiNodeVersions = append(apiNodeVersions, *mapper.DbNodeVersionToApiNodeVersion(dbNodeVersion))
 	}
 
-	log.Ctx(ctx).Info().Msgf("Found %d node versions", len(apiNodeVersions))
+	log.Ctx(ctx).Info().Msgf("Found %d node versions", nodeVersionResults.Total)
 	return drip.ListAllNodeVersions200JSONResponse{
 		Versions:   &apiNodeVersions,
 		Total:      &nodeVersionResults.Total,

services/registry/registry_svc.go

@@ -400,6 +400,7 @@ func (s *RegistryService) ListNodeVersions(ctx context.Context, client *ent.Clie
 	}
 
 	if filter.Status != nil && len(filter.Status) > 0 {
+		log.Ctx(ctx).Info().Msgf("listing node versions with status: %v", filter.Status)
 		query.Where(nodeversion.StatusIn(filter.Status...))
 	}
 
@@ -744,7 +745,7 @@ func (s *RegistryService) PerformSecurityCheck(ctx context.Context, client *ent.
 
 	if issues != "" {
 		log.Ctx(ctx).Info().Msgf("No security issues found in node %s@%s. Updating to active.", nodeVersion.NodeID, nodeVersion.Version)
-		err := nodeVersion.Update().SetStatus(schema.NodeVersionStatusActive).Exec(ctx)
+		err := nodeVersion.Update().SetStatus(schema.NodeVersionStatusActive).SetStatusReason("Passed automated checks").Exec(ctx)
 		if err != nil {
 			log.Ctx(ctx).Error().Err(err).Msgf("failed to update node version status to active")
 		}