diff --git a/cmd/cart/main.go b/cmd/cart/main.go index 1882c2f..7226698 100644 --- a/cmd/cart/main.go +++ b/cmd/cart/main.go @@ -82,7 +82,7 @@ func main() { inventoryPubSub := actor.NewPubSub[inventory.InventoryChange]() - promotionService := promotions.NewPromotionService(nil) + // promotionService := promotions.NewPromotionService(nil) reg := cart.NewCartMultationRegistry() reg.RegisterProcessor( @@ -91,12 +91,14 @@ func main() { defer span.End() g.UpdateTotals() - promotionCtx := promotions.NewContextFromCart(g, promotions.WithNow(time.Now()), promotions.WithCustomerSegment("vip")) - _, actions := promotionService.EvaluateAll(promotionData.State.Promotions, promotionCtx) - for _, action := range actions { - log.Printf("apply: %+v", action) - g.UpdateTotals() - } + // promotionCtx := promotions.NewContextFromCart(g, promotions.WithNow(time.Now()), promotions.WithCustomerSegment("vip")) + // _, actions := promotionService.EvaluateAll(promotionData.State.Promotions, promotionCtx) + // for _, action := range actions { + + // log.Printf("apply: %+v", action) + + // g.UpdateTotals() + // } return nil }), ) diff --git a/pkg/actor/pubsub.go b/pkg/actor/pubsub.go index c066ac7..0b13aef 100644 --- a/pkg/actor/pubsub.go +++ b/pkg/actor/pubsub.go @@ -2,7 +2,6 @@ package actor import ( "iter" - "log" "slices" "sync" ) @@ -28,7 +27,7 @@ func (p *PubSub[V]) Subscribe(receiver ReceiverFunc[V]) { } p.mu.Lock() defer p.mu.Unlock() - log.Printf("adding subscriber") + // log.Printf("adding subscriber") p.subscribers = append(p.subscribers, &receiver) } @@ -43,7 +42,7 @@ func (p *PubSub[V]) Unsubscribe(receiver ReceiverFunc[V]) { continue } if sub == prt { - log.Printf("removing subscriber") + // log.Printf("removing subscriber") p.subscribers = append(list[:i], list[i+1:]...) break }