factory.go

package application

import (
	"context"
	"crypto/sha512"
	"encoding/base64"
	"encoding/hex"
	"net/url"
	"regexp"
	"strconv"
	"strings"

	customerDomain "flamingo.me/flamingo-commerce/v3/customer/domain"
	"flamingo.me/flamingo/v3/core/auth"
	"flamingo.me/flamingo/v3/framework/flamingo"
	"flamingo.me/flamingo/v3/framework/web"
	"github.com/pkg/errors"
	"go.opencensus.io/tag"

	"flamingo.me/flamingo-commerce/v3/cart/domain/decorator"
	productDomain "flamingo.me/flamingo-commerce/v3/product/domain"
	"flamingo.me/flamingo-commerce/v3/w3cdatalayer/domain"
)

type (
	// Factory is used to build new datalayers
	Factory struct {
		router                  *web.Router
		logger                  flamingo.Logger
		datalayerProvider       domain.DatalayerProvider
		webIdentityService      *auth.WebIdentityService
		customerIdentityService customerDomain.CustomerIdentityService
		hashEncoder             encoder

		pageInstanceIDPrefix           string
		pageInstanceIDStage            string
		productMediaBaseURL            string
		productMediaURLPrefix          string
		productMediaThumbnailURLPrefix string
		pageNamePrefix                 string
		siteName                       string
		locale                         string
		defaultCurrency                string
		hashUserValues                 bool
		regex                          *regexp.Regexp
	}

	// hexEncoder is a wrapper for hex.EncodeToString
	hexEncoder struct{}

	encoder interface {
		EncodeToString(src []byte) string
	}
)

func (h *hexEncoder) EncodeToString(src []byte) string {
	return hex.EncodeToString(src)
}

// Inject factory dependencies
func (s *Factory) Inject(
	router2 *web.Router,
	logger flamingo.Logger,
	provider domain.DatalayerProvider,
	webIdentityService *auth.WebIdentityService,
	customerIdentityService customerDomain.CustomerIdentityService,
	config *struct {
		PageInstanceIDPrefix           string `inject:"config:commerce.w3cDatalayer.pageInstanceIDPrefix,optional"`
		PageInstanceIDStage            string `inject:"config:commerce.w3cDatalayer.pageInstanceIDStage,optional"`
		ProductMediaBaseURL            string `inject:"config:commerce.w3cDatalayer.productMediaBaseUrl,optional"`
		ProductMediaURLPrefix          string `inject:"config:commerce.w3cDatalayer.productMediaUrlPrefix,optional"`
		ProductMediaThumbnailURLPrefix string `inject:"config:commerce.w3cDatalayer.productMediaThumbnailUrlPrefix,optional"`
		PageNamePrefix                 string `inject:"config:commerce.w3cDatalayer.pageNamePrefix,optional"`
		SiteName                       string `inject:"config:commerce.w3cDatalayer.siteName,optional"`
		Locale                         string `inject:"config:locale.locale,optional"`
		DefaultCurrency                string `inject:"config:commerce.w3cDatalayer.defaultCurrency,optional"`
		HashUserValues                 bool   `inject:"config:commerce.w3cDatalayer.hashUserValues,optional"`
		HashEncoding                   string `inject:"config:commerce.w3cDatalayer.hashEncoding,optional"`
	},
) {
	s.router = router2
	s.logger = logger.WithField(flamingo.LogKeyModule, "w3cdatalayer")
	s.datalayerProvider = provider
	s.webIdentityService = webIdentityService
	s.customerIdentityService = customerIdentityService

	s.pageInstanceIDPrefix = config.PageInstanceIDPrefix
	s.pageInstanceIDStage = config.PageInstanceIDStage
	s.productMediaBaseURL = config.ProductMediaBaseURL
	s.productMediaURLPrefix = config.ProductMediaURLPrefix
	s.productMediaThumbnailURLPrefix = config.ProductMediaThumbnailURLPrefix
	s.pageNamePrefix = config.PageNamePrefix
	s.siteName = config.SiteName
	s.locale = config.Locale
	s.defaultCurrency = config.DefaultCurrency
	s.hashUserValues = config.HashUserValues

	if config.HashUserValues {
		switch config.HashEncoding {
		case "base64url":
			s.hashEncoder = base64.URLEncoding
		case "hex":
			s.hashEncoder = &hexEncoder{}
		default:
			s.logger.Warn("invalid configuration for commerce.w3cDatalayer.hashEncoding, using base64url encoding as fallback")
			s.hashEncoder = base64.URLEncoding
		}
	}

	regexString := "[,|;|\\|]"
	r, err := regexp.Compile(regexString)
	if err != nil {
		panic(err)
	}
	s.regex = r
}

