mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

Complete refactor to new grpc control plane and only http proxy for carts #4

Merged
mats merged 75 commits from refactor/http-proxy into main 2025-10-14 22:31:28 +02:00
Conversation 0 Commits 75 Files Changed 88 +12 -10
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 22ac64c14d - Show all commits

22
cmd/cart/pool-server.go
View File

@@ -177,18 +177,20 @@ type SetCartItems struct {
func getMultipleAddMessages(items []Item, country string) []proto.Message { func getMultipleAddMessages(items []Item, country string) []proto.Message {
wg := sync.WaitGroup{} wg := sync.WaitGroup{}
mu := sync.Mutex{}
msgs := make([]proto.Message, 0, len(items)) msgs := make([]proto.Message, 0, len(items))
for _, itm := range items { for _, itm := range items {
wg.Add(1) wg.Go(
go func(itm Item) { func() {
defer wg.Done() msg, err := GetItemAddMessage(itm.Sku, itm.Quantity, country, itm.StoreId)
msg, err := GetItemAddMessage(itm.Sku, itm.Quantity, country, itm.StoreId) if err != nil {
if err != nil { log.Printf("error adding item %s: %v", itm.Sku, err)
log.Printf("error adding item %s: %v", itm.Sku, err) return
return }
} mu.Lock()
msgs = append(msgs, msg) msgs = append(msgs, msg)
}(itm) mu.Unlock()
})
} }
wg.Wait() wg.Wait()
return msgs return msgs