go-cart-actor/cmd/cart/product-fetcher.go

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"net/http"

	"git.k6n.net/go-cart-actor/pkg/cart"
	messages "git.k6n.net/go-cart-actor/proto/cart"

	"github.com/matst80/slask-finder/pkg/index"
)

// TODO make this configurable
func getBaseUrl(country string) string {
	// if country == "se" {
	// 	return "http://s10n-se:8080"
	// }
	if country == "no" {
		return "http://s10n-no.s10n:8080"
	}
	if country == "se" {
		return "http://s10n-se.s10n:8080"
	}
	return "http://localhost:8082"
}

func FetchItem(ctx context.Context, sku string, country string) (*index.DataItem, error) {
	baseUrl := getBaseUrl(country)
	req, err := http.NewRequest("GET", fmt.Sprintf("%s/api/by-sku/%s", baseUrl, sku), nil)
	innerCtx, span := tracer.Start(ctx, fmt.Sprintf("fetching data for %s", sku))
	defer span.End()
	req = req.WithContext(innerCtx)
	if err != nil {
		return nil, err
	}
	res, err := http.DefaultClient.Do(req)
	if err != nil {
		return nil, err
	}
	defer res.Body.Close()
	var item index.DataItem
	err = json.NewDecoder(res.Body).Decode(&item)
	return &item, err
}

func GetItemAddMessage(ctx context.Context, sku string, qty int, country string, storeId *string) (*messages.AddItem, error) {
	item, err := FetchItem(ctx, sku, country)
	if err != nil {
		return nil, err
	}
	return ToItemAddMessage(item, storeId, qty, country)
}

func ToItemAddMessage(item *index.DataItem, storeId *string, qty int, country string) (*messages.AddItem, error) {
	orgPrice, _ := getInt(item.GetNumberFieldValue(5)) // getInt(item.Fields[5])

	price, err := getInt(item.GetNumberFieldValue(4)) //Fields[4]
	if err != nil {
		return nil, err
	}
	stk := item.GetStock()
	stock := cart.StockStatus(0)

	if storeId == nil {
		centralStock, ok := stk[country]
		if ok {
			if !item.Buyable {
				return nil, fmt.Errorf("item not available")
			}

			if centralStock == 0 && item.SaleStatus == "TBD" {
				return nil, fmt.Errorf("no items available")
			}
			stock = cart.StockStatus(centralStock)
		}

	} else {
		if !item.BuyableInStore {
			return nil, fmt.Errorf("item not available in store")
		}
		storeStock, ok := stk[*storeId]
		if ok {
			stock = cart.StockStatus(storeStock)
		}

	}

	articleType, _ := item.GetStringFieldValue(1)   //.Fields[1].(string)
	outletGrade, ok := item.GetStringFieldValue(20) //.Fields[20].(string)
	var outlet *string
	if ok {
		outlet = &outletGrade
	}
	sellerId, _ := item.GetStringFieldValue(24)  // .Fields[24].(string)
	sellerName, _ := item.GetStringFieldValue(9) // .Fields[9].(string)

	brand, _ := item.GetStringFieldValue(2)      //.Fields[2].(string)
	category, _ := item.GetStringFieldValue(10)  //.Fields[10].(string)
	category2, _ := item.GetStringFieldValue(11) //.Fields[11].(string)
	category3, _ := item.GetStringFieldValue(12) //.Fields[12].(string)
	category4, _ := item.GetStringFieldValue(13) //Fields[13].(string)
	category5, _ := item.GetStringFieldValue(14) //.Fields[14].(string)

	cgm, _ := item.GetStringFieldValue(35) // Customer Group Membership

	return &messages.AddItem{
		ItemId:      uint32(item.Id),
		Quantity:    int32(qty),
		Price:       int64(price),
		OrgPrice:    int64(orgPrice),
		Sku:         item.GetSku(),
		Name:        item.Title,
		Image:       item.Img,
		Stock:       int32(stock),
		Brand:       brand,
		Category:    category,
		Category2:   category2,
		Category3:   category3,
		Category4:   category4,
		Category5:   category5,
		Tax:         getTax(articleType),
		SellerId:    sellerId,
		SellerName:  sellerName,
		ArticleType: articleType,
		Disclaimer:  item.Disclaimer,
		Country:     country,
		Outlet:      outlet,
		StoreId:     storeId,
		SaleStatus:  item.SaleStatus,
		Cgm:         cgm,
	}, nil
}

func getTax(articleType string) int32 {
	switch articleType {
	case "ZDIE":
		return 600
	default:
		return 2500
	}
}

func getInt(data float64, ok bool) (int, error) {
	if !ok {
		return 0, fmt.Errorf("invalid type")
	}
	return int(data), nil
}