image_create_test.go 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. package client
  2. import (
  3. "bytes"
  4. "fmt"
  5. "io/ioutil"
  6. "net/http"
  7. "strings"
  8. "testing"
  9. "golang.org/x/net/context"
  10. "github.com/docker/docker/api/types"
  11. )
  12. func TestImageCreateError(t *testing.T) {
  13. client := &Client{
  14. client: newMockClient(errorMock(http.StatusInternalServerError, "Server error")),
  15. }
  16. _, err := client.ImageCreate(context.Background(), "reference", types.ImageCreateOptions{})
  17. if err == nil || err.Error() != "Error response from daemon: Server error" {
  18. t.Fatalf("expected a Server error, got %v", err)
  19. }
  20. }
  21. func TestImageCreate(t *testing.T) {
  22. expectedURL := "/images/create"
  23. expectedImage := "test:5000/my_image"
  24. expectedTag := "sha256:ffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffff"
  25. expectedReference := fmt.Sprintf("%s@%s", expectedImage, expectedTag)
  26. expectedRegistryAuth := "eyJodHRwczovL2luZGV4LmRvY2tlci5pby92MS8iOnsiYXV0aCI6ImRHOTBid289IiwiZW1haWwiOiJqb2huQGRvZS5jb20ifX0="
  27. client := &Client{
  28. client: newMockClient(func(r *http.Request) (*http.Response, error) {
  29. if !strings.HasPrefix(r.URL.Path, expectedURL) {
  30. return nil, fmt.Errorf("Expected URL '%s', got '%s'", expectedURL, r.URL)
  31. }
  32. registryAuth := r.Header.Get("X-Registry-Auth")
  33. if registryAuth != expectedRegistryAuth {
  34. return nil, fmt.Errorf("X-Registry-Auth header not properly set in the request. Expected '%s', got %s", expectedRegistryAuth, registryAuth)
  35. }
  36. query := r.URL.Query()
  37. fromImage := query.Get("fromImage")
  38. if fromImage != expectedImage {
  39. return nil, fmt.Errorf("fromImage not set in URL query properly. Expected '%s', got %s", expectedImage, fromImage)
  40. }
  41. tag := query.Get("tag")
  42. if tag != expectedTag {
  43. return nil, fmt.Errorf("tag not set in URL query properly. Expected '%s', got %s", expectedTag, tag)
  44. }
  45. return &http.Response{
  46. StatusCode: http.StatusOK,
  47. Body: ioutil.NopCloser(bytes.NewReader([]byte("body"))),
  48. }, nil
  49. }),
  50. }
  51. createResponse, err := client.ImageCreate(context.Background(), expectedReference, types.ImageCreateOptions{
  52. RegistryAuth: expectedRegistryAuth,
  53. })
  54. if err != nil {
  55. t.Fatal(err)
  56. }
  57. response, err := ioutil.ReadAll(createResponse)
  58. if err != nil {
  59. t.Fatal(err)
  60. }
  61. if err = createResponse.Close(); err != nil {
  62. t.Fatal(err)
  63. }
  64. if string(response) != "body" {
  65. t.Fatalf("expected Body to contain 'body' string, got %s", response)
  66. }
  67. }