helper.go

package validator

import (
	"github.com/viant/endly"
	"github.com/viant/endly/internal/util"
	"github.com/viant/endly/service/workflow"
	"github.com/viant/toolbox"
)

// NewAssertRequestFromContext creates a new assert rquest from context for current activity
func NewAssertRequestFromContext(context *endly.Context, source, expected, actual interface{}, name, description string) (*AssertRequest, error) {
	tagID := ""
	if process := workflow.Last(context); process != nil {
		if activity := process.Last(); activity != nil {
			if description == "" {
				description = activity.Description
			}
			tagID = activity.TagID
		}
	}
	if expected != nil && toolbox.IsSlice(expected) {
		if normalized, err := util.NormalizeMap(expected, true); err == nil {
			expected = normalized
		}
	}
	return NewAssertRequest(tagID, name, description, source, expected, actual), nil

}

// Assert compares provided expected amd actual
func Assert(context *endly.Context, source, expected, actual interface{}, name, description string) (*AssertResponse, error) {
	var request, err = NewAssertRequestFromContext(context, source, expected, actual, name, description)
	if err != nil {
		return nil, err
	}
	var response = &AssertResponse{}
	err = endly.Run(context, request, response)
	return response, err
}