docker_cli_stack_test.go 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162
  1. package main
  2. import (
  3. "encoding/json"
  4. "io/ioutil"
  5. "os"
  6. "sort"
  7. "github.com/docker/docker/api/types/swarm"
  8. "github.com/docker/docker/integration-cli/checker"
  9. "github.com/go-check/check"
  10. )
  11. func (s *DockerSwarmSuite) TestStackRemove(c *check.C) {
  12. d := s.AddDaemon(c, true, true)
  13. stackArgs := append([]string{"stack", "remove", "UNKNOWN_STACK"})
  14. out, err := d.Cmd(stackArgs...)
  15. c.Assert(err, checker.IsNil)
  16. c.Assert(out, check.Equals, "Nothing found in stack: UNKNOWN_STACK\n")
  17. }
  18. func (s *DockerSwarmSuite) TestStackTasks(c *check.C) {
  19. d := s.AddDaemon(c, true, true)
  20. stackArgs := append([]string{"stack", "ps", "UNKNOWN_STACK"})
  21. out, err := d.Cmd(stackArgs...)
  22. c.Assert(err, checker.IsNil)
  23. c.Assert(out, check.Equals, "Nothing found in stack: UNKNOWN_STACK\n")
  24. }
  25. func (s *DockerSwarmSuite) TestStackServices(c *check.C) {
  26. d := s.AddDaemon(c, true, true)
  27. stackArgs := append([]string{"stack", "services", "UNKNOWN_STACK"})
  28. out, err := d.Cmd(stackArgs...)
  29. c.Assert(err, checker.IsNil)
  30. c.Assert(out, check.Equals, "Nothing found in stack: UNKNOWN_STACK\n")
  31. }
  32. func (s *DockerSwarmSuite) TestStackDeployComposeFile(c *check.C) {
  33. d := s.AddDaemon(c, true, true)
  34. testStackName := "testdeploy"
  35. stackArgs := []string{
  36. "stack", "deploy",
  37. "--compose-file", "fixtures/deploy/default.yaml",
  38. testStackName,
  39. }
  40. out, err := d.Cmd(stackArgs...)
  41. c.Assert(err, checker.IsNil, check.Commentf(out))
  42. out, err = d.Cmd("stack", "ls")
  43. c.Assert(err, checker.IsNil)
  44. c.Assert(out, check.Equals, "NAME SERVICES\n"+"testdeploy 2\n")
  45. out, err = d.Cmd("stack", "rm", testStackName)
  46. c.Assert(err, checker.IsNil)
  47. out, err = d.Cmd("stack", "ls")
  48. c.Assert(err, checker.IsNil)
  49. c.Assert(out, check.Equals, "NAME SERVICES\n")
  50. }
  51. func (s *DockerSwarmSuite) TestStackDeployWithSecretsTwice(c *check.C) {
  52. d := s.AddDaemon(c, true, true)
  53. out, err := d.Cmd("secret", "create", "outside", "fixtures/secrets/default")
  54. c.Assert(err, checker.IsNil, check.Commentf(out))
  55. testStackName := "testdeploy"
  56. stackArgs := []string{
  57. "stack", "deploy",
  58. "--compose-file", "fixtures/deploy/secrets.yaml",
  59. testStackName,
  60. }
  61. out, err = d.Cmd(stackArgs...)
  62. c.Assert(err, checker.IsNil, check.Commentf(out))
  63. out, err = d.Cmd("service", "inspect", "--format", "{{ json .Spec.TaskTemplate.ContainerSpec.Secrets }}", "testdeploy_web")
  64. c.Assert(err, checker.IsNil)
  65. var refs []swarm.SecretReference
  66. c.Assert(json.Unmarshal([]byte(out), &refs), checker.IsNil)
  67. c.Assert(refs, checker.HasLen, 3)
  68. sort.Sort(sortSecrets(refs))
  69. c.Assert(refs[0].SecretName, checker.Equals, "outside")
  70. c.Assert(refs[1].SecretName, checker.Equals, "testdeploy_special")
  71. c.Assert(refs[1].File.Name, checker.Equals, "special")
  72. c.Assert(refs[2].SecretName, checker.Equals, "testdeploy_super")
  73. c.Assert(refs[2].File.Name, checker.Equals, "foo.txt")
  74. c.Assert(refs[2].File.Mode, checker.Equals, os.FileMode(0400))
  75. // Deploy again to ensure there are no errors when secret hasn't changed
  76. out, err = d.Cmd(stackArgs...)
  77. c.Assert(err, checker.IsNil, check.Commentf(out))
  78. }
  79. type sortSecrets []swarm.SecretReference
  80. func (s sortSecrets) Len() int { return len(s) }
  81. func (s sortSecrets) Swap(i, j int) { s[i], s[j] = s[j], s[i] }
  82. func (s sortSecrets) Less(i, j int) bool { return s[i].SecretName < s[j].SecretName }
  83. // testDAB is the DAB JSON used for testing.
  84. // TODO: Use template/text and substitute "Image" with the result of
  85. // `docker inspect --format '{{index .RepoDigests 0}}' busybox:latest`
  86. const testDAB = `{
  87. "Version": "0.1",
  88. "Services": {
  89. "srv1": {
  90. "Image": "busybox@sha256:e4f93f6ed15a0cdd342f5aae387886fba0ab98af0a102da6276eaf24d6e6ade0",
  91. "Command": ["top"]
  92. },
  93. "srv2": {
  94. "Image": "busybox@sha256:e4f93f6ed15a0cdd342f5aae387886fba0ab98af0a102da6276eaf24d6e6ade0",
  95. "Command": ["tail"],
  96. "Args": ["-f", "/dev/null"]
  97. }
  98. }
  99. }`
  100. func (s *DockerSwarmSuite) TestStackDeployWithDAB(c *check.C) {
  101. testRequires(c, ExperimentalDaemon)
  102. // setup
  103. testStackName := "test"
  104. testDABFileName := testStackName + ".dab"
  105. defer os.RemoveAll(testDABFileName)
  106. err := ioutil.WriteFile(testDABFileName, []byte(testDAB), 0444)
  107. c.Assert(err, checker.IsNil)
  108. d := s.AddDaemon(c, true, true)
  109. // deploy
  110. stackArgs := []string{
  111. "stack", "deploy",
  112. "--bundle-file", testDABFileName,
  113. testStackName,
  114. }
  115. out, err := d.Cmd(stackArgs...)
  116. c.Assert(err, checker.IsNil)
  117. c.Assert(out, checker.Contains, "Loading bundle from test.dab\n")
  118. c.Assert(out, checker.Contains, "Creating service test_srv1\n")
  119. c.Assert(out, checker.Contains, "Creating service test_srv2\n")
  120. // ls
  121. stackArgs = []string{"stack", "ls"}
  122. out, err = d.Cmd(stackArgs...)
  123. c.Assert(err, checker.IsNil)
  124. c.Assert(out, check.Equals, "NAME SERVICES\n"+"test 2\n")
  125. // rm
  126. stackArgs = []string{"stack", "rm", testStackName}
  127. out, err = d.Cmd(stackArgs...)
  128. c.Assert(err, checker.IsNil)
  129. c.Assert(out, checker.Contains, "Removing service test_srv1\n")
  130. c.Assert(out, checker.Contains, "Removing service test_srv2\n")
  131. // ls (empty)
  132. stackArgs = []string{"stack", "ls"}
  133. out, err = d.Cmd(stackArgs...)
  134. c.Assert(err, checker.IsNil)
  135. c.Assert(out, check.Equals, "NAME SERVICES\n")
  136. }