Draft booking flow

models/booking/booking.go

@@ -36,6 +36,10 @@ type Booking struct {
 	ResourceID   string         `json:"resource_id,omitempty" bson:"resource_id,omitempty" validate:"required"`     // could be a Compute or a Storage
 	InstanceID   string         `json:"instance_id,omitempty" bson:"instance_id,omitempty" validate:"required"`     // could be a Compute or a Storage
 
+	// Authorization: identifies who created this draft and the Check session it belongs to.
+	// Used to verify UPDATE and DELETE orders from remote schedulers.
+	SchedulerPeerID     string `json:"scheduler_peer_id,omitempty" bson:"scheduler_peer_id,omitempty"`
+	SchedulingSessionID string `json:"scheduling_session_id,omitempty" bson:"scheduling_session_id,omitempty"`
 }
 
 func (b *Booking) CalcDeltaOfExecution() map[string]map[string]models.MetricResume {

models/booking/planner/planner.go

@@ -58,10 +58,15 @@ func GenerateShallow(request *tools.APIRequest) (*Planner, error) {
 
 func generate(request *tools.APIRequest, shallow bool) (*Planner, error) {
 	accessor := booking.NewAccessor(request)
-	bookings, code, err := accessor.Search(nil, "*", false)
+	// Include both confirmed (IsDraft=false) and draft (IsDraft=true) bookings
+	// so the planner reflects the full picture: first-come first-served on all
+	// pending reservations regardless of confirmation state.
+	confirmed, code, err := accessor.Search(nil, "*", false)
 	if code != 200 || err != nil {
 		return nil, err
 	}
+	drafts, _, _ := accessor.Search(nil, "*", true)
+	bookings := append(confirmed, drafts...)
 
 	p := &Planner{
 		GeneratedAt: time.Now(),

models/resources/purchase_resource/purchase_resource.go

@@ -19,6 +19,10 @@ type PurchaseResource struct {
 	InstanceID   string     `json:"instance_id,omitempty" bson:"instance_id,omitempty" validate:"required"` // could be a Compute or a Storage
 
 	ResourceType tools.DataType `json:"resource_type" bson:"resource_type" validate:"required"`
+
+	// Authorization: identifies who created this draft and the Check session it belongs to.
+	SchedulerPeerID     string `json:"scheduler_peer_id,omitempty" bson:"scheduler_peer_id,omitempty"`
+	SchedulingSessionID string `json:"scheduling_session_id,omitempty" bson:"scheduling_session_id,omitempty"`
 }
 
 func (d *PurchaseResource) GetAccessor(request *tools.APIRequest) utils.Accessor {

models/workflow_execution/workflow_execution.go

@@ -167,6 +167,7 @@ func (d *WorkflowExecution) buyEach(bs pricing.BillingStrategy, executionsID str
 			AbstractObject: utils.AbstractObject{
 				UUID:    uuid.New().String(),
 				Name:    d.GetName() + "_" + executionsID + "_" + wfID,
+				IsDraft: true,
 			},
 			PricedItem:   m,
 			ExecutionID:  d.GetID(),
@@ -226,10 +227,11 @@ func (d *WorkflowExecution) bookEach(executionsID string, wfID string, dt tools.
 			AbstractObject: utils.AbstractObject{
 				UUID:    uuid.New().String(),
 				Name:    d.GetName() + "_" + executionsID + "_" + wfID,
+				IsDraft: true,
 			},
 			PricedItem:        m,
 			ExecutionsID:      executionsID,
-			State:             enum.SCHEDULED,
+			State:             enum.DRAFT,
 			ResourceID:        priced.GetID(),
 			InstanceID:        priced.GetInstanceID(),
 			ResourceType:      dt,