change 'XXXXOpts' to pointers; return url.URL from BuildQueryString
diff --git a/openstack/objectstorage/v1/containers/requests.go b/openstack/objectstorage/v1/containers/requests.go
index 013c6ff..8b54c81 100644
--- a/openstack/objectstorage/v1/containers/requests.go
+++ b/openstack/objectstorage/v1/containers/requests.go
@@ -20,15 +20,20 @@
// List is a function that retrieves all objects in a container. It also returns the details
// for the account. To extract just the container information or names, pass the ListResult
// response to the ExtractInfo or ExtractNames function, respectively.
-func List(c *gophercloud.ServiceClient, opts ListOpts) pagination.Pager {
+func List(c *gophercloud.ServiceClient, opts *ListOpts) pagination.Pager {
var headers map[string]string
- query, err := gophercloud.BuildQueryString(opts)
- if err != nil {
- return pagination.Pager{Err: err}
- }
- if !opts.Full {
- headers = map[string]string{"Accept": "text/plain", "Content-Type": "text/plain"}
+ url := accountURL(c)
+ if opts != nil {
+ query, err := gophercloud.BuildQueryString(opts)
+ if err != nil {
+ return pagination.Pager{Err: err}
+ }
+ url += query.String()
+
+ if !opts.Full {
+ headers = map[string]string{"Accept": "text/plain", "Content-Type": "text/plain"}
+ }
}
createPage := func(r pagination.LastHTTPResponse) pagination.Page {
@@ -37,7 +42,6 @@
return p
}
- url := accountURL(c) + query
pager := pagination.NewPager(c, url, createPage)
pager.Headers = headers
return pager
@@ -57,24 +61,26 @@
}
// Create is a function that creates a new container.
-func Create(c *gophercloud.ServiceClient, containerName string, opts CreateOpts) (Container, error) {
+func Create(c *gophercloud.ServiceClient, containerName string, opts *CreateOpts) (Container, error) {
var container Container
h := c.Provider.AuthenticatedHeaders()
- headers, err := gophercloud.BuildHeaders(opts)
- if err != nil {
- return container, err
+ if opts != nil {
+ headers, err := gophercloud.BuildHeaders(opts)
+ if err != nil {
+ return container, err
+ }
+
+ for k, v := range headers {
+ h[k] = v
+ }
+
+ for k, v := range opts.Metadata {
+ h["X-Container-Meta-"+k] = v
+ }
}
- for k, v := range headers {
- h[k] = v
- }
-
- for k, v := range opts.Metadata {
- h["X-Container-Meta-"+k] = v
- }
-
- _, err = perigee.Request("PUT", containerURL(c, containerName), perigee.Options{
+ _, err := perigee.Request("PUT", containerURL(c, containerName), perigee.Options{
MoreHeaders: h,
OkCodes: []int{201, 204},
})
@@ -108,24 +114,25 @@
}
// Update is a function that creates, updates, or deletes a container's metadata.
-func Update(c *gophercloud.ServiceClient, containerName string, opts UpdateOpts) error {
+func Update(c *gophercloud.ServiceClient, containerName string, opts *UpdateOpts) error {
h := c.Provider.AuthenticatedHeaders()
- headers, err := gophercloud.BuildHeaders(opts)
- if err != nil {
- return err
+ if opts != nil {
+ headers, err := gophercloud.BuildHeaders(opts)
+ if err != nil {
+ return err
+ }
+
+ for k, v := range headers {
+ h[k] = v
+ }
+
+ for k, v := range opts.Metadata {
+ h["X-Container-Meta-"+k] = v
+ }
}
- for k, v := range headers {
- h[k] = v
- }
-
- for k, v := range opts.Metadata {
- h["X-Container-Meta-"+k] = v
- }
-
- url := containerURL(c, containerName)
- _, err = perigee.Request("POST", url, perigee.Options{
+ _, err := perigee.Request("POST", containerURL(c, containerName), perigee.Options{
MoreHeaders: h,
OkCodes: []int{204},
})
diff --git a/openstack/objectstorage/v1/containers/requests_test.go b/openstack/objectstorage/v1/containers/requests_test.go
index 1c9ee11..d58ebeb 100644
--- a/openstack/objectstorage/v1/containers/requests_test.go
+++ b/openstack/objectstorage/v1/containers/requests_test.go
@@ -34,7 +34,6 @@
w.Header().Add("Content-Type", "application/json")
r.ParseForm()
- fmt.Printf("r: %+v\n", r)
marker := r.Form.Get("marker")
switch marker {
case "":
@@ -58,7 +57,9 @@
})
client := serviceClient()
- List(client, ListOpts{Full: true}).EachPage(func(page pagination.Page) (bool, error) {
+ count := 0
+ List(client, &ListOpts{Full: true}).EachPage(func(page pagination.Page) (bool, error) {
+ count++
actual, err := ExtractInfo(page)
if err != nil {
t.Errorf("Failed to extract container info: %v", err)
@@ -78,10 +79,16 @@
},
}
+ t.Logf("actual: %+v/n", actual)
+
testhelper.CheckDeepEquals(t, expected, actual)
return true, nil
})
+
+ if count != 1 {
+ t.Errorf("Expected 1 page, got %d", count)
+ }
}
func TestListContainerNames(t *testing.T) {
@@ -107,7 +114,9 @@
})
client := serviceClient()
- List(client, ListOpts{Full: false}).EachPage(func(page pagination.Page) (bool, error) {
+ count := 0
+ List(client, &ListOpts{Full: false}).EachPage(func(page pagination.Page) (bool, error) {
+ count++
actual, err := ExtractNames(page)
if err != nil {
t.Errorf("Failed to extract container names: %v", err)
@@ -120,6 +129,10 @@
return true, nil
})
+
+ if count != 1 {
+ t.Errorf("Expected 1 page, got %d", count)
+ }
}
func TestCreateContainer(t *testing.T) {
@@ -134,7 +147,7 @@
})
client := serviceClient()
- _, err := Create(client, "testContainer", CreateOpts{})
+ _, err := Create(client, "testContainer", nil)
if err != nil {
t.Fatalf("Unexpected error creating container: %v", err)
}
@@ -170,7 +183,7 @@
})
client := serviceClient()
- err := Update(client, "testContainer", UpdateOpts{})
+ err := Update(client, "testContainer", nil)
if err != nil {
t.Fatalf("Unexpected error updating container metadata: %v", err)
}
@@ -185,9 +198,6 @@
testhelper.TestHeader(t, r, "X-Auth-Token", tokenId)
testhelper.TestHeader(t, r, "Accept", "application/json")
w.WriteHeader(http.StatusNoContent)
- fmt.Fprintf(w, `
-
- `)
})
client := serviceClient()