X-Git-Url: https://git.r.bdr.sh/rbdr/mobius/blobdiff_plain/c5d9af5aa4d9fb20316be45ab1b775bcf61bcad5..da5bdd82beef668f49c2cec09cea85435c0bec34:/hotline/file_path.go diff --git a/hotline/file_path.go b/hotline/file_path.go index 733dfaa..460af03 100644 --- a/hotline/file_path.go +++ b/hotline/file_path.go @@ -1,12 +1,14 @@ package hotline import ( + "bytes" "encoding/binary" + "errors" + "io" + "path/filepath" "strings" ) -const pathSeparator = "/" // File path separator TODO: make configurable to support Windows - // FilePathItem represents the file or directory portion of a delimited file path (e.g. foo and bar in "/foo/bar") // 00 00 // 09 @@ -16,48 +18,82 @@ 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) Len() uint16 { - return binary.BigEndian.Uint16(fp.ItemCount) +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) String() string { - var out []string - for _, i := range fp.Items { - out = append(out, string(i.Name)) +func (fp *FilePath) IsUploadDir() bool { + if fp.Len() == 0 { + return false } - return strings.Join(out, pathSeparator) + + return strings.Contains(strings.ToLower(string(fp.Items[fp.Len()-1].Name)), "upload") +} + +func (fp *FilePath) Len() uint16 { + return binary.BigEndian.Uint16(fp.ItemCount[:]) } -func ReadFilePath(filePathFieldData []byte) string { +func readPath(fileRoot string, filePath, fileName []byte) (fullPath string, err error) { var fp FilePath - err := fp.UnmarshalBinary(filePathFieldData) - if err != nil { - // TODO + if filePath != nil { + if err = fp.UnmarshalBinary(filePath); err != nil { + return "", err + } + } + + var subPath string + for _, pathItem := range fp.Items { + subPath = filepath.Join("/", subPath, string(pathItem.Name)) } - return fp.String() + + fullPath = filepath.Join( + fileRoot, + subPath, + filepath.Join("/", string(fileName)), + ) + + return fullPath, nil }