// Copyright 2020 The Prometheus Authors
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package internal

import (
	"fmt"
	"strconv"

	"github.com/go-kit/kit/log"
	"github.com/go-kit/kit/log/level"
	"github.com/kawamuray/jsonpath" // Originally: "github.com/NickSardo/jsonpath"
	"github.com/prometheus/client_golang/prometheus"
)

type JsonGaugeCollector struct {
	*prometheus.GaugeVec
	KeyJsonPath    string
	ValueJsonPath  string
	LabelsJsonPath map[string]string
}

func Scrape(logger log.Logger, collectors []JsonGaugeCollector, json []byte) {

	for _, collector := range collectors {
		if collector.ValueJsonPath == "" { // ScrapeType is 'value'

			// Since this is a 'value' type metric, there should be exactly one element in results
			// If there are more, just return the first one
			// TODO: Better handling/logging for this scenario
			floatValue, err := extractValue(logger, json, collector.KeyJsonPath)
			if err != nil {
				level.Error(logger).Log("msg", "Failed to extract float value for metric", "path", collector.KeyJsonPath, "err", err) //nolint:errcheck
				continue
			}

			collector.With(extractLabels(logger, json, collector.LabelsJsonPath)).Set(floatValue)
		} else { // ScrapeType is 'object'
			path, err := compilePath(collector.KeyJsonPath)
			if err != nil {
				level.Error(logger).Log("msg", "Failed to compile path", "path", collector.KeyJsonPath, "err", err) //nolint:errcheck
				continue
			}

			eval, err := jsonpath.EvalPathsInBytes(json, []*jsonpath.Path{path})
			if err != nil {
				level.Error(logger).Log("msg", "Failed to create evaluator for json path", "path", collector.KeyJsonPath, "err", err) //nolint:errcheck
				continue
			}
			for {
				if result, ok := eval.Next(); ok {
					floatValue, err := extractValue(logger, result.Value, collector.ValueJsonPath)
					if err != nil {
						level.Error(logger).Log("msg", "Failed to extract value", "path", collector.ValueJsonPath, "err", err) //nolint:errcheck
						continue
					}

					collector.With(extractLabels(logger, result.Value, collector.LabelsJsonPath)).Set(floatValue)
				} else {
					break
				}
			}
		}
	}
}

func compilePath(path string) (*jsonpath.Path, error) {
	// All paths in this package is for extracting a value.
	// Complete trailing '+' sign if necessary.
	if path[len(path)-1] != '+' {
		path += "+"
	}

	paths, err := jsonpath.ParsePaths(path)
	if err != nil {
		return nil, err
	}
	return paths[0], nil
}

// Returns the first matching float value at the given json path
func extractValue(logger log.Logger, json []byte, path string) (float64, error) {
	var floatValue = -1.0
	var result *jsonpath.Result
	var err error

	if len(path) < 1 || path[0] != '$' {
		// Static value
		return parseValue([]byte(path))
	}

	// Dynamic value
	p, err := compilePath(path)
	if err != nil {
		return floatValue, fmt.Errorf("Failed to compile path: '%s', ERROR: '%s'", path, err)
	}

	eval, err := jsonpath.EvalPathsInBytes(json, []*jsonpath.Path{p})
	if err != nil {
		return floatValue, fmt.Errorf("Failed to create evaluator for JSON Path: %s, ERROR: '%s'", path, err)
	}

	result, ok := eval.Next()
	if result == nil || !ok {
		if eval.Error != nil {
			return floatValue, fmt.Errorf("Failed to evaluate json. ERROR: '%s', PATH: '%s', JSON: '%s'", eval.Error, path, string(json))
		} else {
			level.Debug(logger).Log("msg", "Path not found", "path", path, "json", string(json)) //nolint:errcheck
			return floatValue, fmt.Errorf("Could not find path. PATH: '%s'", path)
		}
	}

	return SanitizeValue(result)
}

func extractLabels(logger log.Logger, json []byte, l map[string]string) map[string]string {
	labels := make(map[string]string)
	for label, path := range l {

		if len(path) < 1 || path[0] != '$' {
			// Static value
			labels[label] = path
			continue
		}

		// Dynamic value
		p, err := compilePath(path)
		if err != nil {
			level.Error(logger).Log("msg", "Failed to compile path for label", "path", path, "label", label, "err", err) //nolint:errcheck
			labels[label] = ""
			continue
		}

		eval, err := jsonpath.EvalPathsInBytes(json, []*jsonpath.Path{p})
		if err != nil {
			level.Error(logger).Log("msg", "Failed to create evaluator for json", "path", path, "err", err) //nolint:errcheck
			labels[label] = ""
			continue
		}

		result, ok := eval.Next()
		if result == nil || !ok {
			if eval.Error != nil {
				level.Error(logger).Log("msg", "Failed to evaluate", "label", label, "json", string(json), "err", eval.Error) //nolint:errcheck
			} else {
				level.Warn(logger).Log("msg", "Label path not found in json", "path", path, "label", label)                        //nolint:errcheck
				level.Debug(logger).Log("msg", "Label path not found in json", "path", path, "label", label, "json", string(json)) //nolint:errcheck
			}
			continue
		}

		l, err := strconv.Unquote(string(result.Value))
		if err == nil {
			labels[label] = l
		} else {
			labels[label] = string(result.Value)
		}
	}
	return labels
}