From be3b09b68340d8e11c511d2b7179905af3267a33 Mon Sep 17 00:00:00 2001
From: mr <mr>
Date: Tue, 17 Dec 2024 10:42:00 +0100
Subject: [PATCH] set up unfonctionnal rework, TODO -> pricing separation

---
 doc/order_model.puml                          |  2 +-
 doc/paymentflowV1.puml                        | 29 ++++++++
 models/buying_status/buying_status.go         | 31 --------
 .../buying_status/buying_status_accessor.go   | 72 -------------------
 models/common/pricing/interfaces.go           |  2 +-
 models/common/pricing/pricing_profile.go      |  2 +-
 models/order/order.go                         | 29 ++++----
 models/resources/compute.go                   |  2 +-
 models/resources/data.go                      | 22 +++---
 .../priced_resource/priced_resource.go        |  6 ++
 models/resources/processing.go                | 26 +++----
 .../purchase_resource/purchase_resource.go    | 30 ++++++++
 .../purchase_resource_accessor.go             | 72 +++++++++++++++++++
 models/resources/resource.go                  |  4 +-
 models/resources/storage.go                   |  2 +-
 models/resources/workflow.go                  |  2 +-
 models/utils/abstracts.go                     | 19 ++---
 models/workflow/workflow_test.go              |  5 +-
 .../workflow_execution/workflow_execution.go  |  4 +-
 .../workflow_execution/workflow_scheduler.go  | 12 ++--
 20 files changed, 199 insertions(+), 174 deletions(-)
 create mode 100644 doc/paymentflowV1.puml
 delete mode 100644 models/buying_status/buying_status.go
 delete mode 100644 models/buying_status/buying_status_accessor.go
 create mode 100644 models/resources/priced_resource/priced_resource.go
 create mode 100644 models/resources/purchase_resource/purchase_resource.go
 create mode 100644 models/resources/purchase_resource/purchase_resource_accessor.go

