111 lines
2.8 KiB
Go
111 lines
2.8 KiB
Go
|
package parsers
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"strconv"
|
||
|
|
"strings"
|
||
|
|
)
|
||
|
|
|
||
|
|
// FIXME: Change this not to receive default value as parameter
|
||
|
|
func ParseHost(defaultHost string, defaultUnix, addr string) (string, error) {
|
||
|
|
var (
|
||
|
|
proto string
|
||
|
|
host string
|
||
|
|
port int
|
||
|
|
)
|
||
|
|
addr = strings.TrimSpace(addr)
|
||
|
|
switch {
|
||
|
|
case addr == "tcp://":
|
||
|
|
return "", fmt.Errorf("Invalid bind address format: %s", addr)
|
||
|
|
case strings.HasPrefix(addr, "unix://"):
|
||
|
|
proto = "unix"
|
||
|
|
addr = strings.TrimPrefix(addr, "unix://")
|
||
|
|
if addr == "" {
|
||
|
|
addr = defaultUnix
|
||
|
|
}
|
||
|
|
case strings.HasPrefix(addr, "tcp://"):
|
||
|
|
proto = "tcp"
|
||
|
|
addr = strings.TrimPrefix(addr, "tcp://")
|
||
|
|
case strings.HasPrefix(addr, "fd://"):
|
||
|
|
return addr, nil
|
||
|
|
case addr == "":
|
||
|
|
proto = "unix"
|
||
|
|
addr = defaultUnix
|
||
|
|
default:
|
||
|
|
if strings.Contains(addr, "://") {
|
||
|
|
return "", fmt.Errorf("Invalid bind address protocol: %s", addr)
|
||
|
|
}
|
||
|
|
proto = "tcp"
|
||
|
|
}
|
||
|
|
|
||
|
|
if proto != "unix" && strings.Contains(addr, ":") {
|
||
|
|
hostParts := strings.Split(addr, ":")
|
||
|
|
if len(hostParts) != 2 {
|
||
|
|
return "", fmt.Errorf("Invalid bind address format: %s", addr)
|
||
|
|
}
|
||
|
|
if hostParts[0] != "" {
|
||
|
|
host = hostParts[0]
|
||
|
|
} else {
|
||
|
|
host = defaultHost
|
||
|
|
}
|
||
|
|
|
||
|
|
if p, err := strconv.Atoi(hostParts[1]); err == nil && p != 0 {
|
||
|
|
port = p
|
||
|
|
} else {
|
||
|
|
return "", fmt.Errorf("Invalid bind address format: %s", addr)
|
||
|
|
}
|
||
|
|
|
||
|
|
} else if proto == "tcp" && !strings.Contains(addr, ":") {
|
||
|
|
return "", fmt.Errorf("Invalid bind address format: %s", addr)
|
||
|
|
} else {
|
||
|
|
host = addr
|
||
|
|
}
|
||
|
|
if proto == "unix" {
|
||
|
|
return fmt.Sprintf("%s://%s", proto, host), nil
|
||
|
|
}
|
||
|
|
return fmt.Sprintf("%s://%s:%d", proto, host, port), nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// Get a repos name and returns the right reposName + tag
|
||
|
|
// The tag can be confusing because of a port in a repository name.
|
||
|
|
// Ex: localhost.localdomain:5000/samalba/hipache:latest
|
||
|
|
func ParseRepositoryTag(repos string) (string, string) {
|
||
|
|
n := strings.LastIndex(repos, ":")
|
||
|
|
if n < 0 {
|
||
|
|
return repos, ""
|
||
|
|
}
|
||
|
|
if tag := repos[n+1:]; !strings.Contains(tag, "/") {
|
||
|
|
return repos[:n], tag
|
||
|
|
}
|
||
|
|
return repos, ""
|
||
|
|
}
|
||
|
|
|
||
|
|
func PartParser(template, data string) (map[string]string, error) {
|
||
|
|
// ip:public:private
|
||
|
|
var (
|
||
|
|
templateParts = strings.Split(template, ":")
|
||
|
|
parts = strings.Split(data, ":")
|
||
|
|
out = make(map[string]string, len(templateParts))
|
||
|
|
)
|
||
|
|
if len(parts) != len(templateParts) {
|
||
|
|
return nil, fmt.Errorf("Invalid format to parse. %s should match template %s", data, template)
|
||
|
|
}
|
||
|
|
|
||
|
|
for i, t := range templateParts {
|
||
|
|
value := ""
|
||
|
|
if len(parts) > i {
|
||
|
|
value = parts[i]
|
||
|
|
}
|
||
|
|
out[t] = value
|
||
|
|
}
|
||
|
|
return out, nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func ParseKeyValueOpt(opt string) (string, string, error) {
|
||
|
|
parts := strings.SplitN(opt, "=", 2)
|
||
|
|
if len(parts) != 2 {
|
||
|
|
return "", "", fmt.Errorf("Unable to parse key/value option: %s", opt)
|
||
|
|
}
|
||
|
|
return strings.TrimSpace(parts[0]), strings.TrimSpace(parts[1]), nil
|
||
|
|
}
|