pkgio

type ByteReader struct {
	Reader io.Reader

	// allows the consumer to specify its own data store
	DataStore store.Storer[[]byte]

	// Path of the file the user is reading
	Path string
}

type ByteWriter struct {
	Type OutputSink
	// Could be a file or directory
	Path string
}

type CommitByteReader struct {
	Commit *object.Commit
	// allows the consumer to specify its own data store
	DataStore store.Storer[[]byte]

	Path           string
	MatchFilesGlob MatchFilesGlob
	SkipDir        bool
}

type CommitYAMLReader struct {
	Commit *object.Commit
	// allows the consumer to specify its own data store
	DataStore store.Storer[*yaml.RNode]

	Path      string
	SkipDir   bool
	MatchGVKs []schema.GroupVersionKind
}

type DirReader struct {
	RelFsysPath    string // dir
	Fsys           fsys.FS
	MatchFilesGlob MatchFilesGlob
	IgnoreRules    *ignore.Rules
	SkipDir        bool
	Checksum       bool
}

type FileReader struct {
	FileName string
	Fsys     fsys.FS
	Checksum bool
}

type GitReader struct {
	// URL of the Git Repository
	URL string
	// Secret with crendentials to access the repo
	Secret string
	// Deployment determines if this is a catalog repo or not
	Deployment bool
	// Directory used in the git repository as an offset
	Directory string
	// PackageID identifies target, repo, realm, package, workspace and revision (if assigned)
	PkgRevID *pkgrevid.PackageRevID
	// PkgPath identifies the localation of the package in the local filesystem
	PkgPath string
	// allows the consumer to specify its own data store
	DataStore store.Storer[[]byte]
}

type GitWriter struct {
	// URL of the Git Repository
	URL string
	// Secret with crendentials to access the repo
	Secret string
	// Deployment determines if this is a catalog repo or not
	Deployment bool
	// Directory used in the git repository as an offset
	Directory string
	// PackageID identifies target, repo, realm, package, workspace and revision (if assigned)
	PkgRevID *pkgrevid.PackageRevID
	// PkgPath identifies the localation of the package in the local filesystem
	PkgPath string
}

type InventoryReader struct {
}

type KformDirReader struct {
	Path  string
	Input bool
}

type KformFileReader struct {
	Path  string
	Input bool
}

type KformMemReader struct {
	Resources map[string]string
	Data      store.Storer[[]byte]
	Input     bool
}

type KformStreamReader struct {
	Reader io.Reader
	Input  bool
}

type KformWriter struct {
	//Writer io.Writer
	Type OutputSink
	// Could be a file or directory
	Path string

	OuputData store.Storer[[]byte] // used for memory
}

type MatchFilesGlob []string

type MemReader struct {
	Resources map[string]string
}

type OutputSink int64

type Pipeline[T1 any] struct {
	Inputs     []Reader[T1]  `json:"inputs,omitempty" yaml:"inputs,omitempty"`
	Processors []Process[T1] `json:"processors,omitempty" yaml:"processors,omitempty"`
	Outputs    []Writer[T1]  `json:"outputs,omitempty" yaml:"outputs,omitempty"`
}

type PkgPushReadWriter interface {
	Reader[[]byte]
	Writer[[]byte]
}

type Process[T1 any] interface {
	Process(context.Context, store.Storer[T1]) (store.Storer[T1], error)
}

type Reader[T1 any] interface {
	Read(context.Context) (store.Storer[T1], error)
}

type Writer[T1 any] interface {
	Write(context.Context, store.Storer[T1]) error
}

type YAMLDirReader struct {
	FsysPath    string
	RelFsysPath string
	Fsys        fs.FS
	SkipDir     bool
	MatchGVKs   []schema.GroupVersionKind
}

type YAMLMemReader struct {
	Resources map[string]string
}

type YAMLReader struct {
	Reader io.Reader

	// Path of the file the user is reading
	Path string

	// Client supplied annotations
	Annotations map[string]string

	// allows the consumer to specify its own data store
	DataStore store.Storer[*yaml.RNode]

	MatchGVKs []schema.GroupVersionKind
}

type YAMLWriter struct {
	Writer io.Writer

	Type OutputSink
	// Could be a file or directory
	Path string
}