X-Git-Url: https://git.r.bdr.sh/rbdr/mobius/blobdiff_plain/22c599abc18895f73e96095f35b71cf3357d41b4..d2810ae9038b057e8f18e8b495a57d8f96ae5be6:/hotline/file_path.go diff --git a/hotline/file_path.go b/hotline/file_path.go index 71168dc..f7da298 100644 --- a/hotline/file_path.go +++ b/hotline/file_path.go @@ -1,7 +1,10 @@ package hotline import ( + "bytes" "encoding/binary" + "errors" + "path" "strings" ) @@ -24,33 +27,86 @@ func NewFilePathItem(b []byte) FilePathItem { } type FilePath struct { - PathItemCount []byte - PathItems []FilePathItem + ItemCount [2]byte + Items []FilePathItem } -func NewFilePath(b []byte) FilePath { +const minFilePathLen = 2 + +func (fp *FilePath) UnmarshalBinary(b []byte) error { if b == nil { - return FilePath{} + return nil + } + if len(b) < minFilePathLen { + return errors.New("insufficient bytes") + } + err := binary.Read(bytes.NewReader(b[0:2]), binary.BigEndian, &fp.ItemCount) + if err != nil { + return err } - fp := FilePath{PathItemCount: b[0:2]} - - // number of items in the path - pathItemLen := binary.BigEndian.Uint16(b[0:2]) pathData := b[2:] - for i := uint16(0); i < pathItemLen; i++ { + for i := uint16(0); i < fp.Len(); i++ { segLen := pathData[2] - fp.PathItems = append(fp.PathItems, NewFilePathItem(pathData[:segLen+3])) + fp.Items = append(fp.Items, NewFilePathItem(pathData[:segLen+3])) pathData = pathData[3+segLen:] } - return fp + 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[:]) } func (fp *FilePath) String() string { - var out []string - for _, i := range fp.PathItems { + 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 }