[scd] Factorize volume4D union from rest

Author: RustedBones

pkg/models/scd_conversions.go

@@ -77,6 +77,24 @@ func Volume4DFromSCDRest(vol4 *restapi.Volume4D, validators ...Volume4DValidator
 	return volume, nil
 }
 
+// UnionVolume4DFromSCDRest converts a slice of vol4 SCD v1 REST model to a single bounding Volume4D
+func UnionVolume4DFromSCDRest(vol4s []restapi.Volume4D, validators ...Volume4DValidator) (*Volume4D, error) {
+	volumes := make([]*Volume4D, len(vol4s))
+	for idx, vol4 := range vol4s {
+		volume, err := Volume4DFromSCDRest(&vol4, validators...)
+		if err != nil {
+			return nil, stacktrace.Propagate(err, "Failed to parse volume %d", idx)
+		}
+		volumes[idx] = volume
+	}
+	union, err := UnionVolumes4D(volumes...)
+	if err != nil {
+		return nil, stacktrace.Propagate(err, "Failed to union volumes")
+	}
+
+	return union, nil
+}
+
 // Volume3DFromSCDRest converts a vol3 SCD v1 REST model to a Volume3D
 func Volume3DFromSCDRest(vol3 *restapi.Volume3D) (*Volume3D, error) {
 	if vol3 == nil {

pkg/scd/constraints_handler.go

@@ -362,7 +362,6 @@ func (a *Server) PutConstraintReference(ctx context.Context, manager string, ent
 
 type validConstraintParams struct {
 	id         dssmodels.ID
-	extents    []*dssmodels.Volume4D
 	uExtent    *dssmodels.Volume4D
 	cells      s2.CellUnion
 	ussBaseURL string
@@ -414,19 +413,10 @@ func validateAndReturnConstraintUpsertParams(
 		}
 	}
 
-	// TODO: factor out logic below into common multi-vol4d parser and reuse with PutOperationReference
-	valid.extents = make([]*dssmodels.Volume4D, len(params.Extents))
-	for idx, extent := range params.Extents {
-		// Start and end times are required for each volume
-		cExtent, err := dssmodels.Volume4DFromSCDRest(&extent, dssmodels.WithRequireTimeBounds())
-		if err != nil {
-			return nil, stacktrace.Propagate(err, "Failed to parse extent %d", idx)
-		}
-		valid.extents[idx] = cExtent
-	}
-	valid.uExtent, err = dssmodels.UnionVolumes4D(valid.extents...)
+	// Start and end times are required for each volume
+	valid.uExtent, err = dssmodels.UnionVolume4DFromSCDRest(params.Extents, dssmodels.WithRequireTimeBounds())
 	if err != nil {
-		return nil, stacktrace.Propagate(err, "Failed to union extents")
+		return nil, stacktrace.Propagate(err, "Invalid extents")
 	}
 
 	if now.After(*valid.uExtent.EndTime) {

pkg/scd/operational_intents_handler.go

@@ -393,7 +393,6 @@ type validOIRParams struct {
 	ovn                  scdmodels.OVN
 	newOVN               scdmodels.OVN
 	state                scdmodels.OperationalIntentState
-	extents              []*dssmodels.Volume4D
 	uExtent              *dssmodels.Volume4D
 	cells                s2.CellUnion
 	subscriptionID       dssmodels.ID
@@ -503,19 +502,10 @@ func validateAndReturnOIRUpsertParams(
 		return nil, stacktrace.NewError("Invalid OperationalIntent state: %s", params.State)
 	}
 
-	valid.extents = make([]*dssmodels.Volume4D, len(params.Extents))
-	for idx, extent := range params.Extents {
-		// Start and end times, as well as lower and upper altitudes, are required for each volume
-		cExtent, err := dssmodels.Volume4DFromSCDRest(&extent, dssmodels.WithRequireTimeBounds(), dssmodels.WithRequireAltitudeBounds())
-		if err != nil {
-			return nil, stacktrace.Propagate(err, "Failed to parse extent %d", idx)
-		}
-		valid.extents[idx] = cExtent
-	}
-
-	valid.uExtent, err = dssmodels.UnionVolumes4D(valid.extents...)
+	// Start and end times, as well as lower and upper altitudes, are required for each volume
+	valid.uExtent, err = dssmodels.UnionVolume4DFromSCDRest(params.Extents, dssmodels.WithRequireTimeBounds(), dssmodels.WithRequireAltitudeBounds())
 	if err != nil {
-		return nil, stacktrace.Propagate(err, "Failed to union extents")
+		return nil, stacktrace.Propagate(err, "Invalid extents")
 	}
 
 	if now.After(*valid.uExtent.EndTime) {