Update upload.go
This commit is contained in:
parent
17441020c2
commit
0156fdb15b
25
upload.go
25
upload.go
|
@ -136,6 +136,11 @@ func uploadPutHandler(c web.C, w http.ResponseWriter, r *http.Request) {
|
||||||
upReq := UploadRequest{}
|
upReq := UploadRequest{}
|
||||||
uploadHeaderProcess(r, &upReq)
|
uploadHeaderProcess(r, &upReq)
|
||||||
|
|
||||||
|
defer r.Body.Close()
|
||||||
|
upReq.filename = c.URLParams["name"]
|
||||||
|
upReq.src = http.MaxBytesReader(w, r.Body, Config.maxSize)
|
||||||
|
upReq.srcIp = r.Header.Get("X-Forwarded-For")
|
||||||
|
|
||||||
if len(r.Header.Get("Content-Length")) > 0 {
|
if len(r.Header.Get("Content-Length")) > 0 {
|
||||||
i, err := strconv.ParseInt(r.Header.Get("Content-Length"), 10, 64)
|
i, err := strconv.ParseInt(r.Header.Get("Content-Length"), 10, 64)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
|
@ -145,10 +150,6 @@ func uploadPutHandler(c web.C, w http.ResponseWriter, r *http.Request) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
defer r.Body.Close()
|
|
||||||
upReq.filename = c.URLParams["name"]
|
|
||||||
upReq.src = http.MaxBytesReader(w, r.Body, Config.maxSize)
|
|
||||||
upReq.srcIp = r.Header.Get("X-Forwarded-For")
|
|
||||||
upload, err := processUpload(upReq)
|
upload, err := processUpload(upReq)
|
||||||
|
|
||||||
if strings.EqualFold("application/json", r.Header.Get("Accept")) {
|
if strings.EqualFold("application/json", r.Header.Get("Accept")) {
|
||||||
|
@ -213,6 +214,15 @@ func uploadRemote(c web.C, w http.ResponseWriter, r *http.Request) {
|
||||||
oopsHandler(c, w, r, RespAUTO, "Could not retrieve URL")
|
oopsHandler(c, w, r, RespAUTO, "Could not retrieve URL")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
upReq.filename = filepath.Base(grabUrl.Path)
|
||||||
|
upReq.src = http.MaxBytesReader(w, resp.Body, Config.maxSize)
|
||||||
|
upReq.deleteKey = r.FormValue("deletekey")
|
||||||
|
upReq.accessKey = r.FormValue(accessKeyParamName)
|
||||||
|
upReq.randomBarename = r.FormValue("randomize") == "yes"
|
||||||
|
upReq.expiry = parseExpiry(r.FormValue("expiry"))
|
||||||
|
upReq.srcIp = r.Header.Get("X-Forwarded-For")
|
||||||
|
|
||||||
if len(r.Header.Get("Content-Length")) > 0 {
|
if len(r.Header.Get("Content-Length")) > 0 {
|
||||||
i, err := strconv.ParseInt(r.Header.Get("Content-Length"), 10, 64)
|
i, err := strconv.ParseInt(r.Header.Get("Content-Length"), 10, 64)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
|
@ -222,13 +232,6 @@ func uploadRemote(c web.C, w http.ResponseWriter, r *http.Request) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
upReq.filename = filepath.Base(grabUrl.Path)
|
|
||||||
upReq.src = http.MaxBytesReader(w, resp.Body, Config.maxSize)
|
|
||||||
upReq.deleteKey = r.FormValue("deletekey")
|
|
||||||
upReq.accessKey = r.FormValue(accessKeyParamName)
|
|
||||||
upReq.randomBarename = r.FormValue("randomize") == "yes"
|
|
||||||
upReq.expiry = parseExpiry(r.FormValue("expiry"))
|
|
||||||
upReq.srcIp = r.Header.Get("X-Forwarded-For")
|
|
||||||
upload, err := processUpload(upReq)
|
upload, err := processUpload(upReq)
|
||||||
|
|
||||||
if strings.EqualFold("application/json", r.Header.Get("Accept")) {
|
if strings.EqualFold("application/json", r.Header.Get("Accept")) {
|
||||||
|
|
Loading…
Reference in New Issue