Merge pull request #466 from ckemper67/sftp-path-clean

Cleaned up the sftp parsing logic.

src/restic/backend/sftp/config.go

@@ -3,6 +3,7 @@ package sftp
 import (
 	"errors"
 	"net/url"
+	"path"
 	"strings"
 )
 
@@ -11,58 +12,49 @@ type Config struct {
 	User, Host, Dir string
 }
 
-// ParseConfig extracts all information for the sftp connection from the string s.
+// ParseConfig parses the string s and extracts the sftp config. The
+// supported configuration formats are sftp://user@host/directory
+// (with an optional port sftp://user@host:port/directory) and
+// sftp:user@host:directory.  The directory will be path Cleaned and
+// can be an absolute path if it starts with a '/'
+// (e.g. sftp://user@host//absolute and sftp:user@host:/absolute).
 func ParseConfig(s string) (interface{}, error) {
-	if strings.HasPrefix(s, "sftp://") {
-		return parseFormat1(s)
-	}
-
-	// otherwise parse in the sftp:user@host:path format, which means we'll get
-	// "user@host:path" in s
-	return parseFormat2(s)
-}
-
-// parseFormat1 parses the first format, starting with a slash, so the user
-// either specified "sftp://host/path", so we'll get everything after the first
-// colon character
-func parseFormat1(s string) (Config, error) {
+	var user, host, dir string
+	switch {
+	case strings.HasPrefix(s, "sftp://"):
+		// parse the "sftp://user@host/path" url format
 		url, err := url.Parse(s)
 		if err != nil {
-		return Config{}, err
-	}
-
-	cfg := Config{
-		Host: url.Host,
-		Dir:  url.Path[1:],
+			return nil, err
 		}
 		if url.User != nil {
-		cfg.User = url.User.Username()
+			user = url.User.Username()
 		}
-	return cfg, nil
+		host = url.Host
+		dir = url.Path[1:]
+	case strings.HasPrefix(s, "sftp:"):
+		// parse the sftp:user@host:path format, which means we'll get
+		// "user@host:path" in s
+		s = s[5:]
+		// split user@host and path at the colon
+		data := strings.SplitN(s, ":", 2)
+		if len(data) < 2 {
+			return nil, errors.New("sftp: invalid format, hostname or path not found")
 		}
-
-// parseFormat2 parses the second format, sftp:user@host:path
-func parseFormat2(s string) (cfg Config, err error) {
-	// split user/host and path at the second colon
-	data := strings.SplitN(s, ":", 3)
-	if len(data) < 3 {
-		return Config{}, errors.New("sftp: invalid format, hostname or path not found")
-	}
-
-	if data[0] != "sftp" {
-		return Config{}, errors.New(`invalid format, does not start with "sftp:"`)
-	}
-
-	userhost := data[1]
-	cfg.Dir = data[2]
-
-	data = strings.SplitN(userhost, "@", 2)
+		host = data[0]
+		dir = data[1]
+		// split user and host at the "@"
+		data = strings.SplitN(host, "@", 2)
 		if len(data) == 2 {
-		cfg.User = data[0]
-		cfg.Host = data[1]
-	} else {
-		cfg.Host = userhost
+			user = data[0]
+			host = data[1]
 		}
-
-	return cfg, nil
+	default:
+		return nil, errors.New(`invalid format, does not start with "sftp:"`)
+	}
+	return Config{
+		User: user,
+		Host: host,
+		Dir:  path.Clean(dir),
+	}, nil
 }

src/restic/backend/sftp/config_test.go

@@ -3,7 +3,7 @@ package sftp
 import "testing"
 
 var configTests = []struct {
-	s   string
+	in  string
 	cfg Config
 }{
 	// first form, user specified sftp://user@host/dir
@@ -27,33 +27,49 @@ var configTests = []struct {
 		"sftp://user@host:10022//dir/subdir",
 		Config{User: "user", Host: "host:10022", Dir: "/dir/subdir"},
 	},
+	{
+		"sftp://user@host/dir/subdir/../other",
+		Config{User: "user", Host: "host", Dir: "dir/other"},
+	},
+	{
+		"sftp://user@host/dir///subdir",
+		Config{User: "user", Host: "host", Dir: "dir/subdir"},
+	},
 
 	// second form, user specified sftp:user@host:/dir
 	{
-		"sftp:foo@bar:/baz/quux",
-		Config{User: "foo", Host: "bar", Dir: "/baz/quux"},
+		"sftp:user@host:/dir/subdir",
+		Config{User: "user", Host: "host", Dir: "/dir/subdir"},
 	},
 	{
-		"sftp:bar:../baz/quux",
-		Config{Host: "bar", Dir: "../baz/quux"},
+		"sftp:host:../dir/subdir",
+		Config{Host: "host", Dir: "../dir/subdir"},
 	},
 	{
-		"sftp:fux@bar:baz/qu:ux",
-		Config{User: "fux", Host: "bar", Dir: "baz/qu:ux"},
+		"sftp:user@host:dir/subdir:suffix",
+		Config{User: "user", Host: "host", Dir: "dir/subdir:suffix"},
+	},
+	{
+		"sftp:user@host:dir/subdir/../other",
+		Config{User: "user", Host: "host", Dir: "dir/other"},
+	},
+	{
+		"sftp:user@host:dir///subdir",
+		Config{User: "user", Host: "host", Dir: "dir/subdir"},
 	},
 }
 
 func TestParseConfig(t *testing.T) {
 	for i, test := range configTests {
-		cfg, err := ParseConfig(test.s)
+		cfg, err := ParseConfig(test.in)
 		if err != nil {
-			t.Errorf("test %d failed: %v", i, err)
+			t.Errorf("test %d:%s failed: %v", i, test.in, err)
 			continue
 		}
 
 		if cfg != test.cfg {
-			t.Errorf("test %d: wrong config, want:\n  %v\ngot:\n  %v",
-				i, test.cfg, cfg)
+			t.Errorf("test %d:\ninput:\n  %s\n wrong config, want:\n  %v\ngot:\n  %v",
+				i, test.in, test.cfg, cfg)
 			continue
 		}
 	}