customtargetingvalue.go

package customtargeting

import (
	"errors"
	"fmt"

	"github.com/ezoic/go-dfpapi/generated/customtargetingservice"
	l4g "github.com/ezoic/log4go"
)

type CustomTargetingValueModel struct {
	Attributes customtargetingservice.CustomTargetingValue `json:"attributes"`
}

func (ct *CustomTargeting) FindAllValuesByKeyName(keyName string) ([]CustomTargetingValueModel, error) {
	key, err := ct.FindKeyByName(keyName)
	if err != nil {
		var empty []CustomTargetingValueModel
		l4g.Debug(err)
		return empty, err
	}

	if key == nil {
		var empty []CustomTargetingValueModel
		return empty, fmt.Errorf(`Unable to find key by name '%s'`, keyName)
	}

	return ct.FindAllValuesByKey(*key)
}

func (ct *CustomTargeting) FindAllValuesByKey(key CustomTargetingKeyModel) ([]CustomTargetingValueModel, error) {
	id := key.Attributes.Id
	query := fmt.Sprintf(`WHERE customTargetingKeyId = '%d' AND status = 'ACTIVE'`, id)
	return ct.SearchValuesWithStatement(query)
}

func (ct *CustomTargeting) SearchValuesWithStatement(query string) ([]CustomTargetingValueModel, error) {
	var results []CustomTargetingValueModel
	statement := customtargetingservice.Statement{Query: &query}
	getCustomTargetingsByStatement := customtargetingservice.GetCustomTargetingValuesByStatement{FilterStatement: &statement}
	response, err := ct.service.GetCustomTargetingValuesByStatement(&getCustomTargetingsByStatement)
	if err != nil {
		l4g.Debug(err)
		return results, err
	}

	customTargetingValuePage := response.Rval
	if customTargetingValuePage == nil {
		return results, errors.New("CustomTargetingPage from get line items statement was not given.")
	}

	res := customTargetingValuePage.Results

	for _, result := range res {
		if result == nil {
			continue
		}

		ctvp := CustomTargetingValueModel{Attributes: *result}
		results = append(results, ctvp)
	}

	return results, nil
}