diff --git a/doc/order_model.puml b/doc/order_model.puml
index f79715d..98211b7 100644
--- a/doc/order_model.puml
+++ b/doc/order_model.puml
@@ -195,7 +195,7 @@ ExploitPricingProfile ^-- ComputeResourcePricingProfile
 ExploitPricingProfile ^-- StorageResourcePricingProfile
 interface PricingProfileITF {
   GetPrice(quantity float64, val float64, start date, end date, request) float64
-  IsBuying() bool
+  IsPurchased() bool
 }
 class AccessPricingProfile {
   ID string 
diff --git a/doc/paymentflowV1.puml b/doc/paymentflowV1.puml
new file mode 100644
index 0000000..ecd6ede
--- /dev/null
+++ b/doc/paymentflowV1.puml
@@ -0,0 +1,29 @@
+@startuml
+user -> client : schedule 
+client -> OrderAPIP1 : check book
+OrderAPIP1 -> datacenterAPIP2 : check book
+datacenterAPIP2 -> OrderAPIP1 : send ok
+OrderAPIP1 -> datacenterAPIP2 : generate draft book
+OrderAPIP1 -> client : send ok 
+client -> OrderAPIP1 : send scheduler
+OrderAPIP1 -> OrderAPIP1 : draft executions
+OrderAPIP1 -> OrderAPIP1 : draft order
+OrderAPIP1 -> client : send drafted order
+client -> user : 
+user -> client : select pricing profile
+client -> OrderAPIP1 : update order 
+OrderAPIP1 -> datacenterAPIP2 : check book
+datacenterAPIP2 -> OrderAPIP1 : send ok
+OrderAPIP1 -> datacenterAPIP2 : generate draft book
+OrderAPIP1 -> client : send order
+user -> client : order
+client -> OrderAPIP1 : order 
+OrderAPIP1 -> PaymentAPIBCP1 : send payment
+PaymentAPIBCP1 -> OrderAPIP1 : send ok 
+OrderAPIP1 -> datacenterAPIP2 : undraft booking
+OrderAPIP1 -> OrderAPIP1 : undraft execution
+OrderAPIP1 -> OrderAPIP1 : undraft order
+OrderAPIP1 -> client : send ok 
+client -> client : redirect
+@enduml
+
diff --git a/models/buying_status/buying_status.go b/models/buying_status/buying_status.go
deleted file mode 100644
index 3306e08..0000000
--- a/models/buying_status/buying_status.go
+++ /dev/null
@@ -1,31 +0,0 @@
-package buying_status
-
-import (
-	"time"
-
-	"cloud.o-forge.io/core/oc-lib/models/utils"
-	"cloud.o-forge.io/core/oc-lib/tools"
-)
-
-type BuyingStatus struct {
-	utils.AbstractObject
-	BuyingDate    time.Time      `json:"buying_date" bson:"buying_date" validate:"required"`
-	EndBuyingDate *time.Time     `json:"end_buying_date,omitempty" bson:"end_buying_date,omitempty"`
-	ResourceID    string         `json:"resource_id" bson:"resource_id" validate:"required"`
-	ResourceType  tools.DataType `json:"resource_type" bson:"resource_type" validate:"required"`
-}
-
-func (d *BuyingStatus) GetAccessor(request *tools.APIRequest) utils.Accessor {
-	return NewAccessor(request) // Create a new instance of the accessor
-}
-
-func (r *BuyingStatus) CanUpdate(set utils.DBObject) (bool, utils.DBObject) {
-	return r.IsDraft, set // only draft buying can be updated
-}
-
-func (r *BuyingStatus) CanDelete() bool { // ENDBuyingDate is passed
-	if r.EndBuyingDate != nil {
-		return time.Now().UTC().After(*r.EndBuyingDate)
-	}
-	return false // only draft bookings can be deleted
-}
diff --git a/models/buying_status/buying_status_accessor.go b/models/buying_status/buying_status_accessor.go
deleted file mode 100644
index 9104539..0000000
--- a/models/buying_status/buying_status_accessor.go
+++ /dev/null
@@ -1,72 +0,0 @@
-package buying_status
-
-import (
-	"time"
-
-	"cloud.o-forge.io/core/oc-lib/dbs"
-	"cloud.o-forge.io/core/oc-lib/logs"
-	"cloud.o-forge.io/core/oc-lib/models/utils"
-	"cloud.o-forge.io/core/oc-lib/tools"
-)
-
-type buyingStatusMongoAccessor struct {
-	utils.AbstractAccessor // AbstractAccessor contains the basic fields of an accessor (model, caller)
-}
-
-// New creates a new instance of the bookingMongoAccessor
-func NewAccessor(request *tools.APIRequest) *buyingStatusMongoAccessor {
-	return &buyingStatusMongoAccessor{
-		AbstractAccessor: utils.AbstractAccessor{
-			Logger:  logs.CreateLogger(tools.BUYING_STATUS.String()), // Create a logger with the data type
-			Request: request,
-			Type:    tools.BUYING_STATUS,
-		},
-	}
-}
-
-/*
-* Nothing special here, just the basic CRUD operations
- */
-func (a *buyingStatusMongoAccessor) DeleteOne(id string) (utils.DBObject, int, error) {
-	return utils.GenericDeleteOne(id, a)
-}
-
-func (a *buyingStatusMongoAccessor) UpdateOne(set utils.DBObject, id string) (utils.DBObject, int, error) {
-	return utils.GenericUpdateOne(set, id, a, &BuyingStatus{})
-}
-
-func (a *buyingStatusMongoAccessor) StoreOne(data utils.DBObject) (utils.DBObject, int, error) {
-	return utils.GenericStoreOne(data, a)
-}
-
-func (a *buyingStatusMongoAccessor) CopyOne(data utils.DBObject) (utils.DBObject, int, error) {
-	return utils.GenericStoreOne(data, a)
-}
-
-func (a *buyingStatusMongoAccessor) LoadOne(id string) (utils.DBObject, int, error) {
-	return utils.GenericLoadOne[*BuyingStatus](id, func(d utils.DBObject) (utils.DBObject, int, error) {
-		if d.(*BuyingStatus).EndBuyingDate != nil && time.Now().UTC().After(*d.(*BuyingStatus).EndBuyingDate) {
-			utils.GenericDeleteOne(id, a)
-			return nil, 404, nil
-		}
-		return d, 200, nil
-	}, a)
-}
-
-func (a *buyingStatusMongoAccessor) LoadAll(isDraft bool) ([]utils.ShallowDBObject, int, error) {
-	return utils.GenericLoadAll[*BuyingStatus](a.getExec(), isDraft, a)
-}
-
-func (a *buyingStatusMongoAccessor) Search(filters *dbs.Filters, search string, isDraft bool) ([]utils.ShallowDBObject, int, error) {
-	return utils.GenericSearch[*BuyingStatus](filters, search, (&BuyingStatus{}).GetObjectFilters(search), a.getExec(), isDraft, a)
-}
-
-func (a *buyingStatusMongoAccessor) getExec() func(utils.DBObject) utils.ShallowDBObject {
-	return func(d utils.DBObject) utils.ShallowDBObject {
-		if d.(*BuyingStatus).EndBuyingDate != nil && time.Now().UTC().After(*d.(*BuyingStatus).EndBuyingDate) {
-			utils.GenericDeleteOne(d.GetID(), a)
-			return nil
-		}
-		return d
-	}
-}
diff --git a/models/common/pricing/interfaces.go b/models/common/pricing/interfaces.go
index e245ecf..539053e 100644
--- a/models/common/pricing/interfaces.go
+++ b/models/common/pricing/interfaces.go
@@ -9,7 +9,7 @@ import (
 type PricedItemITF interface {
 	GetID() string
 	GetType() tools.DataType
-	IsBuying(request *tools.APIRequest) bool
+	IsPurchased(request *tools.APIRequest) bool
 	GetCreatorID() string
 	GetLocationStart() *time.Time
 	GetLocationEnd() *time.Time
diff --git a/models/common/pricing/pricing_profile.go b/models/common/pricing/pricing_profile.go
index 87accf7..bf9c20c 100644
--- a/models/common/pricing/pricing_profile.go
+++ b/models/common/pricing/pricing_profile.go
@@ -9,7 +9,7 @@ import (
 type PricingProfileITF interface {
 	GetID() string
 	GetPrice(quantity float64, val float64, start time.Time, end time.Time, request *tools.APIRequest, params ...string) (float64, error)
-	IsBuying() bool
+	IsPurchased() bool
 	GetOverrideStrategyValue() int
 }
 
diff --git a/models/order/order.go b/models/order/order.go
index 505b90e..ccd67da 100644
--- a/models/order/order.go
+++ b/models/order/order.go
@@ -8,9 +8,9 @@ import (
 
 	"cloud.o-forge.io/core/oc-lib/dbs"
 	"cloud.o-forge.io/core/oc-lib/models/booking"
-	"cloud.o-forge.io/core/oc-lib/models/buying_status"
 	"cloud.o-forge.io/core/oc-lib/models/common/pricing"
 	"cloud.o-forge.io/core/oc-lib/models/peer"
+	"cloud.o-forge.io/core/oc-lib/models/resources/purchase_resource"
 	"cloud.o-forge.io/core/oc-lib/models/utils"
 	"cloud.o-forge.io/core/oc-lib/models/workflow_execution"
 	"cloud.o-forge.io/core/oc-lib/tools"
@@ -172,7 +172,7 @@ func (o *Order) draftBookOrder(scheduler *workflow_execution.WorkflowSchedule, r
 		return draftedBookings, errors.New("no request found")
 	}
 	for _, exec := range scheduler.WorkflowExecutions {
-		bookings := exec.ToBookings(scheduler.Workflow)
+		bookings := exec.Book(scheduler.Workflow)
 		for _, booking := range bookings {
 			_, err := (&peer.Peer{}).LaunchPeerExecution(booking.DestPeerID, "",
 				tools.BOOKING, tools.POST, booking.Serialize(booking), request.Caller)
@@ -261,15 +261,14 @@ func (d *PeerOrder) Pay(request *tools.APIRequest, response chan *PeerOrder, wg
 		d.Status = PAID // TO REMOVE LATER IT'S A MOCK
 		if d.Status == PAID {
 			for _, b := range d.Items {
-				if !b.Item.IsBuying(request) {
+				if !b.Item.IsPurchased(request) {
 					continue
 				}
-				accessor := buying_status.NewAccessor(request)
-				accessor.StoreOne(&buying_status.BuyingStatus{
-					BuyingDate:    time.Now(),
-					ResourceID:    b.Item.GetID(),
-					ResourceType:  b.Item.GetType(),
-					EndBuyingDate: b.Item.GetLocationEnd(),
+				accessor := purchase_resource.NewAccessor(request)
+				accessor.StoreOne(&purchase_resource.PurchaseResource{
+					ResourceID:   b.Item.GetID(),
+					ResourceType: b.Item.GetType(),
+					EndDate:      b.Item.GetLocationEnd(),
 				})
 			}
 		}
@@ -304,21 +303,21 @@ func (d *PeerOrder) SetName() {
 }
 
 type PeerItemOrder struct {
-	Quantity     int                        `json:"quantity,omitempty" bson:"quantity,omitempty"`
-	BuyingStatus buying_status.BuyingStatus `json:"buying_status,omitempty" bson:"buying_status,omitempty"`
-	Item         pricing.PricedItemITF      `json:"item,omitempty" bson:"item,omitempty"`
+	Quantity int                                `json:"quantity,omitempty" bson:"quantity,omitempty"`
+	Purchase purchase_resource.PurchaseResource `json:"purchase,omitempty" bson:"purchase,omitempty"`
+	Item     pricing.PricedItemITF              `json:"item,omitempty" bson:"item,omitempty"`
 }
 
 func (d *PeerItemOrder) GetPrice(request *tools.APIRequest) (float64, error) {
-	accessor := buying_status.NewAccessor(request)
+	accessor := purchase_resource.NewAccessor(request)
 	search, code, _ := accessor.Search(&dbs.Filters{
 		And: map[string][]dbs.Filter{
 			"resource_id": {{Operator: dbs.EQUAL.String(), Value: d.Item.GetID()}},
 		},
-	}, "", d.BuyingStatus.IsDraft)
+	}, "", d.Purchase.IsDraft)
 	if code == 200 && len(search) > 0 {
 		for _, s := range search {
-			if s.(*buying_status.BuyingStatus).EndBuyingDate == nil || time.Now().UTC().After(*s.(*buying_status.BuyingStatus).EndBuyingDate) {
+			if s.(*purchase_resource.PurchaseResource).EndDate == nil || time.Now().UTC().After(*s.(*purchase_resource.PurchaseResource).EndDate) {
 				return 0, nil
 			}
 		}
diff --git a/models/resources/compute.go b/models/resources/compute.go
index 8248a16..cb18839 100644
--- a/models/resources/compute.go
+++ b/models/resources/compute.go
@@ -58,7 +58,7 @@ type ComputeResourcePricingProfile struct {
 
 // PROBLEM
 
-func (p *ComputeResourcePricingProfile) IsBuying() bool {
+func (p *ComputeResourcePricingProfile) IsPurchased() bool {
 	return p.Pricing.BuyingStrategy != pricing.PAY_PER_USE
 }
 
diff --git a/models/resources/data.go b/models/resources/data.go
index 30443d9..8959600 100644
--- a/models/resources/data.go
+++ b/models/resources/data.go
@@ -18,7 +18,12 @@ const (
 	LICENCED
 )
 
-type abstractDataResource struct {
+/*
+* DataResource is a struct that represents a data resource
+* it defines the resource data
+ */
+type DataResource struct {
+	AbstractResource[*ResourceInstance[*DataResourcePartnership]]
 	Type                   string    `bson:"type,omitempty" json:"type,omitempty"`
 	Quality                string    `bson:"quality,omitempty" json:"quality,omitempty"`
 	OpenData               bool      `bson:"open_data" json:"open_data" default:"false"` // Type is the type of the storage
@@ -26,17 +31,7 @@ type abstractDataResource struct {
 	UpdatePeriod           time.Time `bson:"update_period,omitempty" json:"update_period,omitempty"`
 	PersonalData           bool      `bson:"personal_data,omitempty" json:"personal_data,omitempty"`
 	AnonymizedPersonalData bool      `bson:"anonymized_personal_data,omitempty" json:"anonymized_personal_data,omitempty"`
-	SizeGB                 float64   `json:"size_gb,omitempty" bson:"size_gb,omitempty"` // SizeGB is the size of the data
-}
-
-/*
-* DataResource is a struct that represents a data resource
-* it defines the resource data
- */
-type DataResource struct {
-	AbstractResource[*ResourceInstance[*DataResourcePartnership]]
-	abstractDataResource             // AbstractResource contains the basic fields of an object (id, name)
-	License              DataLicense `json:"license" bson:"license" description:"license of the data" default:"0"` // License is the license of the data
+	SizeGB                 float64   `json:"size_gb,omitempty" bson:"size_gb,omitempty"` // SizeGB is the size of the data	License              DataLicense `json:"license" bson:"license" description:"license of the data" default:"0"` // License is the license of the data
 	// ? Interest               DataLicense `json:"interest" bson:"interest" description:"interest of the data" default:"0"`      // Interest is the interest of the data
 	Example string `json:"example,omitempty" bson:"example,omitempty" description:"base64 encoded data"` // Example is an example of the data
 }
@@ -102,13 +97,12 @@ func (p *DataResourcePricingProfile) GetPrice(amountOfData float64, explicitDura
 	return p.Pricing.GetPrice(amountOfData, explicitDuration, start, &end)
 }
 
-func (p *DataResourcePricingProfile) IsBuying() bool {
+func (p *DataResourcePricingProfile) IsPurchased() bool {
 	return p.Pricing.BuyingStrategy != pricing.PAY_PER_USE
 }
 
 type CustomizedDataResource struct {
 	AbstractCustomizedResource[*ResourceInstance[*DataResourcePartnership]]
-	abstractDataResource
 	StorageGB float64 `json:"storage_gb,omitempty" bson:"storage_gb,omitempty"`
 }
 
diff --git a/models/resources/priced_resource/priced_resource.go b/models/resources/priced_resource/priced_resource.go
new file mode 100644
index 0000000..22fefbb
--- /dev/null
+++ b/models/resources/priced_resource/priced_resource.go
@@ -0,0 +1,6 @@
+package priced_resource
+
+type PricedResource struct {
+}
+
+/*TODO*/
diff --git a/models/resources/processing.go b/models/resources/processing.go
index 752882e..c88f504 100644
--- a/models/resources/processing.go
+++ b/models/resources/processing.go
@@ -19,28 +19,24 @@ type ProcessingUsage struct {
 	ScalingModel string  `bson:"scaling_model,omitempty" json:"scaling_model,omitempty"` // ScalingModel is the scaling model
 }
 
-type abstractProcessingResource struct {
-	Infrastructure common.InfrastructureType `json:"infrastructure,omitempty" bson:"infrastructure,omitempty"`
-	Service        bool                      `json:"is_service,omitempty" bson:"is_service,omitempty"` // IsService is a flag that indicates if the processing is a service
-	Usage          *ProcessingUsage          `bson:"usage,omitempty" json:"usage,omitempty"`           // Usage is the usage of the processing
-}
-
 /*
 * ProcessingResource is a struct that represents a processing resource
 * it defines the resource processing
  */
 type ProcessingResource struct {
 	AbstractResource[*ResourceInstance[*ResourcePartnerShip[*ProcessingResourcePricingProfile]]]
-	abstractProcessingResource
-	OpenSource bool   `json:"open_source" bson:"open_source" default:"false"`
-	License    string `json:"license,omitempty" bson:"license,omitempty"`
-	Maturity   string `json:"maturity,omitempty" bson:"maturity,omitempty"`
+	Infrastructure common.InfrastructureType `json:"infrastructure,omitempty" bson:"infrastructure,omitempty"`
+	IsService      bool                      `json:"is_service,omitempty" bson:"is_service,omitempty"` // IsService is a flag that indicates if the processing is a service
+	Usage          *ProcessingUsage          `bson:"usage,omitempty" json:"usage,omitempty"`           // Usage is the usage of the processing
+	OpenSource     bool                      `json:"open_source" bson:"open_source" default:"false"`
+	License        string                    `json:"license,omitempty" bson:"license,omitempty"`
+	Maturity       string                    `json:"maturity,omitempty" bson:"maturity,omitempty"`
+	Container      common.Container          `json:"container,omitempty" bson:"container,omitempty"` // Container is the container
 }
 
 type CustomizedProcessingResource struct {
 	AbstractCustomizedResource[*ResourceInstance[*ResourcePartnerShip[*ProcessingResourcePricingProfile]]]
-	abstractProcessingResource
-	Container common.Container `json:"container,omitempty" bson:"container,omitempty"` // Container is the container
+	IsService bool
 }
 
 func (r *CustomizedProcessingResource) GetType() tools.DataType {
@@ -49,8 +45,8 @@ func (r *CustomizedProcessingResource) GetType() tools.DataType {
 
 func (a *CustomizedProcessingResource) GetExplicitDurationInS() float64 {
 	if a.ExplicitBookingDurationS == 0 {
-		if a.UsageEnd == nil || a.UsageStart == nil {
-			if a.Service {
+		if a.IsService || a.UsageStart == nil {
+			if a.IsService {
 				return -1
 			}
 			return time.Duration(1 * time.Hour).Seconds()
@@ -68,7 +64,7 @@ type ProcessingResourcePricingProfile struct {
 	pricing.AccessPricingProfile[pricing.TimePricingStrategy] // AccessPricingProfile is the pricing profile of a data it means that we can access the data for an amount of time
 }
 
-func (p *ProcessingResourcePricingProfile) IsBuying() bool {
+func (p *ProcessingResourcePricingProfile) IsPurchased() bool {
 	return p.Pricing.BuyingStrategy != pricing.PAY_PER_USE
 }
 
diff --git a/models/resources/purchase_resource/purchase_resource.go b/models/resources/purchase_resource/purchase_resource.go
new file mode 100644
index 0000000..0f02de2
--- /dev/null
+++ b/models/resources/purchase_resource/purchase_resource.go
@@ -0,0 +1,30 @@
+package purchase_resource
+
+import (
+	"time"
+
+	"cloud.o-forge.io/core/oc-lib/models/utils"
+	"cloud.o-forge.io/core/oc-lib/tools"
+)
+
+type PurchaseResource struct {
+	utils.AbstractObject
+	EndDate      *time.Time     `json:"end_buying_date,omitempty" bson:"end_buying_date,omitempty"`
+	ResourceID   string         `json:"resource_id" bson:"resource_id" validate:"required"`
+	ResourceType tools.DataType `json:"resource_type" bson:"resource_type" validate:"required"`
+}
+
+func (d *PurchaseResource) GetAccessor(request *tools.APIRequest) utils.Accessor {
+	return NewAccessor(request) // Create a new instance of the accessor
+}
+
+func (r *PurchaseResource) CanUpdate(set utils.DBObject) (bool, utils.DBObject) {
+	return r.IsDraft, set // only draft buying can be updated
+}
+
+func (r *PurchaseResource) CanDelete() bool { // ENDBuyingDate is passed
+	if r.EndDate != nil {
+		return time.Now().UTC().After(*r.EndDate)
+	}
+	return false // only draft bookings can be deleted
+}
diff --git a/models/resources/purchase_resource/purchase_resource_accessor.go b/models/resources/purchase_resource/purchase_resource_accessor.go
new file mode 100644
index 0000000..d30ae15
--- /dev/null
+++ b/models/resources/purchase_resource/purchase_resource_accessor.go
@@ -0,0 +1,72 @@
+package purchase_resource
+
+import (
+	"time"
+
+	"cloud.o-forge.io/core/oc-lib/dbs"
+	"cloud.o-forge.io/core/oc-lib/logs"
+	"cloud.o-forge.io/core/oc-lib/models/utils"
+	"cloud.o-forge.io/core/oc-lib/tools"
+)
+
+type purchaseResourceMongoAccessor struct {
+	utils.AbstractAccessor // AbstractAccessor contains the basic fields of an accessor (model, caller)
+}
+
+// New creates a new instance of the bookingMongoAccessor
+func NewAccessor(request *tools.APIRequest) *purchaseResourceMongoAccessor {
+	return &purchaseResourceMongoAccessor{
+		AbstractAccessor: utils.AbstractAccessor{
+			Logger:  logs.CreateLogger(tools.BUYING_STATUS.String()), // Create a logger with the data type
+			Request: request,
+			Type:    tools.BUYING_STATUS,
+		},
+	}
+}
+
+/*
+* Nothing special here, just the basic CRUD operations
+ */
+func (a *purchaseResourceMongoAccessor) DeleteOne(id string) (utils.DBObject, int, error) {
+	return utils.GenericDeleteOne(id, a)
+}
+
+func (a *purchaseResourceMongoAccessor) UpdateOne(set utils.DBObject, id string) (utils.DBObject, int, error) {
+	return utils.GenericUpdateOne(set, id, a, &PurchaseResource{})
+}
+
+func (a *purchaseResourceMongoAccessor) StoreOne(data utils.DBObject) (utils.DBObject, int, error) {
+	return utils.GenericStoreOne(data, a)
+}
+
+func (a *purchaseResourceMongoAccessor) CopyOne(data utils.DBObject) (utils.DBObject, int, error) {
+	return utils.GenericStoreOne(data, a)
+}
+
+func (a *purchaseResourceMongoAccessor) LoadOne(id string) (utils.DBObject, int, error) {
+	return utils.GenericLoadOne[*PurchaseResource](id, func(d utils.DBObject) (utils.DBObject, int, error) {
+		if d.(*PurchaseResource).EndDate != nil && time.Now().UTC().After(*d.(*PurchaseResource).EndDate) {
+			utils.GenericDeleteOne(id, a)
+			return nil, 404, nil
+		}
+		return d, 200, nil
+	}, a)
+}
+
+func (a *purchaseResourceMongoAccessor) LoadAll(isDraft bool) ([]utils.ShallowDBObject, int, error) {
+	return utils.GenericLoadAll[*PurchaseResource](a.getExec(), isDraft, a)
+}
+
+func (a *purchaseResourceMongoAccessor) Search(filters *dbs.Filters, search string, isDraft bool) ([]utils.ShallowDBObject, int, error) {
+	return utils.GenericSearch[*PurchaseResource](filters, search, (&PurchaseResource{}).GetObjectFilters(search), a.getExec(), isDraft, a)
+}
+
+func (a *purchaseResourceMongoAccessor) getExec() func(utils.DBObject) utils.ShallowDBObject {
+	return func(d utils.DBObject) utils.ShallowDBObject {
+		if d.(*PurchaseResource).EndDate != nil && time.Now().UTC().After(*d.(*PurchaseResource).EndDate) {
+			utils.GenericDeleteOne(d.GetID(), a)
+			return nil
+		}
+		return d
+	}
+}
diff --git a/models/resources/resource.go b/models/resources/resource.go
index 0e6d60b..b10d687 100644
--- a/models/resources/resource.go
+++ b/models/resources/resource.go
@@ -130,8 +130,8 @@ func (abs *AbstractCustomizedResource[T]) SetEndUsage(end time.Time) {
 	}
 }
 
-func (abs *AbstractCustomizedResource[T]) IsBuying(request *tools.APIRequest) bool {
-	return abs.GetPartnership(request).GetPricing(abs.SelectedPricing).IsBuying()
+func (abs *AbstractCustomizedResource[T]) IsPurchased(request *tools.APIRequest) bool {
+	return abs.GetPartnership(request).GetPricing(abs.SelectedPricing).IsPurchased()
 }
 
 func (abs *AbstractCustomizedResource[T]) GetLocationEnd() *time.Time {
diff --git a/models/resources/storage.go b/models/resources/storage.go
index 90cc422..6b629f6 100644
--- a/models/resources/storage.go
+++ b/models/resources/storage.go
@@ -99,7 +99,7 @@ type StorageResourcePricingProfile struct {
 	pricing.ExploitPricingProfile[StorageResourcePricingStrategy] // ExploitPricingProfile is the pricing profile of a storage it means that we exploit the resource for an amount of continuous time
 }
 
-func (p *StorageResourcePricingProfile) IsBuying() bool {
+func (p *StorageResourcePricingProfile) IsPurchased() bool {
 	return p.Pricing.BuyingStrategy != pricing.PAY_PER_USE
 }
 
diff --git a/models/resources/workflow.go b/models/resources/workflow.go
index e3065dd..8592e41 100644
--- a/models/resources/workflow.go
+++ b/models/resources/workflow.go
@@ -47,7 +47,7 @@ func (p *WorkflowResourcePricingProfile) GetID() string {
 	return p.ID
 }
 
-func (p *WorkflowResourcePricingProfile) IsBuying() bool {
+func (p *WorkflowResourcePricingProfile) IsPurchased() bool {
 	return false
 }
 
diff --git a/models/utils/abstracts.go b/models/utils/abstracts.go
index 285fa30..c57baee 100644
--- a/models/utils/abstracts.go
+++ b/models/utils/abstracts.go
@@ -27,13 +27,15 @@ const (
 * every data in base root model should inherit from this struct (only exception is the ResourceModel)
  */
 type AbstractObject struct {
-	UUID           string     `json:"id,omitempty" bson:"id,omitempty" validate:"required"`
-	Name           string     `json:"name,omitempty" bson:"name,omitempty" validate:"required"`
-	IsDraft        bool       `json:"is_draft" bson:"is_draft" default:"false"`
-	UpdateDate     time.Time  `json:"update_date" bson:"update_date"`
-	LastPeerWriter string     `json:"last_peer_writer" bson:"last_peer_writer"`
-	CreatorID      string     `json:"creator_id" bson:"creator_id" default:"unknown"`
-	AccessMode     AccessMode `json:"access_mode" bson:"access_mode" default:"0"`
+	UUID      string `json:"id,omitempty" bson:"id,omitempty" validate:"required"`
+	Name      string `json:"name,omitempty" bson:"name,omitempty" validate:"required"`
+	IsDraft   bool   `json:"is_draft" bson:"is_draft" default:"false"`
+	CreatorID string `json:"creator_id" bson:"creator_id" default:"unknown"`
+
+	CreationDate time.Time  `json:"creation_date" bson:"creation_date"`
+	UpdateDate   time.Time  `json:"update_date" bson:"update_date"`
+	UpdaterID    string     `json:"updater_id" bson:"updater_id"`
+	AccessMode   AccessMode `json:"access_mode" bson:"access_mode" default:"0"`
 }
 
 func (r *AbstractObject) GenerateID() {
@@ -70,8 +72,9 @@ func (ao AbstractObject) GetName() string {
 
 func (ao *AbstractObject) UpToDate(user string, create bool) {
 	ao.UpdateDate = time.Now()
-	ao.LastPeerWriter = user
+	ao.UpdaterID = user
 	if create {
+		ao.CreationDate = time.Now()
 		ao.CreatorID = user
 	}
 }
diff --git a/models/workflow/workflow_test.go b/models/workflow/workflow_test.go
index dc515e2..57b3b99 100644
--- a/models/workflow/workflow_test.go
+++ b/models/workflow/workflow_test.go
@@ -4,7 +4,6 @@ import (
 	"testing"
 
 	"cloud.o-forge.io/core/oc-lib/models/utils"
-	"cloud.o-forge.io/core/oc-lib/tools"
 	"github.com/stretchr/testify/assert"
 )
 
@@ -13,7 +12,7 @@ func TestStoreOneWorkflow(t *testing.T) {
 		AbstractObject: utils.AbstractObject{Name: "testWorkflow"},
 	}
 
-	wma := NewAccessor(tools.APIRequest{})
+	wma := NewAccessor(nil)
 	id, _, _ := wma.StoreOne(&w)
 
 	assert.NotEmpty(t, id)
@@ -24,7 +23,7 @@ func TestLoadOneWorkflow(t *testing.T) {
 		AbstractObject: utils.AbstractObject{Name: "testWorkflow"},
 	}
 
-	wma := NewAccessor(tools.APIRequest{})
+	wma := NewAccessor(nil)
 	new_w, _, _ := wma.StoreOne(&w)
 	assert.Equal(t, w, new_w)
 }
diff --git a/models/workflow_execution/workflow_execution.go b/models/workflow_execution/workflow_execution.go
index 1e883d6..fcc1da5 100644
--- a/models/workflow_execution/workflow_execution.go
+++ b/models/workflow_execution/workflow_execution.go
@@ -98,14 +98,14 @@ func (d *WorkflowExecutions) GetName() string {
 }
 
 func (d *WorkflowExecutions) GetAccessor(request *tools.APIRequest) utils.Accessor {
-	return NewShallowAccessor(request) // Create a new instance of the accessor
+	return NewAccessor(request) // Create a new instance of the accessor
 }
 
 func (d *WorkflowExecutions) VerifyAuth(request *tools.APIRequest) bool {
 	return true
 }
 
-func (d *WorkflowExecutions) ToBookings(wf *workflow.Workflow) []*booking.Booking {
+func (d *WorkflowExecutions) Book(wf *workflow.Workflow) []*booking.Booking {
 	booking := []*booking.Booking{}
 	for _, p := range wf.ProcessingResources {
 		booking = append(booking, d.toItemBooking(wf.GetByRelatedProcessing(p.GetID(), wf.IsStorage))...)
diff --git a/models/workflow_execution/workflow_scheduler.go b/models/workflow_execution/workflow_scheduler.go
index 3625b25..f793ccd 100644
--- a/models/workflow_execution/workflow_scheduler.go
+++ b/models/workflow_execution/workflow_scheduler.go
@@ -16,11 +16,6 @@ import (
 	"github.com/robfig/cron"
 )
 
-type Schedule struct {
-	Start time.Time
-	End   *time.Time
-}
-
 /*
 * WorkflowSchedule is a struct that contains the scheduling information of a workflow
 * It contains the mode of the schedule (Task or Service), the name of the schedule, the start and end time of the schedule and the cron expression
@@ -78,7 +73,7 @@ func (ws *WorkflowSchedule) CheckBooking(wfID string, caller *tools.HTTPCaller)
 		return false, wf, []*WorkflowExecutions{}, err
 	}
 	for _, exec := range execs {
-		bookings := exec.ToBookings(wf)
+		bookings := exec.Book(wf)
 		for _, booking := range bookings {
 			_, err := (&peer.Peer{}).LaunchPeerExecution(booking.DestPeerID, "",
 				tools.BOOKING, tools.POSTCHECK, booking.Serialize(booking), caller)
@@ -243,6 +238,11 @@ func (ws *WorkflowSchedule) getDates() ([]Schedule, error) {
 	return schedule, nil
 }
 
+type Schedule struct {
+	Start time.Time
+	End   *time.Time
+}
+
 /*
 * TODO : LARGEST GRAIN PLANIFYING THE WORKFLOW WHEN OPTION IS SET
 * SET PROTECTION BORDER TIME