Fix server header parsing.
Signed-off-by: David Calavera <david.calavera@gmail.com>
This commit is contained in:
parent
a5efa69750
commit
8ce403bde7
2 changed files with 36 additions and 38 deletions
|
@ -5,11 +5,15 @@ import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"net/http"
|
"net/http"
|
||||||
"regexp"
|
"regexp"
|
||||||
"strings"
|
|
||||||
|
|
||||||
"github.com/docker/docker/pkg/jsonmessage"
|
"github.com/docker/docker/pkg/jsonmessage"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
headerRegexp = regexp.MustCompile(`^(?:(.+)/(.+))\s\((.+)\).*$`)
|
||||||
|
errInvalidHeader = errors.New("Bad header, should be in format `docker/version (platform)`")
|
||||||
|
)
|
||||||
|
|
||||||
// Download requests a given URL and returns an io.Reader.
|
// Download requests a given URL and returns an io.Reader.
|
||||||
func Download(url string) (resp *http.Response, err error) {
|
func Download(url string) (resp *http.Response, err error) {
|
||||||
if resp, err = http.Get(url); err != nil {
|
if resp, err = http.Get(url); err != nil {
|
||||||
|
@ -39,21 +43,13 @@ type ServerHeader struct {
|
||||||
// ParseServerHeader extracts pieces from an HTTP server header
|
// ParseServerHeader extracts pieces from an HTTP server header
|
||||||
// which is in the format "docker/version (os)" eg docker/1.8.0-dev (windows).
|
// which is in the format "docker/version (os)" eg docker/1.8.0-dev (windows).
|
||||||
func ParseServerHeader(hdr string) (*ServerHeader, error) {
|
func ParseServerHeader(hdr string) (*ServerHeader, error) {
|
||||||
re := regexp.MustCompile(`.*\((.+)\).*$`)
|
matches := headerRegexp.FindStringSubmatch(hdr)
|
||||||
r := &ServerHeader{}
|
if len(matches) != 4 {
|
||||||
if matches := re.FindStringSubmatch(hdr); matches != nil {
|
return nil, errInvalidHeader
|
||||||
r.OS = matches[1]
|
|
||||||
parts := strings.Split(hdr, "/")
|
|
||||||
if len(parts) != 2 {
|
|
||||||
return nil, errors.New("Bad header: '/' missing")
|
|
||||||
}
|
|
||||||
r.App = parts[0]
|
|
||||||
v := strings.Split(parts[1], " ")
|
|
||||||
if len(v) != 2 {
|
|
||||||
return nil, errors.New("Bad header: Expected single space")
|
|
||||||
}
|
|
||||||
r.Ver = v[0]
|
|
||||||
return r, nil
|
|
||||||
}
|
}
|
||||||
return nil, errors.New("Bad header: Failed regex match")
|
return &ServerHeader{
|
||||||
|
App: matches[1],
|
||||||
|
Ver: matches[2],
|
||||||
|
OS: matches[3],
|
||||||
|
}, nil
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,19 +1,17 @@
|
||||||
package httputils
|
package httputils
|
||||||
|
|
||||||
import (
|
import "testing"
|
||||||
"testing"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestDownload(t *testing.T) {
|
func TestDownload(t *testing.T) {
|
||||||
_, err := Download("http://docker.com")
|
_, err := Download("http://docker.com")
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Errorf("Expected error to not exist when Download(http://docker.com)")
|
t.Fatalf("Expected error to not exist when Download(http://docker.com)")
|
||||||
}
|
}
|
||||||
|
|
||||||
// Expected status code = 404
|
// Expected status code = 404
|
||||||
if _, err = Download("http://docker.com/abc1234567"); err == nil {
|
if _, err = Download("http://docker.com/abc1234567"); err == nil {
|
||||||
t.Errorf("Expected error to exist when Download(http://docker.com/abc1234567)")
|
t.Fatalf("Expected error to exist when Download(http://docker.com/abc1234567)")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -21,37 +19,41 @@ func TestNewHTTPRequestError(t *testing.T) {
|
||||||
errorMessage := "Some error message"
|
errorMessage := "Some error message"
|
||||||
httpResponse, _ := Download("http://docker.com")
|
httpResponse, _ := Download("http://docker.com")
|
||||||
if err := NewHTTPRequestError(errorMessage, httpResponse); err.Error() != errorMessage {
|
if err := NewHTTPRequestError(errorMessage, httpResponse); err.Error() != errorMessage {
|
||||||
t.Errorf("Expected err to equal error Message")
|
t.Fatalf("Expected err to equal error Message")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestParseServerHeader(t *testing.T) {
|
func TestParseServerHeader(t *testing.T) {
|
||||||
serverHeader, err := ParseServerHeader("bad header")
|
if _, err := ParseServerHeader("bad header"); err != errInvalidHeader {
|
||||||
if err.Error() != "Bad header: Failed regex match" {
|
t.Fatalf("Should fail when header can not be parsed")
|
||||||
t.Errorf("Should fail when header can not be parsed")
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if serverHeader, err = ParseServerHeader("(bad header)"); err.Error() != "Bad header: '/' missing" {
|
if _, err := ParseServerHeader("(bad header)"); err != errInvalidHeader {
|
||||||
t.Errorf("Should fail when header can not be parsed")
|
t.Fatalf("Should fail when header can not be parsed")
|
||||||
}
|
}
|
||||||
|
|
||||||
if serverHeader, err = ParseServerHeader("(without/spaces)"); err.Error() != "Bad header: Expected single space" {
|
if _, err := ParseServerHeader("(without/spaces)"); err != errInvalidHeader {
|
||||||
t.Errorf("Should fail when header can not be parsed")
|
t.Fatalf("Should fail when header can not be parsed")
|
||||||
}
|
}
|
||||||
|
|
||||||
if serverHeader, err = ParseServerHeader("(header/with space)"); err != nil {
|
if _, err := ParseServerHeader("(header/with space)"); err != errInvalidHeader {
|
||||||
t.Errorf("Expected err to not exist when ParseServerHeader(\"(header/with space)\")")
|
t.Fatalf("Expected err to not exist when ParseServerHeader(\"(header/with space)\")")
|
||||||
}
|
}
|
||||||
|
|
||||||
if serverHeader.App != "(header" {
|
serverHeader, err := ParseServerHeader("foo/bar (baz)")
|
||||||
t.Errorf("Expected serverHeader.App to equal \"(header\"")
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if serverHeader.Ver != "with" {
|
if serverHeader.App != "foo" {
|
||||||
t.Errorf("Expected serverHeader.Ver to equal \"with\"")
|
t.Fatalf("Expected serverHeader.App to equal \"foo\", got %s", serverHeader.App)
|
||||||
}
|
}
|
||||||
|
|
||||||
if serverHeader.OS != "header/with space" {
|
if serverHeader.Ver != "bar" {
|
||||||
t.Errorf("Expected serverHeader.OS to equal \"header/with space\"")
|
t.Fatalf("Expected serverHeader.Ver to equal \"bar\", got %s", serverHeader.Ver)
|
||||||
|
}
|
||||||
|
|
||||||
|
if serverHeader.OS != "baz" {
|
||||||
|
t.Fatalf("Expected serverHeader.OS to equal \"baz\", got %s", serverHeader.OS)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue