X-Git-Url: https://git.r.bdr.sh/rbdr/mobius/blobdiff_plain/22c599abc18895f73e96095f35b71cf3357d41b4..4a0b69af8997eb3ae1da4d50c35073c073ce04d8:/hotline/files.go diff --git a/hotline/files.go b/hotline/files.go index 69c22b3..478041b 100644 --- a/hotline/files.go +++ b/hotline/files.go @@ -2,84 +2,73 @@ package hotline import ( "encoding/binary" + "errors" + "io/fs" "io/ioutil" "os" "path/filepath" "strings" ) -const defaultCreator = "TTXT" -const defaultType = "TEXT" +func downcaseFileExtension(filename string) string { + splitStr := strings.Split(filename, ".") + ext := strings.ToLower( + splitStr[len(splitStr)-1], + ) -var fileCreatorCodes = map[string]string{ - "sit": "SIT!", - "pdf": "CARO", + return ext } -var fileTypeCodes = map[string]string{ - "sit": "SIT!", - "jpg": "JPEG", - "pdf": "PDF ", -} - -func fileTypeFromFilename(fn string) string { - ext := strings.Split(fn, ".") - code := fileTypeCodes[ext[len(ext)-1]] - - if code == "" { - code = defaultType +func fileTypeFromFilename(fn string) fileType { + ft, ok := fileTypes[downcaseFileExtension(fn)] + if ok { + return ft } - - return code + return defaultFileType } -func fileCreatorFromFilename(fn string) string { - ext := strings.Split(fn, ".") - code := fileCreatorCodes[ext[len(ext)-1]] - if code == "" { - code = defaultCreator - } - - return code -} - -func getFileNameList(filePath string) ([]Field, error) { - var fields []Field - +func getFileNameList(filePath string) (fields []Field, err error) { files, err := ioutil.ReadDir(filePath) if err != nil { return fields, nil } for _, file := range files { - var fileType string - var fileCreator []byte - var fileSize uint32 + var fileType []byte + var fnwi FileNameWithInfo + fileCreator := make([]byte, 4) if !file.IsDir() { - fileType = fileTypeFromFilename(file.Name()) - fileCreator = []byte(fileCreatorFromFilename(file.Name())) - fileSize = uint32(file.Size()) + fileType = []byte(fileTypeFromFilename(file.Name()).TypeCode) + fileCreator = []byte(fileTypeFromFilename(file.Name()).CreatorCode) + + binary.BigEndian.PutUint32(fnwi.FileSize[:], uint32(file.Size())) + copy(fnwi.Type[:], fileType[:]) + copy(fnwi.Creator[:], fileCreator[:]) } else { - fileType = "fldr" - fileCreator = make([]byte, 4) + fileType = []byte("fldr") dir, err := ioutil.ReadDir(filePath + "/" + file.Name()) if err != nil { return fields, err } - fileSize = uint32(len(dir)) + binary.BigEndian.PutUint32(fnwi.FileSize[:], uint32(len(dir))) + copy(fnwi.Type[:], fileType[:]) + copy(fnwi.Creator[:], fileCreator[:]) } - fields = append(fields, NewField( - fieldFileNameWithInfo, - FileNameWithInfo{ - Type: fileType, - Creator: fileCreator, - FileSize: fileSize, - NameScript: []byte{0, 0}, - Name: file.Name(), - }.Payload(), - )) + strippedName := strings.Replace(file.Name(), ".incomplete", "", -1) + + nameSize := make([]byte, 2) + binary.BigEndian.PutUint16(nameSize, uint16(len(strippedName))) + copy(fnwi.NameSize[:], nameSize[:]) + + fnwi.name = []byte(strippedName) + + b, err := fnwi.MarshalBinary() + if err != nil { + return nil, err + } + fields = append(fields, NewField(fieldFileNameWithInfo, b)) } return fields, nil @@ -149,7 +138,20 @@ func EncodeFilePath(filePath string) []byte { return bytes } -func ReadFilePath(filePathFieldData []byte) string { - fp := NewFilePath(filePathFieldData) - return fp.String() +const incompleteFileSuffix = ".incomplete" + +// effectiveFile wraps os.Open to check for the presence of a partial file transfer as a fallback +func effectiveFile(filePath string) (*os.File, error) { + file, err := os.Open(filePath) + if err != nil && !errors.Is(err, fs.ErrNotExist) { + return nil, err + } + + if errors.Is(err, fs.ErrNotExist) { + file, err = os.OpenFile(filePath+incompleteFileSuffix, os.O_APPEND|os.O_WRONLY, 0644) + if err != nil { + return nil, err + } + } + return file, nil }