seaweedfs/weed/storage/needle.go

190 lines
5.1 KiB
Go
Raw Normal View History

package storage
import (
"encoding/json"
"fmt"
"net/http"
"strconv"
"strings"
"time"
"github.com/chrislusf/seaweedfs/weed/images"
. "github.com/chrislusf/seaweedfs/weed/storage/types"
2018-07-21 22:58:48 +00:00
"io/ioutil"
)
2012-12-21 08:36:55 +00:00
const (
NeedleChecksumSize = 4
PairNamePrefix = "Seaweed-"
2012-12-21 08:36:55 +00:00
)
/*
* A Needle means a uploaded and stored file.
* Needle file size is limited to 4GB for now.
*/
type Needle struct {
Cookie Cookie `comment:"random number to mitigate brute force lookups"`
Id NeedleId `comment:"needle id"`
Size uint32 `comment:"sum of DataSize,Data,NameSize,Name,MimeSize,Mime"`
DataSize uint32 `comment:"Data size"` //version2
Data []byte `comment:"The actual file data"`
2019-01-17 01:17:19 +00:00
Flags byte `comment:"boolean flags"` //version2
NameSize uint8 //version2
Name []byte `comment:"maximum 256 characters"` //version2
2019-01-17 01:17:19 +00:00
MimeSize uint8 //version2
Mime []byte `comment:"maximum 256 characters"` //version2
2019-01-17 01:17:19 +00:00
PairsSize uint16 //version2
Pairs []byte `comment:"additional name value pairs, json format, maximum 64kB"`
LastModified uint64 //only store LastModifiedBytesLength bytes, which is 5 bytes to disk
Ttl *TTL
2018-07-24 08:36:04 +00:00
Checksum CRC `comment:"CRC32 to check integrity"`
AppendAtNs uint64 `comment:"append timestamp in nano seconds"` //version3
Padding []byte `comment:"Aligned to 8 bytes"`
}
func (n *Needle) String() (str string) {
2018-07-22 00:41:21 +00:00
str = fmt.Sprintf("%s Size:%d, DataSize:%d, Name:%s, Mime:%s", formatNeedleIdCookie(n.Id, n.Cookie), n.Size, n.DataSize, n.Name, n.Mime)
return
}
2015-12-15 06:38:58 +00:00
func ParseUpload(r *http.Request) (
fileName string, data []byte, mimeType string, pairMap map[string]string, isGzipped bool, originalDataSize int,
2015-12-15 06:38:58 +00:00
modifiedTime uint64, ttl *TTL, isChunkedFile bool, e error) {
pairMap = make(map[string]string)
for k, v := range r.Header {
if len(v) > 0 && strings.HasPrefix(k, PairNamePrefix) {
pairMap[k] = v[0]
}
}
2018-07-21 22:58:48 +00:00
if r.Method == "POST" {
fileName, data, mimeType, isGzipped, originalDataSize, isChunkedFile, e = parseMultipart(r)
2018-07-21 22:58:48 +00:00
} else {
isGzipped = false
mimeType = r.Header.Get("Content-Type")
fileName = ""
data, e = ioutil.ReadAll(r.Body)
originalDataSize = len(data)
2018-07-21 22:58:48 +00:00
}
if e != nil {
2013-08-05 20:37:41 +00:00
return
}
2015-01-16 09:30:23 +00:00
modifiedTime, _ = strconv.ParseUint(r.FormValue("ts"), 10, 64)
ttl, _ = ReadTTL(r.FormValue("ttl"))
return
}
func CreateNeedleFromRequest(r *http.Request, fixJpgOrientation bool) (n *Needle, originalSize int, e error) {
var pairMap map[string]string
fname, mimeType, isGzipped, isChunkedFile := "", "", false, false
n = new(Needle)
fname, n.Data, mimeType, pairMap, isGzipped, originalSize, n.LastModified, n.Ttl, isChunkedFile, e = ParseUpload(r)
if e != nil {
return
}
if len(fname) < 256 {
n.Name = []byte(fname)
n.SetHasName()
}
if len(mimeType) < 256 {
n.Mime = []byte(mimeType)
n.SetHasMime()
}
if len(pairMap) != 0 {
trimmedPairMap := make(map[string]string)
for k, v := range pairMap {
trimmedPairMap[k[len(PairNamePrefix):]] = v
}
pairs, _ := json.Marshal(trimmedPairMap)
if len(pairs) < 65536 {
n.Pairs = pairs
n.PairsSize = uint16(len(pairs))
n.SetHasPairs()
}
}
if isGzipped {
n.SetGzipped()
}
if n.LastModified == 0 {
n.LastModified = uint64(time.Now().Unix())
}
n.SetHasLastModifiedDate()
2014-09-21 03:51:24 +00:00
if n.Ttl != EMPTY_TTL {
n.SetHasTtl()
}
if isChunkedFile {
2015-12-15 06:38:58 +00:00
n.SetIsChunkManifest()
}
2014-05-16 08:10:46 +00:00
if fixJpgOrientation {
loweredName := strings.ToLower(fname)
if mimeType == "image/jpeg" || strings.HasSuffix(loweredName, ".jpg") || strings.HasSuffix(loweredName, ".jpeg") {
n.Data = images.FixJpgOrientation(n.Data)
}
}
n.Checksum = NewCRC(n.Data)
commaSep := strings.LastIndex(r.URL.Path, ",")
dotSep := strings.LastIndex(r.URL.Path, ".")
fid := r.URL.Path[commaSep+1:]
if dotSep > 0 {
2018-07-24 08:38:08 +00:00
fid = r.URL.Path[commaSep+1 : dotSep]
}
e = n.ParsePath(fid)
return
}
func (n *Needle) ParsePath(fid string) (err error) {
length := len(fid)
if length <= CookieSize*2 {
2016-04-10 08:50:58 +00:00
return fmt.Errorf("Invalid fid: %s", fid)
}
delta := ""
deltaIndex := strings.LastIndex(fid, "_")
if deltaIndex > 0 {
fid, delta = fid[0:deltaIndex], fid[deltaIndex+1:]
}
n.Id, n.Cookie, err = ParseNeedleIdCookie(fid)
if err != nil {
return err
}
if delta != "" {
if d, e := strconv.ParseUint(delta, 10, 64); e == nil {
n.Id += NeedleId(d)
} else {
return e
}
}
return err
}
func ParseNeedleIdCookie(key_hash_string string) (NeedleId, Cookie, error) {
if len(key_hash_string) <= CookieSize*2 {
2018-08-01 06:25:26 +00:00
return NeedleIdEmpty, 0, fmt.Errorf("KeyHash is too short.")
2012-12-21 08:36:55 +00:00
}
if len(key_hash_string) > (NeedleIdSize+CookieSize)*2 {
2018-08-01 06:25:26 +00:00
return NeedleIdEmpty, 0, fmt.Errorf("KeyHash is too long.")
2016-04-10 07:54:40 +00:00
}
split := len(key_hash_string) - CookieSize*2
needleId, err := ParseNeedleId(key_hash_string[:split])
2016-04-10 07:54:40 +00:00
if err != nil {
2018-08-01 06:25:26 +00:00
return NeedleIdEmpty, 0, fmt.Errorf("Parse needleId error: %v", err)
2016-04-10 07:54:40 +00:00
}
cookie, err := ParseCookie(key_hash_string[split:])
2016-04-10 07:54:40 +00:00
if err != nil {
2018-08-01 06:25:26 +00:00
return NeedleIdEmpty, 0, fmt.Errorf("Parse cookie error: %v", err)
2016-04-10 07:54:40 +00:00
}
return needleId, cookie, nil
2016-04-10 07:54:40 +00:00
}
func (n *Needle) LastModifiedString() string {
return time.Unix(int64(n.LastModified), 0).Format("2006-01-02T15:04:05")
}