From 0b4bbb18087fe7e280a302f031e19852ef741a48 Mon Sep 17 00:00:00 2001 From: SayaAndy Date: Tue, 19 Aug 2025 00:14:30 +0700 Subject: feat: allow multiple converters for processing --- internal/client/input/b2.go | 3 +-- internal/client/input/input_client_interface.go | 1 + internal/client/input/local_unix.go | 7 ++----- 3 files changed, 4 insertions(+), 7 deletions(-) (limited to 'internal/client/input') diff --git a/internal/client/input/b2.go b/internal/client/input/b2.go index 0092313..db68268 100644 --- a/internal/client/input/b2.go +++ b/internal/client/input/b2.go @@ -5,7 +5,6 @@ import ( "fmt" "io" "slices" - "strconv" "strings" "github.com/Backblaze/blazer/b2" @@ -102,8 +101,8 @@ func (c *B2InputClient) ReadMetadata(path string) (*MetadataStruct, error) { FirstCreated: attrs.UploadTimestamp, LastModified: attrs.LastModified, Misc: attrs.Info, + Size: attrs.Size, } - metadata.Misc["Size"] = strconv.FormatInt(attrs.Size, 10) switch attrs.Status { case b2.Uploaded: diff --git a/internal/client/input/input_client_interface.go b/internal/client/input/input_client_interface.go index 5d12fa8..4930aa0 100644 --- a/internal/client/input/input_client_interface.go +++ b/internal/client/input/input_client_interface.go @@ -20,6 +20,7 @@ type MetadataStruct struct { ContentType string FirstCreated time.Time LastModified time.Time + Size int64 Misc map[string]string } diff --git a/internal/client/input/local_unix.go b/internal/client/input/local_unix.go index 2df3a41..27a7947 100644 --- a/internal/client/input/local_unix.go +++ b/internal/client/input/local_unix.go @@ -87,10 +87,6 @@ func (c *LocalUnixInputClient) ReadMetadata(path string) (*MetadataStruct, error stat_t := fileInfo.Sys().(*syscall.Stat_t) creationTime := time.Unix(stat_t.Ctim.Sec, stat_t.Ctim.Nsec) - misc := map[string]string{ - "Size": strconv.FormatInt(fileInfo.Size(), 10), - } - return &MetadataStruct{ Name: fileInfo.Name(), StorageType: "local-unix", @@ -98,7 +94,8 @@ func (c *LocalUnixInputClient) ReadMetadata(path string) (*MetadataStruct, error ContentType: mime.TypeByExtension("." + nodeExt), FirstCreated: creationTime, LastModified: fileInfo.ModTime(), - Misc: misc, + Size: fileInfo.Size(), + Misc: map[string]string{}, }, nil } -- cgit v1.3.1+13