networkHttpController_test.go 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572
  1. package controller
  2. import (
  3. "testing"
  4. "time"
  5. "github.com/gravitl/netmaker/functions"
  6. "github.com/gravitl/netmaker/models"
  7. "github.com/stretchr/testify/assert"
  8. )
  9. type NetworkValidationTestCase struct {
  10. testname string
  11. network models.Network
  12. errMessage string
  13. }
  14. func deleteNet(t *testing.T) {
  15. nodes, err := functions.GetAllNodes()
  16. assert.Nil(t, err)
  17. for _, node := range nodes {
  18. t.Log("deleting node", node.Name)
  19. result, err := DeleteNode(node.MacAddress, node.Network)
  20. assert.Nil(t, err)
  21. assert.True(t, result)
  22. }
  23. dns, err := GetAllDNS()
  24. assert.Nil(t, err)
  25. for _, entry := range dns {
  26. t.Log("deleting dns enty", entry.Name, entry.Network)
  27. success, err := DeleteDNS(entry.Name, entry.Network)
  28. assert.Nil(t, err)
  29. assert.True(t, success)
  30. }
  31. networks, _ := functions.ListNetworks()
  32. for _, network := range networks {
  33. t.Log("deleting network", network.NetID)
  34. success, err := DeleteNetwork(network.NetID)
  35. t.Log(success, err)
  36. }
  37. }
  38. func createNet() {
  39. var network models.Network
  40. network.NetID = "skynet"
  41. network.AddressRange = "10.0.0.1/24"
  42. network.DisplayName = "mynetwork"
  43. _, err := GetNetwork("skynet")
  44. if err != nil {
  45. CreateNetwork(network)
  46. }
  47. }
  48. func getNet() models.Network {
  49. network, _ := GetNetwork("skynet")
  50. return network
  51. }
  52. func TestGetNetworks(t *testing.T) {
  53. //calls functions.ListNetworks --- nothing to be done
  54. }
  55. func TestCreateNetwork(t *testing.T) {
  56. deleteNet(t)
  57. var network models.Network
  58. network.NetID = "skynet"
  59. network.AddressRange = "10.0.0.1/24"
  60. network.DisplayName = "mynetwork"
  61. err := CreateNetwork(network)
  62. assert.Nil(t, err)
  63. }
  64. func TestGetDeleteNetwork(t *testing.T) {
  65. createNet()
  66. //create nodes
  67. t.Run("NetworkwithNodes", func(t *testing.T) {
  68. })
  69. t.Run("GetExistingNetwork", func(t *testing.T) {
  70. network, err := GetNetwork("skynet")
  71. assert.Nil(t, err)
  72. assert.Equal(t, "skynet", network.NetID)
  73. })
  74. t.Run("DeleteExistingNetwork", func(t *testing.T) {
  75. result, err := DeleteNetwork("skynet")
  76. assert.Nil(t, err)
  77. assert.Equal(t, int64(1), result.DeletedCount)
  78. t.Log(result.DeletedCount)
  79. })
  80. t.Run("GetNonExistantNetwork", func(t *testing.T) {
  81. network, err := GetNetwork("skynet")
  82. assert.NotNil(t, err)
  83. assert.Equal(t, "mongo: no documents in result", err.Error())
  84. assert.Equal(t, "", network.NetID)
  85. })
  86. t.Run("NonExistantNetwork", func(t *testing.T) {
  87. result, err := DeleteNetwork("skynet")
  88. assert.Nil(t, err)
  89. assert.Equal(t, int64(0), result.DeletedCount)
  90. t.Log(result.DeletedCount)
  91. })
  92. }
  93. func TestGetNetwork(t *testing.T) {
  94. createNet()
  95. t.Run("NoNetwork", func(t *testing.T) {
  96. network, err := GetNetwork("badnet")
  97. assert.NotNil(t, err)
  98. assert.Equal(t, "mongo: no documents in result", err.Error())
  99. assert.Equal(t, models.Network{}, network)
  100. })
  101. t.Run("Valid", func(t *testing.T) {
  102. network, err := GetNetwork("skynet")
  103. assert.Nil(t, err)
  104. assert.Equal(t, "skynet", network.NetID)
  105. })
  106. }
  107. func TestUpdateNetwork(t *testing.T) {
  108. createNet()
  109. network := getNet()
  110. t.Run("NetID", func(t *testing.T) {
  111. var networkupdate models.NetworkUpdate
  112. networkupdate.NetID = "wirecat"
  113. _, err := UpdateNetwork(networkupdate, network)
  114. assert.NotNil(t, err)
  115. assert.Equal(t, "NetID is not editable", err.Error())
  116. })
  117. t.Run("LocalRange", func(t *testing.T) {
  118. var networkupdate models.NetworkUpdate
  119. //NetID needs to be set as it will be in updateNetwork
  120. networkupdate.NetID = "skynet"
  121. networkupdate.LocalRange = "192.168.0.1/24"
  122. update, err := UpdateNetwork(networkupdate, network)
  123. assert.Nil(t, err)
  124. t.Log(err, update)
  125. })
  126. }
  127. func TestKeyUpdate(t *testing.T) {
  128. createNet()
  129. existing, err := GetNetwork("skynet")
  130. assert.Nil(t, err)
  131. time.Sleep(time.Second * 1)
  132. network, err := KeyUpdate("skynet")
  133. assert.Nil(t, err)
  134. network, err = GetNetwork("skynet")
  135. assert.Nil(t, err)
  136. assert.Greater(t, network.KeyUpdateTimeStamp, existing.KeyUpdateTimeStamp)
  137. }
  138. func TestCreateKey(t *testing.T) {
  139. createNet()
  140. var accesskey models.AccessKey
  141. var network models.Network
  142. network.NetID = "skynet"
  143. t.Run("InvalidName", func(t *testing.T) {
  144. network, err := GetNetwork("skynet")
  145. assert.Nil(t, err)
  146. accesskey.Name = "bad-name"
  147. _, err = CreateAccessKey(accesskey, network)
  148. assert.NotNil(t, err)
  149. assert.Contains(t, err.Error(), "Field validation for 'Name' failed on the 'alphanum' tag")
  150. })
  151. t.Run("NameTooLong", func(t *testing.T) {
  152. network, err := GetNetwork("skynet")
  153. assert.Nil(t, err)
  154. accesskey.Name = "Thisisareallylongkeynamethatwillfail"
  155. _, err = CreateAccessKey(accesskey, network)
  156. assert.NotNil(t, err)
  157. assert.Contains(t, err.Error(), "Field validation for 'Name' failed on the 'max' tag")
  158. })
  159. t.Run("BlankName", func(t *testing.T) {
  160. network, err := GetNetwork("skynet")
  161. assert.Nil(t, err)
  162. accesskey.Name = ""
  163. key, err := CreateAccessKey(accesskey, network)
  164. assert.Nil(t, err)
  165. assert.NotEqual(t, "", key.Name)
  166. })
  167. t.Run("InvalidValue", func(t *testing.T) {
  168. network, err := GetNetwork("skynet")
  169. assert.Nil(t, err)
  170. accesskey.Value = "bad-value"
  171. _, err = CreateAccessKey(accesskey, network)
  172. assert.NotNil(t, err)
  173. assert.Contains(t, err.Error(), "Field validation for 'Value' failed on the 'alphanum' tag")
  174. })
  175. t.Run("BlankValue", func(t *testing.T) {
  176. network, err := GetNetwork("skynet")
  177. assert.Nil(t, err)
  178. accesskey.Name = "mykey"
  179. accesskey.Value = ""
  180. key, err := CreateAccessKey(accesskey, network)
  181. assert.Nil(t, err)
  182. assert.NotEqual(t, "", key.Value)
  183. assert.Equal(t, accesskey.Name, key.Name)
  184. })
  185. t.Run("ValueTooLong", func(t *testing.T) {
  186. network, err := GetNetwork("skynet")
  187. assert.Nil(t, err)
  188. accesskey.Name = "keyname"
  189. accesskey.Value = "AccessKeyValuethatistoolong"
  190. _, err = CreateAccessKey(accesskey, network)
  191. assert.NotNil(t, err)
  192. assert.Contains(t, err.Error(), "Field validation for 'Value' failed on the 'max' tag")
  193. })
  194. t.Run("BlankUses", func(t *testing.T) {
  195. network, err := GetNetwork("skynet")
  196. assert.Nil(t, err)
  197. accesskey.Uses = 0
  198. accesskey.Value = ""
  199. key, err := CreateAccessKey(accesskey, network)
  200. assert.Nil(t, err)
  201. assert.Equal(t, 1, key.Uses)
  202. })
  203. t.Run("DuplicateKey", func(t *testing.T) {
  204. network, err := GetNetwork("skynet")
  205. assert.Nil(t, err)
  206. accesskey.Name = "mykey"
  207. _, err = CreateAccessKey(accesskey, network)
  208. assert.NotNil(t, err)
  209. assert.Equal(t, "Duplicate AccessKey Name", err.Error())
  210. })
  211. }
  212. func TestGetKeys(t *testing.T) {
  213. deleteNet(t)
  214. createNet()
  215. network, err := GetNetwork("skynet")
  216. assert.Nil(t, err)
  217. var key models.AccessKey
  218. key.Name = "mykey"
  219. _, err = CreateAccessKey(key, network)
  220. assert.Nil(t, err)
  221. t.Run("KeyExists", func(t *testing.T) {
  222. keys, err := GetKeys(network.NetID)
  223. assert.Nil(t, err)
  224. assert.NotEqual(t, models.AccessKey{}, keys)
  225. })
  226. t.Run("NonExistantKey", func(t *testing.T) {
  227. err := DeleteKey("mykey", "skynet")
  228. assert.Nil(t, err)
  229. keys, err := GetKeys(network.NetID)
  230. assert.Nil(t, err)
  231. assert.Equal(t, []models.AccessKey(nil), keys)
  232. })
  233. }
  234. func TestDeleteKey(t *testing.T) {
  235. createNet()
  236. network, err := GetNetwork("skynet")
  237. assert.Nil(t, err)
  238. var key models.AccessKey
  239. key.Name = "mykey"
  240. _, err = CreateAccessKey(key, network)
  241. assert.Nil(t, err)
  242. t.Run("ExistingKey", func(t *testing.T) {
  243. err := DeleteKey("mykey", "skynet")
  244. assert.Nil(t, err)
  245. })
  246. t.Run("NonExistantKey", func(t *testing.T) {
  247. err := DeleteKey("mykey", "skynet")
  248. assert.NotNil(t, err)
  249. assert.Equal(t, "key mykey does not exist", err.Error())
  250. })
  251. }
  252. func TestSecurityCheck(t *testing.T) {
  253. t.Run("NoNetwork", func(t *testing.T) {
  254. err := SecurityCheck(false, "", "Bearer secretkey")
  255. assert.Nil(t, err)
  256. })
  257. t.Run("WithNetwork", func(t *testing.T) {
  258. err := SecurityCheck(false, "skynet", "Bearer secretkey")
  259. assert.Nil(t, err)
  260. })
  261. t.Run("BadNet", func(t *testing.T) {
  262. err := SecurityCheck(false, "badnet", "Bearer secretkey")
  263. assert.NotNil(t, err)
  264. t.Log(err)
  265. })
  266. t.Run("BadToken", func(t *testing.T) {
  267. err := SecurityCheck(false, "skynet", "Bearer badkey")
  268. assert.NotNil(t, err)
  269. t.Log(err)
  270. })
  271. }
  272. func TestValidateNetworkUpdate(t *testing.T) {
  273. //yes := true
  274. //no := false
  275. deleteNet(t)
  276. //DeleteNetworks
  277. cases := []NetworkValidationTestCase{
  278. NetworkValidationTestCase{
  279. testname: "InvalidAddress",
  280. network: models.Network{
  281. AddressRange: "10.0.0.256",
  282. },
  283. errMessage: "Field validation for 'AddressRange' failed on the 'cidr' tag",
  284. },
  285. NetworkValidationTestCase{
  286. testname: "InvalidAddress6",
  287. network: models.Network{
  288. AddressRange6: "2607::ag",
  289. },
  290. errMessage: "Field validation for 'AddressRange6' failed on the 'cidr' tag",
  291. },
  292. NetworkValidationTestCase{
  293. testname: "BadDisplayName",
  294. network: models.Network{
  295. DisplayName: "skynet*",
  296. },
  297. errMessage: "Field validation for 'DisplayName' failed on the 'alphanum' tag",
  298. },
  299. NetworkValidationTestCase{
  300. testname: "DisplayNameTooLong",
  301. network: models.Network{
  302. DisplayName: "Thisisareallylongdisplaynamethatistoolong",
  303. },
  304. errMessage: "Field validation for 'DisplayName' failed on the 'max' tag",
  305. },
  306. NetworkValidationTestCase{
  307. testname: "DisplayNameTooShort",
  308. network: models.Network{
  309. DisplayName: "1",
  310. },
  311. errMessage: "Field validation for 'DisplayName' failed on the 'min' tag",
  312. },
  313. NetworkValidationTestCase{
  314. testname: "InvalidNetID",
  315. network: models.Network{
  316. NetID: "contains spaces",
  317. },
  318. errMessage: "Field validation for 'NetID' failed on the 'alphanum' tag",
  319. },
  320. NetworkValidationTestCase{
  321. testname: "NetIDTooLong",
  322. network: models.Network{
  323. NetID: "LongNetIDName",
  324. },
  325. errMessage: "Field validation for 'NetID' failed on the 'max' tag",
  326. },
  327. NetworkValidationTestCase{
  328. testname: "ListenPortTooLow",
  329. network: models.Network{
  330. DefaultListenPort: 1023,
  331. },
  332. errMessage: "Field validation for 'DefaultListenPort' failed on the 'min' tag",
  333. },
  334. NetworkValidationTestCase{
  335. testname: "ListenPortTooHigh",
  336. network: models.Network{
  337. DefaultListenPort: 65536,
  338. },
  339. errMessage: "Field validation for 'DefaultListenPort' failed on the 'max' tag",
  340. },
  341. NetworkValidationTestCase{
  342. testname: "KeepAliveTooBig",
  343. network: models.Network{
  344. DefaultKeepalive: 1010,
  345. },
  346. errMessage: "Field validation for 'DefaultKeepalive' failed on the 'max' tag",
  347. },
  348. NetworkValidationTestCase{
  349. testname: "InvalidLocalRange",
  350. network: models.Network{
  351. LocalRange: "192.168.0.1",
  352. },
  353. errMessage: "Field validation for 'LocalRange' failed on the 'cidr' tag",
  354. },
  355. NetworkValidationTestCase{
  356. testname: "CheckInIntervalTooBig",
  357. network: models.Network{
  358. DefaultCheckInInterval: 100001,
  359. },
  360. errMessage: "Field validation for 'DefaultCheckInInterval' failed on the 'max' tag",
  361. },
  362. NetworkValidationTestCase{
  363. testname: "CheckInIntervalTooSmall",
  364. network: models.Network{
  365. DefaultCheckInInterval: 1,
  366. },
  367. errMessage: "Field validation for 'DefaultCheckInInterval' failed on the 'min' tag",
  368. },
  369. }
  370. for _, tc := range cases {
  371. t.Run(tc.testname, func(t *testing.T) {
  372. network := models.NetworkUpdate(tc.network)
  373. err := ValidateNetworkUpdate(network)
  374. assert.NotNil(t, err)
  375. assert.Contains(t, err.Error(), tc.errMessage)
  376. })
  377. }
  378. }
  379. func TestValidateNetworkCreate(t *testing.T) {
  380. yes := true
  381. no := false
  382. deleteNet(t)
  383. //DeleteNetworks
  384. cases := []NetworkValidationTestCase{
  385. NetworkValidationTestCase{
  386. testname: "InvalidAddress",
  387. network: models.Network{
  388. AddressRange: "10.0.0.256",
  389. NetID: "skynet",
  390. IsDualStack: &no,
  391. },
  392. errMessage: "Field validation for 'AddressRange' failed on the 'cidr' tag",
  393. },
  394. NetworkValidationTestCase{
  395. testname: "BadDisplayName",
  396. network: models.Network{
  397. AddressRange: "10.0.0.1/24",
  398. NetID: "skynet",
  399. DisplayName: "skynet*",
  400. IsDualStack: &no,
  401. },
  402. errMessage: "Field validation for 'DisplayName' failed on the 'alphanum' tag",
  403. },
  404. NetworkValidationTestCase{
  405. testname: "DisplayNameTooLong",
  406. network: models.Network{
  407. AddressRange: "10.0.0.1/24",
  408. NetID: "skynet",
  409. DisplayName: "Thisisareallylongdisplaynamethatistoolong",
  410. IsDualStack: &no,
  411. },
  412. errMessage: "Field validation for 'DisplayName' failed on the 'max' tag",
  413. },
  414. NetworkValidationTestCase{
  415. testname: "DisplayNameTooShort",
  416. network: models.Network{
  417. AddressRange: "10.0.0.1/24",
  418. NetID: "skynet",
  419. DisplayName: "1",
  420. IsDualStack: &no,
  421. },
  422. errMessage: "Field validation for 'DisplayName' failed on the 'min' tag",
  423. },
  424. NetworkValidationTestCase{
  425. testname: "NetIDMissing",
  426. network: models.Network{
  427. AddressRange: "10.0.0.1/24",
  428. IsDualStack: &no,
  429. },
  430. errMessage: "Field validation for 'NetID' failed on the 'required' tag",
  431. },
  432. NetworkValidationTestCase{
  433. testname: "InvalidNetID",
  434. network: models.Network{
  435. AddressRange: "10.0.0.1/24",
  436. NetID: "contains spaces",
  437. IsDualStack: &no,
  438. },
  439. errMessage: "Field validation for 'NetID' failed on the 'alphanum' tag",
  440. },
  441. NetworkValidationTestCase{
  442. testname: "NetIDTooShort",
  443. network: models.Network{
  444. AddressRange: "10.0.0.1/24",
  445. NetID: "",
  446. IsDualStack: &no,
  447. },
  448. errMessage: "Field validation for 'NetID' failed on the 'required' tag",
  449. },
  450. NetworkValidationTestCase{
  451. testname: "NetIDTooLong",
  452. network: models.Network{
  453. AddressRange: "10.0.0.1/24",
  454. NetID: "LongNetIDName",
  455. IsDualStack: &no,
  456. },
  457. errMessage: "Field validation for 'NetID' failed on the 'max' tag",
  458. },
  459. NetworkValidationTestCase{
  460. testname: "ListenPortTooLow",
  461. network: models.Network{
  462. AddressRange: "10.0.0.1/24",
  463. NetID: "skynet",
  464. DefaultListenPort: 1023,
  465. IsDualStack: &no,
  466. },
  467. errMessage: "Field validation for 'DefaultListenPort' failed on the 'min' tag",
  468. },
  469. NetworkValidationTestCase{
  470. testname: "ListenPortTooHigh",
  471. network: models.Network{
  472. AddressRange: "10.0.0.1/24",
  473. NetID: "skynet",
  474. DefaultListenPort: 65536,
  475. IsDualStack: &no,
  476. },
  477. errMessage: "Field validation for 'DefaultListenPort' failed on the 'max' tag",
  478. },
  479. NetworkValidationTestCase{
  480. testname: "KeepAliveTooBig",
  481. network: models.Network{
  482. AddressRange: "10.0.0.1/24",
  483. NetID: "skynet",
  484. DefaultKeepalive: 1010,
  485. IsDualStack: &no,
  486. },
  487. errMessage: "Field validation for 'DefaultKeepalive' failed on the 'max' tag",
  488. },
  489. NetworkValidationTestCase{
  490. testname: "InvalidLocalRange",
  491. network: models.Network{
  492. AddressRange: "10.0.0.1/24",
  493. NetID: "skynet",
  494. LocalRange: "192.168.0.1",
  495. IsDualStack: &no,
  496. },
  497. errMessage: "Field validation for 'LocalRange' failed on the 'cidr' tag",
  498. },
  499. NetworkValidationTestCase{
  500. testname: "DualStackWithoutIPv6",
  501. network: models.Network{
  502. AddressRange: "10.0.0.1/24",
  503. NetID: "skynet",
  504. IsDualStack: &yes,
  505. },
  506. errMessage: "Field validation for 'AddressRange6' failed on the 'addressrange6_valid' tag",
  507. },
  508. NetworkValidationTestCase{
  509. testname: "CheckInIntervalTooBig",
  510. network: models.Network{
  511. AddressRange: "10.0.0.1/24",
  512. NetID: "skynet",
  513. IsDualStack: &no,
  514. DefaultCheckInInterval: 100001,
  515. },
  516. errMessage: "Field validation for 'DefaultCheckInInterval' failed on the 'max' tag",
  517. },
  518. NetworkValidationTestCase{
  519. testname: "CheckInIntervalTooSmall",
  520. network: models.Network{
  521. AddressRange: "10.0.0.1/24",
  522. NetID: "skynet",
  523. IsDualStack: &no,
  524. DefaultCheckInInterval: 1,
  525. },
  526. errMessage: "Field validation for 'DefaultCheckInInterval' failed on the 'min' tag",
  527. },
  528. }
  529. for _, tc := range cases {
  530. t.Run(tc.testname, func(t *testing.T) {
  531. err := ValidateNetworkCreate(tc.network)
  532. assert.NotNil(t, err)
  533. assert.Contains(t, err.Error(), tc.errMessage)
  534. })
  535. }
  536. t.Run("DuplicateNetID", func(t *testing.T) {
  537. deleteNet(t)
  538. var net1, net2 models.Network
  539. net1.NetID = "skynet"
  540. net1.AddressRange = "10.0.0.1/24"
  541. net1.DisplayName = "mynetwork"
  542. net2.NetID = "skynet"
  543. net2.AddressRange = "10.0.1.1/24"
  544. net2.IsDualStack = &no
  545. err := CreateNetwork(net1)
  546. assert.Nil(t, err)
  547. err = ValidateNetworkCreate(net2)
  548. assert.NotNil(t, err)
  549. assert.Contains(t, err.Error(), "Field validation for 'NetID' failed on the 'netid_valid' tag")
  550. })
  551. t.Run("DuplicateDisplayName", func(t *testing.T) {
  552. var network models.Network
  553. network.NetID = "wirecat"
  554. network.AddressRange = "10.0.100.1/24"
  555. network.IsDualStack = &no
  556. network.DisplayName = "mynetwork"
  557. err := ValidateNetworkCreate(network)
  558. assert.NotNil(t, err)
  559. assert.Contains(t, err.Error(), "Field validation for 'DisplayName' failed on the 'displayname_unique' tag")
  560. })
  561. }