func SearchResources()

in wstl1/mapping_engine/testing/util/utils.go [32:86]
46 lines of code
13 McCabe index (conditional complexity)

func SearchResources(ctx context.Context, dataset jsonutil.JSONToken, address string, method string) (*json.RawMessage, error) {
	arr, ok := dataset.(jsonutil.JSONArr)
	if !ok {
		j, err := json.Marshal(dataset)
		msg := json.RawMessage(j)
		return &msg, err
	}

	pa, err := url.Parse(address)
	if err != nil {
		return nil, fmt.Errorf("failed to parse URL %s: %v", address, err)
	}

	var matchingResources jsonutil.JSONArr

	searchParams := pa.Query()

	urlPathParams := urlParse.FindStringSubmatch(pa.Path)
	if urlPathParams[1] != "" {
		searchParams["resourceType"] = []string{urlPathParams[1]}
	}
	if urlPathParams[2] != "" {
		searchParams["id"] = []string{urlPathParams[2]}
	}

	for _, res := range arr {
		match := true
		for k, vs := range searchParams {
			valueSet := stringset.New(vs...)

			v, err := jsonutil.GetField(res, k)
			if v, ok := v.(jsonutil.JSONStr); err != nil || !ok || !valueSet.Contains(string(v)) {
				match = false
				break
			}
		}

		if match {
			matchingResources = append(matchingResources, res)
		}
	}

	var res jsonutil.JSONToken = matchingResources
	if len(matchingResources) == 0 {
		msg := json.RawMessage(`{}`)
		return &msg, nil
	}
	if len(matchingResources) == 1 {
		res = matchingResources[0]
	}

	resj, err := json.Marshal(res)
	msg := json.RawMessage(resj)
	return &msg, err
}