pkg/cart/cart-grain.go

@@ -81,6 +81,7 @@ type CartGrain struct {
 	lastAccess          time.Time
 	lastChange          time.Time // unix seconds of last successful mutation (replay sets from event ts)
 	userId              string
+	InventoryReserved   bool                            `json:"inventoryReserved"`
 	Id                  CartId                          `json:"id"`
 	Items               []*CartItem                     `json:"items"`
 	TotalPrice          *Price                          `json:"totalPrice"`

pkg/cart/cart-mutation-helper.go

@@ -45,6 +45,9 @@ func NewCartMultationRegistry() actor.MutationRegistry {
 		actor.NewMutation(UpsertSubscriptionDetails, func() *messages.UpsertSubscriptionDetails {
 			return &messages.UpsertSubscriptionDetails{}
 		}),
+		actor.NewMutation(InventoryReserved, func() *messages.InventoryReserved {
+			return &messages.InventoryReserved{}
+		}),
 		actor.NewMutation(PreConditionFailed, func() *messages.PreConditionFailed {
 			return &messages.PreConditionFailed{}
 		}),

pkg/cart/mutation_inventory_reserved.go

@@ -0,0 +1,8 @@
+package cart
+
+import "git.tornberg.me/go-cart-actor/pkg/messages"
+
+func InventoryReserved(g *CartGrain, m *messages.InventoryReserved) error {
+	g.InventoryReserved = true
+	return nil
+}