gatus/jsonpath/jsonpath.go

package jsonpath

import (
	"encoding/json"
	"fmt"
	"strconv"
	"strings"
)

// Eval is a half-baked json path implementation that needs some love
func Eval(path string, b []byte) (string, int, error) {
	var object interface{}
	err := json.Unmarshal(b, &object)
	if err != nil {
		// Try to unmarshal it into an array instead
		return "", 0, err
	}
	return walk(path, object)
}

func walk(path string, object interface{}) (string, int, error) {
	keys := strings.Split(path, ".")
	currentKey := keys[0]
	switch value := extractValue(currentKey, object).(type) {
	case map[string]interface{}:
		return walk(strings.Replace(path, fmt.Sprintf("%s.", currentKey), "", 1), value)
	case string:
		if len(keys) > 1 {
			return "", 0, fmt.Errorf("couldn't walk through '%s', because '%s' was a string instead of an object", keys[1], currentKey)
		}
		return value, len(value), nil
	case []interface{}:
		return fmt.Sprintf("%v", value), len(value), nil
	case interface{}:
		return fmt.Sprintf("%v", value), 1, nil
	default:
		return "", 0, fmt.Errorf("couldn't walk through '%s' because type was '%T', but expected 'map[string]interface{}'", currentKey, value)
	}
}

func extractValue(currentKey string, value interface{}) interface{} {
	// Check if the current key ends with [#]
	if strings.HasSuffix(currentKey, "]") && strings.Contains(currentKey, "[") {
		tmp := strings.SplitN(currentKey, "[", 3)
		arrayIndex, err := strconv.Atoi(strings.Replace(tmp[1], "]", "", 1))
		if err != nil {
			return nil
		}
		currentKey := tmp[0]
		// if currentKey contains only an index (i.e. [0] or 0)
		if len(currentKey) == 0 {
			array := value.([]interface{})
			if len(array) > arrayIndex {
				if len(tmp) > 2 {
					// Nested array? Go deeper.
					return extractValue(fmt.Sprintf("%s[%s", currentKey, tmp[2]), array[arrayIndex])
				}
				return array[arrayIndex]
			}
			return nil
		}
		if value == nil || value.(map[string]interface{})[currentKey] == nil {
			return nil
		}
		// if currentKey contains both a key and an index (i.e. data[0])
		array := value.(map[string]interface{})[currentKey].([]interface{})
		if len(array) > arrayIndex {
			if len(tmp) > 2 {
				// Nested array? Go deeper.
				return extractValue(fmt.Sprintf("[%s", tmp[2]), array[arrayIndex])
			}
			return array[arrayIndex]
		}
		return nil
	}
	return value.(map[string]interface{})[currentKey]
}