Merge lp:~julian-edwards/gwacl/putblob into lp:gwacl

[Julian Edwards]

Add a PutBlob() method on StorageContext.

[Gavin Panella (allenap)]

review: Approve

[lp:~julian-edwards/gwacl/putblob]

40. By Julian Edwards on 2013-03-21

cleanups

=== modified file 'storage.go'
--- storage.go	2013-03-21 01:19:23 +0000
+++ storage.go	2013-03-21 02:05:24 +0000
@@ -267,3 +267,24 @@
     _, err = context.send(req, blob)
     return blob, err
 }
+
+// Send a request to create a space to upload a blob.  Note that this does not
+// do the uploading, it just makes an empty file.
+func (context *StorageContext) PutBlob(container, filename string) error {
+    uri := fmt.Sprintf(
+        "http://%s.blob.core.windows.net/%s/%s",
+        context.Account, container, filename)
+    req, err := http.NewRequest("PUT", uri, nil)
+    if err != nil {
+        return err
+    }
+    addStandardHeaders(req, context.Account, context.Key, "2012-02-12")
+    resp, err := context.send(req, nil)
+    if err != nil {
+        return err
+    }
+    if resp.StatusCode != http.StatusCreated {
+        return fmt.Errorf("Failed to put blob: %s", resp.Status)
+    }
+    return nil
+}

=== modified file 'storage_test.go'
--- storage_test.go	2013-03-21 01:13:27 +0000
+++ storage_test.go	2013-03-21 02:05:24 +0000
@@ -421,3 +421,47 @@
     _, err := context.ListBlobs("container")
     c.Assert(err, Not(IsNil))
 }
+
+type TestPutBlob struct{}
+
+var _ = Suite(&TestPutBlob{})
+
+// The ListBlobs Storage API call returns 201 CREATED on success.
+func (suite *TestPutBlob) Test(c *C) {
+    context := makeStorageContext()
+    response := &http.Response{
+        Status:     fmt.Sprintf("%d", http.StatusCreated),
+        StatusCode: http.StatusCreated,
+    }
+    transport := &TestTransport{Response: response}
+    context.client = &http.Client{Transport: transport}
+    err := context.PutBlob("container", "blobname")
+    c.Assert(err, IsNil)
+    c.Check(transport.Request.URL.String(), Equals, fmt.Sprintf(
+        "http://%s.blob.core.windows.net/container/blobname",
+        context.Account))
+    c.Check(transport.Request.Header.Get("Authorization"), Not(Equals), "")
+}
+
+// Client-side errors from the HTTP client are propagated back to the caller.
+func (suite *TestPutBlob) TestError(c *C) {
+    error := fmt.Errorf("canned-error")
+    transport := &TestTransport{Error: error}
+    context := makeStorageContext()
+    context.client = &http.Client{Transport: transport}
+    err := context.PutBlob("container", "blobname")
+    c.Assert(err, Not(IsNil))
+}
+
+// Server-side errors are propagated back to the caller.
+func (suite *TestPutBlob) TestErrorResponse(c *C) {
+    response := &http.Response{
+        Status:     "202 Frotzed",
+        StatusCode: 202,
+    }
+    transport := &TestTransport{Response: response}
+    context := makeStorageContext()
+    context.client = &http.Client{Transport: transport}
+    err := context.PutBlob("container", "blobname")
+    c.Assert(err.Error(), Equals, "failed to put blob: 202 Frotzed")
+}