From ba39c3a9fd2f0588ab79c272aeda5d435351f447 Mon Sep 17 00:00:00 2001 From: Sergey Petrov Date: Wed, 9 Apr 2025 16:34:44 +0500 Subject: [PATCH] Refactoring. --- writer/pkg/storage/file.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/writer/pkg/storage/file.go b/writer/pkg/storage/file.go index 22dd68a..f1de59a 100644 --- a/writer/pkg/storage/file.go +++ b/writer/pkg/storage/file.go @@ -427,11 +427,12 @@ func GetHeader(id, res, file string) ([]string, error) { if _, err := io.ReadFull(f, segData); err != nil { return nil, errors.New("reading header error: " + err.Error()) } - headerReader := bytes.NewReader(segData) - headerSeg, err := ReadHeaderSegment(headerReader) + //headerReader := bytes.NewReader(segData) + //headerSeg, err := ReadHeaderSegment(headerReader) if err != nil { return nil, errors.New("reading header error: " + err.Error()) } + return strings.Split(string(segData), "\n"), nil } // readString reads string length and then reads string data. @@ -517,8 +518,8 @@ func readPacket(r io.Reader) (InterleavedPacket, error) { return pkt, nil } -// readPacketSegment reads segment packets. -func readPacketSegment(r io.Reader) ([]InterleavedPacket, error) { +// ReadPacketSegment reads segment packets. +func ReadPacketSegment(r io.Reader) ([]InterleavedPacket, error) { var numPackets int32 if err := binary.Read(r, binary.LittleEndian, &numPackets); err != nil { return nil, err