X-Git-Url: https://git.r.bdr.sh/rbdr/mobius/blobdiff_plain/72dd37f1abb2b550aaaac48eac677403d5664797..d1cd666473e5d9097b34bad3388c8c0595612089:/hotline/file_path.go?ds=sidebyside diff --git a/hotline/file_path.go b/hotline/file_path.go index ae96e52..3ff2435 100644 --- a/hotline/file_path.go +++ b/hotline/file_path.go @@ -1,7 +1,11 @@ package hotline import ( + "bytes" "encoding/binary" + "errors" + "io" + "path" "strings" ) @@ -16,39 +20,96 @@ type FilePathItem struct { Name []byte } -func NewFilePathItem(b []byte) FilePathItem { - return FilePathItem{ - Len: b[2], - Name: b[3:], - } -} - type FilePath struct { - ItemCount []byte + ItemCount [2]byte Items []FilePathItem } func (fp *FilePath) UnmarshalBinary(b []byte) error { - fp.ItemCount = b[0:2] + reader := bytes.NewReader(b) + err := binary.Read(reader, binary.BigEndian, &fp.ItemCount) + if err != nil && !errors.Is(err, io.EOF) { + return err + } + if errors.Is(err, io.EOF) { + return nil + } - pathData := b[2:] for i := uint16(0); i < fp.Len(); i++ { - segLen := pathData[2] - fp.Items = append(fp.Items, NewFilePathItem(pathData[:segLen+3])) - pathData = pathData[3+segLen:] + // skip two bytes for the file path delimiter + _, _ = reader.Seek(2, io.SeekCurrent) + + // read the length of the next pathItem + segLen, err := reader.ReadByte() + if err != nil { + return err + } + + pBytes := make([]byte, segLen) + + _, err = reader.Read(pBytes) + if err != nil && !errors.Is(err, io.EOF) { + return err + } + + fp.Items = append(fp.Items, FilePathItem{Len: segLen, Name: pBytes}) } return nil } +func (fp *FilePath) IsDropbox() bool { + if fp.Len() == 0 { + return false + } + + return strings.Contains(strings.ToLower(string(fp.Items[fp.Len()-1].Name)), "drop box") +} + +func (fp *FilePath) IsUploadDir() bool { + if fp.Len() == 0 { + return false + } + + return strings.Contains(strings.ToLower(string(fp.Items[fp.Len()-1].Name)), "upload") +} + func (fp *FilePath) Len() uint16 { - return binary.BigEndian.Uint16(fp.ItemCount) + return binary.BigEndian.Uint16(fp.ItemCount[:]) } func (fp *FilePath) String() string { - var out []string + out := []string{"/"} for _, i := range fp.Items { out = append(out, string(i.Name)) } - return strings.Join(out, pathSeparator) + + return path.Join(out...) +} + +func ReadFilePath(filePathFieldData []byte) string { + var fp FilePath + err := fp.UnmarshalBinary(filePathFieldData) + if err != nil { + // TODO + } + return fp.String() +} + +func readPath(fileRoot string, filePath, fileName []byte) (fullPath string, err error) { + var fp FilePath + if filePath != nil { + if err = fp.UnmarshalBinary(filePath); err != nil { + return "", err + } + } + + fullPath = path.Join( + "/", + fileRoot, + fp.String(), + path.Join("/", string(fileName)), + ) + + return fullPath, nil }