// BuildForCurrentRequest builds the datalayer for the current request
func (s Factory) BuildForCurrentRequest(ctx context.Context, request *web.Request) domain.Datalayer {
	layer := s.datalayerProvider()

	// get language from locale code configuration
	language := ""
	localeParts := strings.Split(s.locale, "-")
	if len(localeParts) > 0 {
		language = localeParts[0]
	}

	baseURL, err := s.router.Absolute(request, request.Request().URL.Path, nil)
	if err != nil {
		s.logger.Warn(errors.Wrap(err, "cannot build absolute url"))
		baseURL = new(url.URL)
	}
	layer.Page = &domain.Page{
		PageInfo: domain.PageInfo{
			PageID:         request.Request().URL.Path,
			PageName:       s.pageNamePrefix + request.Request().URL.Path,
			DestinationURL: baseURL.String(),
			Language:       language,
		},
		Attributes: make(map[string]interface{}),
	}

	layer.Page.Attributes["currency"] = s.defaultCurrency

	// Use the handler name as PageId if available
	if controllerHandler, ok := tag.FromContext(ctx).Value(web.ControllerKey); ok {
		layer.Page.PageInfo.PageID = controllerHandler
	}

	layer.SiteInfo = &domain.SiteInfo{
		SiteName: s.siteName,
	}

	layer.PageInstanceID = s.pageInstanceIDPrefix + s.pageInstanceIDStage

	// Handle User
	layer.Page.Attributes["loggedIn"] = false
	layer.Page.Attributes["logintype"] = "guest"

	identity := s.webIdentityService.Identify(ctx, request)
	if identity != nil {
		// logged in
		layer.Page.Attributes["loggedIn"] = true
		layer.Page.Attributes["logintype"] = "external"
		userData := s.getUserFromIdentity(ctx, identity)
		if userData != nil {
			layer.User = append(layer.User, *userData)
		}
	}

	return *layer
}

func (s Factory) getUserFromIdentity(ctx context.Context, identity auth.Identity) *domain.User {
	if identity == nil {
		return nil
	}

	customer, err := s.customerIdentityService.GetByIdentity(ctx, identity)
	if err != nil {
		return nil
	}

	dataLayerProfile := s.getUserProfile(customer.GetPersonalData().MainEmail, identity.Subject())
	if dataLayerProfile == nil {
		return nil
	}

	dataLayerUser := domain.User{}
	dataLayerUser.Profile = append(dataLayerUser.Profile, *dataLayerProfile)
	return &dataLayerUser
}

func (s Factory) getUserProfile(email string, sub string) *domain.UserProfile {
	dataLayerProfile := domain.UserProfile{
		ProfileInfo: domain.UserProfileInfo{
			EmailID:   s.HashValueIfConfigured(email),
			ProfileID: s.HashValueIfConfigured(sub),
		},
	}
	return &dataLayerProfile
}

// HashValueIfConfigured returns the hashed `value` if hashing is configured
func (s Factory) HashValueIfConfigured(value string) string {
	if s.hashUserValues && value != "" {
		return s.hashWithSHA512(value)
	}
	return value
}

