Function parseEntry

util/lockfile/lockfile.go:223–272

(line []byte)

}

func parseEntry(line []byte) (lockEntry, error) {
	var tuple []json.RawMessage
	if err := decodeJSON(line, &tuple); err != nil {
		return lockEntry{}, fmt.Errorf("invalid tuple JSON: %w", err)
	}
	if len(tuple) != 5 {
		return lockEntry{}, fmt.Errorf("invalid tuple length %d: expected 5", len(tuple))
	}

	var namespace string
	if err := decodeJSON(tuple[0], &namespace); err != nil {
		return lockEntry{}, fmt.Errorf("invalid namespace: %w", err)
	}

	var operation string
	if err := decodeJSON(tuple[1], &operation); err != nil {
		return lockEntry{}, fmt.Errorf("invalid operation: %w", err)
	}

	var inputs []any
	if err := decodeJSON(tuple[2], &inputs); err != nil {
		return lockEntry{}, fmt.Errorf("invalid inputs: %w", err)
	}
	canonicalInputs, inputsJSON, err := canonicalizeInputs(inputs)
	if err != nil {
		return lockEntry{}, fmt.Errorf("canonicalizing inputs: %w", err)
	}

	var value any
	if err := decodeJSON(tuple[3], &value); err != nil {
		return lockEntry{}, fmt.Errorf("invalid value: %w", err)
	}
	canonicalValue, err := canonicalizeValue(value)
	if err != nil {
		return lockEntry{}, fmt.Errorf("canonicalizing value: %w", err)
	}
	var policy string
	if err := decodeJSON(tuple[4], &policy); err != nil {
		return lockEntry{}, fmt.Errorf("invalid policy: %w", err)
	}

	return lockEntry{
		namespace:  namespace,
		operation:  operation,
		inputs:     canonicalInputs,
		inputsJSON: inputsJSON,
		value:      canonicalValue,
		policy:     policy,
	}, nil
}

func canonicalizeInputs(inputs []any) ([]any, string, error) {
	if inputs == nil {