remove promotions for now
All checks were successful
Build and Publish / BuildAndDeployAmd64 (push) Successful in 35s
Build and Publish / BuildAndDeployArm64 (push) Successful in 3m49s

This commit is contained in:
matst80
2025-11-25 23:16:54 +01:00
parent d5d2b3e711
commit 59e01e763f
2 changed files with 11 additions and 10 deletions

View File

@@ -82,7 +82,7 @@ func main() {
inventoryPubSub := actor.NewPubSub[inventory.InventoryChange]() inventoryPubSub := actor.NewPubSub[inventory.InventoryChange]()
promotionService := promotions.NewPromotionService(nil) // promotionService := promotions.NewPromotionService(nil)
reg := cart.NewCartMultationRegistry() reg := cart.NewCartMultationRegistry()
reg.RegisterProcessor( reg.RegisterProcessor(
@@ -91,12 +91,14 @@ func main() {
defer span.End() defer span.End()
g.UpdateTotals() g.UpdateTotals()
promotionCtx := promotions.NewContextFromCart(g, promotions.WithNow(time.Now()), promotions.WithCustomerSegment("vip")) // promotionCtx := promotions.NewContextFromCart(g, promotions.WithNow(time.Now()), promotions.WithCustomerSegment("vip"))
_, actions := promotionService.EvaluateAll(promotionData.State.Promotions, promotionCtx) // _, actions := promotionService.EvaluateAll(promotionData.State.Promotions, promotionCtx)
for _, action := range actions { // for _, action := range actions {
log.Printf("apply: %+v", action)
g.UpdateTotals() // log.Printf("apply: %+v", action)
}
// g.UpdateTotals()
// }
return nil return nil
}), }),
) )

View File

@@ -2,7 +2,6 @@ package actor
import ( import (
"iter" "iter"
"log"
"slices" "slices"
"sync" "sync"
) )
@@ -28,7 +27,7 @@ func (p *PubSub[V]) Subscribe(receiver ReceiverFunc[V]) {
} }
p.mu.Lock() p.mu.Lock()
defer p.mu.Unlock() defer p.mu.Unlock()
log.Printf("adding subscriber") // log.Printf("adding subscriber")
p.subscribers = append(p.subscribers, &receiver) p.subscribers = append(p.subscribers, &receiver)
} }
@@ -43,7 +42,7 @@ func (p *PubSub[V]) Unsubscribe(receiver ReceiverFunc[V]) {
continue continue
} }
if sub == prt { if sub == prt {
log.Printf("removing subscriber") // log.Printf("removing subscriber")
p.subscribers = append(list[:i], list[i+1:]...) p.subscribers = append(list[:i], list[i+1:]...)
break break
} }