loader_test.go 21 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087
  1. package loader
  2. import (
  3. "fmt"
  4. "io/ioutil"
  5. "os"
  6. "sort"
  7. "testing"
  8. "time"
  9. "github.com/docker/docker/cli/compose/types"
  10. "github.com/stretchr/testify/assert"
  11. )
  12. func buildConfigDetails(source types.Dict) types.ConfigDetails {
  13. workingDir, err := os.Getwd()
  14. if err != nil {
  15. panic(err)
  16. }
  17. return types.ConfigDetails{
  18. WorkingDir: workingDir,
  19. ConfigFiles: []types.ConfigFile{
  20. {Filename: "filename.yml", Config: source},
  21. },
  22. Environment: nil,
  23. }
  24. }
  25. var sampleYAML = `
  26. version: "3"
  27. services:
  28. foo:
  29. image: busybox
  30. networks:
  31. with_me:
  32. bar:
  33. image: busybox
  34. environment:
  35. - FOO=1
  36. networks:
  37. - with_ipam
  38. volumes:
  39. hello:
  40. driver: default
  41. driver_opts:
  42. beep: boop
  43. networks:
  44. default:
  45. driver: bridge
  46. driver_opts:
  47. beep: boop
  48. with_ipam:
  49. ipam:
  50. driver: default
  51. config:
  52. - subnet: 172.28.0.0/16
  53. `
  54. var sampleDict = types.Dict{
  55. "version": "3",
  56. "services": types.Dict{
  57. "foo": types.Dict{
  58. "image": "busybox",
  59. "networks": types.Dict{"with_me": nil},
  60. },
  61. "bar": types.Dict{
  62. "image": "busybox",
  63. "environment": []interface{}{"FOO=1"},
  64. "networks": []interface{}{"with_ipam"},
  65. },
  66. },
  67. "volumes": types.Dict{
  68. "hello": types.Dict{
  69. "driver": "default",
  70. "driver_opts": types.Dict{
  71. "beep": "boop",
  72. },
  73. },
  74. },
  75. "networks": types.Dict{
  76. "default": types.Dict{
  77. "driver": "bridge",
  78. "driver_opts": types.Dict{
  79. "beep": "boop",
  80. },
  81. },
  82. "with_ipam": types.Dict{
  83. "ipam": types.Dict{
  84. "driver": "default",
  85. "config": []interface{}{
  86. types.Dict{
  87. "subnet": "172.28.0.0/16",
  88. },
  89. },
  90. },
  91. },
  92. },
  93. }
  94. var sampleConfig = types.Config{
  95. Services: []types.ServiceConfig{
  96. {
  97. Name: "foo",
  98. Image: "busybox",
  99. Environment: map[string]string{},
  100. Networks: map[string]*types.ServiceNetworkConfig{
  101. "with_me": nil,
  102. },
  103. },
  104. {
  105. Name: "bar",
  106. Image: "busybox",
  107. Environment: map[string]string{"FOO": "1"},
  108. Networks: map[string]*types.ServiceNetworkConfig{
  109. "with_ipam": nil,
  110. },
  111. },
  112. },
  113. Networks: map[string]types.NetworkConfig{
  114. "default": {
  115. Driver: "bridge",
  116. DriverOpts: map[string]string{
  117. "beep": "boop",
  118. },
  119. },
  120. "with_ipam": {
  121. Ipam: types.IPAMConfig{
  122. Driver: "default",
  123. Config: []*types.IPAMPool{
  124. {
  125. Subnet: "172.28.0.0/16",
  126. },
  127. },
  128. },
  129. },
  130. },
  131. Volumes: map[string]types.VolumeConfig{
  132. "hello": {
  133. Driver: "default",
  134. DriverOpts: map[string]string{
  135. "beep": "boop",
  136. },
  137. },
  138. },
  139. }
  140. func TestParseYAML(t *testing.T) {
  141. dict, err := ParseYAML([]byte(sampleYAML))
  142. if !assert.NoError(t, err) {
  143. return
  144. }
  145. assert.Equal(t, sampleDict, dict)
  146. }
  147. func TestLoad(t *testing.T) {
  148. actual, err := Load(buildConfigDetails(sampleDict))
  149. if !assert.NoError(t, err) {
  150. return
  151. }
  152. assert.Equal(t, serviceSort(sampleConfig.Services), serviceSort(actual.Services))
  153. assert.Equal(t, sampleConfig.Networks, actual.Networks)
  154. assert.Equal(t, sampleConfig.Volumes, actual.Volumes)
  155. }
  156. func TestLoadV31(t *testing.T) {
  157. actual, err := loadYAML(`
  158. version: "3.1"
  159. services:
  160. foo:
  161. image: busybox
  162. secrets: [super]
  163. secrets:
  164. super:
  165. external: true
  166. `)
  167. if !assert.NoError(t, err) {
  168. return
  169. }
  170. assert.Equal(t, len(actual.Services), 1)
  171. assert.Equal(t, len(actual.Secrets), 1)
  172. }
  173. func TestParseAndLoad(t *testing.T) {
  174. actual, err := loadYAML(sampleYAML)
  175. if !assert.NoError(t, err) {
  176. return
  177. }
  178. assert.Equal(t, serviceSort(sampleConfig.Services), serviceSort(actual.Services))
  179. assert.Equal(t, sampleConfig.Networks, actual.Networks)
  180. assert.Equal(t, sampleConfig.Volumes, actual.Volumes)
  181. }
  182. func TestInvalidTopLevelObjectType(t *testing.T) {
  183. _, err := loadYAML("1")
  184. assert.Error(t, err)
  185. assert.Contains(t, err.Error(), "Top-level object must be a mapping")
  186. _, err = loadYAML("\"hello\"")
  187. assert.Error(t, err)
  188. assert.Contains(t, err.Error(), "Top-level object must be a mapping")
  189. _, err = loadYAML("[\"hello\"]")
  190. assert.Error(t, err)
  191. assert.Contains(t, err.Error(), "Top-level object must be a mapping")
  192. }
  193. func TestNonStringKeys(t *testing.T) {
  194. _, err := loadYAML(`
  195. version: "3"
  196. 123:
  197. foo:
  198. image: busybox
  199. `)
  200. assert.Error(t, err)
  201. assert.Contains(t, err.Error(), "Non-string key at top level: 123")
  202. _, err = loadYAML(`
  203. version: "3"
  204. services:
  205. foo:
  206. image: busybox
  207. 123:
  208. image: busybox
  209. `)
  210. assert.Error(t, err)
  211. assert.Contains(t, err.Error(), "Non-string key in services: 123")
  212. _, err = loadYAML(`
  213. version: "3"
  214. services:
  215. foo:
  216. image: busybox
  217. networks:
  218. default:
  219. ipam:
  220. config:
  221. - 123: oh dear
  222. `)
  223. assert.Error(t, err)
  224. assert.Contains(t, err.Error(), "Non-string key in networks.default.ipam.config[0]: 123")
  225. _, err = loadYAML(`
  226. version: "3"
  227. services:
  228. dict-env:
  229. image: busybox
  230. environment:
  231. 1: FOO
  232. `)
  233. assert.Error(t, err)
  234. assert.Contains(t, err.Error(), "Non-string key in services.dict-env.environment: 1")
  235. }
  236. func TestSupportedVersion(t *testing.T) {
  237. _, err := loadYAML(`
  238. version: "3"
  239. services:
  240. foo:
  241. image: busybox
  242. `)
  243. assert.NoError(t, err)
  244. _, err = loadYAML(`
  245. version: "3.0"
  246. services:
  247. foo:
  248. image: busybox
  249. `)
  250. assert.NoError(t, err)
  251. }
  252. func TestUnsupportedVersion(t *testing.T) {
  253. _, err := loadYAML(`
  254. version: "2"
  255. services:
  256. foo:
  257. image: busybox
  258. `)
  259. assert.Error(t, err)
  260. assert.Contains(t, err.Error(), "version")
  261. _, err = loadYAML(`
  262. version: "2.0"
  263. services:
  264. foo:
  265. image: busybox
  266. `)
  267. assert.Error(t, err)
  268. assert.Contains(t, err.Error(), "version")
  269. }
  270. func TestInvalidVersion(t *testing.T) {
  271. _, err := loadYAML(`
  272. version: 3
  273. services:
  274. foo:
  275. image: busybox
  276. `)
  277. assert.Error(t, err)
  278. assert.Contains(t, err.Error(), "version must be a string")
  279. }
  280. func TestV1Unsupported(t *testing.T) {
  281. _, err := loadYAML(`
  282. foo:
  283. image: busybox
  284. `)
  285. assert.Error(t, err)
  286. }
  287. func TestNonMappingObject(t *testing.T) {
  288. _, err := loadYAML(`
  289. version: "3"
  290. services:
  291. - foo:
  292. image: busybox
  293. `)
  294. assert.Error(t, err)
  295. assert.Contains(t, err.Error(), "services must be a mapping")
  296. _, err = loadYAML(`
  297. version: "3"
  298. services:
  299. foo: busybox
  300. `)
  301. assert.Error(t, err)
  302. assert.Contains(t, err.Error(), "services.foo must be a mapping")
  303. _, err = loadYAML(`
  304. version: "3"
  305. networks:
  306. - default:
  307. driver: bridge
  308. `)
  309. assert.Error(t, err)
  310. assert.Contains(t, err.Error(), "networks must be a mapping")
  311. _, err = loadYAML(`
  312. version: "3"
  313. networks:
  314. default: bridge
  315. `)
  316. assert.Error(t, err)
  317. assert.Contains(t, err.Error(), "networks.default must be a mapping")
  318. _, err = loadYAML(`
  319. version: "3"
  320. volumes:
  321. - data:
  322. driver: local
  323. `)
  324. assert.Error(t, err)
  325. assert.Contains(t, err.Error(), "volumes must be a mapping")
  326. _, err = loadYAML(`
  327. version: "3"
  328. volumes:
  329. data: local
  330. `)
  331. assert.Error(t, err)
  332. assert.Contains(t, err.Error(), "volumes.data must be a mapping")
  333. }
  334. func TestNonStringImage(t *testing.T) {
  335. _, err := loadYAML(`
  336. version: "3"
  337. services:
  338. foo:
  339. image: ["busybox", "latest"]
  340. `)
  341. assert.Error(t, err)
  342. assert.Contains(t, err.Error(), "services.foo.image must be a string")
  343. }
  344. func TestValidEnvironment(t *testing.T) {
  345. config, err := loadYAML(`
  346. version: "3"
  347. services:
  348. dict-env:
  349. image: busybox
  350. environment:
  351. FOO: "1"
  352. BAR: 2
  353. BAZ: 2.5
  354. QUUX:
  355. list-env:
  356. image: busybox
  357. environment:
  358. - FOO=1
  359. - BAR=2
  360. - BAZ=2.5
  361. - QUUX=
  362. `)
  363. assert.NoError(t, err)
  364. expected := types.MappingWithEquals{
  365. "FOO": "1",
  366. "BAR": "2",
  367. "BAZ": "2.5",
  368. "QUUX": "",
  369. }
  370. assert.Equal(t, 2, len(config.Services))
  371. for _, service := range config.Services {
  372. assert.Equal(t, expected, service.Environment)
  373. }
  374. }
  375. func TestInvalidEnvironmentValue(t *testing.T) {
  376. _, err := loadYAML(`
  377. version: "3"
  378. services:
  379. dict-env:
  380. image: busybox
  381. environment:
  382. FOO: ["1"]
  383. `)
  384. assert.Error(t, err)
  385. assert.Contains(t, err.Error(), "services.dict-env.environment.FOO must be a string, number or null")
  386. }
  387. func TestInvalidEnvironmentObject(t *testing.T) {
  388. _, err := loadYAML(`
  389. version: "3"
  390. services:
  391. dict-env:
  392. image: busybox
  393. environment: "FOO=1"
  394. `)
  395. assert.Error(t, err)
  396. assert.Contains(t, err.Error(), "services.dict-env.environment must be a mapping")
  397. }
  398. func TestEnvironmentInterpolation(t *testing.T) {
  399. config, err := loadYAML(`
  400. version: "3"
  401. services:
  402. test:
  403. image: busybox
  404. labels:
  405. - home1=$HOME
  406. - home2=${HOME}
  407. - nonexistent=$NONEXISTENT
  408. - default=${NONEXISTENT-default}
  409. networks:
  410. test:
  411. driver: $HOME
  412. volumes:
  413. test:
  414. driver: $HOME
  415. `)
  416. assert.NoError(t, err)
  417. home := os.Getenv("HOME")
  418. expectedLabels := types.MappingWithEquals{
  419. "home1": home,
  420. "home2": home,
  421. "nonexistent": "",
  422. "default": "default",
  423. }
  424. assert.Equal(t, expectedLabels, config.Services[0].Labels)
  425. assert.Equal(t, home, config.Networks["test"].Driver)
  426. assert.Equal(t, home, config.Volumes["test"].Driver)
  427. }
  428. func TestUnsupportedProperties(t *testing.T) {
  429. dict, err := ParseYAML([]byte(`
  430. version: "3"
  431. services:
  432. web:
  433. image: web
  434. build: ./web
  435. links:
  436. - bar
  437. db:
  438. image: db
  439. build: ./db
  440. `))
  441. assert.NoError(t, err)
  442. configDetails := buildConfigDetails(dict)
  443. _, err = Load(configDetails)
  444. assert.NoError(t, err)
  445. unsupported := GetUnsupportedProperties(configDetails)
  446. assert.Equal(t, []string{"build", "links"}, unsupported)
  447. }
  448. func TestDeprecatedProperties(t *testing.T) {
  449. dict, err := ParseYAML([]byte(`
  450. version: "3"
  451. services:
  452. web:
  453. image: web
  454. container_name: web
  455. db:
  456. image: db
  457. container_name: db
  458. expose: ["5434"]
  459. `))
  460. assert.NoError(t, err)
  461. configDetails := buildConfigDetails(dict)
  462. _, err = Load(configDetails)
  463. assert.NoError(t, err)
  464. deprecated := GetDeprecatedProperties(configDetails)
  465. assert.Equal(t, 2, len(deprecated))
  466. assert.Contains(t, deprecated, "container_name")
  467. assert.Contains(t, deprecated, "expose")
  468. }
  469. func TestForbiddenProperties(t *testing.T) {
  470. _, err := loadYAML(`
  471. version: "3"
  472. services:
  473. foo:
  474. image: busybox
  475. volumes:
  476. - /data
  477. volume_driver: some-driver
  478. bar:
  479. extends:
  480. service: foo
  481. `)
  482. assert.Error(t, err)
  483. assert.IsType(t, &ForbiddenPropertiesError{}, err)
  484. fmt.Println(err)
  485. forbidden := err.(*ForbiddenPropertiesError).Properties
  486. assert.Equal(t, 2, len(forbidden))
  487. assert.Contains(t, forbidden, "volume_driver")
  488. assert.Contains(t, forbidden, "extends")
  489. }
  490. func TestInvalidExternalAndDriverCombination(t *testing.T) {
  491. _, err := loadYAML(`
  492. version: "3"
  493. volumes:
  494. external_volume:
  495. external: true
  496. driver: foobar
  497. `)
  498. assert.Error(t, err)
  499. assert.Contains(t, err.Error(), "conflicting parameters \"external\" and \"driver\" specified for volume")
  500. assert.Contains(t, err.Error(), "external_volume")
  501. }
  502. func TestInvalidExternalAndDirverOptsCombination(t *testing.T) {
  503. _, err := loadYAML(`
  504. version: "3"
  505. volumes:
  506. external_volume:
  507. external: true
  508. driver_opts:
  509. beep: boop
  510. `)
  511. assert.Error(t, err)
  512. assert.Contains(t, err.Error(), "conflicting parameters \"external\" and \"driver_opts\" specified for volume")
  513. assert.Contains(t, err.Error(), "external_volume")
  514. }
  515. func TestInvalidExternalAndLabelsCombination(t *testing.T) {
  516. _, err := loadYAML(`
  517. version: "3"
  518. volumes:
  519. external_volume:
  520. external: true
  521. labels:
  522. - beep=boop
  523. `)
  524. assert.Error(t, err)
  525. assert.Contains(t, err.Error(), "conflicting parameters \"external\" and \"labels\" specified for volume")
  526. assert.Contains(t, err.Error(), "external_volume")
  527. }
  528. func durationPtr(value time.Duration) *time.Duration {
  529. return &value
  530. }
  531. func int64Ptr(value int64) *int64 {
  532. return &value
  533. }
  534. func uint64Ptr(value uint64) *uint64 {
  535. return &value
  536. }
  537. func TestFullExample(t *testing.T) {
  538. bytes, err := ioutil.ReadFile("full-example.yml")
  539. assert.NoError(t, err)
  540. config, err := loadYAML(string(bytes))
  541. if !assert.NoError(t, err) {
  542. return
  543. }
  544. workingDir, err := os.Getwd()
  545. assert.NoError(t, err)
  546. homeDir := os.Getenv("HOME")
  547. stopGracePeriod := time.Duration(20 * time.Second)
  548. expectedServiceConfig := types.ServiceConfig{
  549. Name: "foo",
  550. CapAdd: []string{"ALL"},
  551. CapDrop: []string{"NET_ADMIN", "SYS_ADMIN"},
  552. CgroupParent: "m-executor-abcd",
  553. Command: []string{"bundle", "exec", "thin", "-p", "3000"},
  554. ContainerName: "my-web-container",
  555. DependsOn: []string{"db", "redis"},
  556. Deploy: types.DeployConfig{
  557. Mode: "replicated",
  558. Replicas: uint64Ptr(6),
  559. Labels: map[string]string{"FOO": "BAR"},
  560. UpdateConfig: &types.UpdateConfig{
  561. Parallelism: uint64Ptr(3),
  562. Delay: time.Duration(10 * time.Second),
  563. FailureAction: "continue",
  564. Monitor: time.Duration(60 * time.Second),
  565. MaxFailureRatio: 0.3,
  566. },
  567. Resources: types.Resources{
  568. Limits: &types.Resource{
  569. NanoCPUs: "0.001",
  570. MemoryBytes: 50 * 1024 * 1024,
  571. },
  572. Reservations: &types.Resource{
  573. NanoCPUs: "0.0001",
  574. MemoryBytes: 20 * 1024 * 1024,
  575. },
  576. },
  577. RestartPolicy: &types.RestartPolicy{
  578. Condition: "on_failure",
  579. Delay: durationPtr(5 * time.Second),
  580. MaxAttempts: uint64Ptr(3),
  581. Window: durationPtr(2 * time.Minute),
  582. },
  583. Placement: types.Placement{
  584. Constraints: []string{"node=foo"},
  585. },
  586. },
  587. Devices: []string{"/dev/ttyUSB0:/dev/ttyUSB0"},
  588. DNS: []string{"8.8.8.8", "9.9.9.9"},
  589. DNSSearch: []string{"dc1.example.com", "dc2.example.com"},
  590. DomainName: "foo.com",
  591. Entrypoint: []string{"/code/entrypoint.sh", "-p", "3000"},
  592. Environment: map[string]string{
  593. "RACK_ENV": "development",
  594. "SHOW": "true",
  595. "SESSION_SECRET": "",
  596. "FOO": "1",
  597. "BAR": "2",
  598. "BAZ": "3",
  599. },
  600. EnvFile: []string{
  601. "./example1.env",
  602. "./example2.env",
  603. },
  604. Expose: []string{"3000", "8000"},
  605. ExternalLinks: []string{
  606. "redis_1",
  607. "project_db_1:mysql",
  608. "project_db_1:postgresql",
  609. },
  610. ExtraHosts: map[string]string{
  611. "otherhost": "50.31.209.229",
  612. "somehost": "162.242.195.82",
  613. },
  614. HealthCheck: &types.HealthCheckConfig{
  615. Test: types.HealthCheckTest([]string{"CMD-SHELL", "echo \"hello world\""}),
  616. Interval: "10s",
  617. Timeout: "1s",
  618. Retries: uint64Ptr(5),
  619. },
  620. Hostname: "foo",
  621. Image: "redis",
  622. Ipc: "host",
  623. Labels: map[string]string{
  624. "com.example.description": "Accounting webapp",
  625. "com.example.number": "42",
  626. "com.example.empty-label": "",
  627. },
  628. Links: []string{
  629. "db",
  630. "db:database",
  631. "redis",
  632. },
  633. Logging: &types.LoggingConfig{
  634. Driver: "syslog",
  635. Options: map[string]string{
  636. "syslog-address": "tcp://192.168.0.42:123",
  637. },
  638. },
  639. MacAddress: "02:42:ac:11:65:43",
  640. NetworkMode: "container:0cfeab0f748b9a743dc3da582046357c6ef497631c1a016d28d2bf9b4f899f7b",
  641. Networks: map[string]*types.ServiceNetworkConfig{
  642. "some-network": {
  643. Aliases: []string{"alias1", "alias3"},
  644. Ipv4Address: "",
  645. Ipv6Address: "",
  646. },
  647. "other-network": {
  648. Ipv4Address: "172.16.238.10",
  649. Ipv6Address: "2001:3984:3989::10",
  650. },
  651. "other-other-network": nil,
  652. },
  653. Pid: "host",
  654. Ports: []types.ServicePortConfig{
  655. //"3000",
  656. {
  657. Mode: "ingress",
  658. Target: 3000,
  659. Protocol: "tcp",
  660. },
  661. //"3000-3005",
  662. {
  663. Mode: "ingress",
  664. Target: 3000,
  665. Protocol: "tcp",
  666. },
  667. {
  668. Mode: "ingress",
  669. Target: 3001,
  670. Protocol: "tcp",
  671. },
  672. {
  673. Mode: "ingress",
  674. Target: 3002,
  675. Protocol: "tcp",
  676. },
  677. {
  678. Mode: "ingress",
  679. Target: 3003,
  680. Protocol: "tcp",
  681. },
  682. {
  683. Mode: "ingress",
  684. Target: 3004,
  685. Protocol: "tcp",
  686. },
  687. {
  688. Mode: "ingress",
  689. Target: 3005,
  690. Protocol: "tcp",
  691. },
  692. //"8000:8000",
  693. {
  694. Mode: "ingress",
  695. Target: 8000,
  696. Published: 8000,
  697. Protocol: "tcp",
  698. },
  699. //"9090-9091:8080-8081",
  700. {
  701. Mode: "ingress",
  702. Target: 8080,
  703. Published: 9090,
  704. Protocol: "tcp",
  705. },
  706. {
  707. Mode: "ingress",
  708. Target: 8081,
  709. Published: 9091,
  710. Protocol: "tcp",
  711. },
  712. //"49100:22",
  713. {
  714. Mode: "ingress",
  715. Target: 22,
  716. Published: 49100,
  717. Protocol: "tcp",
  718. },
  719. //"127.0.0.1:8001:8001",
  720. {
  721. Mode: "ingress",
  722. Target: 8001,
  723. Published: 8001,
  724. Protocol: "tcp",
  725. },
  726. //"127.0.0.1:5000-5010:5000-5010",
  727. {
  728. Mode: "ingress",
  729. Target: 5000,
  730. Published: 5000,
  731. Protocol: "tcp",
  732. },
  733. {
  734. Mode: "ingress",
  735. Target: 5001,
  736. Published: 5001,
  737. Protocol: "tcp",
  738. },
  739. {
  740. Mode: "ingress",
  741. Target: 5002,
  742. Published: 5002,
  743. Protocol: "tcp",
  744. },
  745. {
  746. Mode: "ingress",
  747. Target: 5003,
  748. Published: 5003,
  749. Protocol: "tcp",
  750. },
  751. {
  752. Mode: "ingress",
  753. Target: 5004,
  754. Published: 5004,
  755. Protocol: "tcp",
  756. },
  757. {
  758. Mode: "ingress",
  759. Target: 5005,
  760. Published: 5005,
  761. Protocol: "tcp",
  762. },
  763. {
  764. Mode: "ingress",
  765. Target: 5006,
  766. Published: 5006,
  767. Protocol: "tcp",
  768. },
  769. {
  770. Mode: "ingress",
  771. Target: 5007,
  772. Published: 5007,
  773. Protocol: "tcp",
  774. },
  775. {
  776. Mode: "ingress",
  777. Target: 5008,
  778. Published: 5008,
  779. Protocol: "tcp",
  780. },
  781. {
  782. Mode: "ingress",
  783. Target: 5009,
  784. Published: 5009,
  785. Protocol: "tcp",
  786. },
  787. {
  788. Mode: "ingress",
  789. Target: 5010,
  790. Published: 5010,
  791. Protocol: "tcp",
  792. },
  793. },
  794. Privileged: true,
  795. ReadOnly: true,
  796. Restart: "always",
  797. SecurityOpt: []string{
  798. "label=level:s0:c100,c200",
  799. "label=type:svirt_apache_t",
  800. },
  801. StdinOpen: true,
  802. StopSignal: "SIGUSR1",
  803. StopGracePeriod: &stopGracePeriod,
  804. Tmpfs: []string{"/run", "/tmp"},
  805. Tty: true,
  806. Ulimits: map[string]*types.UlimitsConfig{
  807. "nproc": {
  808. Single: 65535,
  809. },
  810. "nofile": {
  811. Soft: 20000,
  812. Hard: 40000,
  813. },
  814. },
  815. User: "someone",
  816. Volumes: []string{
  817. "/var/lib/mysql",
  818. "/opt/data:/var/lib/mysql",
  819. fmt.Sprintf("%s:/code", workingDir),
  820. fmt.Sprintf("%s/static:/var/www/html", workingDir),
  821. fmt.Sprintf("%s/configs:/etc/configs/:ro", homeDir),
  822. "datavolume:/var/lib/mysql",
  823. },
  824. WorkingDir: "/code",
  825. }
  826. assert.Equal(t, []types.ServiceConfig{expectedServiceConfig}, config.Services)
  827. expectedNetworkConfig := map[string]types.NetworkConfig{
  828. "some-network": {},
  829. "other-network": {
  830. Driver: "overlay",
  831. DriverOpts: map[string]string{
  832. "foo": "bar",
  833. "baz": "1",
  834. },
  835. Ipam: types.IPAMConfig{
  836. Driver: "overlay",
  837. Config: []*types.IPAMPool{
  838. {Subnet: "172.16.238.0/24"},
  839. {Subnet: "2001:3984:3989::/64"},
  840. },
  841. },
  842. },
  843. "external-network": {
  844. External: types.External{
  845. Name: "external-network",
  846. External: true,
  847. },
  848. },
  849. "other-external-network": {
  850. External: types.External{
  851. Name: "my-cool-network",
  852. External: true,
  853. },
  854. },
  855. }
  856. assert.Equal(t, expectedNetworkConfig, config.Networks)
  857. expectedVolumeConfig := map[string]types.VolumeConfig{
  858. "some-volume": {},
  859. "other-volume": {
  860. Driver: "flocker",
  861. DriverOpts: map[string]string{
  862. "foo": "bar",
  863. "baz": "1",
  864. },
  865. },
  866. "external-volume": {
  867. External: types.External{
  868. Name: "external-volume",
  869. External: true,
  870. },
  871. },
  872. "other-external-volume": {
  873. External: types.External{
  874. Name: "my-cool-volume",
  875. External: true,
  876. },
  877. },
  878. }
  879. assert.Equal(t, expectedVolumeConfig, config.Volumes)
  880. }
  881. func loadYAML(yaml string) (*types.Config, error) {
  882. dict, err := ParseYAML([]byte(yaml))
  883. if err != nil {
  884. return nil, err
  885. }
  886. return Load(buildConfigDetails(dict))
  887. }
  888. func serviceSort(services []types.ServiceConfig) []types.ServiceConfig {
  889. sort.Sort(servicesByName(services))
  890. return services
  891. }
  892. type servicesByName []types.ServiceConfig
  893. func (sbn servicesByName) Len() int { return len(sbn) }
  894. func (sbn servicesByName) Swap(i, j int) { sbn[i], sbn[j] = sbn[j], sbn[i] }
  895. func (sbn servicesByName) Less(i, j int) bool { return sbn[i].Name < sbn[j].Name }
  896. func TestLoadAttachableNetwork(t *testing.T) {
  897. config, err := loadYAML(`
  898. version: "3.1"
  899. networks:
  900. mynet1:
  901. driver: overlay
  902. attachable: true
  903. mynet2:
  904. driver: bridge
  905. `)
  906. assert.NoError(t, err)
  907. expected := map[string]types.NetworkConfig{
  908. "mynet1": {
  909. Driver: "overlay",
  910. Attachable: true,
  911. },
  912. "mynet2": {
  913. Driver: "bridge",
  914. Attachable: false,
  915. },
  916. }
  917. assert.Equal(t, expected, config.Networks)
  918. }
  919. func TestLoadExpandedPortFormat(t *testing.T) {
  920. config, err := loadYAML(`
  921. version: "3.1"
  922. services:
  923. web:
  924. image: busybox
  925. ports:
  926. - "80-82:8080-8082"
  927. - "90-92:8090-8092/udp"
  928. - "85:8500"
  929. - 8600
  930. - protocol: udp
  931. target: 53
  932. published: 10053
  933. - mode: host
  934. target: 22
  935. published: 10022
  936. `)
  937. assert.NoError(t, err)
  938. expected := []types.ServicePortConfig{
  939. {
  940. Mode: "ingress",
  941. Target: 8080,
  942. Published: 80,
  943. Protocol: "tcp",
  944. },
  945. {
  946. Mode: "ingress",
  947. Target: 8081,
  948. Published: 81,
  949. Protocol: "tcp",
  950. },
  951. {
  952. Mode: "ingress",
  953. Target: 8082,
  954. Published: 82,
  955. Protocol: "tcp",
  956. },
  957. {
  958. Mode: "ingress",
  959. Target: 8090,
  960. Published: 90,
  961. Protocol: "udp",
  962. },
  963. {
  964. Mode: "ingress",
  965. Target: 8091,
  966. Published: 91,
  967. Protocol: "udp",
  968. },
  969. {
  970. Mode: "ingress",
  971. Target: 8092,
  972. Published: 92,
  973. Protocol: "udp",
  974. },
  975. {
  976. Mode: "ingress",
  977. Target: 8500,
  978. Published: 85,
  979. Protocol: "tcp",
  980. },
  981. {
  982. Mode: "ingress",
  983. Target: 8600,
  984. Published: 0,
  985. Protocol: "tcp",
  986. },
  987. {
  988. Target: 53,
  989. Published: 10053,
  990. Protocol: "udp",
  991. },
  992. {
  993. Mode: "host",
  994. Target: 22,
  995. Published: 10022,
  996. },
  997. }
  998. assert.Equal(t, 1, len(config.Services))
  999. assert.Equal(t, expected, config.Services[0].Ports)
  1000. }