// BuildCartData builds the domain cart data
func (s Factory) BuildCartData(cart decorator.DecoratedCart) *domain.Cart {
	cartData := domain.Cart{
		CartID: cart.Cart.ID,
		Price: &domain.CartPrice{
			Currency:       cart.Cart.GrandTotal().Currency(),
			BasePrice:      cart.Cart.SubTotalNet().FloatAmount(),
			CartTotal:      cart.Cart.GrandTotal().FloatAmount(),
			Shipping:       cart.Cart.SumShippingNet().FloatAmount(),
			ShippingMethod: strings.Join(cart.Cart.AllShippingTitles(), "/"),
			PriceWithTax:   cart.Cart.GrandTotal().FloatAmount(),
		},
		Attributes: make(map[string]interface{}),
	}
	for _, item := range cart.GetAllDecoratedItems() {
		itemData := s.buildCartItem(item, cart.Cart.GrandTotal().Currency())
		cartData.Item = append(cartData.Item, itemData)
	}
	return &cartData
}

// BuildTransactionData builds the domain transaction data
func (s Factory) BuildTransactionData(ctx context.Context, cart decorator.DecoratedCart, decoratedItems []decorator.DecoratedCartItem, orderID string, email string) *domain.Transaction {
	identity := s.webIdentityService.Identify(ctx, web.RequestFromContext(ctx))
	profile := s.getUserProfile(email, "")

	if identity != nil {
		user := s.getUserFromIdentity(ctx, identity)
		if user != nil {
			profile = &user.Profile[0]
		}
	}

	transactionData := domain.Transaction{
		TransactionID: orderID,
		Price: &domain.TransactionPrice{
			Currency:         cart.Cart.GrandTotal().Currency(),
			BasePrice:        cart.Cart.GrandTotal().FloatAmount(),
			TransactionTotal: cart.Cart.GrandTotal().FloatAmount(),
			Shipping:         cart.Cart.SumShippingNet().FloatAmount(),
			ShippingMethod:   strings.Join(cart.Cart.AllShippingTitles(), "/"),
		},
		Profile:    profile,
		Attributes: make(map[string]interface{}),
	}
	for _, item := range decoratedItems {
		itemData := s.buildCartItem(item, cart.Cart.GrandTotal().Currency())
		transactionData.Item = append(transactionData.Item, itemData)
	}
	return &transactionData
}

func (s Factory) buildCartItem(item decorator.DecoratedCartItem, currencyCode string) domain.CartItem {
	cartItem := domain.CartItem{
		Category:    s.getProductCategory(item.Product),
		Quantity:    item.Item.Qty,
		ProductInfo: s.getProductInfo(item.Product),
		Price: domain.CartItemPrice{
			BasePrice:    item.Item.SinglePriceNet.FloatAmount(),
			PriceWithTax: item.Item.SinglePriceGross.FloatAmount(),
			TaxRate:      item.Item.TotalTaxAmount().FloatAmount(),
			Currency:     currencyCode,
		},
		Attributes: make(map[string]interface{}),
	}
	cartItem.Attributes["sourceId"] = item.Item.SourceID
	cartItem.Attributes["terminal"] = ""
	cartItem.Attributes["leadtime"] = ""
	return cartItem
}

