cgimport/reader/blockreader.go

package reader

import (
	"io"
	"path/filepath"

	"git.wecise.com/wecise/cgimport/schema"
	"git.wecise.com/wecise/util/merrs"
)

type BlockReader interface {
	ReadBlock() (block map[string]any, line string, linecount int, err error)
}

func NewBlockReader(filename string, filetype schema.FileType, reader io.Reader) (BlockReader, error) {
	fileext := filepath.Ext(filename)
	switch fileext {
	case ".csv":
		return NewCSVBlockReader(filename, filetype, reader), nil
	case ".txt":
		return NewTXTBlockReader(filename, filetype, reader), nil
	}
	return nil, merrs.UnsupportedError.NewError("unsupported data format " + filetype)
}