1 files changed, 9 insertions, 84 deletions
diff --git a/weed/storage/needle.go b/weed/storage/needle.go
index 492e4646c..46ba933ca 100644
--- a/weed/storage/needle.go
+++ b/weed/storage/needle.go
@@ -3,18 +3,14 @@ package storage
 import (
 	"encoding/json"
 	"fmt"
-	"io/ioutil"
-	"mime"
 	"net/http"
-	"path"
 	"strconv"
 	"strings"
 	"time"
 
-	"github.com/chrislusf/seaweedfs/weed/glog"
 	"github.com/chrislusf/seaweedfs/weed/images"
-	"github.com/chrislusf/seaweedfs/weed/operation"
 	. "github.com/chrislusf/seaweedfs/weed/storage/types"
+	"io/ioutil"
 )
 
 const (
@@ -62,91 +58,20 @@ func ParseUpload(r *http.Request) (
 		}
 	}
 
-	form, fe := r.MultipartReader()
-	if fe != nil {
-		glog.V(0).Infoln("MultipartReader [ERROR]", fe)
-		e = fe
-		return
-	}
-
-	//first multi-part item
-	part, fe := form.NextPart()
-	if fe != nil {
-		glog.V(0).Infoln("Reading Multi part [ERROR]", fe)
-		e = fe
-		return
-	}
+	isChunkedFile, _ = strconv.ParseBool(r.FormValue("cm"))
 
-	fileName = part.FileName()
-	if fileName != "" {
-		fileName = path.Base(fileName)
+	if r.Method == "POST" {
+		fileName, data, mimeType, isGzipped, e = parseMultipart(r, isChunkedFile)
+	} else {
+		isGzipped = false
+		mimeType = r.Header.Get("Content-Type")
+		fileName = ""
+		data, e = ioutil.ReadAll(r.Body)
 	}
-
-	data, e = ioutil.ReadAll(part)
 	if e != nil {
-		glog.V(0).Infoln("Reading Content [ERROR]", e)
 		return
 	}
 
-	//if the filename is empty string, do a search on the other multi-part items
-	for fileName == "" {
-		part2, fe := form.NextPart()
-		if fe != nil {
-			break // no more or on error, just safely break
-		}
-
-		fName := part2.FileName()
-
-		//found the first <file type> multi-part has filename
-		if fName != "" {
-			data2, fe2 := ioutil.ReadAll(part2)
-			if fe2 != nil {
-				glog.V(0).Infoln("Reading Content [ERROR]", fe2)
-				e = fe2
-				return
-			}
-
-			//update
-			data = data2
-			fileName = path.Base(fName)
-			break
-		}
-	}
-
-	isChunkedFile, _ = strconv.ParseBool(r.FormValue("cm"))
-
-	if !isChunkedFile {
-
-		dotIndex := strings.LastIndex(fileName, ".")
-		ext, mtype := "", ""
-		if dotIndex > 0 {
-			ext = strings.ToLower(fileName[dotIndex:])
-			mtype = mime.TypeByExtension(ext)
-		}
-		contentType := part.Header.Get("Content-Type")
-		if contentType != "" && mtype != contentType {
-			mimeType = contentType //only return mime type if not deductable
-			mtype = contentType
-		}
-
-		if part.Header.Get("Content-Encoding") == "gzip" {
-			isGzipped = true
-		} else if operation.IsGzippable(ext, mtype) {
-			if data, e = operation.GzipData(data); e != nil {
-				return
-			}
-			isGzipped = true
-		}
-		if ext == ".gz" {
-			if strings.HasSuffix(fileName, ".css.gz") ||
-				strings.HasSuffix(fileName, ".html.gz") ||
-				strings.HasSuffix(fileName, ".txt.gz") ||
-				strings.HasSuffix(fileName, ".js.gz") {
-				fileName = fileName[:len(fileName)-3]
-				isGzipped = true
-			}
-		}
-	}
 	modifiedTime, _ = strconv.ParseUint(r.FormValue("ts"), 10, 64)
 	ttl, _ = ReadTTL(r.FormValue("ttl"))