Merge pull request #18693 from dnephin/move_parse_docker_host
Move ParseDockerDaemonHost to opts/ package
This commit is contained in:
Antonio Murdaca
commit
e0a1a648d8
2 changed files with 0 additions and 214 deletions
|
|
@ -5,111 +5,11 @@ package parsers
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
"net"
|
|
||||||
"net/url"
|
|
||||||
"path"
|
"path"
|
||||||
"runtime"
|
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
|
|
||||||
// ParseDockerDaemonHost parses the specified address and returns an address that will be used as the host.
|
|
||||||
// Depending of the address specified, will use the defaultTCPAddr or defaultUnixAddr
|
|
||||||
// defaultUnixAddr must be a absolute file path (no `unix://` prefix)
|
|
||||||
// defaultTCPAddr must be the full `tcp://host:port` form
|
|
||||||
func ParseDockerDaemonHost(defaultTCPAddr, defaultTLSHost, defaultUnixAddr, defaultAddr, addr string) (string, error) {
|
|
||||||
addr = strings.TrimSpace(addr)
|
|
||||||
if addr == "" {
|
|
||||||
if defaultAddr == defaultTLSHost {
|
|
||||||
return defaultTLSHost, nil
|
|
||||||
}
|
|
||||||
if runtime.GOOS != "windows" {
|
|
||||||
return fmt.Sprintf("unix://%s", defaultUnixAddr), nil
|
|
||||||
}
|
|
||||||
return defaultTCPAddr, nil
|
|
||||||
}
|
|
||||||
addrParts := strings.Split(addr, "://")
|
|
||||||
if len(addrParts) == 1 {
|
|
||||||
addrParts = []string{"tcp", addrParts[0]}
|
|
||||||
}
|
|
||||||
|
|
||||||
switch addrParts[0] {
|
|
||||||
case "tcp":
|
|
||||||
return ParseTCPAddr(addrParts[1], defaultTCPAddr)
|
|
||||||
case "unix":
|
|
||||||
return ParseUnixAddr(addrParts[1], defaultUnixAddr)
|
|
||||||
case "fd":
|
|
||||||
return addr, nil
|
|
||||||
default:
|
|
||||||
return "", fmt.Errorf("Invalid bind address format: %s", addr)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// ParseUnixAddr parses and validates that the specified address is a valid UNIX
|
|
||||||
// socket address. It returns a formatted UNIX socket address, either using the
|
|
||||||
// address parsed from addr, or the contents of defaultAddr if addr is a blank
|
|
||||||
// string.
|
|
||||||
func ParseUnixAddr(addr string, defaultAddr string) (string, error) {
|
|
||||||
addr = strings.TrimPrefix(addr, "unix://")
|
|
||||||
if strings.Contains(addr, "://") {
|
|
||||||
return "", fmt.Errorf("Invalid proto, expected unix: %s", addr)
|
|
||||||
}
|
|
||||||
if addr == "" {
|
|
||||||
addr = defaultAddr
|
|
||||||
}
|
|
||||||
return fmt.Sprintf("unix://%s", addr), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// ParseTCPAddr parses and validates that the specified address is a valid TCP
|
|
||||||
// address. It returns a formatted TCP address, either using the address parsed
|
|
||||||
// from tryAddr, or the contents of defaultAddr if tryAddr is a blank string.
|
|
||||||
// tryAddr is expected to have already been Trim()'d
|
|
||||||
// defaultAddr must be in the full `tcp://host:port` form
|
|
||||||
func ParseTCPAddr(tryAddr string, defaultAddr string) (string, error) {
|
|
||||||
if tryAddr == "" || tryAddr == "tcp://" {
|
|
||||||
return defaultAddr, nil
|
|
||||||
}
|
|
||||||
addr := strings.TrimPrefix(tryAddr, "tcp://")
|
|
||||||
if strings.Contains(addr, "://") || addr == "" {
|
|
||||||
return "", fmt.Errorf("Invalid proto, expected tcp: %s", tryAddr)
|
|
||||||
}
|
|
||||||
|
|
||||||
defaultAddr = strings.TrimPrefix(defaultAddr, "tcp://")
|
|
||||||
defaultHost, defaultPort, err := net.SplitHostPort(defaultAddr)
|
|
||||||
if err != nil {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
// url.Parse fails for trailing colon on IPv6 brackets on Go 1.5, but
|
|
||||||
// not 1.4. See https://github.com/golang/go/issues/12200 and
|
|
||||||
// https://github.com/golang/go/issues/6530.
|
|
||||||
if strings.HasSuffix(addr, "]:") {
|
|
||||||
addr += defaultPort
|
|
||||||
}
|
|
||||||
|
|
||||||
u, err := url.Parse("tcp://" + addr)
|
|
||||||
if err != nil {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
|
|
||||||
host, port, err := net.SplitHostPort(u.Host)
|
|
||||||
if err != nil {
|
|
||||||
return "", fmt.Errorf("Invalid bind address format: %s", tryAddr)
|
|
||||||
}
|
|
||||||
|
|
||||||
if host == "" {
|
|
||||||
host = defaultHost
|
|
||||||
}
|
|
||||||
if port == "" {
|
|
||||||
port = defaultPort
|
|
||||||
}
|
|
||||||
p, err := strconv.Atoi(port)
|
|
||||||
if err != nil && p == 0 {
|
|
||||||
return "", fmt.Errorf("Invalid bind address format: %s", tryAddr)
|
|
||||||
}
|
|
||||||
|
|
||||||
return fmt.Sprintf("tcp://%s%s", net.JoinHostPort(host, port), u.Path), nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// PartParser parses and validates the specified string (data) using the specified template
|
// PartParser parses and validates the specified string (data) using the specified template
|
||||||
// e.g. ip:public:private -> 192.168.0.1:80:8000
|
// e.g. ip:public:private -> 192.168.0.1:80:8000
|
||||||
func PartParser(template, data string) (map[string]string, error) {
|
func PartParser(template, data string) (map[string]string, error) {
|
||||||
|
|
|
||||||
|
|
@ -2,124 +2,10 @@ package parsers
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"reflect"
|
"reflect"
|
||||||
"runtime"
|
|
||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestParseDockerDaemonHost(t *testing.T) {
|
|
||||||
var (
|
|
||||||
defaultHTTPHost = "tcp://localhost:2375"
|
|
||||||
defaultHTTPSHost = "tcp://localhost:2376"
|
|
||||||
defaultUnix = "/var/run/docker.sock"
|
|
||||||
defaultHOST = "unix:///var/run/docker.sock"
|
|
||||||
)
|
|
||||||
if runtime.GOOS == "windows" {
|
|
||||||
defaultHOST = defaultHTTPHost
|
|
||||||
}
|
|
||||||
invalids := map[string]string{
|
|
||||||
"0.0.0.0": "Invalid bind address format: 0.0.0.0",
|
|
||||||
"tcp:a.b.c.d": "Invalid bind address format: tcp:a.b.c.d",
|
|
||||||
"tcp:a.b.c.d/path": "Invalid bind address format: tcp:a.b.c.d/path",
|
|
||||||
"udp://127.0.0.1": "Invalid bind address format: udp://127.0.0.1",
|
|
||||||
"udp://127.0.0.1:2375": "Invalid bind address format: udp://127.0.0.1:2375",
|
|
||||||
"tcp://unix:///run/docker.sock": "Invalid bind address format: unix",
|
|
||||||
"tcp": "Invalid bind address format: tcp",
|
|
||||||
"unix": "Invalid bind address format: unix",
|
|
||||||
"fd": "Invalid bind address format: fd",
|
|
||||||
}
|
|
||||||
valids := map[string]string{
|
|
||||||
"0.0.0.1:": "tcp://0.0.0.1:2375",
|
|
||||||
"0.0.0.1:5555": "tcp://0.0.0.1:5555",
|
|
||||||
"0.0.0.1:5555/path": "tcp://0.0.0.1:5555/path",
|
|
||||||
"[::1]:": "tcp://[::1]:2375",
|
|
||||||
"[::1]:5555/path": "tcp://[::1]:5555/path",
|
|
||||||
"[0:0:0:0:0:0:0:1]:": "tcp://[0:0:0:0:0:0:0:1]:2375",
|
|
||||||
"[0:0:0:0:0:0:0:1]:5555/path": "tcp://[0:0:0:0:0:0:0:1]:5555/path",
|
|
||||||
":6666": "tcp://localhost:6666",
|
|
||||||
":6666/path": "tcp://localhost:6666/path",
|
|
||||||
"": defaultHOST,
|
|
||||||
" ": defaultHOST,
|
|
||||||
" ": defaultHOST,
|
|
||||||
"tcp://": defaultHTTPHost,
|
|
||||||
"tcp://:7777": "tcp://localhost:7777",
|
|
||||||
"tcp://:7777/path": "tcp://localhost:7777/path",
|
|
||||||
" tcp://:7777/path ": "tcp://localhost:7777/path",
|
|
||||||
"unix:///run/docker.sock": "unix:///run/docker.sock",
|
|
||||||
"unix://": "unix:///var/run/docker.sock",
|
|
||||||
"fd://": "fd://",
|
|
||||||
"fd://something": "fd://something",
|
|
||||||
"localhost:": "tcp://localhost:2375",
|
|
||||||
"localhost:5555": "tcp://localhost:5555",
|
|
||||||
"localhost:5555/path": "tcp://localhost:5555/path",
|
|
||||||
}
|
|
||||||
for invalidAddr, expectedError := range invalids {
|
|
||||||
if addr, err := ParseDockerDaemonHost(defaultHTTPHost, defaultHTTPSHost, defaultUnix, "", invalidAddr); err == nil || err.Error() != expectedError {
|
|
||||||
t.Errorf("tcp %v address expected error %v return, got %s and addr %v", invalidAddr, expectedError, err, addr)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for validAddr, expectedAddr := range valids {
|
|
||||||
if addr, err := ParseDockerDaemonHost(defaultHTTPHost, defaultHTTPSHost, defaultUnix, "", validAddr); err != nil || addr != expectedAddr {
|
|
||||||
t.Errorf("%v -> expected %v, got (%v) addr (%v)", validAddr, expectedAddr, err, addr)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestParseTCP(t *testing.T) {
|
|
||||||
var (
|
|
||||||
defaultHTTPHost = "tcp://127.0.0.1:2376"
|
|
||||||
)
|
|
||||||
invalids := map[string]string{
|
|
||||||
"0.0.0.0": "Invalid bind address format: 0.0.0.0",
|
|
||||||
"tcp:a.b.c.d": "Invalid bind address format: tcp:a.b.c.d",
|
|
||||||
"tcp:a.b.c.d/path": "Invalid bind address format: tcp:a.b.c.d/path",
|
|
||||||
"udp://127.0.0.1": "Invalid proto, expected tcp: udp://127.0.0.1",
|
|
||||||
"udp://127.0.0.1:2375": "Invalid proto, expected tcp: udp://127.0.0.1:2375",
|
|
||||||
}
|
|
||||||
valids := map[string]string{
|
|
||||||
"": defaultHTTPHost,
|
|
||||||
"tcp://": defaultHTTPHost,
|
|
||||||
"0.0.0.1:": "tcp://0.0.0.1:2376",
|
|
||||||
"0.0.0.1:5555": "tcp://0.0.0.1:5555",
|
|
||||||
"0.0.0.1:5555/path": "tcp://0.0.0.1:5555/path",
|
|
||||||
":6666": "tcp://127.0.0.1:6666",
|
|
||||||
":6666/path": "tcp://127.0.0.1:6666/path",
|
|
||||||
"tcp://:7777": "tcp://127.0.0.1:7777",
|
|
||||||
"tcp://:7777/path": "tcp://127.0.0.1:7777/path",
|
|
||||||
"[::1]:": "tcp://[::1]:2376",
|
|
||||||
"[::1]:5555": "tcp://[::1]:5555",
|
|
||||||
"[::1]:5555/path": "tcp://[::1]:5555/path",
|
|
||||||
"[0:0:0:0:0:0:0:1]:": "tcp://[0:0:0:0:0:0:0:1]:2376",
|
|
||||||
"[0:0:0:0:0:0:0:1]:5555": "tcp://[0:0:0:0:0:0:0:1]:5555",
|
|
||||||
"[0:0:0:0:0:0:0:1]:5555/path": "tcp://[0:0:0:0:0:0:0:1]:5555/path",
|
|
||||||
"localhost:": "tcp://localhost:2376",
|
|
||||||
"localhost:5555": "tcp://localhost:5555",
|
|
||||||
"localhost:5555/path": "tcp://localhost:5555/path",
|
|
||||||
}
|
|
||||||
for invalidAddr, expectedError := range invalids {
|
|
||||||
if addr, err := ParseTCPAddr(invalidAddr, defaultHTTPHost); err == nil || err.Error() != expectedError {
|
|
||||||
t.Errorf("tcp %v address expected error %v return, got %s and addr %v", invalidAddr, expectedError, err, addr)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
for validAddr, expectedAddr := range valids {
|
|
||||||
if addr, err := ParseTCPAddr(validAddr, defaultHTTPHost); err != nil || addr != expectedAddr {
|
|
||||||
t.Errorf("%v -> expected %v, got %v and addr %v", validAddr, expectedAddr, err, addr)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestParseInvalidUnixAddrInvalid(t *testing.T) {
|
|
||||||
if _, err := ParseUnixAddr("tcp://127.0.0.1", "unix:///var/run/docker.sock"); err == nil || err.Error() != "Invalid proto, expected unix: tcp://127.0.0.1" {
|
|
||||||
t.Fatalf("Expected an error, got %v", err)
|
|
||||||
}
|
|
||||||
if _, err := ParseUnixAddr("unix://tcp://127.0.0.1", "/var/run/docker.sock"); err == nil || err.Error() != "Invalid proto, expected unix: tcp://127.0.0.1" {
|
|
||||||
t.Fatalf("Expected an error, got %v", err)
|
|
||||||
}
|
|
||||||
if v, err := ParseUnixAddr("", "/var/run/docker.sock"); err != nil || v != "unix:///var/run/docker.sock" {
|
|
||||||
t.Fatalf("Expected an %v, got %v", v, "unix:///var/run/docker.sock")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestParseKeyValueOpt(t *testing.T) {
|
func TestParseKeyValueOpt(t *testing.T) {
|
||||||
invalids := map[string]string{
|
invalids := map[string]string{
|
||||||
"": "Unable to parse key/value option: ",
|
"": "Unable to parse key/value option: ",
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue