good morning!!!!

Skip to content
Snippets Groups Projects
Commit f31f630b authored by a's avatar a
Browse files

remove another copy

parent 02837c79
Branches
Tags
No related merge requests found
package fs_weed package fs_weed
import ( import (
"bytes"
"fmt" "fmt"
"io" "io"
"log"
"mime/multipart" "mime/multipart"
"net/textproto" "net/textproto"
"gitlab.com/gfxlabs/goutil/bufpool"
) )
func makeFormData( func makeFormData(
filename, mimeType string, filename, mimeType string,
content io.Reader, content []byte,
) (formData *bytes.Buffer, contentType string, err error) { ) (formData *bufpool.PooledBuffer, err error) {
buf := new(bytes.Buffer) buf := BUFPOOL.Get()
writer := multipart.NewWriter(buf) writer := multipart.NewWriter(buf)
defer writer.Close()
part, err := createFormFile(writer, "file", filename, mimeType) part, err := createFormFile(writer, "file", filename, mimeType)
if err != nil { if err != nil {
log.Println(err) return buf, err
return
} }
_, err = io.Copy(part, content) _, err = part.Write(content)
if err != nil { if err != nil {
log.Println(err) return buf, err
return
} }
formData = buf return buf, err
contentType = writer.FormDataContentType()
writer.Close()
return
} }
func createFormFile(writer *multipart.Writer, fieldname, filename, mime string) (io.Writer, error) { func createFormFile(writer *multipart.Writer, fieldname, filename, mime string) (io.Writer, error) {
......
package fs_weed package fs_weed
import ( import (
"bytes"
"encoding/json" "encoding/json"
"errors" "errors"
"io" "io"
...@@ -115,11 +114,13 @@ func (F *FS) get(file string) (http.Header, []byte, error) { ...@@ -115,11 +114,13 @@ func (F *FS) get(file string) (http.Header, []byte, error) {
func (F *FS) push( func (F *FS) push(
file, content string, dat []byte, file, content string, dat []byte,
) (http.Header, []byte, error) { ) (http.Header, []byte, error) {
if content == "" { contentType := content
content = http.DetectContentType(dat) if contentType == "" {
contentType = http.DetectContentType(dat)
} }
sum := meow.Checksum64(THREEBEEF, dat) sum := meow.Checksum64(THREEBEEF, dat)
d, ct, err := makeFormData(normalizeName(file), content, bytes.NewBuffer(dat)) d, err := makeFormData(normalizeName(file), contentType, dat)
defer d.Release()
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
} }
...@@ -134,7 +135,7 @@ func (F *FS) push( ...@@ -134,7 +135,7 @@ func (F *FS) push(
return nil, nil, err return nil, nil, err
} }
req.Header.Set("Seaweed-Meow64", strconv.FormatUint(sum, 10)) req.Header.Set("Seaweed-Meow64", strconv.FormatUint(sum, 10))
req.Header.Set("Content-Type", ct) req.Header.Set("Content-Type", contentType)
resp, err := F.client.Do(req) resp, err := F.client.Do(req)
if err != nil { if err != nil {
return nil, nil, err return nil, nil, err
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment