rest: Make backend honor the REST protocol

src/cmds/restic/global.go

@@ -379,7 +379,7 @@ func create(s string) (restic.Backend, error) {
 		debug.Log("create s3 repository at %#v", loc.Config)
 		return s3.Open(cfg)
 	case "rest":
-		return rest.Open(loc.Config.(rest.Config))
+		return rest.Create(loc.Config.(rest.Config))
 	}
 
 	debug.Log("invalid repository scheme: %v", s)

src/restic/backend/rest/rest.go

@@ -69,6 +69,45 @@ func Open(cfg Config) (restic.Backend, error) {
 	return &restBackend{url: cfg.URL, connChan: connChan, client: client}, nil
 }
 
+// Create creates a new REST on server configured in config.
+func Create(cfg Config) (restic.Backend, error) {
+	be, err := Open(cfg)
+	if err != nil {
+		return nil, err
+	}
+
+	_, err = be.Stat(restic.Handle{Type: restic.ConfigFile})
+	if err == nil {
+		return nil, errors.Fatal("config file already exists")
+	}
+
+	url := *cfg.URL
+	values := url.Query()
+	values.Set("create", "true")
+	url.RawQuery = values.Encode()
+
+	resp, err := http.Post(url.String(), "binary/octet-stream", strings.NewReader(""))
+	if err != nil {
+		return nil, err
+	}
+
+	if resp.StatusCode != http.StatusOK {
+		return nil, errors.Fatalf("server response unexpected: %v (%v)", resp.Status, resp.StatusCode)
+	}
+
+	_, err = io.Copy(ioutil.Discard, resp.Body)
+	if err != nil {
+		return nil, err
+	}
+
+	err = resp.Body.Close()
+	if err != nil {
+		return nil, err
+	}
+
+	return be, nil
+}
+
 // Location returns this backend's location (the server's URL).
 func (b *restBackend) Location() string {
 	return b.url.String()
@@ -103,6 +142,7 @@ func (b *restBackend) Save(h restic.Handle, rd io.Reader) (err error) {
 		return errors.Wrap(err, "client.Post")
 	}
 
+	// fmt.Printf("status is %v (%v)\n", resp.Status, resp.StatusCode)
 	if resp.StatusCode != 200 {
 		return errors.Errorf("unexpected HTTP response code %v", resp.StatusCode)
 	}
@@ -222,7 +262,7 @@ func (b *restBackend) Remove(h restic.Handle) error {
 	}
 
 	if resp.StatusCode != 200 {
-		return errors.New("blob not removed")
+		return errors.Errorf("blob not removed, server response: %v (%v)", resp.Status, resp.StatusCode)
 	}
 
 	io.Copy(ioutil.Discard, resp.Body)

src/restic/backend/rest/rest_test.go

@@ -6,8 +6,6 @@ import (
 	"os"
 	"restic"
 
-	"restic/errors"
-
 	"restic/backend/rest"
 	"restic/backend/test"
 	. "restic/test"
@@ -32,21 +30,7 @@ func init() {
 	}
 
 	test.CreateFn = func() (restic.Backend, error) {
-		be, err := rest.Open(cfg)
+		return rest.Create(cfg)
-		if err != nil {
-			return nil, err
-		}
-
-		exists, err := be.Test(restic.Handle{Type: restic.ConfigFile, Name: ""})
-		if err != nil {
-			return nil, err
-		}
-
-		if exists {
-			return nil, errors.New("config already exists")
-		}
-
-		return be, nil
 	}
 
 	test.OpenFn = func() (restic.Backend, error) {

src/restic/backend/test/tests.go

@@ -375,7 +375,7 @@ var filenameTests = []struct {
 	data string
 }{
 	{"1dfc6bc0f06cb255889e9ea7860a5753e8eb9665c9a96627971171b444e3113e", "x"},
-	{"foobar", "foobar"},
+	{"f00b4r", "foobar"},
 	{
 		"1dfc6bc0f06cb255889e9ea7860a5753e8eb9665c9a96627971171b444e3113e4bf8f2d9144cc5420a80f04a4880ad6155fc58903a4fb6457c476c43541dcaa6-5",
 		"foobar content of data blob",
@@ -500,11 +500,11 @@ func TestBackend(t testing.TB) {
 		ts := testStrings[0]
 
 		// create blob
-		err := b.Save(restic.Handle{Type: tpe, Name: ts.id}, strings.NewReader(ts.data))
+		h := restic.Handle{Type: tpe, Name: ts.id}
-		test.Assert(t, err != nil, "expected error, got %v", err)
+		err := b.Save(h, strings.NewReader(ts.data))
+		test.Assert(t, err != nil, "expected error for %v, got %v", h, err)
 
 		// remove and recreate
-		h := restic.Handle{Type: tpe, Name: ts.id}
 		err = b.Remove(h)
 		test.OK(t, err)