refactor: Decompose list func

This commit is contained in:
Felicitas Pojtinger
2021-12-06 22:48:23 +01:00
parent 8d991a8237
commit a0f1bdfea7
5 changed files with 72 additions and 48 deletions
+5
View File
@@ -0,0 +1,5 @@
package inventory
type MetadataConfig struct {
Metadata string
}
+11
View File
@@ -0,0 +1,11 @@
package inventory
import "archive/tar"
func Find(
state MetadataConfig,
expression string,
) ([]*tar.Header, error) {
return nil, nil
}
-19
View File
@@ -1,19 +0,0 @@
package inventory
import "archive/tar"
type MetadataConfig struct {
Metadata string
}
func Find(
state MetadataConfig,
expression string,
) ([]*tar.Header, error)
func List(
state MetadataConfig,
name string,
) ([]*tar.Header, error)
+48
View File
@@ -0,0 +1,48 @@
package inventory
import (
"archive/tar"
"context"
"github.com/pojntfx/stfs/internal/converters"
"github.com/pojntfx/stfs/internal/formatting"
"github.com/pojntfx/stfs/internal/persisters"
)
func List(
state MetadataConfig,
name string,
) ([]*tar.Header, error) {
metadataPersister := persisters.NewMetadataPersister(state.Metadata)
if err := metadataPersister.Open(); err != nil {
return []*tar.Header{}, err
}
dbHdrs, err := metadataPersister.GetHeaderDirectChildren(context.Background(), name)
if err != nil {
return []*tar.Header{}, err
}
headers := []*tar.Header{}
for i, dbhdr := range dbHdrs {
if i == 0 {
if err := formatting.PrintCSV(formatting.TARHeaderCSV); err != nil {
return []*tar.Header{}, err
}
}
hdr, err := converters.DBHeaderToTarHeader(dbhdr)
if err != nil {
return []*tar.Header{}, err
}
if err := formatting.PrintCSV(formatting.GetTARHeaderAsCSV(dbhdr.Record, dbhdr.Block, hdr)); err != nil {
return []*tar.Header{}, err
}
headers = append(headers, hdr)
}
return headers, nil
}