// BuildProductData builds the domain product data
func (s Factory) BuildProductData(product productDomain.BasicProduct) domain.Product {
	productData := domain.Product{
		ProductInfo: s.getProductInfo(product),
		Category:    s.getProductCategory(product),
		Attributes:  make(map[string]interface{}),
	}

	// check for defaultVariant
	baseData := product.BaseData()
	saleableData := product.SaleableData()
	if product.Type() == productDomain.TypeConfigurable {
		if configurable, ok := product.(productDomain.ConfigurableProduct); ok {
			defaultVariant, _ := configurable.GetDefaultVariant()
			baseData = defaultVariant.BaseData()
			saleableData = defaultVariant.SaleableData()
		}
	}

	// set prices
	productData.Attributes["productPrice"] = strconv.FormatFloat(saleableData.ActivePrice.GetFinalPrice().FloatAmount(), 'f', 2, 64)

	// check for highstreet price
	if baseData.HasAttribute("rrp") {
		productData.Attributes["highstreetPrice"] = baseData.Attributes["rrp"].Value()
	}

	// if FinalPrice is discounted, add it to specialPrice
	if saleableData.ActivePrice.IsDiscounted {
		productData.Attributes["specialPrice"] = strconv.FormatFloat(saleableData.ActivePrice.Discounted.FloatAmount(), 'f', 2, 64)
		productData.Attributes["productPrice"] = strconv.FormatFloat(saleableData.ActivePrice.Default.FloatAmount(), 'f', 2, 64)
	}

	// set badge
	productData.Attributes["badge"] = s.EvaluateBadgeHierarchy(product)

	if product.BaseData().HasAttribute("ispuLimitedToAreas") {
		replacer := strings.NewReplacer("[", "", "]", "")
		productData.Attributes["ispuLimitedToAreas"] = strings.Split(replacer.Replace(product.BaseData().Attributes["ispuLimitedToAreas"].Value()), " ")
	}
	return productData
}

func (s Factory) getProductCategory(product productDomain.BasicProduct) *domain.ProductCategory {
	level0 := ""
	level1 := ""
	level2 := ""

	categoryPath := product.BaseData().MainCategory.Path
	baseData := product.BaseData()

	firstPathLevels := strings.Split(categoryPath, "/")
	if len(firstPathLevels) > 0 {
		level0 = firstPathLevels[0]
	}
	if len(firstPathLevels) > 1 {
		level1 = firstPathLevels[1]
	}
	if len(firstPathLevels) > 2 {
		level2 = firstPathLevels[2]
	}

	productFamily := ""
	if baseData.HasAttribute("gs1Family") {
		productFamily = baseData.Attributes["gs1Family"].Value()
	}
	return &domain.ProductCategory{
		PrimaryCategory: level0,
		SubCategory1:    level1,
		SubCategory2:    level2,
		SubCategory:     level1,
		ProductType:     productFamily,
	}
}

func (s Factory) getProductInfo(product productDomain.BasicProduct) domain.ProductInfo {
	baseData := product.BaseData()
	retailerCode := baseData.RetailerCode

	productName := s.regex.ReplaceAllString(baseData.Title, "-")

	// Handle Variants if it is a Configurable
	var parentIDRef *string
	var variantSelectedAttributeRef *string
	if product.Type() == productDomain.TypeConfigurableWithActiveVariant {
		if configurableWithActiveVariant, ok := product.(productDomain.ConfigurableProductWithActiveVariant); ok {
			parentID := configurableWithActiveVariant.ConfigurableBaseData().MarketPlaceCode
			parentIDRef = &parentID
			variantSelectedAttribute := configurableWithActiveVariant.ActiveVariant.BaseData().Attributes[configurableWithActiveVariant.VariantVariationAttributes[0]].Value()
			variantSelectedAttributeRef = &variantSelectedAttribute
		}
	}
	if product.Type() == productDomain.TypeConfigurable {
		if configurable, ok := product.(productDomain.ConfigurableProduct); ok {
			parentID := configurable.BaseData().MarketPlaceCode
			parentIDRef = &parentID

			defaultVariant, err := configurable.GetDefaultVariant()
			if err == nil {
				retailerCode = defaultVariant.RetailerCode
			}
		}
	}
	// Search for some common product attributes to fill the productInfos (This maybe better to be configurable later)
	color := ""
	if baseData.HasAttribute("manufacturerColor") {
		color = baseData.Attributes["manufacturerColor"].Value()
	}
	if baseData.HasAttribute("baseColor") {
		color = baseData.Attributes["baseColor"].Value()
	}
	size := ""
	if baseData.HasAttribute("shoeSize") {
		size = baseData.Attributes["shoeSize"].Value()
	}
	if baseData.HasAttribute("clothingSize") {
		size = baseData.Attributes["clothingSize"].Value()
	}
	brand := ""
	if baseData.HasAttribute("brandCode") {
		brand = baseData.Attributes["brandCode"].Value()
	}
	gtin := ""
	if baseData.HasAttribute("gtin") {
		if baseData.Attributes["gtin"].HasMultipleValues() {
			gtins := baseData.Attributes["gtin"].Values()
			gtin = strings.Join(gtins, ",")
		} else {
			gtin = baseData.Attributes["gtin"].Value()
		}
	}

	return domain.ProductInfo{
		ProductID:                baseData.MarketPlaceCode,
		ProductName:              productName,
		ProductThumbnail:         s.getProductThumbnailURL(baseData),
		ProductImage:             s.getProductImageURL(baseData),
		ProductType:              product.Type(),
		ParentID:                 parentIDRef,
		VariantSelectedAttribute: variantSelectedAttributeRef,
		Retailer:                 retailerCode,
		Brand:                    brand,
		SKU:                      gtin,
		Manufacturer:             brand,
		Color:                    color,
		Size:                     size,
		InStock:                  strconv.FormatBool(baseData.IsInStock()),
	}
}

