workflow_execution

type BookingState struct {
	IsBooked bool `json:"is_booked" bson:"is_booked"`
	IsDone   bool `json:"is_done" bson:"is_done"`
}

type ExecutionGraph map[string]ExecutionGraphItem

type ExecutionGraphItem struct {
	Name        string             `json:"name" bson:"name"`
	StartDate   *time.Time         `json:"start_date,omitempty" bson:"start_date,omitempty"`
	EndDate     *time.Time         `json:"end_date,omitempty" bson:"end_date,omitempty"`
	State       ExecutionStepState `json:"state" bson:"state"`
	Deps        []string           `json:"deps,omitempty" bson:"deps,omitempty"`
	WhenRunning []string           `json:"when_running,omitempty" bson:"when_running,omitempty"`
}

type ExecutionStepState string

type WorkflowExecution struct {
	utils.AbstractObject                                // AbstractObject contains the basic fields of an object (id, name)
	Priority             int                            `json:"priority" bson:"priority"`                                         // will best effort on default                                    // Will Best Effort on priority
	PeerBuyByGraph       map[string]map[string][]string `json:"peer_buy_by_graph,omitempty" bson:"peer_buy_by_graph,omitempty"`   // BookByResource is a map of the resource id and the list of the booking id
	PeerBookByGraph      map[string]map[string][]string `json:"peer_book_by_graph,omitempty" bson:"peer_book_by_graph,omitempty"` // BookByResource is a map of the resource id and the list of the booking id
	ExecutionsID         string                         `json:"executions_id,omitempty" bson:"executions_id,omitempty"`
	ExecDate             time.Time                      `json:"execution_date,omitempty" bson:"execution_date,omitempty" validate:"required"` // ExecDate is the execution date of the workflow, is required
	EndDate              *time.Time                     `json:"end_date,omitempty" bson:"end_date,omitempty"`                                 // EndDate is the end date of the workflow
	State                enum.BookingStatus             `json:"state" bson:"state" default:"0"`                                               // TEMPORARY TODO DEFAULT 1 -> 0 State is the state of the workflow
	WorkflowID           string                         `json:"workflow_id" bson:"workflow_id,omitempty"`                                     // WorkflowID is the ID of the workflow

	BookingsState  map[string]BookingState `json:"bookings_state" bson:"bookings_state,omitempty"`   // booking_id → reservation+completion status
	PurchasesState map[string]bool         `json:"purchases_state" bson:"purchases_state,omitempty"` // purchase_id → confirmed

	// Graph is a lightweight, real-time summary of the workflow execution graph.
	// Keyed by workflow graph item ID; updated by oc-scheduler on each step-done event.
	// Consumed by oc-front to render the live execution panel via websocket updates.
	Graph ExecutionGraph `json:"graph,omitempty" bson:"graph,omitempty"`

	SelectedInstances    workflow.ConfigItem `json:"selected_instances"`
	SelectedPartnerships workflow.ConfigItem `json:"selected_partnerships"`
	SelectedBuyings      workflow.ConfigItem `json:"selected_buyings"`
	SelectedStrategies   workflow.ConfigItem `json:"selected_strategies"`
	SelectedPaymentMode  workflow.ConfigItem `json:"selected_payment_mode"`

	// SelectedBillingStrategy est la fréquence de facturation globale choisie par l'utilisateur
	// (BILL_ONCE, BILL_PER_WEEK, BILL_PER_MONTH, BILL_PER_YEAR).
	// Propagée depuis WorkflowSchedule.SelectedBillingStrategy par GenerateExecutions().
	SelectedBillingStrategy pricing.BillingStrategy `json:"selected_billing_strategy" bson:"selected_billing_strategy"`

	// SelectedEmbeddedStorages records which storage capability was activated on
	// each compute unit graph node (key = compute graph node ID).
	// Populated by oc-scheduler, consumed by oc-monitord's argo builder.
	SelectedEmbeddedStorages map[string]*resources.EmbeddedStorageSelection `json:"selected_embedded_storages,omitempty" bson:"selected_embedded_storages,omitempty"`
}

type WorkflowExecutionMongoAccessor struct {
	utils.AbstractAccessor[*WorkflowExecution]
	// contains filtered or unexported fields
}