api_linux_test.go 59 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405
  1. package api
  2. import (
  3. "bytes"
  4. "encoding/json"
  5. "errors"
  6. "fmt"
  7. "io"
  8. "net/http"
  9. "os"
  10. "regexp"
  11. "runtime"
  12. "testing"
  13. "github.com/docker/docker/libnetwork"
  14. "github.com/docker/docker/libnetwork/datastore"
  15. "github.com/docker/docker/libnetwork/drivers/bridge"
  16. "github.com/docker/docker/libnetwork/netlabel"
  17. "github.com/docker/docker/libnetwork/options"
  18. "github.com/docker/docker/libnetwork/testutils"
  19. "github.com/docker/docker/libnetwork/types"
  20. "github.com/docker/docker/pkg/reexec"
  21. )
  22. const (
  23. bridgeNetType = "bridge"
  24. bridgeName = "docker0"
  25. )
  26. func i2s(i interface{}) string {
  27. s, ok := i.(string)
  28. if !ok {
  29. panic(fmt.Sprintf("Failed i2s for %v", i))
  30. }
  31. return s
  32. }
  33. func i2e(i interface{}) *endpointResource {
  34. s, ok := i.(*endpointResource)
  35. if !ok {
  36. panic(fmt.Sprintf("Failed i2e for %v", i))
  37. }
  38. return s
  39. }
  40. func i2eL(i interface{}) []*endpointResource {
  41. s, ok := i.([]*endpointResource)
  42. if !ok {
  43. panic(fmt.Sprintf("Failed i2eL for %v", i))
  44. }
  45. return s
  46. }
  47. func i2n(i interface{}) *networkResource {
  48. s, ok := i.(*networkResource)
  49. if !ok {
  50. panic(fmt.Sprintf("Failed i2n for %v", i))
  51. }
  52. return s
  53. }
  54. func i2nL(i interface{}) []*networkResource {
  55. s, ok := i.([]*networkResource)
  56. if !ok {
  57. panic(fmt.Sprintf("Failed i2nL for %v", i))
  58. }
  59. return s
  60. }
  61. func i2sb(i interface{}) *sandboxResource {
  62. s, ok := i.(*sandboxResource)
  63. if !ok {
  64. panic(fmt.Sprintf("Failed i2sb for %v", i))
  65. }
  66. return s
  67. }
  68. func i2sbL(i interface{}) []*sandboxResource {
  69. s, ok := i.([]*sandboxResource)
  70. if !ok {
  71. panic(fmt.Sprintf("Failed i2sbL for %v", i))
  72. }
  73. return s
  74. }
  75. func createTestNetwork(t *testing.T, network string) (libnetwork.NetworkController, libnetwork.Network) {
  76. // Cleanup local datastore file
  77. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  78. c, err := libnetwork.New()
  79. if err != nil {
  80. t.Fatal(err)
  81. }
  82. netOption := options.Generic{
  83. netlabel.GenericData: options.Generic{
  84. "BridgeName": network,
  85. },
  86. }
  87. netGeneric := libnetwork.NetworkOptionGeneric(netOption)
  88. nw, err := c.NewNetwork(bridgeNetType, network, "", netGeneric)
  89. if err != nil {
  90. t.Fatal(err)
  91. }
  92. return c, nw
  93. }
  94. func GetOpsMap(bridgeName, defaultMTU string) map[string]string {
  95. if defaultMTU == "" {
  96. return map[string]string{
  97. bridge.BridgeName: bridgeName,
  98. }
  99. }
  100. return map[string]string{
  101. bridge.BridgeName: bridgeName,
  102. netlabel.DriverMTU: defaultMTU,
  103. }
  104. }
  105. func getExposedPorts() []types.TransportPort {
  106. return []types.TransportPort{
  107. {Proto: types.TCP, Port: uint16(5000)},
  108. {Proto: types.UDP, Port: uint16(400)},
  109. {Proto: types.TCP, Port: uint16(600)},
  110. }
  111. }
  112. func getPortMapping() []types.PortBinding {
  113. return []types.PortBinding{
  114. {Proto: types.TCP, Port: uint16(230), HostPort: uint16(23000)},
  115. {Proto: types.UDP, Port: uint16(200), HostPort: uint16(22000)},
  116. {Proto: types.TCP, Port: uint16(120), HostPort: uint16(12000)},
  117. }
  118. }
  119. func TestMain(m *testing.M) {
  120. if reexec.Init() {
  121. return
  122. }
  123. os.Exit(m.Run())
  124. }
  125. func TestSandboxOptionParser(t *testing.T) {
  126. hn := "host1"
  127. dn := "docker.com"
  128. hp := "/etc/hosts"
  129. rc := "/etc/resolv.conf"
  130. dnss := []string{"8.8.8.8", "172.28.34.5"}
  131. ehs := []extraHost{{Name: "extra1", Address: "172.28.9.1"}, {Name: "extra2", Address: "172.28.9.2"}}
  132. sb := sandboxCreate{
  133. HostName: hn,
  134. DomainName: dn,
  135. HostsPath: hp,
  136. ResolvConfPath: rc,
  137. DNS: dnss,
  138. ExtraHosts: ehs,
  139. UseDefaultSandbox: true,
  140. }
  141. if len(sb.parseOptions()) != 9 {
  142. t.Fatal("Failed to generate all libnetwork.SandboxOption methods")
  143. }
  144. }
  145. func TestJson(t *testing.T) {
  146. nc := networkCreate{NetworkType: bridgeNetType}
  147. b, err := json.Marshal(nc)
  148. if err != nil {
  149. t.Fatal(err)
  150. }
  151. var ncp networkCreate
  152. err = json.Unmarshal(b, &ncp)
  153. if err != nil {
  154. t.Fatal(err)
  155. }
  156. if nc.NetworkType != ncp.NetworkType {
  157. t.Fatalf("Incorrect networkCreate after json encoding/deconding: %v", ncp)
  158. }
  159. jl := endpointJoin{SandboxID: "abcdef456789"}
  160. b, err = json.Marshal(jl)
  161. if err != nil {
  162. t.Fatal(err)
  163. }
  164. var jld endpointJoin
  165. err = json.Unmarshal(b, &jld)
  166. if err != nil {
  167. t.Fatal(err)
  168. }
  169. if jl.SandboxID != jld.SandboxID {
  170. t.Fatalf("Incorrect endpointJoin after json encoding/deconding: %v", jld)
  171. }
  172. }
  173. func TestCreateDeleteNetwork(t *testing.T) {
  174. defer testutils.SetupTestOSContext(t)()
  175. // Cleanup local datastore file
  176. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  177. c, err := libnetwork.New()
  178. if err != nil {
  179. t.Fatal(err)
  180. }
  181. defer c.Stop()
  182. badBody, err := json.Marshal("bad body")
  183. if err != nil {
  184. t.Fatal(err)
  185. }
  186. vars := make(map[string]string)
  187. _, errRsp := procCreateNetwork(c, nil, badBody)
  188. if errRsp == &createdResponse {
  189. t.Fatal("Expected to fail but succeeded")
  190. }
  191. if errRsp.StatusCode != http.StatusBadRequest {
  192. t.Fatalf("Expected StatusBadRequest status code, got: %v", errRsp)
  193. }
  194. incompleteBody, err := json.Marshal(networkCreate{})
  195. if err != nil {
  196. t.Fatal(err)
  197. }
  198. _, errRsp = procCreateNetwork(c, vars, incompleteBody)
  199. if errRsp == &createdResponse {
  200. t.Fatal("Expected to fail but succeeded")
  201. }
  202. if errRsp.StatusCode != http.StatusBadRequest {
  203. t.Fatalf("Expected StatusBadRequest status code, got: %v", errRsp)
  204. }
  205. dops := GetOpsMap("abc", "")
  206. nops := map[string]string{}
  207. nc := networkCreate{Name: "network_1", NetworkType: bridgeNetType, DriverOpts: dops, NetworkOpts: nops}
  208. goodBody, err := json.Marshal(nc)
  209. if err != nil {
  210. t.Fatal(err)
  211. }
  212. _, errRsp = procCreateNetwork(c, vars, goodBody)
  213. if errRsp != &createdResponse {
  214. t.Fatalf("Unexpected failure: %v", errRsp)
  215. }
  216. vars[urlNwName] = ""
  217. _, errRsp = procDeleteNetwork(c, vars, nil)
  218. if errRsp == &successResponse {
  219. t.Fatal("Expected to fail but succeeded")
  220. }
  221. vars[urlNwName] = "abc"
  222. _, errRsp = procDeleteNetwork(c, vars, nil)
  223. if errRsp == &successResponse {
  224. t.Fatal("Expected to fail but succeeded")
  225. }
  226. vars[urlNwName] = "network_1"
  227. _, errRsp = procDeleteNetwork(c, vars, nil)
  228. if errRsp != &successResponse {
  229. t.Fatalf("Unexpected failure: %v", errRsp)
  230. }
  231. }
  232. func TestGetNetworksAndEndpoints(t *testing.T) {
  233. defer testutils.SetupTestOSContext(t)()
  234. // Cleanup local datastore file
  235. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  236. c, err := libnetwork.New()
  237. if err != nil {
  238. t.Fatal(err)
  239. }
  240. defer c.Stop()
  241. ops := GetOpsMap("api_test_nw", "")
  242. nc := networkCreate{Name: "sh", NetworkType: bridgeNetType, DriverOpts: ops}
  243. body, err := json.Marshal(nc)
  244. if err != nil {
  245. t.Fatal(err)
  246. }
  247. vars := make(map[string]string)
  248. inid, errRsp := procCreateNetwork(c, vars, body)
  249. if errRsp != &createdResponse {
  250. t.Fatalf("Unexpected failure: %v", errRsp)
  251. }
  252. nid, ok := inid.(string)
  253. if !ok {
  254. t.FailNow()
  255. }
  256. ec1 := endpointCreate{
  257. Name: "ep1",
  258. }
  259. b1, err := json.Marshal(ec1)
  260. if err != nil {
  261. t.Fatal(err)
  262. }
  263. ec2 := endpointCreate{Name: "ep2"}
  264. b2, err := json.Marshal(ec2)
  265. if err != nil {
  266. t.Fatal(err)
  267. }
  268. vars[urlNwName] = "sh"
  269. vars[urlEpName] = "ep1"
  270. ieid1, errRsp := procCreateEndpoint(c, vars, b1)
  271. if errRsp != &createdResponse {
  272. t.Fatalf("Unexpected failure: %v", errRsp)
  273. }
  274. eid1 := i2s(ieid1)
  275. vars[urlEpName] = "ep2"
  276. ieid2, errRsp := procCreateEndpoint(c, vars, b2)
  277. if errRsp != &createdResponse {
  278. t.Fatalf("Unexpected failure: %v", errRsp)
  279. }
  280. eid2 := i2s(ieid2)
  281. vars[urlNwName] = ""
  282. vars[urlEpName] = "ep1"
  283. _, errRsp = procGetEndpoint(c, vars, nil)
  284. if errRsp == &successResponse {
  285. t.Fatalf("Expected failure but succeeded: %v", errRsp)
  286. }
  287. if errRsp.StatusCode != http.StatusBadRequest {
  288. t.Fatalf("Expected to fail with http.StatusBadRequest, but got: %d", errRsp.StatusCode)
  289. }
  290. vars = make(map[string]string)
  291. vars[urlNwName] = "sh"
  292. vars[urlEpID] = ""
  293. _, errRsp = procGetEndpoint(c, vars, nil)
  294. if errRsp == &successResponse {
  295. t.Fatalf("Expected failure but succeeded: %v", errRsp)
  296. }
  297. if errRsp.StatusCode != http.StatusBadRequest {
  298. t.Fatalf("Expected to fail with http.StatusBadRequest, but got: %d", errRsp.StatusCode)
  299. }
  300. vars = make(map[string]string)
  301. vars[urlNwID] = ""
  302. vars[urlEpID] = eid1
  303. _, errRsp = procGetEndpoint(c, vars, nil)
  304. if errRsp == &successResponse {
  305. t.Fatalf("Expected failure but succeeded: %v", errRsp)
  306. }
  307. if errRsp.StatusCode != http.StatusBadRequest {
  308. t.Fatalf("Expected to fail with http.StatusBadRequest, but got: %d", errRsp.StatusCode)
  309. }
  310. // nw by name and ep by id
  311. vars[urlNwName] = "sh"
  312. i1, errRsp := procGetEndpoint(c, vars, nil)
  313. if errRsp != &successResponse {
  314. t.Fatalf("Unexpected failure: %v", errRsp)
  315. }
  316. // nw by name and ep by name
  317. delete(vars, urlEpID)
  318. vars[urlEpName] = "ep1"
  319. i2, errRsp := procGetEndpoint(c, vars, nil)
  320. if errRsp != &successResponse {
  321. t.Fatalf("Unexpected failure: %v", errRsp)
  322. }
  323. // nw by id and ep by name
  324. delete(vars, urlNwName)
  325. vars[urlNwID] = nid
  326. i3, errRsp := procGetEndpoint(c, vars, nil)
  327. if errRsp != &successResponse {
  328. t.Fatalf("Unexpected failure: %v", errRsp)
  329. }
  330. // nw by id and ep by id
  331. delete(vars, urlEpName)
  332. vars[urlEpID] = eid1
  333. i4, errRsp := procGetEndpoint(c, vars, nil)
  334. if errRsp != &successResponse {
  335. t.Fatalf("Unexpected failure: %v", errRsp)
  336. }
  337. id1 := i2e(i1).ID
  338. if id1 != i2e(i2).ID || id1 != i2e(i3).ID || id1 != i2e(i4).ID {
  339. t.Fatalf("Endpoints retrieved via different query parameters differ: %v, %v, %v, %v", i1, i2, i3, i4)
  340. }
  341. vars[urlNwName] = ""
  342. _, errRsp = procGetEndpoints(c, vars, nil)
  343. if errRsp == &successResponse {
  344. t.Fatalf("Expected failure, got: %v", errRsp)
  345. }
  346. delete(vars, urlNwName)
  347. vars[urlNwID] = "fakeID"
  348. _, errRsp = procGetEndpoints(c, vars, nil)
  349. if errRsp == &successResponse {
  350. t.Fatalf("Expected failure, got: %v", errRsp)
  351. }
  352. vars[urlNwID] = nid
  353. _, errRsp = procGetEndpoints(c, vars, nil)
  354. if errRsp != &successResponse {
  355. t.Fatalf("Unexpected failure: %v", errRsp)
  356. }
  357. vars[urlNwName] = "sh"
  358. iepList, errRsp := procGetEndpoints(c, vars, nil)
  359. if errRsp != &successResponse {
  360. t.Fatalf("Unexpected failure: %v", errRsp)
  361. }
  362. epList := i2eL(iepList)
  363. if len(epList) != 2 {
  364. t.Fatalf("Did not return the expected number (2) of endpoint resources: %d", len(epList))
  365. }
  366. if "sh" != epList[0].Network || "sh" != epList[1].Network {
  367. t.Fatal("Did not find expected network name in endpoint resources")
  368. }
  369. vars = make(map[string]string)
  370. vars[urlNwName] = ""
  371. _, errRsp = procGetNetwork(c, vars, nil)
  372. if errRsp == &successResponse {
  373. t.Fatalf("Expected failure, got: %v", errRsp)
  374. }
  375. vars[urlNwName] = "shhhhh"
  376. _, errRsp = procGetNetwork(c, vars, nil)
  377. if errRsp == &successResponse {
  378. t.Fatalf("Expected failure, got: %v", errRsp)
  379. }
  380. vars[urlNwName] = "sh"
  381. inr1, errRsp := procGetNetwork(c, vars, nil)
  382. if errRsp != &successResponse {
  383. t.Fatalf("Unexpected failure: %v", errRsp)
  384. }
  385. nr1 := i2n(inr1)
  386. delete(vars, urlNwName)
  387. vars[urlNwID] = "acacac"
  388. _, errRsp = procGetNetwork(c, vars, nil)
  389. if errRsp == &successResponse {
  390. t.Fatalf("Expected failure. Got: %v", errRsp)
  391. }
  392. vars[urlNwID] = nid
  393. inr2, errRsp := procGetNetwork(c, vars, nil)
  394. if errRsp != &successResponse {
  395. t.Fatalf("procgetNetworkByName() != procgetNetworkById(), %v vs %v", inr1, inr2)
  396. }
  397. nr2 := i2n(inr2)
  398. if nr1.Name != nr2.Name || nr1.Type != nr2.Type || nr1.ID != nr2.ID || len(nr1.Endpoints) != len(nr2.Endpoints) {
  399. t.Fatalf("Get by name and Get failure: %v", errRsp)
  400. }
  401. if len(nr1.Endpoints) != 2 {
  402. t.Fatalf("Did not find the expected number (2) of endpoint resources in the network resource: %d", len(nr1.Endpoints))
  403. }
  404. for _, er := range nr1.Endpoints {
  405. if er.ID != eid1 && er.ID != eid2 {
  406. t.Fatalf("Did not find the expected endpoint resources in the network resource: %v", nr1.Endpoints)
  407. }
  408. }
  409. iList, errRsp := procGetNetworks(c, nil, nil)
  410. if errRsp != &successResponse {
  411. t.Fatalf("Unexpected failure: %v", errRsp)
  412. }
  413. netList := i2nL(iList)
  414. if len(netList) != 1 {
  415. t.Fatal("Did not return the expected number of network resources")
  416. }
  417. if nid != netList[0].ID {
  418. t.Fatalf("Did not find expected network %s: %v", nid, netList)
  419. }
  420. _, errRsp = procDeleteNetwork(c, vars, nil)
  421. if errRsp == &successResponse {
  422. t.Fatalf("Expected failure, got: %v", errRsp)
  423. }
  424. vars[urlEpName] = "ep1"
  425. _, errRsp = procDeleteEndpoint(c, vars, nil)
  426. if errRsp != &successResponse {
  427. t.Fatalf("Unexpected failure: %v", errRsp)
  428. }
  429. delete(vars, urlEpName)
  430. iepList, errRsp = procGetEndpoints(c, vars, nil)
  431. if errRsp != &successResponse {
  432. t.Fatalf("Unexpected failure: %v", errRsp)
  433. }
  434. epList = i2eL(iepList)
  435. if len(epList) != 1 {
  436. t.Fatalf("Did not return the expected number (1) of endpoint resources: %d", len(epList))
  437. }
  438. vars[urlEpName] = "ep2"
  439. _, errRsp = procDeleteEndpoint(c, vars, nil)
  440. if errRsp != &successResponse {
  441. t.Fatalf("Unexpected failure: %v", errRsp)
  442. }
  443. iepList, errRsp = procGetEndpoints(c, vars, nil)
  444. if errRsp != &successResponse {
  445. t.Fatalf("Unexpected failure: %v", errRsp)
  446. }
  447. epList = i2eL(iepList)
  448. if len(epList) != 0 {
  449. t.Fatalf("Did not return the expected number (0) of endpoint resources: %d", len(epList))
  450. }
  451. _, errRsp = procDeleteNetwork(c, vars, nil)
  452. if errRsp != &successResponse {
  453. t.Fatalf("Unexpected failure: %v", errRsp)
  454. }
  455. iList, errRsp = procGetNetworks(c, nil, nil)
  456. if errRsp != &successResponse {
  457. t.Fatalf("Unexpected failure: %v", errRsp)
  458. }
  459. netList = i2nL(iList)
  460. if len(netList) != 0 {
  461. t.Fatal("Did not return the expected number of network resources")
  462. }
  463. }
  464. func TestProcGetServices(t *testing.T) {
  465. defer testutils.SetupTestOSContext(t)()
  466. // Cleanup local datastore file
  467. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  468. c, err := libnetwork.New()
  469. if err != nil {
  470. t.Fatal(err)
  471. }
  472. defer c.Stop()
  473. // Create 2 networks
  474. netName1 := "production"
  475. netOption := options.Generic{
  476. netlabel.GenericData: options.Generic{
  477. "BridgeName": netName1,
  478. },
  479. }
  480. nw1, err := c.NewNetwork(bridgeNetType, netName1, "", libnetwork.NetworkOptionGeneric(netOption))
  481. if err != nil {
  482. t.Fatal(err)
  483. }
  484. netName2 := "workdev"
  485. netOption = options.Generic{
  486. netlabel.GenericData: options.Generic{
  487. "BridgeName": netName2,
  488. },
  489. }
  490. nw2, err := c.NewNetwork(bridgeNetType, netName2, "", libnetwork.NetworkOptionGeneric(netOption))
  491. if err != nil {
  492. t.Fatal(err)
  493. }
  494. vars := make(map[string]string)
  495. li, errRsp := procGetServices(c, vars, nil)
  496. if !errRsp.isOK() {
  497. t.Fatalf("Unexpected failure: %v", errRsp)
  498. }
  499. list := i2eL(li)
  500. if len(list) != 0 {
  501. t.Fatalf("Unexpected services in response: %v", list)
  502. }
  503. // Add a couple of services on one network and one on the other network
  504. ep11, err := nw1.CreateEndpoint("db-prod")
  505. if err != nil {
  506. t.Fatal(err)
  507. }
  508. ep12, err := nw1.CreateEndpoint("web-prod")
  509. if err != nil {
  510. t.Fatal(err)
  511. }
  512. ep21, err := nw2.CreateEndpoint("db-dev")
  513. if err != nil {
  514. t.Fatal(err)
  515. }
  516. li, errRsp = procGetServices(c, vars, nil)
  517. if !errRsp.isOK() {
  518. t.Fatalf("Unexpected failure: %v", errRsp)
  519. }
  520. list = i2eL(li)
  521. if len(list) != 3 {
  522. t.Fatalf("Unexpected services in response: %v", list)
  523. }
  524. // Filter by network
  525. vars[urlNwName] = netName1
  526. li, errRsp = procGetServices(c, vars, nil)
  527. if !errRsp.isOK() {
  528. t.Fatalf("Unexpected failure: %v", errRsp)
  529. }
  530. list = i2eL(li)
  531. if len(list) != 2 {
  532. t.Fatalf("Unexpected services in response: %v", list)
  533. }
  534. vars[urlNwName] = netName2
  535. li, errRsp = procGetServices(c, vars, nil)
  536. if !errRsp.isOK() {
  537. t.Fatalf("Unexpected failure: %v", errRsp)
  538. }
  539. list = i2eL(li)
  540. if len(list) != 1 {
  541. t.Fatalf("Unexpected services in response: %v", list)
  542. }
  543. vars[urlNwName] = "unknown-network"
  544. li, errRsp = procGetServices(c, vars, nil)
  545. if !errRsp.isOK() {
  546. t.Fatalf("Unexpected failure: %v", errRsp)
  547. }
  548. list = i2eL(li)
  549. if len(list) != 0 {
  550. t.Fatalf("Unexpected services in response: %v", list)
  551. }
  552. // Query by name
  553. delete(vars, urlNwName)
  554. vars[urlEpName] = "db-prod"
  555. li, errRsp = procGetServices(c, vars, nil)
  556. if !errRsp.isOK() {
  557. t.Fatalf("Unexpected failure: %v", errRsp)
  558. }
  559. list = i2eL(li)
  560. if len(list) != 1 {
  561. t.Fatalf("Unexpected services in response: %v", list)
  562. }
  563. vars[urlEpName] = "no-service"
  564. li, errRsp = procGetServices(c, vars, nil)
  565. if !errRsp.isOK() {
  566. t.Fatalf("Unexpected failure: %v", errRsp)
  567. }
  568. list = i2eL(li)
  569. if len(list) != 0 {
  570. t.Fatalf("Unexpected services in response: %v", list)
  571. }
  572. // Query by id or partial id
  573. delete(vars, urlEpName)
  574. vars[urlEpPID] = ep12.ID()
  575. li, errRsp = procGetServices(c, vars, nil)
  576. if !errRsp.isOK() {
  577. t.Fatalf("Unexpected failure: %v", errRsp)
  578. }
  579. list = i2eL(li)
  580. if len(list) != 1 {
  581. t.Fatalf("Unexpected services in response: %v", list)
  582. }
  583. if list[0].ID != ep12.ID() {
  584. t.Fatalf("Unexpected element in response: %v", list)
  585. }
  586. vars[urlEpPID] = "non-id"
  587. li, errRsp = procGetServices(c, vars, nil)
  588. if !errRsp.isOK() {
  589. t.Fatalf("Unexpected failure: %v", errRsp)
  590. }
  591. list = i2eL(li)
  592. if len(list) != 0 {
  593. t.Fatalf("Unexpected services in response: %v", list)
  594. }
  595. delete(vars, urlEpPID)
  596. err = ep11.Delete(false)
  597. if err != nil {
  598. t.Fatal(err)
  599. }
  600. err = ep12.Delete(false)
  601. if err != nil {
  602. t.Fatal(err)
  603. }
  604. err = ep21.Delete(false)
  605. if err != nil {
  606. t.Fatal(err)
  607. }
  608. li, errRsp = procGetServices(c, vars, nil)
  609. if !errRsp.isOK() {
  610. t.Fatalf("Unexpected failure: %v", errRsp)
  611. }
  612. list = i2eL(li)
  613. if len(list) != 0 {
  614. t.Fatalf("Unexpected services in response: %v", list)
  615. }
  616. }
  617. func TestProcGetService(t *testing.T) {
  618. defer testutils.SetupTestOSContext(t)()
  619. c, nw := createTestNetwork(t, "network")
  620. defer c.Stop()
  621. ep1, err := nw.CreateEndpoint("db")
  622. if err != nil {
  623. t.Fatal(err)
  624. }
  625. ep2, err := nw.CreateEndpoint("web")
  626. if err != nil {
  627. t.Fatal(err)
  628. }
  629. vars := map[string]string{urlEpID: ""}
  630. _, errRsp := procGetService(c, vars, nil)
  631. if errRsp.isOK() {
  632. t.Fatal("Expected failure, but succeeded")
  633. }
  634. if errRsp.StatusCode != http.StatusBadRequest {
  635. t.Fatalf("Expected %d, but got: %d", http.StatusBadRequest, errRsp.StatusCode)
  636. }
  637. vars[urlEpID] = "unknown-service-id"
  638. _, errRsp = procGetService(c, vars, nil)
  639. if errRsp.isOK() {
  640. t.Fatal("Expected failure, but succeeded")
  641. }
  642. if errRsp.StatusCode != http.StatusNotFound {
  643. t.Fatalf("Expected %d, but got: %d. (%v)", http.StatusNotFound, errRsp.StatusCode, errRsp)
  644. }
  645. vars[urlEpID] = ep1.ID()
  646. si, errRsp := procGetService(c, vars, nil)
  647. if !errRsp.isOK() {
  648. t.Fatalf("Unexpected failure: %v", errRsp)
  649. }
  650. sv := i2e(si)
  651. if sv.ID != ep1.ID() {
  652. t.Fatalf("Unexpected service resource returned: %v", sv)
  653. }
  654. vars[urlEpID] = ep2.ID()
  655. si, errRsp = procGetService(c, vars, nil)
  656. if !errRsp.isOK() {
  657. t.Fatalf("Unexpected failure: %v", errRsp)
  658. }
  659. sv = i2e(si)
  660. if sv.ID != ep2.ID() {
  661. t.Fatalf("Unexpected service resource returned: %v", sv)
  662. }
  663. }
  664. func TestProcPublishUnpublishService(t *testing.T) {
  665. defer testutils.SetupTestOSContext(t)()
  666. c, _ := createTestNetwork(t, "network")
  667. defer c.Stop()
  668. vars := make(map[string]string)
  669. vbad, err := json.Marshal("bad service create data")
  670. if err != nil {
  671. t.Fatal(err)
  672. }
  673. _, errRsp := procPublishService(c, vars, vbad)
  674. if errRsp == &createdResponse {
  675. t.Fatal("Expected to fail but succeeded")
  676. }
  677. if errRsp.StatusCode != http.StatusBadRequest {
  678. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  679. }
  680. b, err := json.Marshal(servicePublish{Name: ""})
  681. if err != nil {
  682. t.Fatal(err)
  683. }
  684. _, errRsp = procPublishService(c, vars, b)
  685. if errRsp == &createdResponse {
  686. t.Fatal("Expected to fail but succeeded")
  687. }
  688. if errRsp.StatusCode != http.StatusBadRequest {
  689. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  690. }
  691. b, err = json.Marshal(servicePublish{Name: "db"})
  692. if err != nil {
  693. t.Fatal(err)
  694. }
  695. _, errRsp = procPublishService(c, vars, b)
  696. if errRsp == &createdResponse {
  697. t.Fatal("Expected to fail but succeeded")
  698. }
  699. if errRsp.StatusCode != http.StatusBadRequest {
  700. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  701. }
  702. b, err = json.Marshal(servicePublish{Name: "db", Network: "unknown-network"})
  703. if err != nil {
  704. t.Fatal(err)
  705. }
  706. _, errRsp = procPublishService(c, vars, b)
  707. if errRsp == &createdResponse {
  708. t.Fatal("Expected to fail but succeeded")
  709. }
  710. if errRsp.StatusCode != http.StatusNotFound {
  711. t.Fatalf("Expected %d. Got: %v", http.StatusNotFound, errRsp)
  712. }
  713. b, err = json.Marshal(servicePublish{Name: "", Network: "network"})
  714. if err != nil {
  715. t.Fatal(err)
  716. }
  717. _, errRsp = procPublishService(c, vars, b)
  718. if errRsp == &createdResponse {
  719. t.Fatal("Expected to fail but succeeded")
  720. }
  721. if errRsp.StatusCode != http.StatusBadRequest {
  722. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  723. }
  724. b, err = json.Marshal(servicePublish{Name: "db", Network: "network"})
  725. if err != nil {
  726. t.Fatal(err)
  727. }
  728. _, errRsp = procPublishService(c, vars, b)
  729. if errRsp != &createdResponse {
  730. t.Fatalf("Unexpected failure: %v", errRsp)
  731. }
  732. sp := servicePublish{
  733. Name: "web",
  734. Network: "network",
  735. }
  736. b, err = json.Marshal(sp)
  737. if err != nil {
  738. t.Fatal(err)
  739. }
  740. si, errRsp := procPublishService(c, vars, b)
  741. if errRsp != &createdResponse {
  742. t.Fatalf("Unexpected failure: %v", errRsp)
  743. }
  744. sid := i2s(si)
  745. vars[urlEpID] = ""
  746. _, errRsp = procUnpublishService(c, vars, nil)
  747. if errRsp.isOK() {
  748. t.Fatal("Expected failure but succeeded")
  749. }
  750. if errRsp.StatusCode != http.StatusBadRequest {
  751. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  752. }
  753. vars[urlEpID] = "unknown-service-id"
  754. _, errRsp = procUnpublishService(c, vars, nil)
  755. if errRsp.isOK() {
  756. t.Fatal("Expected failure but succeeded")
  757. }
  758. if errRsp.StatusCode != http.StatusNotFound {
  759. t.Fatalf("Expected %d. Got: %v", http.StatusNotFound, errRsp)
  760. }
  761. vars[urlEpID] = sid
  762. _, errRsp = procUnpublishService(c, vars, nil)
  763. if !errRsp.isOK() {
  764. t.Fatalf("Unexpected failure: %v", errRsp)
  765. }
  766. _, errRsp = procGetService(c, vars, nil)
  767. if errRsp.isOK() {
  768. t.Fatal("Expected failure, but succeeded")
  769. }
  770. if errRsp.StatusCode != http.StatusNotFound {
  771. t.Fatalf("Expected %d, but got: %d. (%v)", http.StatusNotFound, errRsp.StatusCode, errRsp)
  772. }
  773. }
  774. func TestAttachDetachBackend(t *testing.T) {
  775. defer testutils.SetupTestOSContext(t)()
  776. c, nw := createTestNetwork(t, "network")
  777. defer c.Stop()
  778. ep1, err := nw.CreateEndpoint("db")
  779. if err != nil {
  780. t.Fatal(err)
  781. }
  782. vars := make(map[string]string)
  783. vbad, err := json.Marshal("bad data")
  784. if err != nil {
  785. t.Fatal(err)
  786. }
  787. _, errRsp := procAttachBackend(c, vars, vbad)
  788. if errRsp == &successResponse {
  789. t.Fatalf("Expected failure, got: %v", errRsp)
  790. }
  791. vars[urlEpName] = "endpoint"
  792. bad, err := json.Marshal(endpointJoin{})
  793. if err != nil {
  794. t.Fatal(err)
  795. }
  796. _, errRsp = procAttachBackend(c, vars, bad)
  797. if errRsp == &successResponse {
  798. t.Fatalf("Expected failure, got: %v", errRsp)
  799. }
  800. if errRsp.StatusCode != http.StatusNotFound {
  801. t.Fatalf("Expected %d. Got: %v", http.StatusNotFound, errRsp)
  802. }
  803. vars[urlEpID] = "db"
  804. _, errRsp = procGetSandbox(c, vars, nil)
  805. if errRsp.isOK() {
  806. t.Fatalf("Expected failure. Got %v", errRsp)
  807. }
  808. if errRsp.StatusCode != http.StatusNotFound {
  809. t.Fatalf("Expected %d. Got: %v", http.StatusNotFound, errRsp)
  810. }
  811. vars[urlEpName] = "db"
  812. _, errRsp = procAttachBackend(c, vars, bad)
  813. if errRsp == &successResponse {
  814. t.Fatalf("Expected failure, got: %v", errRsp)
  815. }
  816. if errRsp.StatusCode != http.StatusBadRequest {
  817. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  818. }
  819. cid := "abcdefghi"
  820. sbox, err := c.NewSandbox(cid)
  821. if err != nil {
  822. t.Fatal(err)
  823. }
  824. sid := sbox.ID()
  825. defer sbox.Delete()
  826. jl := endpointJoin{SandboxID: sid}
  827. jlb, err := json.Marshal(jl)
  828. if err != nil {
  829. t.Fatal(err)
  830. }
  831. _, errRsp = procAttachBackend(c, vars, jlb)
  832. if errRsp != &successResponse {
  833. t.Fatalf("Unexpected failure, got: %v", errRsp)
  834. }
  835. sli, errRsp := procGetSandboxes(c, vars, nil)
  836. if errRsp != &successResponse {
  837. t.Fatalf("Unexpected failure, got: %v", errRsp)
  838. }
  839. sl := i2sbL(sli)
  840. if len(sl) != 1 {
  841. t.Fatalf("Did not find expected number of sandboxes attached to the service: %d", len(sl))
  842. }
  843. if sl[0].ContainerID != cid {
  844. t.Fatalf("Did not find expected sandbox attached to the service: %v", sl[0])
  845. }
  846. _, errRsp = procUnpublishService(c, vars, nil)
  847. if errRsp.isOK() {
  848. t.Fatal("Expected failure but succeeded")
  849. }
  850. if errRsp.StatusCode != http.StatusForbidden {
  851. t.Fatalf("Expected %d. Got: %v", http.StatusForbidden, errRsp)
  852. }
  853. vars[urlEpName] = "endpoint"
  854. _, errRsp = procDetachBackend(c, vars, nil)
  855. if errRsp == &successResponse {
  856. t.Fatalf("Expected failure, got: %v", errRsp)
  857. }
  858. if errRsp.StatusCode != http.StatusNotFound {
  859. t.Fatalf("Expected %d. Got: %v", http.StatusNotFound, errRsp)
  860. }
  861. vars[urlEpName] = "db"
  862. _, errRsp = procDetachBackend(c, vars, nil)
  863. if errRsp == &successResponse {
  864. t.Fatalf("Expected failure, got: %v", errRsp)
  865. }
  866. if errRsp.StatusCode != http.StatusBadRequest {
  867. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  868. }
  869. vars[urlSbID] = sid
  870. _, errRsp = procDetachBackend(c, vars, nil)
  871. if errRsp != &successResponse {
  872. t.Fatalf("Unexpected failure, got: %v", errRsp)
  873. }
  874. delete(vars, urlEpID)
  875. si, errRsp := procGetSandbox(c, vars, nil)
  876. if errRsp != &successResponse {
  877. t.Fatalf("Unexpected failure, got: %v", errRsp)
  878. }
  879. sb := i2sb(si)
  880. if sb.ContainerID != cid {
  881. t.Fatalf("Did not find expected sandbox. Got %v", sb)
  882. }
  883. err = ep1.Delete(false)
  884. if err != nil {
  885. t.Fatal(err)
  886. }
  887. }
  888. func TestDetectGetNetworksInvalidQueryComposition(t *testing.T) {
  889. // Cleanup local datastore file
  890. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  891. c, err := libnetwork.New()
  892. if err != nil {
  893. t.Fatal(err)
  894. }
  895. defer c.Stop()
  896. vars := map[string]string{urlNwName: "x", urlNwPID: "y"}
  897. _, errRsp := procGetNetworks(c, vars, nil)
  898. if errRsp.StatusCode != http.StatusBadRequest {
  899. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  900. }
  901. }
  902. func TestDetectGetEndpointsInvalidQueryComposition(t *testing.T) {
  903. defer testutils.SetupTestOSContext(t)()
  904. c, _ := createTestNetwork(t, "network")
  905. defer c.Stop()
  906. vars := map[string]string{urlNwName: "network", urlEpName: "x", urlEpPID: "y"}
  907. _, errRsp := procGetEndpoints(c, vars, nil)
  908. if errRsp.StatusCode != http.StatusBadRequest {
  909. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  910. }
  911. }
  912. func TestDetectGetServicesInvalidQueryComposition(t *testing.T) {
  913. defer testutils.SetupTestOSContext(t)()
  914. c, _ := createTestNetwork(t, "network")
  915. defer c.Stop()
  916. vars := map[string]string{urlNwName: "network", urlEpName: "x", urlEpPID: "y"}
  917. _, errRsp := procGetServices(c, vars, nil)
  918. if errRsp.StatusCode != http.StatusBadRequest {
  919. t.Fatalf("Expected %d. Got: %v", http.StatusBadRequest, errRsp)
  920. }
  921. }
  922. func TestFindNetworkUtilPanic(t *testing.T) {
  923. defer checkPanic(t)
  924. findNetwork(nil, "", -1)
  925. }
  926. func TestFindNetworkUtil(t *testing.T) {
  927. defer testutils.SetupTestOSContext(t)()
  928. c, nw := createTestNetwork(t, "network")
  929. defer c.Stop()
  930. nid := nw.ID()
  931. _, errRsp := findNetwork(c, "", byName)
  932. if errRsp == &successResponse {
  933. t.Fatal("Expected to fail but succeeded")
  934. }
  935. if errRsp.StatusCode != http.StatusBadRequest {
  936. t.Fatalf("Expected %d, but got: %d", http.StatusBadRequest, errRsp.StatusCode)
  937. }
  938. n, errRsp := findNetwork(c, nid, byID)
  939. if errRsp != &successResponse {
  940. t.Fatalf("Unexpected failure: %v", errRsp)
  941. }
  942. if n == nil {
  943. t.Fatal("Unexpected nil libnetwork.Network")
  944. }
  945. if nid != n.ID() {
  946. t.Fatalf("Incorrect libnetwork.Network resource. It has different id: %v", n)
  947. }
  948. if "network" != n.Name() {
  949. t.Fatalf("Incorrect libnetwork.Network resource. It has different name: %v", n)
  950. }
  951. n, errRsp = findNetwork(c, "network", byName)
  952. if errRsp != &successResponse {
  953. t.Fatalf("Unexpected failure: %v", errRsp)
  954. }
  955. if n == nil {
  956. t.Fatal("Unexpected nil libnetwork.Network")
  957. }
  958. if nid != n.ID() {
  959. t.Fatalf("Incorrect libnetwork.Network resource. It has different id: %v", n)
  960. }
  961. if "network" != n.Name() {
  962. t.Fatalf("Incorrect libnetwork.Network resource. It has different name: %v", n)
  963. }
  964. if err := n.Delete(); err != nil {
  965. t.Fatalf("Failed to delete the network: %s", err.Error())
  966. }
  967. _, errRsp = findNetwork(c, nid, byID)
  968. if errRsp == &successResponse {
  969. t.Fatal("Expected to fail but succeeded")
  970. }
  971. if errRsp.StatusCode != http.StatusNotFound {
  972. t.Fatalf("Expected %d, but got: %d", http.StatusNotFound, errRsp.StatusCode)
  973. }
  974. _, errRsp = findNetwork(c, "network", byName)
  975. if errRsp == &successResponse {
  976. t.Fatal("Expected to fail but succeeded")
  977. }
  978. if errRsp.StatusCode != http.StatusNotFound {
  979. t.Fatalf("Expected %d, but got: %d", http.StatusNotFound, errRsp.StatusCode)
  980. }
  981. }
  982. func TestCreateDeleteEndpoints(t *testing.T) {
  983. defer testutils.SetupTestOSContext(t)()
  984. // Cleanup local datastore file
  985. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  986. c, err := libnetwork.New()
  987. if err != nil {
  988. t.Fatal(err)
  989. }
  990. defer c.Stop()
  991. nc := networkCreate{Name: "firstNet", NetworkType: bridgeNetType}
  992. body, err := json.Marshal(nc)
  993. if err != nil {
  994. t.Fatal(err)
  995. }
  996. vars := make(map[string]string)
  997. i, errRsp := procCreateNetwork(c, vars, body)
  998. if errRsp != &createdResponse {
  999. t.Fatalf("Unexpected failure: %v", errRsp)
  1000. }
  1001. nid := i2s(i)
  1002. vbad, err := json.Marshal("bad endpoint create data")
  1003. if err != nil {
  1004. t.Fatal(err)
  1005. }
  1006. vars[urlNwName] = "firstNet"
  1007. _, errRsp = procCreateEndpoint(c, vars, vbad)
  1008. if errRsp == &createdResponse {
  1009. t.Fatal("Expected to fail but succeeded")
  1010. }
  1011. b, err := json.Marshal(endpointCreate{Name: ""})
  1012. if err != nil {
  1013. t.Fatal(err)
  1014. }
  1015. vars[urlNwName] = "secondNet"
  1016. _, errRsp = procCreateEndpoint(c, vars, b)
  1017. if errRsp == &createdResponse {
  1018. t.Fatal("Expected to fail but succeeded")
  1019. }
  1020. vars[urlNwName] = "firstNet"
  1021. _, errRsp = procCreateEndpoint(c, vars, b)
  1022. if errRsp == &successResponse {
  1023. t.Fatalf("Expected failure but succeeded: %v", errRsp)
  1024. }
  1025. b, err = json.Marshal(endpointCreate{Name: "firstEp"})
  1026. if err != nil {
  1027. t.Fatal(err)
  1028. }
  1029. i, errRsp = procCreateEndpoint(c, vars, b)
  1030. if errRsp != &createdResponse {
  1031. t.Fatalf("Unexpected failure: %v", errRsp)
  1032. }
  1033. eid := i2s(i)
  1034. _, errRsp = findEndpoint(c, "myNet", "firstEp", byName, byName)
  1035. if errRsp == &successResponse {
  1036. t.Fatalf("Expected failure but succeeded: %v", errRsp)
  1037. }
  1038. ep0, errRsp := findEndpoint(c, nid, "firstEp", byID, byName)
  1039. if errRsp != &successResponse {
  1040. t.Fatalf("Unexpected failure: %v", errRsp)
  1041. }
  1042. ep1, errRsp := findEndpoint(c, "firstNet", "firstEp", byName, byName)
  1043. if errRsp != &successResponse {
  1044. t.Fatalf("Unexpected failure: %v", errRsp)
  1045. }
  1046. ep2, errRsp := findEndpoint(c, nid, eid, byID, byID)
  1047. if errRsp != &successResponse {
  1048. t.Fatalf("Unexpected failure: %v", errRsp)
  1049. }
  1050. ep3, errRsp := findEndpoint(c, "firstNet", eid, byName, byID)
  1051. if errRsp != &successResponse {
  1052. t.Fatalf("Unexpected failure: %v", errRsp)
  1053. }
  1054. if ep0.ID() != ep1.ID() || ep0.ID() != ep2.ID() || ep0.ID() != ep3.ID() {
  1055. t.Fatalf("Different queries returned different endpoints: \nep0: %v\nep1: %v\nep2: %v\nep3: %v", ep0, ep1, ep2, ep3)
  1056. }
  1057. vars = make(map[string]string)
  1058. vars[urlNwName] = ""
  1059. vars[urlEpName] = "ep1"
  1060. _, errRsp = procDeleteEndpoint(c, vars, nil)
  1061. if errRsp == &successResponse {
  1062. t.Fatalf("Expected failure, got: %v", errRsp)
  1063. }
  1064. vars[urlNwName] = "firstNet"
  1065. vars[urlEpName] = ""
  1066. _, errRsp = procDeleteEndpoint(c, vars, nil)
  1067. if errRsp == &successResponse {
  1068. t.Fatalf("Expected failure, got: %v", errRsp)
  1069. }
  1070. vars[urlEpName] = "ep2"
  1071. _, errRsp = procDeleteEndpoint(c, vars, nil)
  1072. if errRsp == &successResponse {
  1073. t.Fatalf("Expected failure, got: %v", errRsp)
  1074. }
  1075. vars[urlEpName] = "firstEp"
  1076. _, errRsp = procDeleteEndpoint(c, vars, nil)
  1077. if errRsp != &successResponse {
  1078. t.Fatalf("Unexpected failure: %v", errRsp)
  1079. }
  1080. _, errRsp = findEndpoint(c, "firstNet", "firstEp", byName, byName)
  1081. if errRsp == &successResponse {
  1082. t.Fatalf("Expected failure, got: %v", errRsp)
  1083. }
  1084. }
  1085. func TestJoinLeave(t *testing.T) {
  1086. if runtime.GOARCH == "arm64" {
  1087. t.Skip("This test fails on arm64 foor some reason... this need to be fixed")
  1088. }
  1089. defer testutils.SetupTestOSContext(t)()
  1090. // Cleanup local datastore file
  1091. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  1092. c, err := libnetwork.New()
  1093. if err != nil {
  1094. t.Fatal(err)
  1095. }
  1096. defer c.Stop()
  1097. nb, err := json.Marshal(networkCreate{Name: "network", NetworkType: bridgeNetType})
  1098. if err != nil {
  1099. t.Fatal(err)
  1100. }
  1101. vars := make(map[string]string)
  1102. _, errRsp := procCreateNetwork(c, vars, nb)
  1103. if errRsp != &createdResponse {
  1104. t.Fatalf("Unexpected failure: %v", errRsp)
  1105. }
  1106. eb, err := json.Marshal(endpointCreate{Name: "endpoint"})
  1107. if err != nil {
  1108. t.Fatal(err)
  1109. }
  1110. vars[urlNwName] = "network"
  1111. _, errRsp = procCreateEndpoint(c, vars, eb)
  1112. if errRsp != &createdResponse {
  1113. t.Fatalf("Unexpected failure: %v", errRsp)
  1114. }
  1115. vbad, err := json.Marshal("bad data")
  1116. if err != nil {
  1117. t.Fatal(err)
  1118. }
  1119. _, errRsp = procJoinEndpoint(c, vars, vbad)
  1120. if errRsp == &successResponse {
  1121. t.Fatalf("Expected failure, got: %v", errRsp)
  1122. }
  1123. vars[urlEpName] = "endpoint"
  1124. bad, err := json.Marshal(endpointJoin{})
  1125. if err != nil {
  1126. t.Fatal(err)
  1127. }
  1128. _, errRsp = procJoinEndpoint(c, vars, bad)
  1129. if errRsp == &successResponse {
  1130. t.Fatalf("Expected failure, got: %v", errRsp)
  1131. }
  1132. cid := "abcdefghi"
  1133. sb, err := c.NewSandbox(cid)
  1134. if err != nil {
  1135. t.Fatal(err)
  1136. }
  1137. defer sb.Delete()
  1138. jl := endpointJoin{SandboxID: sb.ID()}
  1139. jlb, err := json.Marshal(jl)
  1140. if err != nil {
  1141. t.Fatal(err)
  1142. }
  1143. vars = make(map[string]string)
  1144. vars[urlNwName] = ""
  1145. vars[urlEpName] = ""
  1146. _, errRsp = procJoinEndpoint(c, vars, jlb)
  1147. if errRsp == &successResponse {
  1148. t.Fatalf("Expected failure, got: %v", errRsp)
  1149. }
  1150. vars[urlNwName] = "network"
  1151. vars[urlEpName] = ""
  1152. _, errRsp = procJoinEndpoint(c, vars, jlb)
  1153. if errRsp == &successResponse {
  1154. t.Fatalf("Expected failure, got: %v", errRsp)
  1155. }
  1156. vars[urlEpName] = "epoint"
  1157. _, errRsp = procJoinEndpoint(c, vars, jlb)
  1158. if errRsp == &successResponse {
  1159. t.Fatalf("Expected failure, got: %v", errRsp)
  1160. }
  1161. // bad labels
  1162. vars[urlEpName] = "endpoint"
  1163. key, errRsp := procJoinEndpoint(c, vars, jlb)
  1164. if errRsp != &successResponse {
  1165. t.Fatalf("Unexpected failure, got: %v", errRsp)
  1166. }
  1167. keyStr := i2s(key)
  1168. if keyStr == "" {
  1169. t.Fatal("Empty sandbox key")
  1170. }
  1171. _, errRsp = procDeleteEndpoint(c, vars, nil)
  1172. if errRsp == &successResponse {
  1173. t.Fatalf("Expected failure, got: %v", errRsp)
  1174. }
  1175. vars[urlNwName] = "network2"
  1176. _, errRsp = procLeaveEndpoint(c, vars, vbad)
  1177. if errRsp == &successResponse {
  1178. t.Fatalf("Expected failure, got: %v", errRsp)
  1179. }
  1180. _, errRsp = procLeaveEndpoint(c, vars, bad)
  1181. if errRsp == &successResponse {
  1182. t.Fatalf("Expected failure, got: %v", errRsp)
  1183. }
  1184. _, errRsp = procLeaveEndpoint(c, vars, jlb)
  1185. if errRsp == &successResponse {
  1186. t.Fatalf("Expected failure, got: %v", errRsp)
  1187. }
  1188. vars = make(map[string]string)
  1189. vars[urlNwName] = ""
  1190. vars[urlEpName] = ""
  1191. _, errRsp = procLeaveEndpoint(c, vars, jlb)
  1192. if errRsp == &successResponse {
  1193. t.Fatalf("Expected failure, got: %v", errRsp)
  1194. }
  1195. vars[urlNwName] = "network"
  1196. vars[urlEpName] = ""
  1197. _, errRsp = procLeaveEndpoint(c, vars, jlb)
  1198. if errRsp == &successResponse {
  1199. t.Fatalf("Expected failure, got: %v", errRsp)
  1200. }
  1201. vars[urlEpName] = "2epoint"
  1202. _, errRsp = procLeaveEndpoint(c, vars, jlb)
  1203. if errRsp == &successResponse {
  1204. t.Fatalf("Expected failure, got: %v", errRsp)
  1205. }
  1206. vars[urlEpName] = "epoint"
  1207. vars[urlCnID] = "who"
  1208. _, errRsp = procLeaveEndpoint(c, vars, jlb)
  1209. if errRsp == &successResponse {
  1210. t.Fatalf("Expected failure, got: %v", errRsp)
  1211. }
  1212. delete(vars, urlCnID)
  1213. vars[urlEpName] = "endpoint"
  1214. _, errRsp = procLeaveEndpoint(c, vars, jlb)
  1215. if errRsp == &successResponse {
  1216. t.Fatalf("Expected failure, got: %v", errRsp)
  1217. }
  1218. vars[urlSbID] = sb.ID()
  1219. _, errRsp = procLeaveEndpoint(c, vars, jlb)
  1220. if errRsp != &successResponse {
  1221. t.Fatalf("Unexpected failure: %v", errRsp)
  1222. }
  1223. _, errRsp = procLeaveEndpoint(c, vars, jlb)
  1224. if errRsp == &successResponse {
  1225. t.Fatalf("Expected failure, got: %v", errRsp)
  1226. }
  1227. _, errRsp = procDeleteEndpoint(c, vars, nil)
  1228. if errRsp != &successResponse {
  1229. t.Fatalf("Unexpected failure: %v", errRsp)
  1230. }
  1231. }
  1232. func TestFindEndpointUtilPanic(t *testing.T) {
  1233. defer testutils.SetupTestOSContext(t)()
  1234. defer checkPanic(t)
  1235. c, nw := createTestNetwork(t, "network")
  1236. defer c.Stop()
  1237. nid := nw.ID()
  1238. findEndpoint(c, nid, "", byID, -1)
  1239. }
  1240. func TestFindServiceUtilPanic(t *testing.T) {
  1241. defer testutils.SetupTestOSContext(t)()
  1242. defer checkPanic(t)
  1243. c, _ := createTestNetwork(t, "network")
  1244. defer c.Stop()
  1245. findService(c, "random_service", -1)
  1246. }
  1247. func TestFindEndpointUtil(t *testing.T) {
  1248. defer testutils.SetupTestOSContext(t)()
  1249. c, nw := createTestNetwork(t, "network")
  1250. defer c.Stop()
  1251. nid := nw.ID()
  1252. ep, err := nw.CreateEndpoint("secondEp", nil)
  1253. if err != nil {
  1254. t.Fatal(err)
  1255. }
  1256. eid := ep.ID()
  1257. _, errRsp := findEndpoint(c, nid, "", byID, byName)
  1258. if errRsp == &successResponse {
  1259. t.Fatalf("Expected failure, but got: %v", errRsp)
  1260. }
  1261. if errRsp.StatusCode != http.StatusBadRequest {
  1262. t.Fatalf("Expected %d, but got: %d", http.StatusBadRequest, errRsp.StatusCode)
  1263. }
  1264. ep0, errRsp := findEndpoint(c, nid, "secondEp", byID, byName)
  1265. if errRsp != &successResponse {
  1266. t.Fatalf("Unexpected failure: %v", errRsp)
  1267. }
  1268. ep1, errRsp := findEndpoint(c, "network", "secondEp", byName, byName)
  1269. if errRsp != &successResponse {
  1270. t.Fatalf("Unexpected failure: %v", errRsp)
  1271. }
  1272. ep2, errRsp := findEndpoint(c, nid, eid, byID, byID)
  1273. if errRsp != &successResponse {
  1274. t.Fatalf("Unexpected failure: %v", errRsp)
  1275. }
  1276. ep3, errRsp := findEndpoint(c, "network", eid, byName, byID)
  1277. if errRsp != &successResponse {
  1278. t.Fatalf("Unexpected failure: %v", errRsp)
  1279. }
  1280. ep4, errRsp := findService(c, "secondEp", byName)
  1281. if errRsp != &successResponse {
  1282. t.Fatalf("Unexpected failure: %v", errRsp)
  1283. }
  1284. ep5, errRsp := findService(c, eid, byID)
  1285. if errRsp != &successResponse {
  1286. t.Fatalf("Unexpected failure: %v", errRsp)
  1287. }
  1288. if ep0.ID() != ep1.ID() || ep0.ID() != ep2.ID() ||
  1289. ep0.ID() != ep3.ID() || ep0.ID() != ep4.ID() || ep0.ID() != ep5.ID() {
  1290. t.Fatal("Different queries returned different endpoints")
  1291. }
  1292. ep.Delete(false)
  1293. _, errRsp = findEndpoint(c, nid, "secondEp", byID, byName)
  1294. if errRsp == &successResponse {
  1295. t.Fatalf("Expected failure, but got: %v", errRsp)
  1296. }
  1297. if errRsp.StatusCode != http.StatusNotFound {
  1298. t.Fatalf("Expected %d, but got: %d", http.StatusNotFound, errRsp.StatusCode)
  1299. }
  1300. _, errRsp = findEndpoint(c, "network", "secondEp", byName, byName)
  1301. if errRsp == &successResponse {
  1302. t.Fatalf("Expected failure, but got: %v", errRsp)
  1303. }
  1304. if errRsp.StatusCode != http.StatusNotFound {
  1305. t.Fatalf("Expected %d, but got: %d", http.StatusNotFound, errRsp.StatusCode)
  1306. }
  1307. _, errRsp = findEndpoint(c, nid, eid, byID, byID)
  1308. if errRsp == &successResponse {
  1309. t.Fatalf("Expected failure, but got: %v", errRsp)
  1310. }
  1311. if errRsp.StatusCode != http.StatusNotFound {
  1312. t.Fatalf("Expected %d, but got: %d", http.StatusNotFound, errRsp.StatusCode)
  1313. }
  1314. _, errRsp = findEndpoint(c, "network", eid, byName, byID)
  1315. if errRsp == &successResponse {
  1316. t.Fatalf("Expected failure, but got: %v", errRsp)
  1317. }
  1318. if errRsp.StatusCode != http.StatusNotFound {
  1319. t.Fatalf("Expected %d, but got: %d", http.StatusNotFound, errRsp.StatusCode)
  1320. }
  1321. _, errRsp = findService(c, "secondEp", byName)
  1322. if errRsp == &successResponse {
  1323. t.Fatalf("Expected failure, but got: %v", errRsp)
  1324. }
  1325. if errRsp.StatusCode != http.StatusNotFound {
  1326. t.Fatalf("Expected %d, but got: %d", http.StatusNotFound, errRsp.StatusCode)
  1327. }
  1328. _, errRsp = findService(c, eid, byID)
  1329. if errRsp == &successResponse {
  1330. t.Fatalf("Expected failure, but got: %v", errRsp)
  1331. }
  1332. if errRsp.StatusCode != http.StatusNotFound {
  1333. t.Fatalf("Expected %d, but got: %d", http.StatusNotFound, errRsp.StatusCode)
  1334. }
  1335. }
  1336. func TestEndpointToService(t *testing.T) {
  1337. r := &responseStatus{Status: "this is one endpoint", StatusCode: http.StatusOK}
  1338. r = endpointToService(r)
  1339. if r.Status != "this is one service" {
  1340. t.Fatalf("endpointToService returned unexpected status string: %s", r.Status)
  1341. }
  1342. r = &responseStatus{Status: "this is one network", StatusCode: http.StatusOK}
  1343. r = endpointToService(r)
  1344. if r.Status != "this is one network" {
  1345. t.Fatalf("endpointToService returned unexpected status string: %s", r.Status)
  1346. }
  1347. }
  1348. func checkPanic(t *testing.T) {
  1349. if r := recover(); r != nil {
  1350. if _, ok := r.(runtime.Error); ok {
  1351. panic(r)
  1352. }
  1353. } else {
  1354. t.Fatal("Expected to panic, but succeeded")
  1355. }
  1356. }
  1357. func TestDetectNetworkTargetPanic(t *testing.T) {
  1358. defer checkPanic(t)
  1359. vars := make(map[string]string)
  1360. detectNetworkTarget(vars)
  1361. }
  1362. func TestDetectEndpointTargetPanic(t *testing.T) {
  1363. defer checkPanic(t)
  1364. vars := make(map[string]string)
  1365. detectEndpointTarget(vars)
  1366. }
  1367. func TestResponseStatus(t *testing.T) {
  1368. list := []int{
  1369. http.StatusBadGateway,
  1370. http.StatusBadRequest,
  1371. http.StatusConflict,
  1372. http.StatusContinue,
  1373. http.StatusExpectationFailed,
  1374. http.StatusForbidden,
  1375. http.StatusFound,
  1376. http.StatusGatewayTimeout,
  1377. http.StatusGone,
  1378. http.StatusHTTPVersionNotSupported,
  1379. http.StatusInternalServerError,
  1380. http.StatusLengthRequired,
  1381. http.StatusMethodNotAllowed,
  1382. http.StatusMovedPermanently,
  1383. http.StatusMultipleChoices,
  1384. http.StatusNoContent,
  1385. http.StatusNonAuthoritativeInfo,
  1386. http.StatusNotAcceptable,
  1387. http.StatusNotFound,
  1388. http.StatusNotModified,
  1389. http.StatusPartialContent,
  1390. http.StatusPaymentRequired,
  1391. http.StatusPreconditionFailed,
  1392. http.StatusProxyAuthRequired,
  1393. http.StatusRequestEntityTooLarge,
  1394. http.StatusRequestTimeout,
  1395. http.StatusRequestURITooLong,
  1396. http.StatusRequestedRangeNotSatisfiable,
  1397. http.StatusResetContent,
  1398. http.StatusServiceUnavailable,
  1399. http.StatusSwitchingProtocols,
  1400. http.StatusTemporaryRedirect,
  1401. http.StatusUnauthorized,
  1402. http.StatusUnsupportedMediaType,
  1403. http.StatusUseProxy,
  1404. }
  1405. for _, c := range list {
  1406. r := responseStatus{StatusCode: c}
  1407. if r.isOK() {
  1408. t.Fatalf("isOK() returned true for code% d", c)
  1409. }
  1410. }
  1411. r := responseStatus{StatusCode: http.StatusOK}
  1412. if !r.isOK() {
  1413. t.Fatal("isOK() failed")
  1414. }
  1415. r = responseStatus{StatusCode: http.StatusCreated}
  1416. if !r.isOK() {
  1417. t.Fatal("isOK() failed")
  1418. }
  1419. }
  1420. // Local structs for end to end testing of api.go
  1421. type localReader struct {
  1422. data []byte
  1423. beBad bool
  1424. }
  1425. func newLocalReader(data []byte) *localReader {
  1426. lr := &localReader{data: make([]byte, len(data))}
  1427. copy(lr.data, data)
  1428. return lr
  1429. }
  1430. func (l *localReader) Read(p []byte) (n int, err error) {
  1431. if l.beBad {
  1432. return 0, errors.New("I am a bad reader")
  1433. }
  1434. if p == nil {
  1435. return -1, errors.New("nil buffer passed")
  1436. }
  1437. if l.data == nil || len(l.data) == 0 {
  1438. return 0, io.EOF
  1439. }
  1440. copy(p[:], l.data[:])
  1441. return len(l.data), io.EOF
  1442. }
  1443. type localResponseWriter struct {
  1444. body []byte
  1445. statusCode int
  1446. }
  1447. func newWriter() *localResponseWriter {
  1448. return &localResponseWriter{}
  1449. }
  1450. func (f *localResponseWriter) Header() http.Header {
  1451. return make(map[string][]string, 0)
  1452. }
  1453. func (f *localResponseWriter) Write(data []byte) (int, error) {
  1454. if data == nil {
  1455. return -1, errors.New("nil data passed")
  1456. }
  1457. f.body = make([]byte, len(data))
  1458. copy(f.body, data)
  1459. return len(f.body), nil
  1460. }
  1461. func (f *localResponseWriter) WriteHeader(c int) {
  1462. f.statusCode = c
  1463. }
  1464. func testWriteJSON(t *testing.T, testCode int, testData interface{}) {
  1465. testDataMarshalled, err := json.Marshal(testData)
  1466. if err != nil {
  1467. t.Fatal(err)
  1468. }
  1469. rsp := newWriter()
  1470. writeJSON(rsp, testCode, testData)
  1471. if rsp.statusCode != testCode {
  1472. t.Fatalf("writeJSON() failed to set the status code. Expected %d. Got %d", testCode, rsp.statusCode)
  1473. }
  1474. // writeJSON calls json.Encode and it appends '\n' to the result,
  1475. // while json.Marshal not
  1476. expected := append(testDataMarshalled, byte('\n'))
  1477. if !bytes.Equal(expected, rsp.body) {
  1478. t.Fatalf("writeJSON() failed to set the body. Expected %q. Got %q", expected, rsp.body)
  1479. }
  1480. }
  1481. func TestWriteJSON(t *testing.T) {
  1482. testWriteJSON(t, 55, "test data as string")
  1483. testWriteJSON(t, 55, []byte("test data as bytes"))
  1484. }
  1485. func TestHttpHandlerUninit(t *testing.T) {
  1486. defer testutils.SetupTestOSContext(t)()
  1487. // Cleanup local datastore file
  1488. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  1489. c, err := libnetwork.New()
  1490. if err != nil {
  1491. t.Fatal(err)
  1492. }
  1493. defer c.Stop()
  1494. h := &httpHandler{c: c}
  1495. h.initRouter()
  1496. if h.r == nil {
  1497. t.Fatal("initRouter() did not initialize the router")
  1498. }
  1499. rsp := newWriter()
  1500. req, err := http.NewRequest("GET", "/v1.19/networks", nil)
  1501. if err != nil {
  1502. t.Fatal(err)
  1503. }
  1504. handleRequest := NewHTTPHandler(nil)
  1505. handleRequest(rsp, req)
  1506. if rsp.statusCode != http.StatusServiceUnavailable {
  1507. t.Fatalf("Expected (%d). Got (%d): %s", http.StatusServiceUnavailable, rsp.statusCode, rsp.body)
  1508. }
  1509. handleRequest = NewHTTPHandler(c)
  1510. handleRequest(rsp, req)
  1511. if rsp.statusCode != http.StatusOK {
  1512. t.Fatalf("Expected (%d). Got: (%d): %s", http.StatusOK, rsp.statusCode, rsp.body)
  1513. }
  1514. var list []*networkResource
  1515. err = json.Unmarshal(rsp.body, &list)
  1516. if err != nil {
  1517. t.Fatal(err)
  1518. }
  1519. if len(list) != 0 {
  1520. t.Fatalf("Expected empty list. Got %v", list)
  1521. }
  1522. n, err := c.NewNetwork(bridgeNetType, "didietro", "", nil)
  1523. if err != nil {
  1524. t.Fatal(err)
  1525. }
  1526. nwr := buildNetworkResource(n)
  1527. expected, err := json.Marshal([]*networkResource{nwr})
  1528. if err != nil {
  1529. t.Fatal(err)
  1530. }
  1531. handleRequest(rsp, req)
  1532. if rsp.statusCode != http.StatusOK {
  1533. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1534. }
  1535. if len(rsp.body) == 0 {
  1536. t.Fatal("Empty list of networks")
  1537. }
  1538. if bytes.Equal(rsp.body, expected) {
  1539. t.Fatal("Incorrect list of networks in response's body")
  1540. }
  1541. }
  1542. func TestHttpHandlerBadBody(t *testing.T) {
  1543. defer testutils.SetupTestOSContext(t)()
  1544. rsp := newWriter()
  1545. // Cleanup local datastore file
  1546. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  1547. c, err := libnetwork.New()
  1548. if err != nil {
  1549. t.Fatal(err)
  1550. }
  1551. defer c.Stop()
  1552. handleRequest := NewHTTPHandler(c)
  1553. req, err := http.NewRequest("POST", "/v1.19/networks", &localReader{beBad: true})
  1554. if err != nil {
  1555. t.Fatal(err)
  1556. }
  1557. handleRequest(rsp, req)
  1558. if rsp.statusCode != http.StatusBadRequest {
  1559. t.Fatalf("Unexpected status code. Expected (%d). Got (%d): %s.", http.StatusBadRequest, rsp.statusCode, string(rsp.body))
  1560. }
  1561. body := []byte{}
  1562. lr := newLocalReader(body)
  1563. req, err = http.NewRequest("POST", "/v1.19/networks", lr)
  1564. if err != nil {
  1565. t.Fatal(err)
  1566. }
  1567. handleRequest(rsp, req)
  1568. if rsp.statusCode != http.StatusBadRequest {
  1569. t.Fatalf("Unexpected status code. Expected (%d). Got (%d): %s.", http.StatusBadRequest, rsp.statusCode, string(rsp.body))
  1570. }
  1571. }
  1572. func TestEndToEnd(t *testing.T) {
  1573. defer testutils.SetupTestOSContext(t)()
  1574. rsp := newWriter()
  1575. // Cleanup local datastore file
  1576. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  1577. c, err := libnetwork.New()
  1578. if err != nil {
  1579. t.Fatal(err)
  1580. }
  1581. defer c.Stop()
  1582. handleRequest := NewHTTPHandler(c)
  1583. dops := GetOpsMap("cdef", "1460")
  1584. nops := map[string]string{}
  1585. // Create network
  1586. nc := networkCreate{Name: "network-fiftyfive", NetworkType: bridgeNetType, DriverOpts: dops, NetworkOpts: nops}
  1587. body, err := json.Marshal(nc)
  1588. if err != nil {
  1589. t.Fatal(err)
  1590. }
  1591. lr := newLocalReader(body)
  1592. req, err := http.NewRequest("POST", "/v1.19/networks", lr)
  1593. if err != nil {
  1594. t.Fatal(err)
  1595. }
  1596. handleRequest(rsp, req)
  1597. if rsp.statusCode != http.StatusCreated {
  1598. t.Fatalf("Unexpected status code. Expected (%d). Got (%d): %s.", http.StatusCreated, rsp.statusCode, string(rsp.body))
  1599. }
  1600. if len(rsp.body) == 0 {
  1601. t.Fatal("Empty response body")
  1602. }
  1603. var nid string
  1604. err = json.Unmarshal(rsp.body, &nid)
  1605. if err != nil {
  1606. t.Fatal(err)
  1607. }
  1608. // Query networks collection
  1609. req, err = http.NewRequest("GET", "/v1.19/networks?name=", nil)
  1610. if err != nil {
  1611. t.Fatal(err)
  1612. }
  1613. handleRequest(rsp, req)
  1614. if rsp.statusCode != http.StatusOK {
  1615. t.Fatalf("Expected StatusOK. Got (%d): %s", rsp.statusCode, rsp.body)
  1616. }
  1617. var list []*networkResource
  1618. err = json.Unmarshal(rsp.body, &list)
  1619. if err != nil {
  1620. t.Fatal(err)
  1621. }
  1622. if len(list) != 0 {
  1623. t.Fatalf("Expected empty list. Got %v", list)
  1624. }
  1625. req, err = http.NewRequest("GET", "/v1.19/networks", nil)
  1626. if err != nil {
  1627. t.Fatal(err)
  1628. }
  1629. handleRequest(rsp, req)
  1630. if rsp.statusCode != http.StatusOK {
  1631. t.Fatalf("Expected StatusOK. Got (%d): %s", rsp.statusCode, rsp.body)
  1632. }
  1633. b0 := make([]byte, len(rsp.body))
  1634. copy(b0, rsp.body)
  1635. req, err = http.NewRequest("GET", "/v1.19/networks?name=network-fiftyfive", nil)
  1636. if err != nil {
  1637. t.Fatal(err)
  1638. }
  1639. handleRequest(rsp, req)
  1640. if rsp.statusCode != http.StatusOK {
  1641. t.Fatalf("Expected StatusOK. Got (%d): %s", rsp.statusCode, rsp.body)
  1642. }
  1643. if !bytes.Equal(b0, rsp.body) {
  1644. t.Fatal("Expected same body from GET /networks and GET /networks?name=<nw> when only network <nw> exist.")
  1645. }
  1646. // Query network by name
  1647. req, err = http.NewRequest("GET", "/v1.19/networks?name=culo", nil)
  1648. if err != nil {
  1649. t.Fatal(err)
  1650. }
  1651. handleRequest(rsp, req)
  1652. if rsp.statusCode != http.StatusOK {
  1653. t.Fatalf("Expected StatusOK. Got (%d): %s", rsp.statusCode, rsp.body)
  1654. }
  1655. err = json.Unmarshal(rsp.body, &list)
  1656. if err != nil {
  1657. t.Fatal(err)
  1658. }
  1659. if len(list) != 0 {
  1660. t.Fatalf("Expected empty list. Got %v", list)
  1661. }
  1662. req, err = http.NewRequest("GET", "/v1.19/networks?name=network-fiftyfive", nil)
  1663. if err != nil {
  1664. t.Fatal(err)
  1665. }
  1666. handleRequest(rsp, req)
  1667. if rsp.statusCode != http.StatusOK {
  1668. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1669. }
  1670. err = json.Unmarshal(rsp.body, &list)
  1671. if err != nil {
  1672. t.Fatal(err)
  1673. }
  1674. if len(list) == 0 {
  1675. t.Fatal("Expected non empty list")
  1676. }
  1677. if list[0].Name != "network-fiftyfive" || nid != list[0].ID {
  1678. t.Fatalf("Incongruent resource found: %v", list[0])
  1679. }
  1680. // Query network by partial id
  1681. chars := []byte(nid)
  1682. partial := string(chars[0 : len(chars)/2])
  1683. req, err = http.NewRequest("GET", "/v1.19/networks?partial-id="+partial, nil)
  1684. if err != nil {
  1685. t.Fatal(err)
  1686. }
  1687. handleRequest(rsp, req)
  1688. if rsp.statusCode != http.StatusOK {
  1689. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1690. }
  1691. err = json.Unmarshal(rsp.body, &list)
  1692. if err != nil {
  1693. t.Fatal(err)
  1694. }
  1695. if len(list) == 0 {
  1696. t.Fatal("Expected non empty list")
  1697. }
  1698. if list[0].Name != "network-fiftyfive" || nid != list[0].ID {
  1699. t.Fatalf("Incongruent resource found: %v", list[0])
  1700. }
  1701. // Get network by id
  1702. req, err = http.NewRequest("GET", "/v1.19/networks/"+nid, nil)
  1703. if err != nil {
  1704. t.Fatal(err)
  1705. }
  1706. handleRequest(rsp, req)
  1707. if rsp.statusCode != http.StatusOK {
  1708. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1709. }
  1710. var nwr networkResource
  1711. err = json.Unmarshal(rsp.body, &nwr)
  1712. if err != nil {
  1713. t.Fatal(err)
  1714. }
  1715. if nwr.Name != "network-fiftyfive" || nid != nwr.ID {
  1716. t.Fatalf("Incongruent resource found: %v", nwr)
  1717. }
  1718. // Create endpoint
  1719. eb, err := json.Marshal(endpointCreate{Name: "ep-TwentyTwo"})
  1720. if err != nil {
  1721. t.Fatal(err)
  1722. }
  1723. lr = newLocalReader(eb)
  1724. req, err = http.NewRequest("POST", "/v1.19/networks/"+nid+"/endpoints", lr)
  1725. if err != nil {
  1726. t.Fatal(err)
  1727. }
  1728. handleRequest(rsp, req)
  1729. if rsp.statusCode != http.StatusCreated {
  1730. t.Fatalf("Unexpected status code. Expected (%d). Got (%d): %s.", http.StatusCreated, rsp.statusCode, string(rsp.body))
  1731. }
  1732. if len(rsp.body) == 0 {
  1733. t.Fatal("Empty response body")
  1734. }
  1735. var eid string
  1736. err = json.Unmarshal(rsp.body, &eid)
  1737. if err != nil {
  1738. t.Fatal(err)
  1739. }
  1740. // Query endpoint(s)
  1741. req, err = http.NewRequest("GET", "/v1.19/networks/"+nid+"/endpoints", nil)
  1742. if err != nil {
  1743. t.Fatal(err)
  1744. }
  1745. handleRequest(rsp, req)
  1746. if rsp.statusCode != http.StatusOK {
  1747. t.Fatalf("Expected StatusOK. Got (%d): %s", rsp.statusCode, rsp.body)
  1748. }
  1749. req, err = http.NewRequest("GET", "/v1.19/networks/"+nid+"/endpoints?name=bla", nil)
  1750. if err != nil {
  1751. t.Fatal(err)
  1752. }
  1753. handleRequest(rsp, req)
  1754. if rsp.statusCode != http.StatusOK {
  1755. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1756. }
  1757. var epList []*endpointResource
  1758. err = json.Unmarshal(rsp.body, &epList)
  1759. if err != nil {
  1760. t.Fatal(err)
  1761. }
  1762. if len(epList) != 0 {
  1763. t.Fatalf("Expected empty list. Got %v", epList)
  1764. }
  1765. // Query endpoint by name
  1766. req, err = http.NewRequest("GET", "/v1.19/networks/"+nid+"/endpoints?name=ep-TwentyTwo", nil)
  1767. if err != nil {
  1768. t.Fatal(err)
  1769. }
  1770. handleRequest(rsp, req)
  1771. if rsp.statusCode != http.StatusOK {
  1772. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1773. }
  1774. err = json.Unmarshal(rsp.body, &epList)
  1775. if err != nil {
  1776. t.Fatal(err)
  1777. }
  1778. if len(epList) == 0 {
  1779. t.Fatal("Empty response body")
  1780. }
  1781. if epList[0].Name != "ep-TwentyTwo" || eid != epList[0].ID {
  1782. t.Fatalf("Incongruent resource found: %v", epList[0])
  1783. }
  1784. // Query endpoint by partial id
  1785. chars = []byte(eid)
  1786. partial = string(chars[0 : len(chars)/2])
  1787. req, err = http.NewRequest("GET", "/v1.19/networks/"+nid+"/endpoints?partial-id="+partial, nil)
  1788. if err != nil {
  1789. t.Fatal(err)
  1790. }
  1791. handleRequest(rsp, req)
  1792. if rsp.statusCode != http.StatusOK {
  1793. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1794. }
  1795. err = json.Unmarshal(rsp.body, &epList)
  1796. if err != nil {
  1797. t.Fatal(err)
  1798. }
  1799. if len(epList) == 0 {
  1800. t.Fatal("Empty response body")
  1801. }
  1802. if epList[0].Name != "ep-TwentyTwo" || eid != epList[0].ID {
  1803. t.Fatalf("Incongruent resource found: %v", epList[0])
  1804. }
  1805. // Get endpoint by id
  1806. req, err = http.NewRequest("GET", "/v1.19/networks/"+nid+"/endpoints/"+eid, nil)
  1807. if err != nil {
  1808. t.Fatal(err)
  1809. }
  1810. handleRequest(rsp, req)
  1811. if rsp.statusCode != http.StatusOK {
  1812. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1813. }
  1814. var epr endpointResource
  1815. err = json.Unmarshal(rsp.body, &epr)
  1816. if err != nil {
  1817. t.Fatal(err)
  1818. }
  1819. if epr.Name != "ep-TwentyTwo" || epr.ID != eid {
  1820. t.Fatalf("Incongruent resource found: %v", epr)
  1821. }
  1822. // Store two container ids and one partial ids
  1823. cid1 := "container10010000000"
  1824. cid2 := "container20010000000"
  1825. chars = []byte(cid1)
  1826. cpid1 := string(chars[0 : len(chars)/2])
  1827. // Create sandboxes
  1828. sb1, err := json.Marshal(sandboxCreate{
  1829. ContainerID: cid1,
  1830. PortMapping: getPortMapping(),
  1831. })
  1832. if err != nil {
  1833. t.Fatal(err)
  1834. }
  1835. lr = newLocalReader(sb1)
  1836. req, err = http.NewRequest("POST", "/v5.22/sandboxes", lr)
  1837. if err != nil {
  1838. t.Fatal(err)
  1839. }
  1840. handleRequest(rsp, req)
  1841. if rsp.statusCode != http.StatusCreated {
  1842. t.Fatalf("Unexpected status code. Expected (%d). Got (%d): %s.", http.StatusCreated, rsp.statusCode, string(rsp.body))
  1843. }
  1844. if len(rsp.body) == 0 {
  1845. t.Fatal("Empty response body")
  1846. }
  1847. // Get sandbox id and partial id
  1848. var sid1 string
  1849. err = json.Unmarshal(rsp.body, &sid1)
  1850. if err != nil {
  1851. t.Fatal(err)
  1852. }
  1853. sb2, err := json.Marshal(sandboxCreate{
  1854. ContainerID: cid2,
  1855. ExposedPorts: getExposedPorts(),
  1856. })
  1857. if err != nil {
  1858. t.Fatal(err)
  1859. }
  1860. lr = newLocalReader(sb2)
  1861. req, err = http.NewRequest("POST", "/v5.22/sandboxes", lr)
  1862. if err != nil {
  1863. t.Fatal(err)
  1864. }
  1865. handleRequest(rsp, req)
  1866. if rsp.statusCode != http.StatusCreated {
  1867. t.Fatalf("Unexpected status code. Expected (%d). Got (%d): %s.", http.StatusCreated, rsp.statusCode, string(rsp.body))
  1868. }
  1869. if len(rsp.body) == 0 {
  1870. t.Fatal("Empty response body")
  1871. }
  1872. // Get sandbox id and partial id
  1873. var sid2 string
  1874. err = json.Unmarshal(rsp.body, &sid2)
  1875. if err != nil {
  1876. t.Fatal(err)
  1877. }
  1878. chars = []byte(sid2)
  1879. spid2 := string(chars[0 : len(chars)/2])
  1880. // Query sandboxes
  1881. req, err = http.NewRequest("GET", "/sandboxes", nil)
  1882. if err != nil {
  1883. t.Fatal(err)
  1884. }
  1885. handleRequest(rsp, req)
  1886. if rsp.statusCode != http.StatusOK {
  1887. t.Fatalf("Expected StatusOK. Got (%d): %s", rsp.statusCode, rsp.body)
  1888. }
  1889. var sbList []*sandboxResource
  1890. err = json.Unmarshal(rsp.body, &sbList)
  1891. if err != nil {
  1892. t.Fatal(err)
  1893. }
  1894. if len(sbList) != 2 {
  1895. t.Fatalf("Expected 2 elements in list. Got %v", sbList)
  1896. }
  1897. // Get sandbox by id
  1898. req, err = http.NewRequest("GET", "/sandboxes/"+sid1, nil)
  1899. if err != nil {
  1900. t.Fatal(err)
  1901. }
  1902. handleRequest(rsp, req)
  1903. if rsp.statusCode != http.StatusOK {
  1904. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1905. }
  1906. var sbr sandboxResource
  1907. err = json.Unmarshal(rsp.body, &sbr)
  1908. if err != nil {
  1909. t.Fatal(err)
  1910. }
  1911. if sbr.ContainerID != cid1 {
  1912. t.Fatalf("Incongruent resource found: %v", sbr)
  1913. }
  1914. // Query sandbox by partial sandbox id
  1915. req, err = http.NewRequest("GET", "/sandboxes?partial-id="+spid2, nil)
  1916. if err != nil {
  1917. t.Fatal(err)
  1918. }
  1919. handleRequest(rsp, req)
  1920. if rsp.statusCode != http.StatusOK {
  1921. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1922. }
  1923. err = json.Unmarshal(rsp.body, &sbList)
  1924. if err != nil {
  1925. t.Fatal(err)
  1926. }
  1927. if len(sbList) == 0 {
  1928. t.Fatal("Empty response body")
  1929. }
  1930. if sbList[0].ID != sid2 {
  1931. t.Fatalf("Incongruent resource found: %v", sbList[0])
  1932. }
  1933. // Query sandbox by container id
  1934. req, err = http.NewRequest("GET", "/sandboxes?container-id="+cid2, nil)
  1935. if err != nil {
  1936. t.Fatal(err)
  1937. }
  1938. handleRequest(rsp, req)
  1939. if rsp.statusCode != http.StatusOK {
  1940. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1941. }
  1942. err = json.Unmarshal(rsp.body, &sbList)
  1943. if err != nil {
  1944. t.Fatal(err)
  1945. }
  1946. if len(sbList) == 0 {
  1947. t.Fatal("Empty response body")
  1948. }
  1949. if sbList[0].ContainerID != cid2 {
  1950. t.Fatalf("Incongruent resource found: %v", sbList[0])
  1951. }
  1952. // Query sandbox by partial container id
  1953. req, err = http.NewRequest("GET", "/sandboxes?partial-container-id="+cpid1, nil)
  1954. if err != nil {
  1955. t.Fatal(err)
  1956. }
  1957. handleRequest(rsp, req)
  1958. if rsp.statusCode != http.StatusOK {
  1959. t.Fatalf("Unexpected failure: (%d): %s", rsp.statusCode, rsp.body)
  1960. }
  1961. err = json.Unmarshal(rsp.body, &sbList)
  1962. if err != nil {
  1963. t.Fatal(err)
  1964. }
  1965. if len(sbList) == 0 {
  1966. t.Fatal("Empty response body")
  1967. }
  1968. if sbList[0].ContainerID != cid1 {
  1969. t.Fatalf("Incongruent resource found: %v", sbList[0])
  1970. }
  1971. }
  1972. func TestEndToEndErrorMessage(t *testing.T) {
  1973. defer testutils.SetupTestOSContext(t)()
  1974. rsp := newWriter()
  1975. // Cleanup local datastore file
  1976. os.Remove(datastore.DefaultScopes("")[datastore.LocalScope].Client.Address)
  1977. c, err := libnetwork.New()
  1978. if err != nil {
  1979. t.Fatal(err)
  1980. }
  1981. defer c.Stop()
  1982. handleRequest := NewHTTPHandler(c)
  1983. body := []byte{}
  1984. lr := newLocalReader(body)
  1985. req, err := http.NewRequest("POST", "/v1.19/networks", lr)
  1986. if err != nil {
  1987. t.Fatal(err)
  1988. }
  1989. handleRequest(rsp, req)
  1990. if len(rsp.body) == 0 {
  1991. t.Fatal("Empty response body.")
  1992. }
  1993. empty := []byte("\"\"")
  1994. if bytes.Equal(empty, bytes.TrimSpace(rsp.body)) {
  1995. t.Fatal("Empty response error message.")
  1996. }
  1997. }
  1998. type bre struct{}
  1999. func (b *bre) Error() string {
  2000. return "I am a bad request error"
  2001. }
  2002. func (b *bre) BadRequest() {}
  2003. type nfe struct{}
  2004. func (n *nfe) Error() string {
  2005. return "I am a not found error"
  2006. }
  2007. func (n *nfe) NotFound() {}
  2008. type forb struct{}
  2009. func (f *forb) Error() string {
  2010. return "I am a bad request error"
  2011. }
  2012. func (f *forb) Forbidden() {}
  2013. type notimpl struct{}
  2014. func (nip *notimpl) Error() string {
  2015. return "I am a not implemented error"
  2016. }
  2017. func (nip *notimpl) NotImplemented() {}
  2018. type inter struct{}
  2019. func (it *inter) Error() string {
  2020. return "I am an internal error"
  2021. }
  2022. func (it *inter) Internal() {}
  2023. type tout struct{}
  2024. func (to *tout) Error() string {
  2025. return "I am a timeout error"
  2026. }
  2027. func (to *tout) Timeout() {}
  2028. type noserv struct{}
  2029. func (nos *noserv) Error() string {
  2030. return "I am a no service error"
  2031. }
  2032. func (nos *noserv) NoService() {}
  2033. type notclassified struct{}
  2034. func (noc *notclassified) Error() string {
  2035. return "I am a non classified error"
  2036. }
  2037. func TestErrorConversion(t *testing.T) {
  2038. if convertNetworkError(new(bre)).StatusCode != http.StatusBadRequest {
  2039. t.Fatal("Failed to recognize BadRequest error")
  2040. }
  2041. if convertNetworkError(new(nfe)).StatusCode != http.StatusNotFound {
  2042. t.Fatal("Failed to recognize NotFound error")
  2043. }
  2044. if convertNetworkError(new(forb)).StatusCode != http.StatusForbidden {
  2045. t.Fatal("Failed to recognize Forbidden error")
  2046. }
  2047. if convertNetworkError(new(notimpl)).StatusCode != http.StatusNotImplemented {
  2048. t.Fatal("Failed to recognize NotImplemented error")
  2049. }
  2050. if convertNetworkError(new(inter)).StatusCode != http.StatusInternalServerError {
  2051. t.Fatal("Failed to recognize Internal error")
  2052. }
  2053. if convertNetworkError(new(tout)).StatusCode != http.StatusRequestTimeout {
  2054. t.Fatal("Failed to recognize Timeout error")
  2055. }
  2056. if convertNetworkError(new(noserv)).StatusCode != http.StatusServiceUnavailable {
  2057. t.Fatal("Failed to recognize No Service error")
  2058. }
  2059. if convertNetworkError(new(notclassified)).StatusCode != http.StatusInternalServerError {
  2060. t.Fatal("Failed to recognize not classified error as Internal error")
  2061. }
  2062. }
  2063. func TestFieldRegex(t *testing.T) {
  2064. pr := regexp.MustCompile(regex)
  2065. qr := regexp.MustCompile(`^` + qregx + `$`) // mux compiles it like this
  2066. if pr.MatchString("") {
  2067. t.Fatal("Unexpected match")
  2068. }
  2069. if !qr.MatchString("") {
  2070. t.Fatal("Unexpected match failure")
  2071. }
  2072. if pr.MatchString(":") {
  2073. t.Fatal("Unexpected match")
  2074. }
  2075. if qr.MatchString(":") {
  2076. t.Fatal("Unexpected match")
  2077. }
  2078. if pr.MatchString(".") {
  2079. t.Fatal("Unexpected match")
  2080. }
  2081. if qr.MatchString(".") {
  2082. t.Fatal("Unexpected match")
  2083. }
  2084. }