Add gof3r to have proper path-style support for S3 compatible endpoints.

gof3r/cp.go

@@ -36,6 +36,7 @@ func (cp *cpOpts) Execute(args []string) (err error) {
 	*conf = *s3gof3r.DefaultConfig
 	s3 := s3gof3r.New(cp.EndPoint, k)
 	conf.Concurrency = cp.Concurrency
+	conf.PathStyle = cp.PathStyle
 	if cp.NoSSL {
 		conf.Scheme = "http"
 	}

gof3r/get.go

@@ -30,6 +30,7 @@ func (get *getOpts) Execute(args []string) (err error) {
 	s3 := s3gof3r.New(get.EndPoint, k)
 	b := s3.Bucket(get.Bucket)
 	conf.Concurrency = get.Concurrency
+	conf.PathStyle = get.PathStyle
 	if get.NoSSL {
 		conf.Scheme = "http"
 	}

gof3r/main_test.go

@@ -18,15 +18,15 @@ var flagTests = []flagTest{
 	{[]string{"gof3r", "nocmd"},
 		errors.New("Unknown command")},
 	{[]string{"gof3r", "put", "-b", "fake-bucket", "-k", "test-key"},
-		errors.New("Access Denied")},
+		errors.New("The AWS Access Key Id you provided does not exist in our records.")},
 	{[]string{"gof3r", "put", "-b", "fake-bucket", "-k", "key",
 		"-c", "1", "-s", "1024", "--debug", "--no-ssl", "--no-md5"},
-		errors.New("Access Denied")},
+		errors.New("The AWS Access Key Id you provided does not exist in our records.")},
 	{[]string{"gof3r", "get", "-b", "fake-bucket", "-k", "test-key"},
-		errors.New("Access Denied")},
+		errors.New("The AWS Access Key Id you provided does not exist in our records.")},
 	{[]string{"gof3r", "get", "-b", "fake-bucket", "-k", "key",
 		"-c", "1", "-s", "1024", "--debug", "--no-ssl", "--no-md5"},
-		errors.New("Access Denied")},
+		errors.New("The AWS Access Key Id you provided does not exist in our records.")},
 	{[]string{"gof3r", "put"},
 		errors.New("required flags")},
 	{[]string{"gof3r", "put", "-b"},

gof3r/options.go

@@ -8,7 +8,7 @@ import (
 	"os/exec"
 	"strings"
 
-	"github.com/jessevdk/go-flags"
+	flags "github.com/jessevdk/go-flags"
 )
 
 const (
@@ -28,6 +28,7 @@ type DataOpts struct {
 	Concurrency int   `long:"concurrency" short:"c" default:"10" description:"Concurrency of transfers" ini-name:"concurrency"`
 	PartSize    int64 `long:"partsize" short:"s" description:"Initial size of concurrent parts, in bytes" default:"20971520" ini-name:"partsize"`
 	NTry        int   `long:"retries" description:"Number of attempts to try" default:"10" ini-name:"retries"`
+	PathStyle   bool  `long:"path-style" description:"Enable path style calls for S3 compatible endpoints." ini-name:"path-style"`
 }
 
 // UpOpts are Options for uploading common to cp and put commands

gof3r/put.go

@@ -36,6 +36,7 @@ func (put *putOpts) Execute(args []string) (err error) {
 	conf.PartSize = put.PartSize
 	conf.Md5Check = !put.NoMd5
 	conf.NTry = put.NTry
+	conf.PathStyle = put.PathStyle
 	s3gof3r.SetLogger(os.Stderr, "", log.LstdFlags, put.Debug)
 
 	if put.Header == nil {