loader.go

package jsons

import (
	"fmt"
	"io"
	"os"
)

// LoadFunc load the input bytes to map[string]interface{}
type LoadFunc func([]byte) (map[string]interface{}, error)

// loader is a configurable loader for specific format files.
type loader struct {
	Name       Format
	Extensions []string
	LoadFunc   LoadFunc
}

// makeLoader makes a merger who merge the format by converting it to JSON
func newLoader(name Format, extensions []string, fn LoadFunc) *loader {
	return &loader{
		Name:       name,
		Extensions: extensions,
		LoadFunc:   fn,
	}
}

// makeLoadFunc makes a merge func who merge the input to
func (l *loader) Load(input interface{}) ([]map[string]interface{}, error) {
	if input == nil {
		return nil, nil
	}
	switch v := input.(type) {
	case string:
		return l.loadFiles([]string{v})
	case []string:
		return l.loadFiles(v)
	case []byte:
		return l.loadSlices([][]byte{v})
	case [][]byte:
		return l.loadSlices(v)
	case io.Reader:
		return l.loadReaders([]io.Reader{v})
	case []io.Reader:
		return l.loadReaders(v)
	default:
		return nil, fmt.Errorf("unsupported input type: %T", input)
	}
}

func (l *loader) loadFiles(files []string) ([]map[string]interface{}, error) {
	maps := make([]map[string]interface{}, 0, len(files))
	for _, file := range files {
		m, err := l.loadFile(file)
		if err != nil {
			return nil, err
		}
		maps = append(maps, m)
	}
	return maps, nil
}

func (l *loader) loadReaders(readers []io.Reader) ([]map[string]interface{}, error) {
	maps := make([]map[string]interface{}, 0, len(readers))
	for _, r := range readers {
		m, err := l.loadReader(r)
		if err != nil {
			return nil, err
		}
		maps = append(maps, m)
	}
	return maps, nil
}

func (l *loader) loadSlices(slices [][]byte) ([]map[string]interface{}, error) {
	maps := make([]map[string]interface{}, 0, len(slices))
	for _, slice := range slices {
		m, err := l.LoadFunc(slice)
		if err != nil {
			return nil, err
		}
		maps = append(maps, m)
	}
	return maps, nil
}

func (l *loader) loadFile(file string) (map[string]interface{}, error) {
	bs, err := os.ReadFile(file)
	if err != nil {
		return nil, err
	}
	return l.LoadFunc(bs)
}

func (l *loader) loadReader(reader io.Reader) (map[string]interface{}, error) {
	bs, err := io.ReadAll(reader)
	if err != nil {
		return nil, err
	}
	return l.LoadFunc(bs)
}