func (s Factory) getProductThumbnailURL(baseData productDomain.BasicProductData) string {
	media := baseData.GetMedia("thumbnail")
	if media.Reference != "" {
		return s.productMediaBaseURL + s.productMediaThumbnailURLPrefix + media.Reference
	}
	media = baseData.GetMedia("list")
	if media.Reference != "" {
		return s.productMediaBaseURL + s.productMediaThumbnailURLPrefix + media.Reference
	}
	return ""
}

func (s Factory) getProductImageURL(baseData productDomain.BasicProductData) string {
	media := baseData.GetMedia("detail")
	if media.Reference != "" {
		return s.productMediaBaseURL + s.productMediaURLPrefix + media.Reference
	}
	return ""
}

func (s Factory) hashWithSHA512(value string) string {
	newHash := sha512.New()
	newHash.Write([]byte(value))
	// the hash is a byte array
	result := newHash.Sum(nil)
	// since we want to use it in a variable we base64 encode it (other alternative would be Hexadecimal representation "% x", h.Sum(nil)
	return s.hashEncoder.EncodeToString(result)
}

// BuildChangeQtyEvent builds the change quantity domain event
func (s Factory) BuildChangeQtyEvent(productIdentifier string, productName string, qty int, qtyBefore int, cartID string) domain.Event {
	event := domain.Event{EventInfo: make(map[string]interface{})}
	event.EventInfo["productId"] = productIdentifier
	event.EventInfo["productName"] = productName
	event.EventInfo["cartId"] = cartID

	if qty == 0 {
		event.EventInfo["eventName"] = "Remove Product"
	} else {
		event.EventInfo["eventName"] = "Update Quantity"
		event.EventInfo["quantity"] = qty
	}
	return event
}

// BuildAddToBagEvent builds the add to bag domain event
func (s Factory) BuildAddToBagEvent(productIdentifier string, productName string, qty int) domain.Event {
	event := domain.Event{EventInfo: make(map[string]interface{})}
	event.EventInfo["eventName"] = "Add To Bag"
	event.EventInfo["productId"] = productIdentifier
	event.EventInfo["productName"] = productName
	event.EventInfo["quantity"] = qty

	return event
}

// EvaluateBadgeHierarchy get the active badge by product
func (s *Factory) EvaluateBadgeHierarchy(product productDomain.BasicProduct) string {
	badge := ""

	if product.BaseData().HasAttribute("airportBadge") {
		badge = "airportBadge"
	} else if product.BaseData().HasAttribute("retailerBadge") {
		badge = "retailerBadge"
	} else if product.BaseData().HasAttribute("exclusiveProduct") && product.BaseData().Attributes["exclusiveProduct"].Value() == "true" {
		badge = "travellerExclusive"
	} else if product.BaseData().IsNew {
		badge = "new"
	}

	return badge
}