a42a906c42
From-SVN: r194460
635 lines
19 KiB
Go
635 lines
19 KiB
Go
// Copyright 2010 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package multipart
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io"
|
|
"io/ioutil"
|
|
"net/textproto"
|
|
"os"
|
|
"reflect"
|
|
"strings"
|
|
"testing"
|
|
)
|
|
|
|
func TestBoundaryLine(t *testing.T) {
|
|
mr := NewReader(strings.NewReader(""), "myBoundary")
|
|
if !mr.isBoundaryDelimiterLine([]byte("--myBoundary\r\n")) {
|
|
t.Error("expected")
|
|
}
|
|
if !mr.isBoundaryDelimiterLine([]byte("--myBoundary \r\n")) {
|
|
t.Error("expected")
|
|
}
|
|
if !mr.isBoundaryDelimiterLine([]byte("--myBoundary \n")) {
|
|
t.Error("expected")
|
|
}
|
|
if mr.isBoundaryDelimiterLine([]byte("--myBoundary bogus \n")) {
|
|
t.Error("expected fail")
|
|
}
|
|
if mr.isBoundaryDelimiterLine([]byte("--myBoundary bogus--")) {
|
|
t.Error("expected fail")
|
|
}
|
|
}
|
|
|
|
func escapeString(v string) string {
|
|
bytes, _ := json.Marshal(v)
|
|
return string(bytes)
|
|
}
|
|
|
|
func expectEq(t *testing.T, expected, actual, what string) {
|
|
if expected == actual {
|
|
return
|
|
}
|
|
t.Errorf("Unexpected value for %s; got %s (len %d) but expected: %s (len %d)",
|
|
what, escapeString(actual), len(actual), escapeString(expected), len(expected))
|
|
}
|
|
|
|
func TestNameAccessors(t *testing.T) {
|
|
tests := [...][3]string{
|
|
{`form-data; name="foo"`, "foo", ""},
|
|
{` form-data ; name=foo`, "foo", ""},
|
|
{`FORM-DATA;name="foo"`, "foo", ""},
|
|
{` FORM-DATA ; name="foo"`, "foo", ""},
|
|
{` FORM-DATA ; name="foo"`, "foo", ""},
|
|
{` FORM-DATA ; name=foo`, "foo", ""},
|
|
{` FORM-DATA ; filename="foo.txt"; name=foo; baz=quux`, "foo", "foo.txt"},
|
|
{` not-form-data ; filename="bar.txt"; name=foo; baz=quux`, "", "bar.txt"},
|
|
}
|
|
for i, test := range tests {
|
|
p := &Part{Header: make(map[string][]string)}
|
|
p.Header.Set("Content-Disposition", test[0])
|
|
if g, e := p.FormName(), test[1]; g != e {
|
|
t.Errorf("test %d: FormName() = %q; want %q", i, g, e)
|
|
}
|
|
if g, e := p.FileName(), test[2]; g != e {
|
|
t.Errorf("test %d: FileName() = %q; want %q", i, g, e)
|
|
}
|
|
}
|
|
}
|
|
|
|
var longLine = strings.Repeat("\n\n\r\r\r\n\r\000", (1<<20)/8)
|
|
|
|
func testMultipartBody(sep string) string {
|
|
testBody := `
|
|
This is a multi-part message. This line is ignored.
|
|
--MyBoundary
|
|
Header1: value1
|
|
HEADER2: value2
|
|
foo-bar: baz
|
|
|
|
My value
|
|
The end.
|
|
--MyBoundary
|
|
name: bigsection
|
|
|
|
[longline]
|
|
--MyBoundary
|
|
Header1: value1b
|
|
HEADER2: value2b
|
|
foo-bar: bazb
|
|
|
|
Line 1
|
|
Line 2
|
|
Line 3 ends in a newline, but just one.
|
|
|
|
--MyBoundary
|
|
|
|
never read data
|
|
--MyBoundary--
|
|
|
|
|
|
useless trailer
|
|
`
|
|
testBody = strings.Replace(testBody, "\n", sep, -1)
|
|
return strings.Replace(testBody, "[longline]", longLine, 1)
|
|
}
|
|
|
|
func TestMultipart(t *testing.T) {
|
|
bodyReader := strings.NewReader(testMultipartBody("\r\n"))
|
|
testMultipart(t, bodyReader, false)
|
|
}
|
|
|
|
func TestMultipartOnlyNewlines(t *testing.T) {
|
|
bodyReader := strings.NewReader(testMultipartBody("\n"))
|
|
testMultipart(t, bodyReader, true)
|
|
}
|
|
|
|
func TestMultipartSlowInput(t *testing.T) {
|
|
bodyReader := strings.NewReader(testMultipartBody("\r\n"))
|
|
testMultipart(t, &slowReader{bodyReader}, false)
|
|
}
|
|
|
|
func testMultipart(t *testing.T, r io.Reader, onlyNewlines bool) {
|
|
reader := NewReader(r, "MyBoundary")
|
|
buf := new(bytes.Buffer)
|
|
|
|
// Part1
|
|
part, err := reader.NextPart()
|
|
if part == nil || err != nil {
|
|
t.Error("Expected part1")
|
|
return
|
|
}
|
|
if x := part.Header.Get("Header1"); x != "value1" {
|
|
t.Errorf("part.Header.Get(%q) = %q, want %q", "Header1", x, "value1")
|
|
}
|
|
if x := part.Header.Get("foo-bar"); x != "baz" {
|
|
t.Errorf("part.Header.Get(%q) = %q, want %q", "foo-bar", x, "baz")
|
|
}
|
|
if x := part.Header.Get("Foo-Bar"); x != "baz" {
|
|
t.Errorf("part.Header.Get(%q) = %q, want %q", "Foo-Bar", x, "baz")
|
|
}
|
|
buf.Reset()
|
|
if _, err := io.Copy(buf, part); err != nil {
|
|
t.Errorf("part 1 copy: %v", err)
|
|
}
|
|
|
|
adjustNewlines := func(s string) string {
|
|
if onlyNewlines {
|
|
return strings.Replace(s, "\r\n", "\n", -1)
|
|
}
|
|
return s
|
|
}
|
|
|
|
expectEq(t, adjustNewlines("My value\r\nThe end."), buf.String(), "Value of first part")
|
|
|
|
// Part2
|
|
part, err = reader.NextPart()
|
|
if err != nil {
|
|
t.Fatalf("Expected part2; got: %v", err)
|
|
return
|
|
}
|
|
if e, g := "bigsection", part.Header.Get("name"); e != g {
|
|
t.Errorf("part2's name header: expected %q, got %q", e, g)
|
|
}
|
|
buf.Reset()
|
|
if _, err := io.Copy(buf, part); err != nil {
|
|
t.Errorf("part 2 copy: %v", err)
|
|
}
|
|
s := buf.String()
|
|
if len(s) != len(longLine) {
|
|
t.Errorf("part2 body expected long line of length %d; got length %d",
|
|
len(longLine), len(s))
|
|
}
|
|
if s != longLine {
|
|
t.Errorf("part2 long body didn't match")
|
|
}
|
|
|
|
// Part3
|
|
part, err = reader.NextPart()
|
|
if part == nil || err != nil {
|
|
t.Error("Expected part3")
|
|
return
|
|
}
|
|
if part.Header.Get("foo-bar") != "bazb" {
|
|
t.Error("Expected foo-bar: bazb")
|
|
}
|
|
buf.Reset()
|
|
if _, err := io.Copy(buf, part); err != nil {
|
|
t.Errorf("part 3 copy: %v", err)
|
|
}
|
|
expectEq(t, adjustNewlines("Line 1\r\nLine 2\r\nLine 3 ends in a newline, but just one.\r\n"),
|
|
buf.String(), "body of part 3")
|
|
|
|
// Part4
|
|
part, err = reader.NextPart()
|
|
if part == nil || err != nil {
|
|
t.Error("Expected part 4 without errors")
|
|
return
|
|
}
|
|
|
|
// Non-existent part5
|
|
part, err = reader.NextPart()
|
|
if part != nil {
|
|
t.Error("Didn't expect a fifth part.")
|
|
}
|
|
if err != io.EOF {
|
|
t.Errorf("On fifth part expected io.EOF; got %v", err)
|
|
}
|
|
}
|
|
|
|
func TestVariousTextLineEndings(t *testing.T) {
|
|
tests := [...]string{
|
|
"Foo\nBar",
|
|
"Foo\nBar\n",
|
|
"Foo\r\nBar",
|
|
"Foo\r\nBar\r\n",
|
|
"Foo\rBar",
|
|
"Foo\rBar\r",
|
|
"\x00\x01\x02\x09\x0a\x0b\x0c\x0d\x0e\x0f\x10",
|
|
}
|
|
|
|
for testNum, expectedBody := range tests {
|
|
body := "--BOUNDARY\r\n" +
|
|
"Content-Disposition: form-data; name=\"value\"\r\n" +
|
|
"\r\n" +
|
|
expectedBody +
|
|
"\r\n--BOUNDARY--\r\n"
|
|
bodyReader := strings.NewReader(body)
|
|
|
|
reader := NewReader(bodyReader, "BOUNDARY")
|
|
buf := new(bytes.Buffer)
|
|
part, err := reader.NextPart()
|
|
if part == nil {
|
|
t.Errorf("Expected a body part on text %d", testNum)
|
|
continue
|
|
}
|
|
if err != nil {
|
|
t.Errorf("Unexpected error on text %d: %v", testNum, err)
|
|
continue
|
|
}
|
|
written, err := io.Copy(buf, part)
|
|
expectEq(t, expectedBody, buf.String(), fmt.Sprintf("test %d", testNum))
|
|
if err != nil {
|
|
t.Errorf("Error copying multipart; bytes=%v, error=%v", written, err)
|
|
}
|
|
|
|
part, err = reader.NextPart()
|
|
if part != nil {
|
|
t.Errorf("Unexpected part in test %d", testNum)
|
|
}
|
|
if err != io.EOF {
|
|
t.Errorf("On test %d expected io.EOF; got %v", testNum, err)
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
type maliciousReader struct {
|
|
t *testing.T
|
|
n int
|
|
}
|
|
|
|
const maxReadThreshold = 1 << 20
|
|
|
|
func (mr *maliciousReader) Read(b []byte) (n int, err error) {
|
|
mr.n += len(b)
|
|
if mr.n >= maxReadThreshold {
|
|
mr.t.Fatal("too much was read")
|
|
return 0, io.EOF
|
|
}
|
|
return len(b), nil
|
|
}
|
|
|
|
func TestLineLimit(t *testing.T) {
|
|
mr := &maliciousReader{t: t}
|
|
r := NewReader(mr, "fooBoundary")
|
|
part, err := r.NextPart()
|
|
if part != nil {
|
|
t.Errorf("unexpected part read")
|
|
}
|
|
if err == nil {
|
|
t.Errorf("expected an error")
|
|
}
|
|
if mr.n >= maxReadThreshold {
|
|
t.Errorf("expected to read < %d bytes; read %d", maxReadThreshold, mr.n)
|
|
}
|
|
}
|
|
|
|
func TestMultipartTruncated(t *testing.T) {
|
|
testBody := `
|
|
This is a multi-part message. This line is ignored.
|
|
--MyBoundary
|
|
foo-bar: baz
|
|
|
|
Oh no, premature EOF!
|
|
`
|
|
body := strings.Replace(testBody, "\n", "\r\n", -1)
|
|
bodyReader := strings.NewReader(body)
|
|
r := NewReader(bodyReader, "MyBoundary")
|
|
|
|
part, err := r.NextPart()
|
|
if err != nil {
|
|
t.Fatalf("didn't get a part")
|
|
}
|
|
_, err = io.Copy(ioutil.Discard, part)
|
|
if err != io.ErrUnexpectedEOF {
|
|
t.Fatalf("expected error io.ErrUnexpectedEOF; got %v", err)
|
|
}
|
|
}
|
|
|
|
type slowReader struct {
|
|
r io.Reader
|
|
}
|
|
|
|
func (s *slowReader) Read(p []byte) (int, error) {
|
|
if len(p) == 0 {
|
|
return s.r.Read(p)
|
|
}
|
|
return s.r.Read(p[:1])
|
|
}
|
|
|
|
func TestLineContinuation(t *testing.T) {
|
|
// This body, extracted from an email, contains headers that span multiple
|
|
// lines.
|
|
|
|
// TODO: The original mail ended with a double-newline before the
|
|
// final delimiter; this was manually edited to use a CRLF.
|
|
testBody :=
|
|
"\n--Apple-Mail-2-292336769\nContent-Transfer-Encoding: 7bit\nContent-Type: text/plain;\n\tcharset=US-ASCII;\n\tdelsp=yes;\n\tformat=flowed\n\nI'm finding the same thing happening on my system (10.4.1).\n\n\n--Apple-Mail-2-292336769\nContent-Transfer-Encoding: quoted-printable\nContent-Type: text/html;\n\tcharset=ISO-8859-1\n\n<HTML><BODY>I'm finding the same thing =\nhappening on my system (10.4.1).=A0 But I built it with XCode =\n2.0.</BODY></=\nHTML>=\n\r\n--Apple-Mail-2-292336769--\n"
|
|
|
|
r := NewReader(strings.NewReader(testBody), "Apple-Mail-2-292336769")
|
|
|
|
for i := 0; i < 2; i++ {
|
|
part, err := r.NextPart()
|
|
if err != nil {
|
|
t.Fatalf("didn't get a part")
|
|
}
|
|
var buf bytes.Buffer
|
|
n, err := io.Copy(&buf, part)
|
|
if err != nil {
|
|
t.Errorf("error reading part: %v\nread so far: %q", err, buf.String())
|
|
}
|
|
if n <= 0 {
|
|
t.Errorf("read %d bytes; expected >0", n)
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestQuotedPrintableEncoding(t *testing.T) {
|
|
// From http://golang.org/issue/4411
|
|
body := "--0016e68ee29c5d515f04cedf6733\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=text\r\nContent-Transfer-Encoding: quoted-printable\r\n\r\nwords words words words words words words words words words words words wor=\r\nds words words words words words words words words words words words words =\r\nwords words words words words words words words words words words words wor=\r\nds words words words words words words words words words words words words =\r\nwords words words words words words words words words\r\n--0016e68ee29c5d515f04cedf6733\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=submit\r\n\r\nSubmit\r\n--0016e68ee29c5d515f04cedf6733--"
|
|
r := NewReader(strings.NewReader(body), "0016e68ee29c5d515f04cedf6733")
|
|
part, err := r.NextPart()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if te, ok := part.Header["Content-Transfer-Encoding"]; ok {
|
|
t.Errorf("unexpected Content-Transfer-Encoding of %q", te)
|
|
}
|
|
var buf bytes.Buffer
|
|
_, err = io.Copy(&buf, part)
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
got := buf.String()
|
|
want := "words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words words"
|
|
if got != want {
|
|
t.Errorf("wrong part value:\n got: %q\nwant: %q", got, want)
|
|
}
|
|
}
|
|
|
|
// Test parsing an image attachment from gmail, which previously failed.
|
|
func TestNested(t *testing.T) {
|
|
// nested-mime is the body part of a multipart/mixed email
|
|
// with boundary e89a8ff1c1e83553e304be640612
|
|
f, err := os.Open("testdata/nested-mime")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer f.Close()
|
|
mr := NewReader(f, "e89a8ff1c1e83553e304be640612")
|
|
p, err := mr.NextPart()
|
|
if err != nil {
|
|
t.Fatalf("error reading first section (alternative): %v", err)
|
|
}
|
|
|
|
// Read the inner text/plain and text/html sections of the multipart/alternative.
|
|
mr2 := NewReader(p, "e89a8ff1c1e83553e004be640610")
|
|
p, err = mr2.NextPart()
|
|
if err != nil {
|
|
t.Fatalf("reading text/plain part: %v", err)
|
|
}
|
|
if b, err := ioutil.ReadAll(p); string(b) != "*body*\r\n" || err != nil {
|
|
t.Fatalf("reading text/plain part: got %q, %v", b, err)
|
|
}
|
|
p, err = mr2.NextPart()
|
|
if err != nil {
|
|
t.Fatalf("reading text/html part: %v", err)
|
|
}
|
|
if b, err := ioutil.ReadAll(p); string(b) != "<b>body</b>\r\n" || err != nil {
|
|
t.Fatalf("reading text/html part: got %q, %v", b, err)
|
|
}
|
|
|
|
p, err = mr2.NextPart()
|
|
if err != io.EOF {
|
|
t.Fatalf("final inner NextPart = %v; want io.EOF", err)
|
|
}
|
|
|
|
// Back to the outer multipart/mixed, reading the image attachment.
|
|
_, err = mr.NextPart()
|
|
if err != nil {
|
|
t.Fatalf("error reading the image attachment at the end: %v", err)
|
|
}
|
|
|
|
_, err = mr.NextPart()
|
|
if err != io.EOF {
|
|
t.Fatalf("final outer NextPart = %v; want io.EOF", err)
|
|
}
|
|
}
|
|
|
|
type headerBody struct {
|
|
header textproto.MIMEHeader
|
|
body string
|
|
}
|
|
|
|
func formData(key, value string) headerBody {
|
|
return headerBody{
|
|
textproto.MIMEHeader{
|
|
"Content-Type": {"text/plain; charset=ISO-8859-1"},
|
|
"Content-Disposition": {"form-data; name=" + key},
|
|
},
|
|
value,
|
|
}
|
|
}
|
|
|
|
type parseTest struct {
|
|
name string
|
|
in, sep string
|
|
want []headerBody
|
|
}
|
|
|
|
var parseTests = []parseTest{
|
|
// Actual body from App Engine on a blob upload. The final part (the
|
|
// Content-Type: message/external-body) is what App Engine replaces
|
|
// the uploaded file with. The other form fields (prefixed with
|
|
// "other" in their form-data name) are unchanged. A bug was
|
|
// reported with blob uploads failing when the other fields were
|
|
// empty. This was the MIME POST body that previously failed.
|
|
{
|
|
name: "App Engine post",
|
|
sep: "00151757727e9583fd04bfbca4c6",
|
|
in: "--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=otherEmpty1\r\n\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=otherFoo1\r\n\r\nfoo\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=otherFoo2\r\n\r\nfoo\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=otherEmpty2\r\n\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=otherRepeatFoo\r\n\r\nfoo\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=otherRepeatFoo\r\n\r\nfoo\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=otherRepeatEmpty\r\n\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=otherRepeatEmpty\r\n\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: text/plain; charset=ISO-8859-1\r\nContent-Disposition: form-data; name=submit\r\n\r\nSubmit\r\n--00151757727e9583fd04bfbca4c6\r\nContent-Type: message/external-body; charset=ISO-8859-1; blob-key=AHAZQqG84qllx7HUqO_oou5EvdYQNS3Mbbkb0RjjBoM_Kc1UqEN2ygDxWiyCPulIhpHRPx-VbpB6RX4MrsqhWAi_ZxJ48O9P2cTIACbvATHvg7IgbvZytyGMpL7xO1tlIvgwcM47JNfv_tGhy1XwyEUO8oldjPqg5Q\r\nContent-Disposition: form-data; name=file; filename=\"fall.png\"\r\n\r\nContent-Type: image/png\r\nContent-Length: 232303\r\nX-AppEngine-Upload-Creation: 2012-05-10 23:14:02.715173\r\nContent-MD5: MzRjODU1ZDZhZGU1NmRlOWEwZmMwMDdlODBmZTA0NzA=\r\nContent-Disposition: form-data; name=file; filename=\"fall.png\"\r\n\r\n\r\n--00151757727e9583fd04bfbca4c6--",
|
|
want: []headerBody{
|
|
formData("otherEmpty1", ""),
|
|
formData("otherFoo1", "foo"),
|
|
formData("otherFoo2", "foo"),
|
|
formData("otherEmpty2", ""),
|
|
formData("otherRepeatFoo", "foo"),
|
|
formData("otherRepeatFoo", "foo"),
|
|
formData("otherRepeatEmpty", ""),
|
|
formData("otherRepeatEmpty", ""),
|
|
formData("submit", "Submit"),
|
|
{textproto.MIMEHeader{
|
|
"Content-Type": {"message/external-body; charset=ISO-8859-1; blob-key=AHAZQqG84qllx7HUqO_oou5EvdYQNS3Mbbkb0RjjBoM_Kc1UqEN2ygDxWiyCPulIhpHRPx-VbpB6RX4MrsqhWAi_ZxJ48O9P2cTIACbvATHvg7IgbvZytyGMpL7xO1tlIvgwcM47JNfv_tGhy1XwyEUO8oldjPqg5Q"},
|
|
"Content-Disposition": {"form-data; name=file; filename=\"fall.png\""},
|
|
}, "Content-Type: image/png\r\nContent-Length: 232303\r\nX-AppEngine-Upload-Creation: 2012-05-10 23:14:02.715173\r\nContent-MD5: MzRjODU1ZDZhZGU1NmRlOWEwZmMwMDdlODBmZTA0NzA=\r\nContent-Disposition: form-data; name=file; filename=\"fall.png\"\r\n\r\n"},
|
|
},
|
|
},
|
|
|
|
// Single empty part, ended with --boundary immediately after headers.
|
|
{
|
|
name: "single empty part, --boundary",
|
|
sep: "abc",
|
|
in: "--abc\r\nFoo: bar\r\n\r\n--abc--",
|
|
want: []headerBody{
|
|
{textproto.MIMEHeader{"Foo": {"bar"}}, ""},
|
|
},
|
|
},
|
|
|
|
// Single empty part, ended with \r\n--boundary immediately after headers.
|
|
{
|
|
name: "single empty part, \r\n--boundary",
|
|
sep: "abc",
|
|
in: "--abc\r\nFoo: bar\r\n\r\n\r\n--abc--",
|
|
want: []headerBody{
|
|
{textproto.MIMEHeader{"Foo": {"bar"}}, ""},
|
|
},
|
|
},
|
|
|
|
// Final part empty.
|
|
{
|
|
name: "final part empty",
|
|
sep: "abc",
|
|
in: "--abc\r\nFoo: bar\r\n\r\n--abc\r\nFoo2: bar2\r\n\r\n--abc--",
|
|
want: []headerBody{
|
|
{textproto.MIMEHeader{"Foo": {"bar"}}, ""},
|
|
{textproto.MIMEHeader{"Foo2": {"bar2"}}, ""},
|
|
},
|
|
},
|
|
|
|
// Final part empty with newlines after final separator.
|
|
{
|
|
name: "final part empty then crlf",
|
|
sep: "abc",
|
|
in: "--abc\r\nFoo: bar\r\n\r\n--abc--\r\n",
|
|
want: []headerBody{
|
|
{textproto.MIMEHeader{"Foo": {"bar"}}, ""},
|
|
},
|
|
},
|
|
|
|
// Final part empty with lwsp-chars after final separator.
|
|
{
|
|
name: "final part empty then lwsp",
|
|
sep: "abc",
|
|
in: "--abc\r\nFoo: bar\r\n\r\n--abc-- \t",
|
|
want: []headerBody{
|
|
{textproto.MIMEHeader{"Foo": {"bar"}}, ""},
|
|
},
|
|
},
|
|
|
|
// No parts (empty form as submitted by Chrome)
|
|
{
|
|
name: "no parts",
|
|
sep: "----WebKitFormBoundaryQfEAfzFOiSemeHfA",
|
|
in: "------WebKitFormBoundaryQfEAfzFOiSemeHfA--\r\n",
|
|
want: []headerBody{},
|
|
},
|
|
|
|
// Part containing data starting with the boundary, but with additional suffix.
|
|
{
|
|
name: "fake separator as data",
|
|
sep: "sep",
|
|
in: "--sep\r\nFoo: bar\r\n\r\n--sepFAKE\r\n--sep--",
|
|
want: []headerBody{
|
|
{textproto.MIMEHeader{"Foo": {"bar"}}, "--sepFAKE"},
|
|
},
|
|
},
|
|
|
|
// Part containing a boundary with whitespace following it.
|
|
{
|
|
name: "boundary with whitespace",
|
|
sep: "sep",
|
|
in: "--sep \r\nFoo: bar\r\n\r\ntext\r\n--sep--",
|
|
want: []headerBody{
|
|
{textproto.MIMEHeader{"Foo": {"bar"}}, "text"},
|
|
},
|
|
},
|
|
|
|
// With ignored leading line.
|
|
{
|
|
name: "leading line",
|
|
sep: "MyBoundary",
|
|
in: strings.Replace(`This is a multi-part message. This line is ignored.
|
|
--MyBoundary
|
|
foo: bar
|
|
|
|
|
|
--MyBoundary--`, "\n", "\r\n", -1),
|
|
want: []headerBody{
|
|
{textproto.MIMEHeader{"Foo": {"bar"}}, ""},
|
|
},
|
|
},
|
|
|
|
roundTripParseTest(),
|
|
}
|
|
|
|
func TestParse(t *testing.T) {
|
|
Cases:
|
|
for _, tt := range parseTests {
|
|
r := NewReader(strings.NewReader(tt.in), tt.sep)
|
|
got := []headerBody{}
|
|
for {
|
|
p, err := r.NextPart()
|
|
if err == io.EOF {
|
|
break
|
|
}
|
|
if err != nil {
|
|
t.Errorf("in test %q, NextPart: %v", tt.name, err)
|
|
continue Cases
|
|
}
|
|
pbody, err := ioutil.ReadAll(p)
|
|
if err != nil {
|
|
t.Errorf("in test %q, error reading part: %v", tt.name, err)
|
|
continue Cases
|
|
}
|
|
got = append(got, headerBody{p.Header, string(pbody)})
|
|
}
|
|
if !reflect.DeepEqual(tt.want, got) {
|
|
t.Errorf("test %q:\n got: %v\nwant: %v", tt.name, got, tt.want)
|
|
if len(tt.want) != len(got) {
|
|
t.Errorf("test %q: got %d parts, want %d", tt.name, len(got), len(tt.want))
|
|
} else if len(got) > 1 {
|
|
for pi, wantPart := range tt.want {
|
|
if !reflect.DeepEqual(wantPart, got[pi]) {
|
|
t.Errorf("test %q, part %d:\n got: %v\nwant: %v", tt.name, pi, got[pi], wantPart)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func roundTripParseTest() parseTest {
|
|
t := parseTest{
|
|
name: "round trip",
|
|
want: []headerBody{
|
|
formData("empty", ""),
|
|
formData("lf", "\n"),
|
|
formData("cr", "\r"),
|
|
formData("crlf", "\r\n"),
|
|
formData("foo", "bar"),
|
|
},
|
|
}
|
|
var buf bytes.Buffer
|
|
w := NewWriter(&buf)
|
|
for _, p := range t.want {
|
|
pw, err := w.CreatePart(p.header)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
_, err = pw.Write([]byte(p.body))
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
}
|
|
w.Close()
|
|
t.in = buf.String()
|
|
t.sep = w.Boundary()
|
|
return t
|
|
}
|