| 
									
										
										
										
											2021-04-19 03:41:13 +08:00
										 |  |  | // Copyright (c) 2015-2021 MinIO, Inc.
 | 
					
						
							|  |  |  | //
 | 
					
						
							|  |  |  | // This file is part of MinIO Object Storage stack
 | 
					
						
							|  |  |  | //
 | 
					
						
							|  |  |  | // This program is free software: you can redistribute it and/or modify
 | 
					
						
							|  |  |  | // it under the terms of the GNU Affero General Public License as published by
 | 
					
						
							|  |  |  | // the Free Software Foundation, either version 3 of the License, or
 | 
					
						
							|  |  |  | // (at your option) any later version.
 | 
					
						
							|  |  |  | //
 | 
					
						
							|  |  |  | // This program is distributed in the hope that it will be useful
 | 
					
						
							|  |  |  | // but WITHOUT ANY WARRANTY; without even the implied warranty of
 | 
					
						
							|  |  |  | // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 | 
					
						
							|  |  |  | // GNU Affero General Public License for more details.
 | 
					
						
							|  |  |  | //
 | 
					
						
							|  |  |  | // You should have received a copy of the GNU Affero General Public License
 | 
					
						
							|  |  |  | // along with this program.  If not, see <http://www.gnu.org/licenses/>.
 | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-08-19 07:23:42 +08:00
										 |  |  | package cmd | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | import ( | 
					
						
							|  |  |  | 	"testing" | 
					
						
							|  |  |  | ) | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | func TestHTTPRequestRangeSpec(t *testing.T) { | 
					
						
							|  |  |  | 	resourceSize := int64(10) | 
					
						
							|  |  |  | 	validRangeSpecs := []struct { | 
					
						
							|  |  |  | 		spec                 string | 
					
						
							|  |  |  | 		expOffset, expLength int64 | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 	}{ | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 		{"bytes=0-", 0, 10}, | 
					
						
							|  |  |  | 		{"bytes=1-", 1, 9}, | 
					
						
							|  |  |  | 		{"bytes=0-9", 0, 10}, | 
					
						
							|  |  |  | 		{"bytes=1-10", 1, 9}, | 
					
						
							|  |  |  | 		{"bytes=1-1", 1, 1}, | 
					
						
							|  |  |  | 		{"bytes=2-5", 2, 4}, | 
					
						
							|  |  |  | 		{"bytes=-5", 5, 5}, | 
					
						
							|  |  |  | 		{"bytes=-1", 9, 1}, | 
					
						
							|  |  |  | 		{"bytes=-1000", 0, 10}, | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 	for i, testCase := range validRangeSpecs { | 
					
						
							|  |  |  | 		rs, err := parseRequestRangeSpec(testCase.spec) | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 		if err != nil { | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 			t.Errorf("unexpected err: %v", err) | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 		} | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 		o, l, err := rs.GetOffsetLength(resourceSize) | 
					
						
							|  |  |  | 		if err != nil { | 
					
						
							|  |  |  | 			t.Errorf("unexpected err: %v", err) | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 		} | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 		if o != testCase.expOffset || l != testCase.expLength { | 
					
						
							|  |  |  | 			t.Errorf("Case %d: got bad offset/length: %d,%d expected: %d,%d", | 
					
						
							|  |  |  | 				i, o, l, testCase.expOffset, testCase.expLength) | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 	unparsableRangeSpecs := []string{ | 
					
						
							| 
									
										
										
										
											2016-07-08 06:05:18 +08:00
										 |  |  | 		"bytes=-", | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 		"bytes==", | 
					
						
							|  |  |  | 		"bytes==1-10", | 
					
						
							|  |  |  | 		"bytes=", | 
					
						
							|  |  |  | 		"bytes=aa", | 
					
						
							|  |  |  | 		"aa", | 
					
						
							| 
									
										
										
										
											2016-07-08 06:05:18 +08:00
										 |  |  | 		"", | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 		"bytes=1-10-", | 
					
						
							|  |  |  | 		"bytes=1--10", | 
					
						
							|  |  |  | 		"bytes=-1-10", | 
					
						
							|  |  |  | 		"bytes=0-+3", | 
					
						
							|  |  |  | 		"bytes=+3-+5", | 
					
						
							| 
									
										
										
										
											2019-04-10 02:39:42 +08:00
										 |  |  | 		"bytes=10-11,12-10", // Unsupported by S3/MinIO (valid in RFC)
 | 
					
						
							| 
									
										
										
										
											2016-07-08 06:05:18 +08:00
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 	for i, urs := range unparsableRangeSpecs { | 
					
						
							|  |  |  | 		rs, err := parseRequestRangeSpec(urs) | 
					
						
							|  |  |  | 		if err == nil { | 
					
						
							|  |  |  | 			t.Errorf("Case %d: Did not get an expected error - got %v", i, rs) | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		if err == errInvalidRange { | 
					
						
							|  |  |  | 			t.Errorf("Case %d: Got invalid range error instead of a parse error", i) | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		if rs != nil { | 
					
						
							|  |  |  | 			t.Errorf("Case %d: Got non-nil rs though err != nil: %v", i, rs) | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 	invalidRangeSpecs := []string{ | 
					
						
							|  |  |  | 		"bytes=5-3", | 
					
						
							| 
									
										
										
										
											2016-07-08 06:05:18 +08:00
										 |  |  | 		"bytes=10-10", | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 		"bytes=10-", | 
					
						
							|  |  |  | 		"bytes=100-", | 
					
						
							| 
									
										
										
										
											2016-07-08 06:05:18 +08:00
										 |  |  | 		"bytes=-0", | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 	for i, irs := range invalidRangeSpecs { | 
					
						
							|  |  |  | 		var err1, err2 error | 
					
						
							|  |  |  | 		var rs *HTTPRangeSpec | 
					
						
							|  |  |  | 		var o, l int64 | 
					
						
							|  |  |  | 		rs, err1 = parseRequestRangeSpec(irs) | 
					
						
							|  |  |  | 		if err1 == nil { | 
					
						
							|  |  |  | 			o, l, err2 = rs.GetOffsetLength(resourceSize) | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		if err1 == errInvalidRange || (err1 == nil && err2 == errInvalidRange) { | 
					
						
							|  |  |  | 			continue | 
					
						
							| 
									
										
										
										
											2016-07-08 06:05:18 +08:00
										 |  |  | 		} | 
					
						
							| 
									
										
										
										
											2018-09-21 10:22:09 +08:00
										 |  |  | 		t.Errorf("Case %d: Expected errInvalidRange but: %v %v %d %d %v", i, rs, err1, o, l, err2) | 
					
						
							| 
									
										
										
										
											2016-07-07 03:50:24 +08:00
										 |  |  | 	} | 
					
						
							|  |  |  | } | 
					
						
							| 
									
										
										
										
											2022-03-09 05:58:55 +08:00
										 |  |  | 
 | 
					
						
							|  |  |  | func TestHTTPRequestRangeToHeader(t *testing.T) { | 
					
						
							|  |  |  | 	validRangeSpecs := []struct { | 
					
						
							|  |  |  | 		spec        string | 
					
						
							|  |  |  | 		errExpected bool | 
					
						
							|  |  |  | 	}{ | 
					
						
							|  |  |  | 		{"bytes=0-", false}, | 
					
						
							|  |  |  | 		{"bytes=1-", false}, | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		{"bytes=0-9", false}, | 
					
						
							|  |  |  | 		{"bytes=1-10", false}, | 
					
						
							|  |  |  | 		{"bytes=1-1", false}, | 
					
						
							|  |  |  | 		{"bytes=2-5", false}, | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		{"bytes=-5", false}, | 
					
						
							|  |  |  | 		{"bytes=-1", false}, | 
					
						
							|  |  |  | 		{"bytes=-1000", false}, | 
					
						
							|  |  |  | 		{"bytes=", true}, | 
					
						
							|  |  |  | 		{"bytes= ", true}, | 
					
						
							|  |  |  | 		{"byte=", true}, | 
					
						
							|  |  |  | 		{"bytes=A-B", true}, | 
					
						
							|  |  |  | 		{"bytes=1-B", true}, | 
					
						
							|  |  |  | 		{"bytes=B-1", true}, | 
					
						
							|  |  |  | 		{"bytes=-1-1", true}, | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 	for i, testCase := range validRangeSpecs { | 
					
						
							|  |  |  | 		rs, err := parseRequestRangeSpec(testCase.spec) | 
					
						
							|  |  |  | 		if err != nil { | 
					
						
							|  |  |  | 			if !testCase.errExpected || err == nil && testCase.errExpected { | 
					
						
							|  |  |  | 				t.Errorf("unexpected err: %v", err) | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 			continue | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		h, err := rs.ToHeader() | 
					
						
							|  |  |  | 		if err != nil && !testCase.errExpected || err == nil && testCase.errExpected { | 
					
						
							|  |  |  | 			t.Errorf("expected error with invalid range: %v", err) | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 		if h != testCase.spec { | 
					
						
							|  |  |  | 			t.Errorf("Case %d: translated to incorrect header: %s expected: %s", | 
					
						
							|  |  |  | 				i, h, testCase.spec) | 
					
						
							|  |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | } |